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

Packages that use DualInputSemanticProperties

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.java.functions
org.apache.flink.api.java.operators

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

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

Modifier and Type	Method and Description
DualInputSemanticProperties	DualInputOperator.getSemanticProperties()

Methods in org.apache.flink.api.common.operators with parameters of type DualInputSemanticProperties

Modifier and Type	Method and Description
void	DualInputOperator.setSemanticProperties(DualInputSemanticProperties semanticProperties)

Uses of DualInputSemanticProperties in org.apache.flink.api.java.functions

Methods in org.apache.flink.api.java.functions that return DualInputSemanticProperties

Modifier and Type	Method and Description
static DualInputSemanticProperties	SemanticPropUtil.addSourceFieldOffsets(DualInputSemanticProperties props, int numInputFields1, int numInputFields2, int offset1, int offset2) Creates SemanticProperties by adding offsets to each input field index of the given SemanticProperties.
static DualInputSemanticProperties	SemanticPropUtil.createProjectionPropertiesDual(int[] fields, boolean[] isFromFirst, TypeInformation<?> inType1, TypeInformation<?> inType2)
static DualInputSemanticProperties	SemanticPropUtil.getSemanticPropsDual(Set<Annotation> set, TypeInformation<?> inType1, TypeInformation<?> inType2, TypeInformation<?> outType)

Methods in org.apache.flink.api.java.functions with parameters of type DualInputSemanticProperties

Modifier and Type	Method and Description
static DualInputSemanticProperties	SemanticPropUtil.addSourceFieldOffsets(DualInputSemanticProperties props, int numInputFields1, int numInputFields2, int offset1, int offset2) Creates SemanticProperties by adding offsets to each input field index of the given SemanticProperties.
static void	SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result, String[] forwardedFirst, String[] forwardedSecond, String[] nonForwardedFirst, String[] nonForwardedSecond, String[] readFieldsFirst, String[] readFieldsSecond, TypeInformation<?> inType1, TypeInformation<?> inType2, TypeInformation<?> outType)
static void	SemanticPropUtil.getSemanticPropsDualFromString(DualInputSemanticProperties result, String[] forwardedFirst, String[] forwardedSecond, String[] nonForwardedFirst, String[] nonForwardedSecond, String[] readFieldsFirst, String[] readFieldsSecond, TypeInformation<?> inType1, TypeInformation<?> inType2, TypeInformation<?> outType, boolean skipIncompatibleTypes)

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

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

Modifier and Type	Method and Description
protected DualInputSemanticProperties	JoinOperator.EquiJoin.extractSemanticAnnotationsFromUdf(Class<?> udfClass)
protected DualInputSemanticProperties	JoinOperator.ProjectJoin.extractSemanticAnnotationsFromUdf(Class<?> udfClass)
protected DualInputSemanticProperties	CrossOperator.ProjectCross.extractSemanticAnnotationsFromUdf(Class<?> udfClass)
protected DualInputSemanticProperties	TwoInputUdfOperator.extractSemanticAnnotationsFromUdf(Class<?> udfClass)
DualInputSemanticProperties	JoinOperator.EquiJoin.getSemanticProperties()
DualInputSemanticProperties	CoGroupOperator.getSemanticProperties()
DualInputSemanticProperties	TwoInputUdfOperator.getSemanticProperties()

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

Modifier and Type	Method and Description
void	TwoInputUdfOperator.setSemanticProperties(DualInputSemanticProperties properties) Sets the semantic properties for the user-defined function (UDF).