@Public public class JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate extends JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
DataSet
by calling
equalTo(int...)
or
equalTo(KeySelector)
.keys1
Modifier and Type | Method and Description |
---|---|
JoinOperator.DefaultJoin<I1,I2> |
equalTo(int... fields)
|
<K> JoinOperator.DefaultJoin<I1,I2> |
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. |
JoinOperator.DefaultJoin<I1,I2> |
equalTo(String... fields)
Continues a Join transformation and defines the fields of the second join
DataSet that should be used as join keys. |
createDefaultJoin, createJoinFunctionAssigner
public JoinOperator.DefaultJoin<I1,I2> equalTo(int... fields)
Tuple
fields of the second join
DataSet
that should be used as join keys.
The resulting JoinOperator.DefaultJoin
wraps each pair of joining elements into a Tuple2
, with
the element of the first input being the first field of the tuple and the element of the
second input being the second field of the tuple.
equalTo
in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
fields
- The indexes of the Tuple fields of the second join DataSet that should be used as keys.public JoinOperator.DefaultJoin<I1,I2> equalTo(String... fields)
DataSet
that should be used as join keys.
The resulting JoinOperator.DefaultJoin
wraps each pair of joining elements into a Tuple2
, with
the element of the first input being the first field of the tuple and the element of the
second input being the second field of the tuple.
equalTo
in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
fields
- The fields of the second join DataSet that should be used as keys.public <K> JoinOperator.DefaultJoin<I1,I2> equalTo(KeySelector<I2,K> keySelector)
KeySelector
function for the second join DataSet
.
The resulting JoinOperator.DefaultJoin
wraps each pair of joining elements into a Tuple2
, with
the element of the first input being the first field of the tuple and the element of the
second input being the second field of the tuple.
equalTo
in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
keySelector
- The KeySelector function which extracts the key values from the second DataSet on which it is joined.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.