Flink SourceFunction/SinkFunction_flink目前自带的sourcefunction和sinkfunction

作者：繁依Fanyi0 | 2024-04-25 09:10:19

踩

flink目前自带的sourcefunction和sinkfunction

Source 是Flink的输入，可以串行，并行，延迟，设置时间窗口等等。

Sink是Flink的输出，设置任意源。

Flink的编程模型就可以概况成接入Source，然后进行数据转换操作，再将处理结果Sink出来。

非并行

class CustomNonParallelSourceFunction extends SourceFunction[Long] {
   
  var count = 0L
  var isRunning = true
  override def run1
2
3
4

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/484430