来实现flink job的动态生成。 数据接口之间可以使用动态类型，也可以支持静态类型，增加了groovy的transform算子，可以通过动态脚本迁入不同的业务。达到flink job级别的复用。 同时提供了flink sql 提交，同时支持sql protobuf格式。