在创建完成执行环境后,需要将数据引入Flink系统中。执行环境提供了不同的数据接入接口,以便将外部数据转换成DataStream数据集或DataSet数据集Flink读取数据源,并将其转换为DataStream数据集或DataSet数据集,这样就完成了从数据源到分布式数据集的转换Flink可以直接从第三方系统中获取数据,因为在Flink中默认提供了多种从外部读取数据的连接器,这些连接器可以处理批量数据和实时数据
欢迎分享,转载请注明来源:内存溢出
在创建完成执行环境后,需要将数据引入Flink系统中。执行环境提供了不同的数据接入接口,以便将外部数据转换成DataStream数据集或DataSet数据集Flink读取数据源,并将其转换为DataStream数据集或DataSet数据集,这样就完成了从数据源到分布式数据集的转换Flink可以直接从第三方系统中获取数据,因为在Flink中默认提供了多种从外部读取数据的连接器,这些连接器可以处理批量数据和实时数据
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)