Uses of Interface
org.apache.flink.api.common.operators.util.UserCodeWrapper

Packages that use UserCodeWrapper

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.operators.util
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.operators.util

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

Fields in org.apache.flink.api.common.operators declared as UserCodeWrapper

Modifier and Type	Field and Description
protected UserCodeWrapper<? extends OutputFormat<IN>>	GenericDataSinkBase.formatWrapper
protected UserCodeWrapper<? extends T>	GenericDataSourceBase.formatWrapper
protected UserCodeWrapper<FT>	AbstractUdfOperator.userFunction The object or class containing the user function.

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

Modifier and Type	Method and Description
UserCodeWrapper<? extends OutputFormat<IN>>	GenericDataSinkBase.getFormatWrapper() Gets the class describing this sinks output format.
UserCodeWrapper<? extends T>	GenericDataSourceBase.getFormatWrapper() Gets the class describing the input format.
UserCodeWrapper<FT>	AbstractUdfOperator.getUserCodeWrapper() Gets the function that is held by this operator.
UserCodeWrapper<? extends OutputFormat<IN>>	GenericDataSinkBase.getUserCodeWrapper() Gets the class describing the output format.
UserCodeWrapper<? extends T>	GenericDataSourceBase.getUserCodeWrapper() Gets the class describing the input format.
UserCodeWrapper<?>	Operator.getUserCodeWrapper() Gets the user code wrapper.

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

Constructor and Description
AbstractUdfOperator(UserCodeWrapper<FT> function, OperatorInformation<OUT> operatorInfo, String name) Creates a new abstract operator with the given name wrapping the given user function.
DualInputOperator(UserCodeWrapper<FT> stub, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name) Creates a new abstract dual-input operator with the given name wrapping the given user function.
DualInputOperator(UserCodeWrapper<FT> stub, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name) Creates a new abstract dual-input Pact with the given name wrapping the given user function.
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 UserCodeWrapper in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base that return UserCodeWrapper

Modifier and Type	Method and Description
UserCodeWrapper<?>	DeltaIterationBase.WorksetPlaceHolder.getUserCodeWrapper()
UserCodeWrapper<?>	DeltaIterationBase.SolutionSetPlaceHolder.getUserCodeWrapper()
UserCodeWrapper<?>	BulkIterationBase.PartialSolutionPlaceHolder.getUserCodeWrapper()

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

Constructor and Description
CoGroupOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
CoGroupRawOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
CrossOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)
FilterOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<T,T> operatorInfo, String name)
FlatMapOperatorBase(UserCodeWrapper<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)
InnerJoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
JoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)
MapOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
MapPartitionOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
OuterJoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name, OuterJoinOperatorBase.OuterJoinType outerJoinType)
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).

Uses of UserCodeWrapper in org.apache.flink.api.common.operators.util

Classes in org.apache.flink.api.common.operators.util that implement UserCodeWrapper

Modifier and Type	Class and Description
class	UserCodeClassWrapper<T> This holds a class containing user defined code.
class	UserCodeObjectWrapper<T> This holds an actual object containing user defined code.

Uses of UserCodeWrapper in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type UserCodeWrapper

Modifier and Type	Method and Description
Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>>	InputOutputFormatContainer.getInputFormats()
Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>>	InputOutputFormatContainer.FormatUserCodeTable.getInputFormats()
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>>	InputOutputFormatContainer.getOutputFormats()
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>>	InputOutputFormatContainer.FormatUserCodeTable.getOutputFormats()

Methods in org.apache.flink.runtime.jobgraph with parameters of type UserCodeWrapper

Modifier and Type	Method and Description
InputOutputFormatContainer	InputOutputFormatContainer.addInputFormat(OperatorID operatorId, UserCodeWrapper<? extends InputFormat<?,?>> wrapper)
void	InputOutputFormatContainer.FormatUserCodeTable.addInputFormat(OperatorID operatorId, UserCodeWrapper<? extends InputFormat<?,?>> wrapper)
InputOutputFormatContainer	InputOutputFormatContainer.addOutputFormat(OperatorID operatorId, UserCodeWrapper<? extends OutputFormat<?>> wrapper)
void	InputOutputFormatContainer.FormatUserCodeTable.addOutputFormat(OperatorID operatorId, UserCodeWrapper<? extends OutputFormat<?>> wrapper)

Uses of UserCodeWrapper in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util that return UserCodeWrapper

Modifier and Type	Method and Description
<T> UserCodeWrapper<T>	TaskConfig.getStubWrapper(ClassLoader cl)

Methods in org.apache.flink.runtime.operators.util with parameters of type UserCodeWrapper

Modifier and Type	Method and Description
void	TaskConfig.setStubWrapper(UserCodeWrapper<?> wrapper)