特牛网址导航

Flink 流处理核心API_flink api keyby过时-CSDN博客

网友收藏
文章浏览阅读139次。Flink 流处理核心APIEnvironmentSource从Java的集合中读取数据从文件读取数据从Socket读取数据从Kafka读取数据自定义数据源TransformmapflatMapfilterkeyByshuffle过时的split和selectconnectunion简单滚动聚合算子reduceprocess对流重新分区的几个算子SinkprintkafkaSinkRedisSinkElasticsearchSink自定义SinkEnvironment// 批处理环境Execution_flink api keyby过时