Skip to content

Commit d3963da

Browse files
authored
Merge a99f27f into 1f9cb6b
2 parents 1f9cb6b + a99f27f commit d3963da

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/core/kqp/executer_actor/kqp_partition_helper.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ THashMap<ui64, TShardParamValuesAndRanges> PartitionParamByKey(
112112
THashMap<ui64, TShardParamValuesAndRanges> PartitionParamByKeyPrefix(
113113
const NUdf::TUnboxedValue& value, NKikimr::NMiniKQL::TType* type,
114114
const TTableId& tableId, const TIntrusiveConstPtr<TTableConstInfo>& tableInfo, const TKeyDesc& key,
115-
const NMiniKQL::THolderFactory&, const NMiniKQL::TTypeEnvironment& typeEnv, bool isFullScan)
115+
const NMiniKQL::THolderFactory&, const NMiniKQL::TTypeEnvironment& typeEnv, bool& isFullScan)
116116
{
117117
YQL_ENSURE(tableInfo);
118118

@@ -754,7 +754,7 @@ using namespace NMiniKQL;
754754

755755
THashMap<ui64, TShardInfo> PartitionLookupByParameterValue(const NKqpProto::TKqpPhyParamValue& proto,
756756
const TStageInfo& stageInfo, const THolderFactory& holderFactory,
757-
const TTypeEnvironment& typeEnv, bool isFullScan)
757+
const TTypeEnvironment& typeEnv, bool& isFullScan)
758758
{
759759
const auto& name = proto.GetParamName();
760760
auto [type, value] = stageInfo.Meta.Tx.Params->GetParameterUnboxedValue(name);
@@ -784,7 +784,7 @@ THashMap<ui64, TShardInfo> PartitionLookupByParameterValue(const NKqpProto::TKqp
784784

785785
THashMap<ui64, TShardInfo> PartitionLookupByRowsList(const NKqpProto::TKqpPhyRowsList& proto,
786786
const TStageInfo& stageInfo, const THolderFactory& holderFactory,
787-
const TTypeEnvironment& typeEnv, bool isFullScan)
787+
const TTypeEnvironment& typeEnv, bool& isFullScan)
788788
{
789789
std::unordered_map<ui64, THashSet<TString>> shardParams; // shardId -> paramNames
790790
std::unordered_map<ui64, TShardParamValuesAndRanges> ret;

0 commit comments

Comments
 (0)