本文整理了Java中org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator.split()
方法的一些代码示例,展示了SingleOutputStreamOperator.split()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SingleOutputStreamOperator.split()
方法的具体详情如下:
包路径:org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
类名称:SingleOutputStreamOperator
方法名:split
暂无
代码示例来源:origin: apache/flink
@Test
public void testSelectAfterSideOutputIsForbidden() {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
SingleOutputStreamOperator<String> processInput = env.fromElements("foo")
.process(new DummyProcessFunction());
processInput.getSideOutput(outputTag);
try {
processInput.split(Collections::singleton);
Assert.fail("Should have failed early with an exception.");
} catch (UnsupportedOperationException expected){
// expected
}
}
代码示例来源:origin: apache/flink
@Test
public void testSideOutputAfterSelectIsForbidden() {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
SingleOutputStreamOperator<String> processInput = env.fromElements("foo")
.process(new DummyProcessFunction());
processInput.split(Collections::singleton);
try {
processInput.getSideOutput(outputTag);
Assert.fail("Should have failed early with an exception.");
} catch (UnsupportedOperationException expected){
// expected
}
}
代码示例来源:origin: apache/flink
.split(new MySelector());
代码示例来源:origin: apache/flink
}).split(new OutputSelector<Tuple2<Integer, Integer>>() {
private static final long serialVersionUID = -8439325199163362470L;
代码示例来源:origin: apache/flink
.split(new EvenOddOutputSelector());
代码示例来源:origin: apache/flink
.map(noOpIntMap)
.name("split")
.split(new EvenOddOutputSelector());
代码示例来源:origin: org.apache.flink/flink-storm
.split(new StormStreamSelector<Tuple>());
代码示例来源:origin: com.alibaba.blink/flink-examples-streaming
.split(new MySelector());
内容来源于网络,如有侵权,请联系作者删除!