Uses of Interface
org.apache.flink.api.common.functions.CrossFunction

Packages that use CrossFunction

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.operators.base
org.apache.flink.api.java.operators
org.apache.flink.api.java.typeutils
org.apache.flink.runtime.operators

Uses of CrossFunction in org.apache.flink.api.common.functions

Classes in org.apache.flink.api.common.functions that implement CrossFunction

Modifier and Type	Class and Description
class	RichCrossFunction<IN1,IN2,OUT> Rich variant of the CrossFunction.

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

Classes in org.apache.flink.api.common.operators.base with type parameters of type CrossFunction

Modifier and Type	Class and Description
class	CrossOperatorBase<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>

Uses of CrossFunction in org.apache.flink.api.java.operators

Classes in org.apache.flink.api.java.operators that implement CrossFunction

Modifier and Type	Class and Description
static class	CrossOperator.ProjectCrossFunction<T1,T2,R extends Tuple>

Methods in org.apache.flink.api.java.operators that return CrossFunction

Modifier and Type	Method and Description
protected CrossFunction<I1,I2,OUT>	CrossOperator.getFunction()

Methods in org.apache.flink.api.java.operators that return types with arguments of type CrossFunction

Modifier and Type	Method and Description
protected CrossOperatorBase<I1,I2,OUT,CrossFunction<I1,I2,OUT>>	CrossOperator.translateToDataFlow(Operator<I1> input1, Operator<I2> input2)

Methods in org.apache.flink.api.java.operators with parameters of type CrossFunction

Modifier and Type	Method and Description
<R> CrossOperator<I1,I2,R>	CrossOperator.DefaultCross.with(CrossFunction<I1,I2,R> function) Finalizes a Cross transformation by applying a CrossFunction to each pair of crossed elements.

Constructors in org.apache.flink.api.java.operators with parameters of type CrossFunction

Constructor and Description
CrossOperator(DataSet<I1> input1, DataSet<I2> input2, CrossFunction<I1,I2,OUT> function, TypeInformation<OUT> returnType, CrossOperatorBase.CrossHint hint, String defaultName)

Uses of CrossFunction in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type CrossFunction

Modifier and Type	Method and Description
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type)
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getCrossReturnTypes(CrossFunction<IN1,IN2,OUT> crossInterface, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type, String functionName, boolean allowMissing)

Uses of CrossFunction in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators that return types with arguments of type CrossFunction

Modifier and Type	Method and Description
Class<CrossFunction<T1,T2,OT>>	CrossDriver.getStubType()

Method parameters in org.apache.flink.runtime.operators with type arguments of type CrossFunction

Modifier and Type	Method and Description
void	CrossDriver.setup(TaskContext<CrossFunction<T1,T2,OT>,OT> context)