Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.java.operators.join |
Modifier and Type | Class and Description |
---|---|
static class |
JoinOperator.DefaultJoin<I1,I2>
|
Modifier and Type | Method and Description |
---|---|
protected JoinFunctionAssigner<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.createJoinFunctionAssigner(Keys<I2> keys2) |
JoinFunctionAssigner<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(int... fields)
Continues a Join transformation and defines the
Tuple fields of the second join
DataSet that should be used as join keys.Note: Fields can only be selected as join keys on Tuple DataSets. The resulting JoinFunctionAssigner needs to be finished by providing a
JoinFunction by calling with(JoinFunction) |
<K> JoinFunctionAssigner<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(KeySelector<I2,K> keySelector)
Continues a Join transformation and defines a
KeySelector function for the second join DataSet .The KeySelector function is called for each element of the second DataSet and extracts a single key value on which the DataSet is joined. |
JoinFunctionAssigner<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(String... fields)
Continues a Join transformation and defines the fields of the second join
DataSet that should be used as join keys.The resulting JoinFunctionAssigner needs to be finished by providing a
JoinFunction by calling with(JoinFunction) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.