In the lab: [de-c3w3lab2]
This is not an issue or problem in lab. But rather a clarification on the SQL format used
Look at this SQL for Sink Table
output_ddl = “”" CREATE TABLE json_sink (
ticker VARCHAR(6),
price DOUBLE,
event_time VARCHAR(64)
)
PARTITIONED BY (ticker)
WITH (
‘connector’ = ‘filesystem’,
‘path’ = ‘{0}’,
‘format’ = ‘json’,
‘json.timestamp-format.standard’ = ‘ISO-8601’
) “”".format(‘data/output_sample’)
table_env.execute_sql(output_ddl)
In this the part starting from PARTITIONED BY and further WITH statement, is it a standard SQL keyowrds allowed or is it allowed only in flink?