Package org.apache.flink.datastream.impl.utils

Class StreamUtils

java.lang.Object

org.apache.flink.datastream.impl.utils.StreamUtils

public final class StreamUtils
extends Object

This class encapsulates the common logic for all type of streams. It can be used to handle things like extract type information, create a new transformation and so on for AbstractDataStream.

Constructor Summary

Constructors

Constructor	Description
StreamUtils()

Method Summary

Modifier and Type	Method	Description
static <T> DataStreamV2SinkTransformation<T,T>	addSinkOperator(AbstractDataStream<T> inputStream, Sink<T> sink, TypeInformation<T> typeInformation)	Add sink operator to the input stream.
static <T,R,K> OneInputTransformation<T,R>	getOneInputKeyedTransformation(String operatorName, AbstractDataStream<T> inputStream, TypeInformation<R> outTypeInformation, OneInputStreamOperator<T,R> operator, KeySelector<T,K> keySelector, TypeInformation<K> keyType)	Construct and return a OneInputTransformation from keyed input streams.
static <T,R> OneInputTransformation<T,R>	getOneInputTransformation(String operatorName, AbstractDataStream<T> inputStream, TypeInformation<R> outTypeInformation, OneInputStreamOperator<T,R> operator)	Construct and return a OneInputTransformation from non-keyed input streams.
static <IN,OUT> TypeInformation<OUT>	getOutputTypeForOneInputProcessFunction(OneInputStreamProcessFunction<IN,OUT> processFunction, TypeInformation<IN> inTypeInformation)	Get the output type information for OneInputStreamProcessFunction from input type information.
static <IN1,IN2,OUT> TypeInformation<OUT>	getOutputTypeForTwoInputBroadcastProcessFunction(TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> processFunction, TypeInformation<IN1> in1TypeInformation, TypeInformation<IN2> in2TypeInformation)	Get the output type information for TwoInputBroadcastStreamProcessFunction from two input type information .
static <IN1,IN2,OUT> TypeInformation<OUT>	getOutputTypeForTwoInputNonBroadcastProcessFunction(TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT> processFunction, TypeInformation<IN1> in1TypeInformation, TypeInformation<IN2> in2TypeInformation)	Get the output type information for TwoInputNonBroadcastStreamProcessFunction from two input type information .
static <IN,OUT1,OUT2> Tuple2<TypeInformation<OUT1>,TypeInformation<OUT2>>	getOutputTypesForTwoOutputProcessFunction(TwoOutputStreamProcessFunction<IN,OUT1,OUT2> twoOutputStreamProcessFunction, TypeInformation<IN> inTypeInformation)	Get output types information for TwoOutputStreamProcessFunction from the input type information.
static <IN1,IN2,OUT> TwoInputTransformation<IN1,IN2,OUT>	getTwoInputTransformation(String operatorName, AbstractDataStream<IN1> inputStream1, AbstractDataStream<IN2> inputStream2, TypeInformation<OUT> outTypeInformation, TwoInputStreamOperator<IN1,IN2,OUT> operator)	Construct and return a TwoInputTransformation from two input streams.
static <T,R> AbstractDataStream<R>	transformOneInputOperator(String operatorName, AbstractDataStream<T> inputStream, TypeInformation<R> outTypeInfo, StreamOperatorFactory<R> operatorFactory)	Construct and return a new DataStream with one input operator.
static void	validateStates(Set<StateDeclaration> inputStateDeclarations, Set<StateDeclaration.RedistributionMode> invalidStateDeclarations)	Wrap a GlobalStreamImpl with configure handle.
static <T> GlobalStream.ProcessConfigurableAndGlobalStream<T>	wrapWithConfigureHandle(GlobalStreamImpl<T> stream)	Wrap a GlobalStreamImpl with configure handle.
static <K,T> KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T>	wrapWithConfigureHandle(KeyedPartitionStreamImpl<K,T> stream)	Wrap a KeyedPartitionStreamImpl with configure handle.
static <T> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T>	wrapWithConfigureHandle(NonKeyedPartitionStreamImpl<T> stream)	Wrap a NonKeyedPartitionStreamImpl with configure handle.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamUtils

public StreamUtils()

Method Detail

getOutputTypeForOneInputProcessFunction

public static <IN,OUT> TypeInformation<OUT> getOutputTypeForOneInputProcessFunction(OneInputStreamProcessFunction<IN,OUT> processFunction,
                                                                                          TypeInformation<IN> inTypeInformation)

