代码之家 › 专栏 › 技术社区 › Tom

是否有一个正式的概念来命名source->process->sink

apache-flink

Tom · 技术社区 · 5 年前

在Flink中,一个工作可以有多个 source->process->sink 数据处理,例如

val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime) env.addSource(new Source1()).name("Source1").addSink(new Sink1()).name("Sink1").setParallelism(1) env.addSource(new Source2()).name("Source2").addSink(new Sink2()).name("Sink2").setParallelism(1)

我想问一下,是否有一个正式的概念/名称来命名这种读进程写处理逻辑?flink作业可以由多个这样的管道组成

0 回复 | 直到 5 年前

Arvid Heise 5 年前

你要找的特定术语是 (pipelined) region . 它有一些很好的性质,当谈到 failovers

推荐文章

Ellen Spertus · 使用Scala访问HBase的推荐方法

8 年前

skrshn · JAVA尝试在Flink中创建Kafka使用者时出现lang.NoClassDefFoundError(CheckpointedRestoring)

8 年前

Daniel · 目录中的Apache Flink流文件

8 年前

Christos Hadjinikolis · Flink:执行管道java时出错。util。同时发生的TimeoutException:期货在[10000毫秒]后超时

8 年前

Mustafa · Apache Flink:自定义InputFormat仅以1的并行度运行

8 年前

Soheil Pourbafrani · Apache Flink-org的类文件。阿帕奇。弗林克。流式处理。api。斯卡拉。找不到数据流

8 年前

Jicaar · 一个卡夫卡制作人可以被多个接收器安全使用吗?

8 年前

Christos Hadjinikolis · Flink JobExecutionException:akka。客户超时

8 年前

Christos Hadjinikolis · Flink IOException:网络缓冲区数量不足

8 年前

Brutal_JL · flink ReduceFunction的默认触发器是什么?

8 年前