Advertisement

【Flink1.11新特性】DataGen和print方便测试

阅读量：

利用datagen connector生成 数据

利用print connector把结果打印在 控制台 ，方便查看结果测试

复制代码 
    package com.otis.scala.test
    
    import org.apache.flink.streaming.api.TimeCharacteristic
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
    import org.apache.flink.table.api._
    import org.apache.flink.table.api.bridge.java.StreamTableEnvironment
    
    object DataGenTest {
      def main(args: Array[String]): Unit = {
    
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(1)
    env.setStreamTimeCharacteristic(TimeCharacteristic.

全部评论 (0)

还没有任何评论哟~

相关文章推荐