File tree Expand file tree Collapse file tree 1 file changed +11
-0
lines changed
ydb/library/yql/providers/pq/provider Expand file tree Collapse file tree 1 file changed +11
-0
lines changed Original file line number Diff line number Diff line change @@ -129,6 +129,16 @@ class TPqDqIntegration: public TDqIntegrationBase {
129
129
columns = ctx.NewList (pos, std::move (cols));
130
130
}
131
131
132
+ auto row = Build<TCoArgument>(ctx, read->Pos ())
133
+ .Name (" row" )
134
+ .Done ();
135
+ auto emptyPredicate = Build<TCoLambda>(ctx, read->Pos ())
136
+ .Args ({row})
137
+ .Body <TCoBool>()
138
+ .Literal ().Build (" true" )
139
+ .Build ()
140
+ .Done ().Ptr ();
141
+
132
142
return Build<TDqSourceWrap>(ctx, read->Pos ())
133
143
.Input <TDqPqTopicSource>()
134
144
.World (pqReadTopic.World ())
@@ -138,6 +148,7 @@ class TPqDqIntegration: public TDqIntegrationBase {
138
148
.Token <TCoSecureParam>()
139
149
.Name ().Build (token)
140
150
.Build ()
151
+ .FilterPredicate (emptyPredicate)
141
152
.Build ()
142
153
.RowType (ExpandType (pqReadTopic.Pos (), *rowType, ctx))
143
154
.DataSource (pqReadTopic.DataSource ().Cast <TCoDataSource>())
You can’t perform that action at this time.
0 commit comments