Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala |
Modifier and Type | Class and Description |
---|---|
static class |
CrossOperator.DefaultCross<I1,I2>
|
static class |
CrossOperator.ProjectCross<I1,I2,OUT extends Tuple>
|
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
CrossOperator.ProjectCross.types(Class<?>... types)
Deprecated.
|
<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.Each CrossFunction call returns exactly one element. |
CrossOperator<I1,I2,OUT> |
CrossOperator.ProjectCross.withForwardedFieldsFirst(String... forwardedFieldsFirst) |
CrossOperator<I1,I2,OUT> |
CrossOperator.ProjectCross.withForwardedFieldsSecond(String... forwardedFieldsSecond) |
Constructor and Description |
---|
CrossDataSet(CrossOperator<L,R,scala.Tuple2<L,R>> defaultCross,
DataSet<L> leftInput,
DataSet<R> rightInput) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.