JSON Format

    JSON Format 能读写 JSON 格式的数据。当前,JSON schema 是从 table schema 中自动推导而得的。

    以下是一个利用 Kafka 以及 JSON Format 构建表的例子。

    1. user_id BIGINT,
    2. item_id BIGINT,
    3. behavior STRING,
    4. ts TIMESTAMP(3)
    5. ) WITH (
    6. 'connector' = 'kafka',
    7. 'topic' = 'user_behavior',
    8. 'properties.bootstrap.servers' = 'localhost:9092',
    9. 'properties.group.id' = 'testGroup',
    10. 'json.fail-on-missing-field' = 'false',
    11. 'json.ignore-parse-errors' = 'true'
    12. )

    在 Flink 中,JSON Format 使用 去解析和生成 JSON。