public class SingleOutputStreamOperatorUtils extends Object
SingleOutputStreamOperator
.
TODO: merge all Flink version related utils into one class.
Constructor and Description |
---|
SingleOutputStreamOperatorUtils() |
Modifier and Type | Method and Description |
---|---|
static <T> org.apache.flink.streaming.api.datastream.DataStream<T> |
getSideOutput(org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<?> input,
org.apache.flink.util.OutputTag<T> outputTag) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.