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数据转换
Flink运行时报错:Specifying keys via field positions is only valid for tuple data types
看异常其实问题已经比较明显了: 代码: keyBy用法keyBy(0)或者keyBy(item->ite… 继续阅读 Flink运行时报错:Specifying keys via field positions is only valid for tuple data types
kafka启动报错:Connection to node -1 (localhost/127.0.0.1:9092) could not be established
Java连接kafka超时报错
报错原因是因为连不上Kafka连不上的原因是因为Java连kafka,kafka需要添加一个配置:advert… 继续阅读 Java连接kafka超时报错
Flink运行时报错:Cannot reference field by position on PojoType
原因是Cannot reference field by position on PojoType,虽然编译器… 继续阅读 Flink运行时报错:Cannot reference field by position on PojoType
Flink运行时报错:could not be determined automatically, due to type erasure
代码: 原因:Lambda无法通过表达式推断出正确的类型 改造代码:1、第一种方法就是使用匿名类 输出结果: … 继续阅读 Flink运行时报错:could not be determined automatically, due to type erasure
Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读
自定义Source,官网有一个比较好的例子,用于生成信用卡交易数据,我们简单来看一下源码。源码主要的功能类有两… 继续阅读 Flink从入门到实战四[DataStream API]-11-Source-官网反欺诈自动生成Demo源码解读
Flink从入门到实战四[DataStream API]-10-Source-自定义数据源
自定义Source,最重要的一个步骤就是实现SourceFunction接口,定义一个Source类。在这个自… 继续阅读 Flink从入门到实战四[DataStream API]-10-Source-自定义数据源
Flink从入门到实战四[DataStream API]-9-Source-从MQ中读取数据
pom文件: 安装 RabbitMQ略 RabbitMQ SourceRMQSource 负责从 Rabbit… 继续阅读 Flink从入门到实战四[DataStream API]-9-Source-从MQ中读取数据
Flink从入门到实战四[DataStream API]-8-Source-从Socket中读取数据
基于Socket的数据源,在之前的demo中已经演示了,我们直接看代码: 测试数据 输出结果
Flink从入门到实战四[DataStream API]-7-Source-从Kafka中读取数据
添加pom依赖: 安装kafka前提是本机需要具备JDK1.8或以上的版本。1、下载kafkahttps://… 继续阅读 Flink从入门到实战四[DataStream API]-7-Source-从Kafka中读取数据
Flink从入门到实战四[DataStream API]-6-Source-从文件中读取数据
Flink 从文件中获取数据 输出结果:
Flink从入门到实战四[DataStream API]-5-Source-从集合中获取数据
Flink 从集合中获取数据,我们直接看代码: 输出结果:
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解析