Get the output type information for OneInputStreamProcessFunction from input type information.

getOutputTypeForTwoInputNonBroadcastProcessFunction

public static <IN1,IN2,OUT> TypeInformation<OUT> getOutputTypeForTwoInputNonBroadcastProcessFunction(TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT> processFunction,
                                                                                                                 TypeInformation<IN1> in1TypeInformation,
                                                                                                                 TypeInformation<IN2> in2TypeInformation)

Get the output type information for TwoInputNonBroadcastStreamProcessFunction from two input type information .

getOutputTypeForTwoInputBroadcastProcessFunction

public static <IN1,IN2,OUT> TypeInformation<OUT> getOutputTypeForTwoInputBroadcastProcessFunction(TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> processFunction,
                                                                                                              TypeInformation<IN1> in1TypeInformation,
                                                                                                              TypeInformation<IN2> in2TypeInformation)

Get the output type information for TwoInputBroadcastStreamProcessFunction from two input type information .

getOutputTypesForTwoOutputProcessFunction

public static <IN,OUT1,OUT2> Tuple2<TypeInformation<OUT1>,TypeInformation<OUT2>> getOutputTypesForTwoOutputProcessFunction(TwoOutputStreamProcessFunction<IN,OUT1,OUT2> twoOutputStreamProcessFunction,
                                                                                                                                             TypeInformation<IN> inTypeInformation)

Get output types information for TwoOutputStreamProcessFunction from the input type information.

getOneInputTransformation

public static <T,R> OneInputTransformation<T,R> getOneInputTransformation(String operatorName,
                                                                                      AbstractDataStream<T> inputStream,
                                                                                      TypeInformation<R> outTypeInformation,
                                                                                      OneInputStreamOperator<T,R> operator)

Construct and return a OneInputTransformation from non-keyed input streams.

getOneInputKeyedTransformation

public static <T,R,K> OneInputTransformation<T,R> getOneInputKeyedTransformation(String operatorName,
                                                                                                   AbstractDataStream<T> inputStream,
                                                                                                   TypeInformation<R> outTypeInformation,
                                                                                                   OneInputStreamOperator<T,R> operator,
                                                                                                   KeySelector<T,K> keySelector,
                                                                                                   TypeInformation<K> keyType)

Construct and return a OneInputTransformation from keyed input streams.

getTwoInputTransformation

public static <IN1,IN2,OUT> TwoInputTransformation<IN1,IN2,OUT> getTwoInputTransformation(String operatorName,
                                                                                                                  AbstractDataStream<IN1> inputStream1,
                                                                                                                  AbstractDataStream<IN2> inputStream2,
                                                                                                                  TypeInformation<OUT> outTypeInformation,
                                                                                                                  TwoInputStreamOperator<IN1,IN2,OUT> operator)

Construct and return a TwoInputTransformation from two input streams.

transformOneInputOperator

public static <T,R> AbstractDataStream<R> transformOneInputOperator(String operatorName,
                                                                          AbstractDataStream<T> inputStream,
                                                                          TypeInformation<R> outTypeInfo,
                                                                          StreamOperatorFactory<R> operatorFactory)

Construct and return a new DataStream with one input operator.

addSinkOperator

public static <T> DataStreamV2SinkTransformation<T,T> addSinkOperator(AbstractDataStream<T> inputStream,
                                                                            Sink<T> sink,
                                                                            TypeInformation<T> typeInformation)

Add sink operator to the input stream.

wrapWithConfigureHandle

public static <T> NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T> wrapWithConfigureHandle(NonKeyedPartitionStreamImpl<T> stream)

Wrap a NonKeyedPartitionStreamImpl with configure handle.

wrapWithConfigureHandle

public static <K,T> KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T> wrapWithConfigureHandle(KeyedPartitionStreamImpl<K,T> stream)

Wrap a KeyedPartitionStreamImpl with configure handle.

wrapWithConfigureHandle

public static <T> GlobalStream.ProcessConfigurableAndGlobalStream<T> wrapWithConfigureHandle(GlobalStreamImpl<T> stream)

Wrap a GlobalStreamImpl with configure handle.

validateStates

public static void validateStates(Set<StateDeclaration> inputStateDeclarations,
                                  Set<StateDeclaration.RedistributionMode> invalidStateDeclarations)

Wrap a GlobalStreamImpl with configure handle.