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


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

use plato;

pragma Engine = "ytflow";

pragma Ytflow.Cluster = "plato";
pragma Ytflow.PipelineDirectory = "pipelines";
pragma Ytflow.PipelineName = "test";

$suffix = FileContent("file.txt");
$delta = Cast(FileContent("http_file.txt") as Int64);
$path = FilePath("file.txt");

insert into Output
select 
    string_field || $suffix || "_" || $path as string_field,
    int64_field + $delta as int64_field,
    true as bool_field
from Input;