diff options
| -rw-r--r-- | ydb/library/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt.cpp b/ydb/library/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt.cpp index 0ae1a77a400..b415f696006 100644 --- a/ydb/library/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt.cpp +++ b/ydb/library/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt.cpp @@ -56,6 +56,8 @@ TYtPhysicalOptProposalTransformer::TYtPhysicalOptProposalTransformer(TYtState::T AddHandler(0, &TYtDqWrite::Match, HNDL(YtDqWrite)); AddHandler(0, &TYtDqProcessWrite::Match, HNDL(YtDqProcessWrite)); AddHandler(0, &TYtEquiJoin::Match, HNDL(EarlyMergeJoin)); + AddHandler(0, &TYtOutputOpBase::Match, HNDL(TableContentWithSettings)); + AddHandler(0, &TYtOutputOpBase::Match, HNDL(NonOptimalTableContent)); if (!State_->Configuration->DisableFuseOperations.Get().GetOrElse(DEFAULT_DISABLE_FUSE_OPERATIONS)) { AddHandler(1, &TYtMap::Match, HNDL(FuseInnerMap)); @@ -68,8 +70,6 @@ TYtPhysicalOptProposalTransformer::TYtPhysicalOptProposalTransformer(TYtState::T AddHandler(1, Names({TYtMap::CallableName(), TYtMapReduce::CallableName()}), HNDL(WeakFields)); AddHandler(1, &TYtTransientOpBase::Match, HNDL(BypassMerge)); AddHandler(1, &TYtPublish::Match, HNDL(BypassMergeBeforePublish)); - AddHandler(1, &TYtOutputOpBase::Match, HNDL(TableContentWithSettings)); - AddHandler(1, &TYtOutputOpBase::Match, HNDL(NonOptimalTableContent)); AddHandler(1, &TCoRight::Match, HNDL(ReadWithSettings)); AddHandler(1, &TYtTransientOpBase::Match, HNDL(PushDownKeyExtract)); AddHandler(1, &TYtTransientOpBase::Match, HNDL(TransientOpWithSettings)); |