blob: ffc0d232f811e53b6d0f779648b473dd269c2033 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
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 || "_ytflow" as string_field,
int64_field * 100 as int64_field,
int64_field > 10 as bool_field
from Input
where string_field = "foo" or int64_field >= 100;
|
