无分类 [case48]聊聊flink的SocketClientSink flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java
无分类 聊聊flink的PrintSinkFunction flink-streaming-java_2.11-1.7.0-sources.jar!/org/apache/flink/streaming/api/datastream/DataStream.java
无分类 聊聊flink的ParallelIteratorInputFormat 这里使用ExecutionEnvironment的generateSequence方法创建了带NumberSequenceIterator的ParallelIteratorInputFormat
无分类 聊聊flink的RichParallelSourceFunction RichParallelSourceFunction实现了ParallelSourceFunction接口,同时继承了AbstractRichFunction
storm [case47]聊聊flink的BoltWrapper flink-storm_2.11-1.6.2-sources.jar!/org/apache/flink/storm/wrappers/BoltWrapper.java
storm 聊聊flink的SpoutWrapper flink-storm_2.11-1.6.2-sources.jar!/org/apache/flink/storm/wrappers/SpoutWrapper.java
storm 聊聊flink如何兼容StormTopology 这里使用FlinkLocalCluster.getLocalCluster()来创建或获取FlinkLocalCluster,之后调用FlinkLocalCluster.submitTopology来提交topology,结束时通过FlinkLocalCluster.shutdown来关闭cluster
无分类 美团点评基于 Flink 的实时数仓建设实践 近些年,企业对数据服务实时化服务的需求日益增多。本文整理了常见实时数据组件的性能特点和适用场景,介绍了美团如何通过 Flink 引擎构建实时数据仓库,从而提供高效、稳健的实时数据服务。此前我们美团技术博客…