IP属地:台湾
看完了Flink的datasource、sink,也就把一头一尾给看完了,从数据流入到数据流出,缺少了中间的处理环节。 而flink的大头恰恰是只在这个中间环节,如下图: 中...
转化算子(transform operator)将一个或多个DataStream转换为新的DataStream,如此下去可以将多个转换组合成复杂的数据流拓扑。 本节介绍了基本...
原文链接:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.htm...