发表评论取消回复
相关阅读
相关 Flink中的ProcessFunction API
一、背景介绍 之前学习的转换算子是无法访问事件的时间戳信息和水位线信息的,而这些信息在一些应用场景是比较重要的。例如,MapFunction这样的map转换算子就无法访问
相关 Flink 流处理API
一、Environment 1.1 getExecutionEnvironment 创建一个执行环境,表示当前执行程序的上下文。如果程序是独立调用的,则此方法返回本
相关 4.1.20 Flink-流处理框架-ProcessFunction API(底层 API)
目录 1.写在前面 2.Process Function中的细节 2.1 KeyedProcessFunction(重点介绍) 2.1.1 TimerService 和
相关 4.1.15 Flink-流处理框架-Flink流处理API之sink输出操作
目录 1.写在前面 2.输出到Kafka(source/sink) 3.输出到Redis(sink) 4.输出到Elasticsearch(sink) 5.JDBC
相关 4.1.14 Flink-流处理框架-Flink流处理API之数据重分区操作
目录 1.写在前面 2.并行度 3.数据重分布 3.1 shuffle 3.2 rebalance与rescale 3.3 broadcast 3.4 globa
相关 4.1.11 Flink-流处理框架-Flink流处理API之Transform转换算子
目录 1.基本转换算子 1.1 map 1.2 flatMap扁平化算子 1.3 Filter过滤算子 1.4 基本算子代码演示 2.聚合算子 2.1 KeyBy
相关 4.1.10 Flink-流处理框架-Flink流处理API之Source数据源
目录 1.写在前面 2.Source数据源 2.1 从集合中读取数据 2.2 从文件中读取数据 2.3 以kafka消息队列的数据作为数据来源 2.4 自定义Sou
相关 4.1.9 Flink-流处理框架-Flink流处理API之Environment
目录 1.写在前面 2.Environment:环境 2.1 getExecutionEnvironment:得到执行环境 2.2 createLocalEnviron
相关 Flink-底层API(ProcessFunction API)学习使用
ProcessFunction API(底层 API) 转换算子 是无法访问事件的时间戳信息和 水位线信息的。而这在一些应用场景下,极为重要。例如 MapFunction
相关 Flink 流处理API之 Source TransForm
DataStream编程模型 > DataStream API 主要分为三个模块 DataSource模块 Transformation模块 Data
还没有评论,来说两句吧...