1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
CREATE SOURCE avro_source
FROM KAFKA CONNECTION kafka_connection (TOPIC 'test_topic')
FORMAT AVRO USING CONFLUENT SCHEMA REGISTRY CONNECTION csr_connection
WITH (SIZE = '3xsmall');
CREATE VIEW jsonified_kafka_source AS
SELECT
data->>'field1' AS field_1,
data->>'field2' AS field_2,
data->>'field3' AS field_3
FROM (SELECT CONVERT_FROM(data, 'utf8')::jsonb AS data FROM json_source);
CREATE SOURCE proto_source
FROM KAFKA CONNECTION kafka_connection (TOPIC 'test_topic')
FORMAT PROTOBUF USING CONFLUENT SCHEMA REGISTRY CONNECTION csr_connection
WITH (SIZE = '3xsmall');
CREATE SOURCE text_source
FROM KAFKA CONNECTION kafka_connection (TOPIC 'test_topic')
FORMAT TEXT
ENVELOPE UPSERT
WITH (SIZE = '3xsmall');
CREATE SOURCE csv_source (col_foo, col_bar, col_baz)
FROM KAFKA CONNECTION kafka_connection (TOPIC 'test_topic')
FORMAT CSV WITH 3 COLUMNS
WITH (SIZE = '3xsmall');
CREATE SOURCE auction_house
FROM LOAD GENERATOR AUCTION
FOR ALL TABLES
WITH (SIZE = '3xsmall');
CREATE SOURCE marketing
FROM LOAD GENERATOR MARKETING (SCALE FACTOR 1)
FOR ALL TABLES
WITH (SIZE = '3xsmall');
CREATE SOURCE marketing
IN CLUSTER my_cluster
FROM LOAD GENERATOR MARKETING
FOR ALL TABLES;
CREATE SOURCE tpch
FROM LOAD GENERATOR TPCH (SCALE FACTOR 1)
FOR ALL TABLES
WITH (SIZE = '3xsmall');
CREATE SOURCE counter
FROM LOAD GENERATOR COUNTER
WITH (SIZE = '3xsmall');
CREATE SOURCE mz_source
FROM POSTGRES CONNECTION pg_connection (PUBLICATION 'mz_source')
FOR ALL TABLES
WITH (SIZE = '3xsmall');
CREATE SOURCE mz_source
IN CLUSTER my_cluster
FROM POSTGRES CONNECTION pg_connection (PUBLICATION 'mz_source')
FOR ALL TABLES;
CREATE SOURCE mz_source
FROM POSTGRES CONNECTION pg_connection (PUBLICATION 'mz_source')
FOR TABLES (table_1, table_2 AS alias_table_2)
WITH (SIZE = '3xsmall');
CREATE SOURCE mz_source
FROM POSTGRES CONNECTION pg_connection (
PUBLICATION 'mz_source',
TEXT COLUMNS (table.column_of_unsupported_type)
) FOR ALL TABLES
WITH (SIZE = '3xsmall');
CREATE SOURCE mz_source
FROM POSTGRES CONNECTION pg_connection (PUBLICATION 'mz_source')
WITH (SIZE = '3xsmall');
CREATE SOURCE my_webhook_source IN CLUSTER my_cluster FROM WEBHOOK
BODY FORMAT JSON
INCLUDE HEADERS ( NOT 'authorization', NOT 'x-api-key' );
CREATE SOURCE my_webhook_source IN CLUSTER my_cluster FROM WEBHOOK
BODY FORMAT JSON
CHECK (
WITH (
HEADERS, BODY AS request_body,
SECRET my_webhook_shared_secret
)
decode(headers->'x-signature', 'base64') = hmac(request_body, my_webhook_shared_secret, 'sha256')
);
CREATE SOURCE webhook_with_basic_auth IN CLUSTER my_cluster
FROM WEBHOOK
BODY FORMAT JSON
CHECK (
WITH (
HEADERS,
BODY AS request_body,
SECRET BASIC_HOOK_AUTH
)
headers->'authorization' = BASIC_HOOK_AUTH
);
CREATE TYPE type_name AS ( field_name field_type , field_name field_type );
CREATE TYPE row_type AS (a int, b text);
CREATE TYPE nested_row_type AS (a row_type, b float8);
|
