Fix HasValue misuse for computation node state (#8555)

igormunkin · web-flow · commit 658689ddb56d · 2024-08-30T23:58:35.000+05:00
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_block_agg.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_block_agg.cpp
@@ -752,7 +752,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TBlockCombineAllWrap
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(state, ctx);
 
             auto& s = *static_cast<TState*>(state.AsBoxed().Get());
@@ -1638,7 +1638,7 @@ class THashedWrapperBase : public TStatefulWideFlowCodegeneratorNode<TDerived>,
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(state, ctx);
 
             auto& s = *static_cast<TState*>(state.AsBoxed().Get());
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_block_compress.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_block_compress.cpp
@@ -655,7 +655,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TCompressBlocks>;
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue())
+        if (state.IsInvalid())
             MakeState(ctx, state);
         return *static_cast<TState*>(state.AsBoxed().Get());
     }
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_block_map_join.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_block_map_join.cpp
@@ -247,7 +247,7 @@ using TState = TBlockJoinState<RightRequired>;
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
         return *static_cast<TState*>(state.AsBoxed().Get());
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_block_top.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_block_top.cpp
@@ -575,7 +575,7 @@ using TChunkedArrayIndex = std::vector<IArrayBuilder::TArrayDataItem>;
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             std::vector<bool> dirs(Directions_.size());
             std::transform(Directions_.cbegin(), Directions_.cend(), dirs.begin(), [&ctx](IComputationNode* dir){ return dir->GetValue(ctx).Get<bool>(); });
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_blocks.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_blocks.cpp
@@ -355,7 +355,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideToBlocksWrapper
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue())
+        if (state.IsInvalid())
             MakeState(ctx, state);
         return *static_cast<TState*>(state.AsBoxed().Get());
     }
@@ -506,7 +506,7 @@ using TBaseComputation = TStatefulFlowCodegeneratorNode<TFromBlocksWrapper>;
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue())
+        if (state.IsInvalid())
             MakeState(ctx, state);
         return *static_cast<TState*>(state.AsBoxed().Get());
     }
@@ -786,7 +786,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideFromBlocksWrapp
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
 
             const auto s = static_cast<TState*>(state.AsBoxed().Get());
@@ -1132,7 +1132,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TBlockExpandChunkedW
     }
 
     TBlockState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
 
             auto& s = *static_cast<TBlockState*>(state.AsBoxed().Get());
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_combine.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_combine.cpp
@@ -176,7 +176,7 @@ class TCombineCoreFlowWrapper: public std::conditional_t<IsMultiRowState,
     {}
 
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_extend.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_extend.cpp
@@ -210,7 +210,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TExtendWideFlowWrapp
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue())
+        if (state.IsInvalid())
             MakeState(ctx, state);
         return *static_cast<TState*>(state.AsBoxed().Get());
     }
@@ -327,7 +327,7 @@ class TExtendFlowWrapper : public TStatefulFlowCodegeneratorNode<TExtendFlowWrap
     }
 
     TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue())
+        if (state.IsInvalid())
             MakeState(ctx, state);
         return *static_cast<TState*>(state.AsBoxed().Get());
     }
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_flow.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_flow.cpp
@@ -296,7 +296,7 @@ using TBaseComputation = TWideFlowSourceCodegeneratorNode<TToWideFlowWrapper>;
     {}
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             state = Stream->GetValue(ctx);
         }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_grace_join.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_grace_join.cpp
@@ -1035,7 +1035,7 @@ class TGraceJoinWrapper : public TStatefulWideFlowCodegeneratorNode<TGraceJoinWr
         {}
 
         EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output)  const {
-            if (!state.HasValue()) {
+            if (state.IsInvalid()) {
                 MakeSpillingSupportState(ctx, state);
             }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_join.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_join.cpp
@@ -707,7 +707,7 @@ class TCommonJoinCoreWrapper : public TStatefulFlowComputationNode<TCommonJoinCo
     }
 
     NUdf::TUnboxedValue DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             state = ctx.HolderFactory.Create<TValue>(ctx, this);
         }
 
@@ -1150,7 +1150,7 @@ class TWideCommonJoinCoreWrapper : public TStatefulWideFlowCodegeneratorNode<TWi
     {}
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_squeeze_to_list.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_squeeze_to_list.cpp
@@ -48,7 +48,7 @@ class TSqueezeToListWrapper: public TStatefulFlowCodegeneratorNode<TSqueezeToLis
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
         if (state.IsFinish()) {
             return NUdf::TUnboxedValuePod::MakeFinish();
-        } else if (!state.HasValue()) {
+        } else if (state.IsInvalid()) {
             MakeState(ctx, Limit->GetValue(ctx).GetOrDefault(std::numeric_limits<ui64>::max()), state);
         }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_switch.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_switch.cpp
