aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/sql/suites/produce/process_streaming.sql
blob: 1ad7274c79c62679fddb8e921f5e891dd35b6a32 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/* syntax version 1 */
/* postgres can not */
-- not supported on windows

$input = (
	SELECT String::JoinFromList(AsList(key, subkey, value), ",") AS Data FROM plato.Input1
);

$processed = (
	PROCESS $input USING Streaming::Process(TableRows(), "grep", AsList("[14]"))
);

$list = (
	SELECT String::SplitToList(Data, ',') AS DataList FROM $processed
);

SELECT 
	input.DataList[0] AS key,
	input.DataList[1] AS subkey,
	input.DataList[2] AS value
FROM $list AS input;