yql/essentials/tests/sql/suites/produce/process_streaming_count.sql


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

/* 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]"))
);

SELECT 
    *
FROM $processed;

SELECT
    COUNT(*)
FROM $processed;