diff --git a/ydb/library/yql/dq/runtime/dq_input_producer.cpp b/ydb/library/yql/dq/runtime/dq_input_producer.cpp index 05c80f11921b..c35e3c45c397 100644 --- a/ydb/library/yql/dq/runtime/dq_input_producer.cpp +++ b/ydb/library/yql/dq/runtime/dq_input_producer.cpp @@ -433,6 +433,10 @@ class TDqInputMergeBlockStreamValue : public TComputationValue= BlockLen_; } + bool IsFinished() const { + return IsFinished_; + } + void NextRow() { Y_DEBUG_ABORT_UNLESS(!IsEmpty()); ++CurrBlockIndex_; @@ -645,7 +649,7 @@ class TDqInputMergeBlockStreamValue : public TComputationValue