Modifier and Type | Class and Description |
---|---|
static class |
Keys.ExpressionKeys<T>
Represents (nested) field access through string and integer-based keys
|
static class |
Keys.SelectorFunctionKeys<T,K> |
Modifier and Type | Method and Description |
---|---|
boolean |
Keys.areCompatible(Keys<?> other)
Check if two sets of keys are compatible to each other (matching types, key counts)
|
Modifier and Type | Field and Description |
---|---|
protected Keys<T> |
Grouping.keys |
protected Keys<I1> |
JoinOperator.keys1 |
protected Keys<I2> |
JoinOperator.keys2 |
Modifier and Type | Method and Description |
---|---|
Keys<T> |
Grouping.getKeys() |
protected Keys<I1> |
JoinOperator.getKeys1() |
protected Keys<I1> |
CoGroupRawOperator.getKeys1() |
protected Keys<I1> |
CoGroupOperator.getKeys1() |
protected Keys<I2> |
JoinOperator.getKeys2() |
protected Keys<I2> |
CoGroupRawOperator.getKeys2() |
protected Keys<I2> |
CoGroupOperator.getKeys2() |
Modifier and Type | Method and Description |
---|---|
static void |
UdfOperatorUtils.analyzeDualInputUdf(TwoInputUdfOperator<?,?,?,?> operator,
Class<?> udfBaseClass,
String defaultName,
Function udf,
Keys<?> key1,
Keys<?> key2) |
static void |
UdfOperatorUtils.analyzeDualInputUdf(TwoInputUdfOperator<?,?,?,?> operator,
Class<?> udfBaseClass,
String defaultName,
Function udf,
Keys<?> key1,
Keys<?> key2) |
static void |
UdfOperatorUtils.analyzeSingleInputUdf(SingleInputUdfOperator<?,?,?> operator,
Class<?> udfBaseClass,
String defaultName,
Function udf,
Keys<?> key) |
Constructor and Description |
---|
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderFirst,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderSecond,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderFirst,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderSecond,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupRawOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
String defaultName) |
CoGroupRawOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
String defaultName) |
DefaultJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
DefaultJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
DeltaIteration(ExecutionEnvironment context,
TypeInformation<ST> type,
DataSet<ST> solutionSet,
DataSet<WT> workset,
Keys<ST> keys,
int maxIterations) |
DistinctOperator(DataSet<T> input,
Keys<T> keys,
String distinctLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> generatedFunction,
JoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
EquiJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
FlatJoinFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
String joinLocationName,
JoinType type) |
Grouping(DataSet<T> set,
Keys<T> keys) |
JoinOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
JoinType type) |
JoinOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
TypeInformation<OUT> returnType,
JoinOperatorBase.JoinHint hint,
JoinType type) |
JoinProjection(DataSet<I1> ds1,
DataSet<I2> ds2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] firstFieldIndexes,
int[] secondFieldIndexes) |
JoinProjection(DataSet<I1> ds1,
DataSet<I2> ds2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] firstFieldIndexes,
int[] secondFieldIndexes) |
PartitionOperator(DataSet<T> input,
Keys<T> pKeys,
Partitioner<?> customPartitioner,
String partitionLocationName) |
PartitionOperator(DataSet<T> input,
Keys<T> pKeys,
Partitioner<P> customPartitioner,
TypeInformation<P> partitionerTypeInfo,
String partitionLocationName) |
PartitionOperator(DataSet<T> input,
PartitionOperatorBase.PartitionMethod pMethod,
Keys<T> pKeys,
DataDistribution distribution,
String partitionLocationName) |
PartitionOperator(DataSet<T> input,
PartitionOperatorBase.PartitionMethod pMethod,
Keys<T> pKeys,
String partitionLocationName) |
ProjectJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType) |
ProjectJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType) |
ProjectJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType,
JoinOperator.JoinProjection<I1,I2> joinProj) |
ProjectJoin(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
JoinOperatorBase.JoinHint hint,
int[] fields,
boolean[] isFromFirst,
TupleTypeInfo<OUT> returnType,
JoinOperator.JoinProjection<I1,I2> joinProj) |
SortedGrouping(DataSet<T> set,
Keys<T> keys,
int field,
Order order) |
SortedGrouping(DataSet<T> set,
Keys<T> keys,
Keys.SelectorFunctionKeys<T,K> keySelector,
Order order) |
SortedGrouping(DataSet<T> set,
Keys<T> keys,
String field,
Order order) |
UnsortedGrouping(DataSet<T> set,
Keys<T> keys) |
Modifier and Type | Field and Description |
---|---|
protected Keys<I1> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.keys1 |
Modifier and Type | Method and Description |
---|---|
protected JoinOperator.DefaultJoin<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.createDefaultJoin(Keys<I2> keys2) |
protected JoinFunctionAssigner<I1,I2> |
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.createJoinFunctionAssigner(Keys<I2> keys2) |
Constructor and Description |
---|
JoinOperatorSetsPredicateBase(Keys<I1> keys1) |
Constructor and Description |
---|
UdfAnalyzer(Class<?> baseClass,
Class<?> udfClass,
String externalUdfName,
TypeInformation<?> in1Type,
TypeInformation<?> in2Type,
TypeInformation<?> outType,
Keys<?> keys1,
Keys<?> keys2,
boolean throwErrorExceptions) |
UdfAnalyzer(Class<?> baseClass,
Class<?> udfClass,
String externalUdfName,
TypeInformation<?> in1Type,
TypeInformation<?> in2Type,
TypeInformation<?> outType,
Keys<?> keys1,
Keys<?> keys2,
boolean throwErrorExceptions) |
Modifier and Type | Method and Description |
---|---|
JoinDataSet<L,R> |
UnfinishedJoinOperationBase.createDefaultJoin(Keys<L> leftKey,
Keys<R> rightKey) |
JoinDataSet<L,R> |
UnfinishedJoinOperationBase.createDefaultJoin(Keys<L> leftKey,
Keys<R> rightKey) |
JoinDataSet<L,R> |
UnfinishedJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
JoinDataSet<L,R> |
UnfinishedJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
abstract O |
UnfinishedJoinOperationBase.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
abstract O |
UnfinishedJoinOperationBase.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
JoinFunctionAssigner<L,R> |
UnfinishedOuterJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
JoinFunctionAssigner<L,R> |
UnfinishedOuterJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
CoGroupDataSet<L,R> |
UnfinishedCoGroupOperation.finish(Keys<L> leftKey,
Keys<R> rightKey) |
CoGroupDataSet<L,R> |
UnfinishedCoGroupOperation.finish(Keys<L> leftKey,
Keys<R> rightKey) |
O |
UnfinishedJoinOperationBase.finish(Keys<L> leftKey,
Keys<R> rightKey) |
O |
UnfinishedJoinOperationBase.finish(Keys<L> leftKey,
Keys<R> rightKey) |
abstract O |
UnfinishedKeyPairOperation.finish(Keys<L> leftKey,
Keys<R> rightKey) |
abstract O |
UnfinishedKeyPairOperation.finish(Keys<L> leftKey,
Keys<R> rightKey) |
Constructor and Description |
---|
CoGroupDataSet(CoGroupOperator<L,R,scala.Tuple2<Object,Object>> defaultCoGroup,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
CoGroupDataSet(CoGroupOperator<L,R,scala.Tuple2<Object,Object>> defaultCoGroup,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
GroupedDataSet(DataSet<T> set,
Keys<T> keys,
scala.reflect.ClassTag<T> evidence$1) |
HalfUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> unfinished,
Keys<L> leftKey) |
JoinDataSet(JoinOperator.EquiJoin<L,R,scala.Tuple2<L,R>> defaultJoin,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
JoinDataSet(JoinOperator.EquiJoin<L,R,scala.Tuple2<L,R>> defaultJoin,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
Modifier and Type | Method and Description |
---|---|
static <X> KeySelector<X,Tuple> |
KeySelectorUtil.getSelectorForKeys(Keys<X> keys,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
static <X,K> KeySelector<X,K> |
KeySelectorUtil.getSelectorForOneKey(Keys<X> keys,
Partitioner<K> partitioner,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.