Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.java.operators.translation | |
org.apache.flink.optimizer.dag |
Modifier and Type | Method and Description |
---|---|
protected GroupCombineOperatorBase<?,OUT,?> |
GroupCombineOperator.translateToDataFlow(Operator<IN> input) |
Modifier and Type | Class and Description |
---|---|
class |
PlanUnwrappingGroupCombineOperator<IN,OUT,K>
A group combine operator that takes 2-tuples (key-value pairs), and applies the group combine operation only
on the unwrapped values.
|
class |
PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2>
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted partial group reduce
operation only on the unwrapped values.
|
Modifier and Type | Method and Description |
---|---|
GroupCombineOperatorBase<?,?,?> |
GroupCombineNode.getOperator()
Gets the operator represented by this optimizer node.
|
Constructor and Description |
---|
GroupCombineNode(GroupCombineOperatorBase<?,?,?> operator)
Creates a new optimizer node for the given operator.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.