在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作业可以由多个这样的管道组成
1条答案
按热度按时间toiithl61#
你要找的特定术语是
(pipelined) region. 当涉及到故障切换时，它有一些很好的特性。