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


1
2
3
4
5
6
7
8
9
10
11
12
13
14

/* syntax version 1 */
/* postgres can not */
-- not supported on windows

$script = @@
#!/bin/bash
cat - | grep $1 | head -n 3 | grep [234]
@@;

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

PROCESS $input USING Streaming::ProcessInline(TableRows(), $script, AsList("bar"));