首页 > TAG信息列表 > DatastreamAPI
【Flink1.14官方文档】开发应用1、DatastreamAPI
一、概要 1、什么是流？ 不可变的数据集，无限的没有边界。一旦产生不可修改和移除其中的元素，可以查看内部的元素，或者做转换。 2、datasource 3、datasink 4、Iterations 5、容错 6、控制延迟 二、执行模式 1、批处理，命令行设置 $ bin/flink run -Dexecution.runtime-modDataStreamApi 之watermark和开窗设置
watermark 设置的方式 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStreamSource<Snapshot> dataStreamSource = env.addSource(new SourceFormClickhouse2()); // 设置watermark WatermarkStrategy<Snapsho第四篇：DataStreamAPI
DataStream算子将一个或多个DataStream转换为新DataStream。程序可以将多个转换组合成复杂的数据流拓扑。 DataStreamAPI和DataSetAPI主要的区别在于Transformation部分。 DataStream Transformation map DataStream→DataStream 用一个数据元生成一个数据元。一个map函数，它将第四篇：DataStreamAPI
DataStream算子将一个或多个DataStream转换为新DataStream。程序可以将多个转换组合成复杂的数据流拓扑。 DataStreamAPI和DataSetAPI主要的区别在于Transformation部分。 DataStream Transformation map DataStream→DataStream 用一个数据元生成一个数据元。一个map函数，它将