ProcessWindowFunction是一个全量计算函数，也就是窗口内数据到达后不计算，而是等到窗口出发时… 继续阅读 Flink从入门到实战五[Window]-7-ProcessWindowFunction基于AggregateFunction增量计算
Flink从入门到实战五[Window]-6-ProcessWindowFunction基于RecuctFunction增量计算
ProcessWindowFunction是一个全量计算函数，也就是窗口内数据到达后不计算，而是等到窗口出发时… 继续阅读 Flink从入门到实战五[Window]-6-ProcessWindowFunction基于RecuctFunction增量计算
Flink从入门到实战五[Window]-5-Window Function ProcessWindowFunction
ProcessWindowFunction官方解释：A ProcessWindowFunction gets … 继续阅读 Flink从入门到实战五[Window]-5-Window Function ProcessWindowFunction
Flink从入门到实战五[Window]-4-Window Function AggregateFunction
AggregateFunction是一个功能加强的ReduceFunction，ReduceFunction只… 继续阅读 Flink从入门到实战五[Window]-4-Window Function AggregateFunction
Flink从入门到实战五[Window]-3-Window Function ReduceFunction
ReduceFunction能够指定两个元素如何合并生成一个元素，两个输入元素和最终输出元素的类型必须相同。R… 继续阅读 Flink从入门到实战五[Window]-3-Window Function ReduceFunction
Flink从入门到实战五[Window]-2-Window API初探
上一篇文章从整体上了解了窗口的概念、分类，接下来我们用两个简单的demo来看一下如何使用窗口来进行计算。 de… 继续阅读 Flink从入门到实战五[Window]-2-Window API初探
Flink从入门到实战五[Window]-1-Window窗口
窗口Windows是处理无限流的核心，Windows是将无限流通过一定条件切割为有限流的一种方式，它会将流数据… 继续阅读 Flink从入门到实战五[Window]-1-Window窗口
Flink从入门到实战四[DataStream API]-24-Sink数据输出到JDBC
Flink除了可以将结果写入到文本、Socket、Kafka、RabbitMQ等终端，还可以将Flink计算结… 继续阅读 Flink从入门到实战四[DataStream API]-24-Sink数据输出到JDBC
Flink从入门到实战四[DataStream API]-23-Sink数据输出到Redis
使用Redis作为Sink，我们需要定义一个RedisSink对象，addSink方法中的RedisSink需… 继续阅读 Flink从入门到实战四[DataStream API]-23-Sink数据输出到Redis
Flink从入门到实战四[DataStream API]-22-Sink数据输出到Kafka
Flink Kafka Producer 被称为 FlinkKafkaProducer。它允许将消息流写入一个… 继续阅读 Flink从入门到实战四[DataStream API]-22-Sink数据输出到Kafka
Flink从入门到实战四[DataStream API]-21-Sink数据输出到Socket
我们来看一下，如何将Flink的计算结果输出到Socket。 使用Socket来接收Flink输出结果。1、启… 继续阅读 Flink从入门到实战四[DataStream API]-21-Sink数据输出到Socket
Flink从入门到实战四[DataStream API]-20-Sink数据输出到文件
Flink将计算结果输出到文件，代码如下： 需要注意的是，输出到文件，运行环境并发度要设置为1，即env.se… 继续阅读 Flink从入门到实战四[DataStream API]-20-Sink数据输出到文件
Flink从入门到实战四[DataStream API]-19-Sink数据输出
了解了前面的数据源和数据转换，接下来我们看一下数据输出部分，Flink中定义为Sink。Data sinks … 继续阅读 Flink从入门到实战四[DataStream API]-19-Sink数据输出
Flink从入门到实战四[DataStream API]-18-Transform Window
Window是Flink中无限流处理的核心，Flink中将Window也算作是数据转换算子。Window有多种… 继续阅读 Flink从入门到实战四[DataStream API]-18-Transform Window
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数据转换