Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.java.operators.join |
Modifier and Type | Method and Description |
---|---|
JoinOperator.DefaultJoin<I1,I2> |
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int... fields)
|
<K> JoinOperator.DefaultJoin<I1,I2> |
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector<I2,K> keySelector)
Continues a Join transformation and defines a
KeySelector function for the
second join DataSet . |
JoinOperator.DefaultJoin<I1,I2> |
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(String... fields)
Continues a Join transformation and defines the fields of the second join
DataSet that should be used as join keys. |
Modifier and Type | Method and Description |
---|---|
protected JoinOperator.DefaultJoin<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.createDefaultJoin(Keys<I2> keys2) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.