blob: 1f616de7e79000b2374e227bdc5eaf3511bca81d (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
#include "yql_pg_provider_impl.h"
#include <yql/essentials/core/expr_nodes/yql_expr_nodes.h>
#include <yql/essentials/providers/pg/expr_nodes/yql_pg_expr_nodes.h>
#include <yql/essentials/providers/common/provider/yql_provider.h>
#include <yql/essentials/providers/common/provider/yql_provider_names.h>
#include <yql/essentials/providers/common/provider/yql_data_provider_impl.h>
#include <yql/essentials/utils/log/log.h>
namespace NYql {
using namespace NNodes;
class TPgDataSinkExecTransformer : public TExecTransformerBase {
public:
TPgDataSinkExecTransformer(TPgState::TPtr state)
: State_(state)
{
AddHandler({TCoCommit::CallableName()}, RequireFirst(), Pass());
}
private:
TPgState::TPtr State_;
};
THolder<TExecTransformerBase> CreatePgDataSinkExecTransformer(TPgState::TPtr state) {
return THolder(new TPgDataSinkExecTransformer(state));
}
} // namespace NYql
|
