Uses of Class
org.apache.flink.api.common.operators.UnaryOperatorInformation

Packages that use UnaryOperatorInformation

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base

Uses of UnaryOperatorInformation in org.apache.flink.api.common.operators

Methods in org.apache.flink.api.common.operators that return UnaryOperatorInformation

Modifier and Type	Method	Description
UnaryOperatorInformation<IN,OUT>	SingleInputOperator.getOperatorInfo()	Gets the information about the operators input/output types.

Constructors in org.apache.flink.api.common.operators with parameters of type UnaryOperatorInformation

Constructor	Description
GenericDataSinkBase(OutputFormat<IN> f, UnaryOperatorInformation<IN,Nothing> operatorInfo, String name)	Creates a GenericDataSink with the provided OutputFormat implementation and the given name.
GenericDataSinkBase(UserCodeWrapper<? extends OutputFormat<IN>> f, UnaryOperatorInformation<IN,Nothing> operatorInfo, String name)	Creates a GenericDataSink with the provided OutputFormat implementation and the given name.
SingleInputOperator(UserCodeWrapper<FT> stub, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)	Creates a new abstract single-input operator with the given name wrapping the given user function.
SingleInputOperator(UserCodeWrapper<FT> stub, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)	Creates a new abstract single-input operator with the given name wrapping the given user function.

Uses of UnaryOperatorInformation in org.apache.flink.api.common.operators.base

Constructors in org.apache.flink.api.common.operators.base with parameters of type UnaryOperatorInformation

Constructor	Description
BulkIterationBase(UnaryOperatorInformation<T,T> operatorInfo)
BulkIterationBase(UnaryOperatorInformation<T,T> operatorInfo, String name)
FilterOperatorBase(FT udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
FilterOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
FilterOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
FlatMapOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
FlatMapOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
FlatMapOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
GroupCombineOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)
GroupReduceOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)
GroupReduceOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
GroupReduceOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)
GroupReduceOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
GroupReduceOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, int[] keyPositions, String name)
GroupReduceOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, int[] keys, String name)
PartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, PartitionOperatorBase.PartitionMethod pMethod, String name)
ReduceOperatorBase(FT udf, UnaryOperatorInformation<T,T> operatorInfo, int[] keyPositions, String name)	Creates a grouped reduce data flow operator.
ReduceOperatorBase(FT udf, UnaryOperatorInformation<T,T> operatorInfo, String name)	Creates a non-grouped reduce data flow operator (all-reduce).
ReduceOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<T,T> operatorInfo, int[] keyPositions, String name)	Creates a grouped reduce data flow operator.
ReduceOperatorBase(Class<? extends FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)	Creates a non-grouped reduce data flow operator (all-reduce).
ReduceOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<T,T> operatorInfo, int[] keyPositions, String name)	Creates a grouped reduce data flow operator.
ReduceOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)	Creates a non-grouped reduce data flow operator (all-reduce).
SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, Ordering partitionOrdering, String name)