开发参考

可参考官方csv format的实现。

注意:开发时pom中相关的flink依赖需要添加<scope>provided</scope>

平台上使用

  1. 在平台的文件依赖中添加format打的jar包文件。
  2. 在sql的配置中:'format'='XXX'(在FormatFactory中定义的identifier)