Skip to content

Commit ba5dde7

Browse files
committed
Intermediate changes
commit_hash:8026b59c61f0972ec1704587621ad2bf4cf4b431
1 parent 6dcbede commit ba5dde7

File tree

2 files changed

+20
-0
lines changed

2 files changed

+20
-0
lines changed
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
in Input input.txt
2+
out Output output.txt
3+
providers ytflow
4+
udf string_udf
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
use plato;
2+
3+
pragma Engine = "ytflow";
4+
5+
pragma Ytflow.Cluster = "plato";
6+
pragma Ytflow.PipelinePath = "pipeline";
7+
8+
pragma Ytflow.YtConsumerPath = "consumers/main_consumer";
9+
pragma Ytflow.YtProducerPath = "consumers/main_producer";
10+
11+
insert into Output
12+
select
13+
String::AsciiToUpper(string_field) as string_field,
14+
LENGTH(string_field) as int64_field,
15+
String::Contains(string_field, "bar") as bool_field
16+
from Input;

0 commit comments

Comments
 (0)