yt/yql/tests/sql/suites/ytflow/write_with_expression_column.yql


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

/* sort outputs */

use plato;

pragma Engine = "ytflow";

pragma Ytflow.Cluster = "plato";
pragma Ytflow.PipelinePath = "pipelines/test";

pragma Ytflow.YtConsumerPath = "yql_ytflow/consumers/main_consumer";
pragma Ytflow.YtProducerPath = "yql_ytflow/producers/main_producer";

insert into Output
select
    string_field as key,
    int64_field as kv_value
from Input
where int64_field >= 10;