org.apache.paimon.flink.utils

Class SingleOutputStreamOperatorUtils

java.lang.Object

org.apache.paimon.flink.utils.SingleOutputStreamOperatorUtils

public class SingleOutputStreamOperatorUtils
extends Object

Utility methods for SingleOutputStreamOperator.

TODO: merge all Flink version related utils into one class.

Constructor Summary

Constructors

Constructor and Description
SingleOutputStreamOperatorUtils()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SingleOutputStreamOperatorUtils

public SingleOutputStreamOperatorUtils()

Method Detail

getSideOutput

public 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)