Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Class and Description |
---|---|
static class |
CrossOperator.DefaultCross<I1,I2>
A Cross transformation that wraps pairs of crossed elements into
Tuple2 . |
static class |
CrossOperator.ProjectCross<I1,I2,OUT extends Tuple>
|
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
CrossOperator.ProjectCross.types(Class<?>... types)
Deprecated.
Deprecated method only kept for compatibility.
|
<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. |
CrossOperator<I1,I2,OUT> |
CrossOperator.ProjectCross.withForwardedFieldsFirst(String... forwardedFieldsFirst) |
CrossOperator<I1,I2,OUT> |
CrossOperator.ProjectCross.withForwardedFieldsSecond(String... forwardedFieldsSecond) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.