Revert adding FilterPredicate (#10763)

Author: APozdniakov

ydb/library/yql/providers/pq/expr_nodes/yql_pq_expr_nodes.json

@@ -71,8 +71,7 @@
                 {"Index": 1, "Name": "Topic", "Type": "TPqTopic"},
                 {"Index": 2, "Name": "Columns", "Type": "TExprBase"},
                 {"Index": 3, "Name": "Settings", "Type": "TCoNameValueTupleList"},
-                {"Index": 4, "Name": "Token", "Type": "TCoSecureParam"},
-                {"Index": 5, "Name": "FilterPredicate", "Type": "TCoLambda"}
+                {"Index": 4, "Name": "Token", "Type": "TCoSecureParam"}
             ]
         },
         {

ydb/library/yql/providers/pq/provider/yql_pq_datasource_type_ann.cpp

@@ -131,7 +131,7 @@ class TPqDataSourceTypeAnnotationTransformer : public TVisitorTransformerBase {
     }
 
     TStatus HandleDqTopicSource(TExprBase input, TExprContext& ctx) {
-        if (!EnsureArgsCount(input.Ref(), 6, ctx)) {
+        if (!EnsureArgsCount(input.Ref(), 5, ctx)) {
             return TStatus::Error;
         }
 

ydb/library/yql/providers/pq/provider/yql_pq_dq_integration.cpp

@@ -129,16 +129,6 @@ class TPqDqIntegration: public TDqIntegrationBase {
                 columns = ctx.NewList(pos, std::move(cols));
             }
 
-            auto row = Build<TCoArgument>(ctx, read->Pos())
-                .Name("row")
-                .Done();
-            auto emptyPredicate = Build<TCoLambda>(ctx, read->Pos())
-                .Args({row})
-                .Body<TCoBool>()
-                    .Literal().Build("true")
-                    .Build()
-                .Done().Ptr();
-
             return Build<TDqSourceWrap>(ctx, read->Pos())
                 .Input<TDqPqTopicSource>()
                     .World(pqReadTopic.World())
@@ -148,7 +138,6 @@ class TPqDqIntegration: public TDqIntegrationBase {
                     .Token<TCoSecureParam>()
                         .Name().Build(token)
                         .Build()
-                    .FilterPredicate(emptyPredicate)
                     .Build()
                 .RowType(ExpandType(pqReadTopic.Pos(), *rowType, ctx))
                 .DataSource(pqReadTopic.DataSource().Cast<TCoDataSource>())