Package | Description |
---|---|
org.apache.flink.api.common.operators.base | |
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala | |
org.apache.flink.ml.nn |
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) |
Modifier and Type | Method and Description |
---|---|
static <L,R> CrossDataSet<L,R> |
CrossDataSet.createCrossOperator(DataSet<L> leftInput,
DataSet<R> rightInput,
CrossOperatorBase.CrossHint crossHint)
Creates a default cross operation with Tuple2 as result.
|
<L,R> CrossDataSet<L,R> |
CrossDataSet$.createCrossOperator(DataSet<L> leftInput,
DataSet<R> rightInput,
CrossOperatorBase.CrossHint crossHint)
Creates a default cross operation with Tuple2 as result.
|
Modifier and Type | Method and Description |
---|---|
scala.Option<CrossOperatorBase.CrossHint> |
KNN.SizeHint$.defaultValue() |
Modifier and Type | Method and Description |
---|---|
KNN |
KNN.setSizeHint(CrossOperatorBase.CrossHint sizeHint)
Parameter a user can specify if one of the training or test sets are small
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.