发表评论取消回复
相关阅读
相关 Flink 1.17教程:DataStream实现Wordcount——读socket(无界流)
pom.xml <properties> <flink.version>1.17.0</flink.version> </
相关 java Flink(二)数据流处理demo
上文介绍的是数据批处理,可以简单理解为就是一批固定的数据 数据流处理的意思是,有源源不断的数据,来一个数据进行以此处理。 还是一样的分词处理,这次用流处理方式,直接上代码(
相关 阻塞队列,有界队列,无界队列
在并发编程中,有时候需要使用线程安全的队列。如果要实现一个线程安全的队列有两种方式:一种是使用阻塞算法,另一种是使用非阻塞算法。 使用阻塞算法的队列可以用一个锁(入队和出队用
相关 Flink的有界流和无界流
Flink的有界流和无界流 一、创建maven项目 POM文件中添加需要的依赖: <properties> <flink.version>
相关 flink使用SQL处理有界数据流
目录 主类 MyOrder类 pom.xml 结果输出 -------------------- 主类 package myflink.sql;
相关 flink使用SQL处理无界数据流
目录 主类 MySource类 pom.xml 结果输出 -------------------- 主类 package myflink.sql;
相关 Flink使用Table API处理有界数据流
目录 主类 pom.xml 结果输出 -------------------- 主类 package myflink.table; i
相关 Flink使用Table API处理无界数据流
目录 主类 pom.xml 结果输出 -------------------- 主类 package practice; import
相关 flink使用DataStream API处理无界数据流
目录 主类: MySource类(生成数据端) pom.xml 输出结果: 添加时间窗口 结果输出 注意: -------------------- 主类:
相关 flink使用DataStream API处理有界数据流
目录 主类 pom.xml 运行结果 -------------------- 主类 package practice; import
还没有评论,来说两句吧...