@@ -36,6 +36,13 @@ EChannelMode GetChannelMode(NKikimrConfig::TTableServiceConfig_EBlockChannelsMod
36
36
}
37
37
}
38
38
39
+ TAutoPtr<NYql::IGraphTransformer> CreateKqpBuildWideBlockChannelsTransformer (
40
+ TTypeAnnotationContext& typesCtx,
41
+ NKikimrConfig::TTableServiceConfig_EBlockChannelsMode blockChannelsMode) {
42
+ const EChannelMode mode = GetChannelMode (blockChannelsMode);
43
+ return NDq::CreateDqBuildWideBlockChannelsTransformer (typesCtx, mode);
44
+ }
45
+
39
46
TAutoPtr<NYql::IGraphTransformer> CreateKqpBuildPhyStagesTransformer (
40
47
bool allowDependantConsumers,
41
48
TTypeAnnotationContext& typesCtx,
@@ -571,6 +578,8 @@ class TKqpBuildTxsTransformer : public TSyncTransformerBase {
571
578
.Add (*TypeAnnTransformer, " TypeAnnotation" )
572
579
.AddPostTypeAnnotation (/* forSubgraph */ true )
573
580
.Add (CreateKqpBuildPhyStagesTransformer (enableSpillingGenericQuery, typesCtx, config->BlockChannelsMode ), " BuildPhysicalStages" )
581
+ // TODO(ilezhankin): "BuildWideBlockChannels" transformer is required only for BLOCK_CHANNELS_FORCE mode.
582
+ .Add (CreateKqpBuildWideBlockChannelsTransformer (typesCtx, config->BlockChannelsMode ), " BuildWideBlockChannels" )
574
583
.Add (*BuildTxTransformer, " BuildPhysicalTx" )
575
584
.Add (CreateKqpTxPeepholeTransformer (
576
585
TypeAnnTransformer.Get (), typesCtx, config,
0 commit comments