Window是Flink中无限流处理的核心,Flink中将Window也算作是数据转换算子。Window有多种… 继续阅读 Flink从入门到实战四[DataStream API]-18-Transform Window
标签: Transform
Flink从入门到实战四[DataStream API]-17-Transform连接流Connect
Connect的支持将两个类型不同的流合并,输出一个类型为ConnectedStream的流。Connecte… 继续阅读 Flink从入门到实战四[DataStream API]-17-Transform连接流Connect
Flink从入门到实战四[DataStream API]-16-Transform连接流Union
Union的作用是将两个或多个流合并,创建出一个新流,要求作为数据源的流类型一致,最终数据的新流类型和数据源一… 继续阅读 Flink从入门到实战四[DataStream API]-16-Transform连接流Union
Flink从入门到实战四[DataStream API]-15-Transform聚合算子Reduce
DataStream API没有reduce和sum这类聚合操作的方法,因为Flink设计中,数据必须先分组才… 继续阅读 Flink从入门到实战四[DataStream API]-15-Transform聚合算子Reduce
Flink从入门到实战四[DataStream API]-14-Transform分组算子KeyBy
DataStream API没有reduce和sum这类聚合操作的方法,因为Flink设计中,数据必须先分组才… 继续阅读 Flink从入门到实战四[DataStream API]-14-Transform分组算子KeyBy
Flink从入门到实战四[DataStream API]-13-Transform基础算子Map、FlatMap和Filter
Transform的基础算子主要用来做数据转换和过滤,包括:map、flatMap和filter。 Map将D… 继续阅读 Flink从入门到实战四[DataStream API]-13-Transform基础算子Map、FlatMap和Filter
Flink从入门到实战四[DataStream API]-12-Transform数据转换
Transform的作用就是对数据进行处理、转换,Flink中提供了丰富的API,这类API也称为算子。数据在… 继续阅读 Flink从入门到实战四[DataStream API]-12-Transform数据转换