JSON Format
JSON Format 能读写 JSON 格式的数据。当前,JSON schema 是从 table schema 中自动推导而得的。
以下是一个利用 Kafka 以及 JSON Format 构建表的例子。
user_id BIGINT,
item_id BIGINT,
behavior STRING,
ts TIMESTAMP(3)
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'testGroup',
'json.fail-on-missing-field' = 'false',
'json.ignore-parse-errors' = 'true'
)
在 Flink 中,JSON Format 使用 去解析和生成 JSON。