flink table api 自定義數據格式解析(binlog 篇)

       flink table api目前支持的數據格式(https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/tableApi.html ）除基礎數據格式外還支持pojo,但畢竟支持有限，我們希望通過固定的解析，就能直接從kafka直接消費數據，並封裝成register table，以供sql查詢。本文主

>>阅读原文<<