@@ -166,7 +166,7 @@ class TSwitchFlowWrapper : public TStatefulFlowCodegeneratorNode<TSwitchFlowWrap
         for (ui32 handlerIndex = 0; handlerIndex < handlersSize; ++handlerIndex) {
             Handlers[handlerIndex].Item->SetGetter([stateIndex = mutables.CurValueIndex - 1, handlerIndex, this](TComputationContext & context) {
                 NUdf::TUnboxedValue& state = context.MutableValues[stateIndex];
-                if (!state.HasValue()) {
+                if (state.IsInvalid()) {
                     MakeState(context, state);
                 }
 
@@ -183,7 +183,7 @@ class TSwitchFlowWrapper : public TStatefulFlowCodegeneratorNode<TSwitchFlowWrap
     }
 
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_todict.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_todict.cpp
@@ -923,7 +923,7 @@ class TSqueezeSetFlowWrapper : public TStatefulFlowCodegeneratorNode<TSqueezeSet
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
         if (state.IsFinish()) {
             return state.Release();
-        } else if (!state.HasValue()) {
+        } else if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
@@ -1108,7 +1108,7 @@ class TSqueezeSetWideWrapper : public TStatefulFlowCodegeneratorNode<TSqueezeSet
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
         if (state.IsFinish()) {
             return state.Release();
-        } else if (!state.HasValue()) {
+        } else if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
         auto** fields = ctx.WideFields.data() + WideFieldsIndex;
@@ -1432,7 +1432,7 @@ class TSqueezeMapFlowWrapper : public TStatefulFlowCodegeneratorNode<TSqueezeMap
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
         if (state.IsFinish()) {
             return state;
-        } else if (!state.HasValue()) {
+        } else if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
@@ -1625,7 +1625,7 @@ class TSqueezeMapWideWrapper : public TStatefulFlowCodegeneratorNode<TSqueezeMap
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
         if (state.IsFinish()) {
             return state;
-        } else if (!state.HasValue()) {
+        } else if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
         auto** fields = ctx.WideFields.data() + WideFieldsIndex;
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_wide_combine.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_wide_combine.cpp
@@ -806,7 +806,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideCombinerWrapper
     {}
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
@@ -1235,7 +1235,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideLastCombinerWra
     {}
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         } 
 
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_wide_top_sort.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_wide_top_sort.cpp
@@ -365,7 +365,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideTopWrapper<Sort
     }
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             const auto count = Count->GetValue(ctx).Get<ui64>();
             std::vector<bool> dirs(Directions.size());
             std::transform(Directions.cbegin(), Directions.cend(), dirs.begin(), [&ctx](IComputationNode* dir){ return dir->GetValue(ctx).Get<bool>(); });
@@ -885,7 +885,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideSortWrapper>;
     }
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             std::vector<bool> dirs(Directions.size());
             std::transform(Directions.cbegin(), Directions.cend(), dirs.begin(), [&ctx](IComputationNode* dir){ return dir->GetValue(ctx).Get<bool>(); });
             MakeState(ctx, state, dirs.data());
diff --git a/ydb/library/yql/minikql/comp_nodes/ut/mkql_block_skiptake_ut.cpp b/ydb/library/yql/minikql/comp_nodes/ut/mkql_block_skiptake_ut.cpp
@@ -59,7 +59,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TTestBlockFlowWrappe
 #endif
 private:
     EFetchResult DoCalculateImpl(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue& val1, NUdf::TUnboxedValue& val2, NUdf::TUnboxedValue& val3) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             state = NUdf::TUnboxedValue::Zero();
         }
 
