Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
JoinOperator.DefaultJoin.projectFirst(int... firstFieldIndexes)
|
<OUT extends Tuple> |
JoinOperator.ProjectJoin.projectFirst(int... firstFieldIndexes)
Continues a ProjectJoin transformation and adds fields of the first join input to the
projection.
|
<OUT extends Tuple> |
JoinOperator.DefaultJoin.projectSecond(int... secondFieldIndexes)
|
<OUT extends Tuple> |
JoinOperator.ProjectJoin.projectSecond(int... secondFieldIndexes)
Continues a ProjectJoin transformation and adds fields of the second join input to the
projection.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.