Package | Description |
---|---|
org.apache.flink.api.common.operators.base | |
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
CrossOperatorBase.CrossHint |
CrossOperatorBase.getCrossHint() |
static CrossOperatorBase.CrossHint |
CrossOperatorBase.CrossHint.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static CrossOperatorBase.CrossHint[] |
CrossOperatorBase.CrossHint.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
CrossOperatorBase.setCrossHint(CrossOperatorBase.CrossHint hint) |
Modifier and Type | Method and Description |
---|---|
CrossOperatorBase.CrossHint |
CrossOperator.getCrossHint() |
Constructor and Description |
---|
CrossOperator(DataSet<I1> input1,
DataSet<I2> input2,
CrossFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
CrossOperatorBase.CrossHint hint,
String defaultName) |
CrossProjection(DataSet<I1> ds1,
DataSet<I2> ds2,
int[] firstFieldIndexes,
int[] secondFieldIndexes,
CrossOperatorBase.CrossHint hint) |
DefaultCross(DataSet<I1> input1,
DataSet<I2> input2,
CrossOperatorBase.CrossHint hint,
String defaultName) |
ProjectCross(DataSet<I1> input1,
DataSet<I2> input2,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType,
CrossOperator.CrossProjection<I1,I2> crossProjection,
CrossOperatorBase.CrossHint hint) |
ProjectCross(DataSet<I1> input1,
DataSet<I2> input2,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType,
CrossOperatorBase.CrossHint hint) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.