diff --git a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_reader_impl.h b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_reader_impl.h
@@ -92,7 +92,7 @@ using TBaseComputation =  TStatefulWideFlowCodegeneratorNode<TDqYtReadWrapperBas
     }
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
diff --git a/ydb/library/yql/providers/yt/comp_nodes/yql_mkql_input.cpp b/ydb/library/yql/providers/yt/comp_nodes/yql_mkql_input.cpp
@@ -134,7 +134,7 @@ class TYtInputWrapper : public TMutableComputationNode<TYtInputWrapper> {
 
     NUdf::TUnboxedValuePod DoCalculate(TComputationContext& ctx) const {
         auto& state = ctx.MutableValues[StateIndex_];
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
@@ -189,7 +189,7 @@ using TBaseComputation = TStatefulFlowCodegeneratorNode<TYtFlowInputWrapper>;
     {}
 
     NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 
@@ -256,7 +256,7 @@ using TBaseComputation = TPairStateWideFlowCodegeneratorNode<TYtWideInputWrapper
     {}
 
     EFetchResult DoCalculate(NUdf::TUnboxedValue& state, NUdf::TUnboxedValue& current, TComputationContext& ctx, NUdf::TUnboxedValue*const* output) const {
-        if (!state.HasValue()) {
+        if (state.IsInvalid()) {
             MakeState(ctx, state);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -752,7 +752,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TBlockCombineAllWrap`
`752`	`752`	`}`
`753`	`753`
`754`	`754`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`755`		`- if (!state.HasValue()) {`
	`755`	`+ if (state.IsInvalid()) {`
`756`	`756`	`MakeState(state, ctx);`
`757`	`757`
`758`	`758`	`auto& s = static_cast<TState>(state.AsBoxed().Get());`
`@@ -1638,7 +1638,7 @@ class THashedWrapperBase : public TStatefulWideFlowCodegeneratorNode<TDerived>,`
`1638`	`1638`	`}`
`1639`	`1639`
`1640`	`1640`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`1641`		`- if (!state.HasValue()) {`
	`1641`	`+ if (state.IsInvalid()) {`
`1642`	`1642`	`MakeState(state, ctx);`
`1643`	`1643`
`1644`	`1644`	`auto& s = static_cast<TState>(state.AsBoxed().Get());`
Original file line number	Diff line number	Diff line change
`@@ -655,7 +655,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TCompressBlocks>;`
`655`	`655`	`}`
`656`	`656`
`657`	`657`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`658`		`- if (!state.HasValue())`
	`658`	`+ if (state.IsInvalid())`
`659`	`659`	`MakeState(ctx, state);`
`660`	`660`	`return static_cast<TState>(state.AsBoxed().Get());`
`661`	`661`	`}`
Original file line number	Diff line number	Diff line change
`@@ -247,7 +247,7 @@ using TState = TBlockJoinState<RightRequired>;`
`247`	`247`	`}`
`248`	`248`
`249`	`249`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`250`		`- if (!state.HasValue()) {`
	`250`	`+ if (state.IsInvalid()) {`
`251`	`251`	`MakeState(ctx, state);`
`252`	`252`	`}`
`253`	`253`	`return static_cast<TState>(state.AsBoxed().Get());`
Original file line number	Diff line number	Diff line change
`@@ -575,7 +575,7 @@ using TChunkedArrayIndex = std::vector<IArrayBuilder::TArrayDataItem>;`
`575`	`575`	`}`
`576`	`576`
`577`	`577`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`578`		`- if (!state.HasValue()) {`
	`578`	`+ if (state.IsInvalid()) {`
`579`	`579`	`std::vector<bool> dirs(Directions_.size());`
`580`	`580`	`std::transform(Directions_.cbegin(), Directions_.cend(), dirs.begin(), [&ctx](IComputationNode* dir){ return dir->GetValue(ctx).Get<bool>(); });`
`581`	`581`
Original file line number	Diff line number	Diff line change
`@@ -355,7 +355,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideToBlocksWrapper`
`355`	`355`	`}`
`356`	`356`
`357`	`357`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`358`		`- if (!state.HasValue())`
	`358`	`+ if (state.IsInvalid())`
`359`	`359`	`MakeState(ctx, state);`
`360`	`360`	`return static_cast<TState>(state.AsBoxed().Get());`
`361`	`361`	`}`
`@@ -506,7 +506,7 @@ using TBaseComputation = TStatefulFlowCodegeneratorNode<TFromBlocksWrapper>;`
`506`	`506`	`}`
`507`	`507`
`508`	`508`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`509`		`- if (!state.HasValue())`
	`509`	`+ if (state.IsInvalid())`
`510`	`510`	`MakeState(ctx, state);`
`511`	`511`	`return static_cast<TState>(state.AsBoxed().Get());`
`512`	`512`	`}`
`@@ -786,7 +786,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TWideFromBlocksWrapp`
`786`	`786`	`}`
`787`	`787`
`788`	`788`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`789`		`- if (!state.HasValue()) {`
	`789`	`+ if (state.IsInvalid()) {`
`790`	`790`	`MakeState(ctx, state);`
`791`	`791`
`792`	`792`	`const auto s = static_cast<TState*>(state.AsBoxed().Get());`
`@@ -1132,7 +1132,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TBlockExpandChunkedW`
`1132`	`1132`	`}`
`1133`	`1133`
`1134`	`1134`	`TBlockState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`1135`		`- if (!state.HasValue()) {`
	`1135`	`+ if (state.IsInvalid()) {`
`1136`	`1136`	`MakeState(ctx, state);`
`1137`	`1137`
`1138`	`1138`	`auto& s = static_cast<TBlockState>(state.AsBoxed().Get());`
Original file line number	Diff line number	Diff line change
`@@ -176,7 +176,7 @@ class TCombineCoreFlowWrapper: public std::conditional_t<IsMultiRowState,`
`176`	`176`	`{}`
`177`	`177`
`178`	`178`	`NUdf::TUnboxedValuePod DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`179`		`- if (!state.HasValue()) {`
	`179`	`+ if (state.IsInvalid()) {`
`180`	`180`	`MakeState(ctx, state);`
`181`	`181`	`}`
`182`	`182`
Original file line number	Diff line number	Diff line change
`@@ -210,7 +210,7 @@ using TBaseComputation = TStatefulWideFlowCodegeneratorNode<TExtendWideFlowWrapp`
`210`	`210`	`}`
`211`	`211`
`212`	`212`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`213`		`- if (!state.HasValue())`
	`213`	`+ if (state.IsInvalid())`
`214`	`214`	`MakeState(ctx, state);`
`215`	`215`	`return static_cast<TState>(state.AsBoxed().Get());`
`216`	`216`	`}`
`@@ -327,7 +327,7 @@ class TExtendFlowWrapper : public TStatefulFlowCodegeneratorNode<TExtendFlowWrap`
`327`	`327`	`}`
`328`	`328`
`329`	`329`	`TState& GetState(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`330`		`- if (!state.HasValue())`
	`330`	`+ if (state.IsInvalid())`
`331`	`331`	`MakeState(ctx, state);`
`332`	`332`	`return static_cast<TState>(state.AsBoxed().Get());`
`333`	`333`	`}`
Original file line number	Diff line number	Diff line change
`@@ -296,7 +296,7 @@ using TBaseComputation = TWideFlowSourceCodegeneratorNode<TToWideFlowWrapper>;`
`296`	`296`	`{}`
`297`	`297`
`298`	`298`	`EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValueconst output) const {`
`299`		`- if (!state.HasValue()) {`
	`299`	`+ if (state.IsInvalid()) {`
`300`	`300`	`state = Stream->GetValue(ctx);`
`301`	`301`	`}`
`302`	`302`
Original file line number	Diff line number	Diff line change
`@@ -1035,7 +1035,7 @@ class TGraceJoinWrapper : public TStatefulWideFlowCodegeneratorNode<TGraceJoinWr`
`1035`	`1035`	`{}`
`1036`	`1036`
`1037`	`1037`	`EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValueconst output) const {`
`1038`		`- if (!state.HasValue()) {`
	`1038`	`+ if (state.IsInvalid()) {`
`1039`	`1039`	`MakeSpillingSupportState(ctx, state);`
`1040`	`1040`	`}`
`1041`	`1041`
Original file line number	Diff line number	Diff line change
`@@ -707,7 +707,7 @@ class TCommonJoinCoreWrapper : public TStatefulFlowComputationNode<TCommonJoinCo`
`707`	`707`	`}`
`708`	`708`
`709`	`709`	`NUdf::TUnboxedValue DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx) const {`
`710`		`- if (!state.HasValue()) {`
	`710`	`+ if (state.IsInvalid()) {`
`711`	`711`	`state = ctx.HolderFactory.Create<TValue>(ctx, this);`
`712`	`712`	`}`
`713`	`713`
`@@ -1150,7 +1150,7 @@ class TWideCommonJoinCoreWrapper : public TStatefulWideFlowCodegeneratorNode<TWi`
`1150`	`1150`	`{}`
`1151`	`1151`
`1152`	`1152`	`EFetchResult DoCalculate(NUdf::TUnboxedValue& state, TComputationContext& ctx, NUdf::TUnboxedValueconst output) const {`
`1153`		`- if (!state.HasValue()) {`
	`1153`	`+ if (state.IsInvalid()) {`
`1154`	`1154`	`MakeState(ctx, state);`
`1155`	`1155`	`}`
`1156`	`1156`