Flink除了可以将结果写入到文本、Socket、Kafka、RabbitMQ等终端,还可以将Flink计算结… 继续阅读 Flink从入门到实战四[DataStream API]-24-Sink数据输出到JDBC
标签: DataStream API
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]-4-Source数据源
Flink应用要计算,必须要有执行环境,有了执行环境,那么就需要将要数据输入到计算应用中了。Flink提供了丰… 继续阅读 Flink从入门到实战四[DataStream API]-4-Source数据源
Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
StreamExecutionEnvironment内部的方法非常多,我们从整体功能上进行简单划分,主要包括:… 继续阅读 Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
Flink从入门到实战四[DataStream API]-1-DataStream API简介
DataStream API是Flink用于数据处理的API。是对有界数据和无界数据处理的API。 DataS… 继续阅读 Flink从入门到实战四[DataStream API]-1-DataStream API简介