Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
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.
|
static <O> CrossDataSet<T,O> |
CrossDataSet.cross(DataSet<O> other) |
<O> CrossDataSet<T,O> |
DataSet.cross(DataSet<O> other)
Creates a new DataSet by forming the cartesian product of
this DataSet and the other
DataSet. |
static <O> CrossDataSet<T,O> |
CrossDataSet.crossWithHuge(DataSet<O> other) |
<O> CrossDataSet<T,O> |
DataSet.crossWithHuge(DataSet<O> other)
Special
cross operation for explicitly telling the system that the left side is assumed
to be a lot smaller than the right side of the cartesian product. |
static <O> CrossDataSet<T,O> |
CrossDataSet.crossWithTiny(DataSet<O> other) |
<O> CrossDataSet<T,O> |
DataSet.crossWithTiny(DataSet<O> other)
Special
cross operation for explicitly telling the system that the right side is assumed
to be a lot smaller than the left side of the cartesian product. |
Constructor and Description |
---|
OnCrossDataSet(CrossDataSet<L,R> ds) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.