public final class GroupReduceProperties extends OperatorDescriptorSingle
keyList, keys
Constructor and Description |
---|
GroupReduceProperties(FieldSet keys) |
GroupReduceProperties(FieldSet keys,
Ordering additionalOrderKeys) |
GroupReduceProperties(FieldSet groupKeys,
Ordering additionalOrderKeys,
Partitioner<?> customPartitioner) |
GroupReduceProperties(FieldSet keys,
Partitioner<?> customPartitioner) |
Modifier and Type | Method and Description |
---|---|
GlobalProperties |
computeGlobalProperties(GlobalProperties gProps)
Returns the global properties which are present after the operator was applied on the
provided global properties.
|
LocalProperties |
computeLocalProperties(LocalProperties lProps)
Returns the local properties which are present after the operator was applied on the
provided local properties.
|
protected List<RequestedGlobalProperties> |
createPossibleGlobalProperties()
Returns a list of global properties that are required by this operator descriptor.
|
protected List<RequestedLocalProperties> |
createPossibleLocalProperties()
Returns a list of local properties that are required by this operator descriptor.
|
DriverStrategy |
getStrategy()
Gets the runtime strategy to be executed by this operator.
|
SingleInputPlanNode |
instantiate(Channel in,
SingleInputNode node) |
getPossibleGlobalProperties, getPossibleLocalProperties
public GroupReduceProperties(FieldSet keys)
public GroupReduceProperties(FieldSet keys, Partitioner<?> customPartitioner)
public GroupReduceProperties(FieldSet groupKeys, Ordering additionalOrderKeys, Partitioner<?> customPartitioner)
public DriverStrategy getStrategy()
AbstractOperatorDescriptor
public SingleInputPlanNode instantiate(Channel in, SingleInputNode node)
instantiate
in class OperatorDescriptorSingle
protected List<RequestedGlobalProperties> createPossibleGlobalProperties()
OperatorDescriptorSingle
createPossibleGlobalProperties
in class OperatorDescriptorSingle
protected List<RequestedLocalProperties> createPossibleLocalProperties()
OperatorDescriptorSingle
createPossibleLocalProperties
in class OperatorDescriptorSingle
public GlobalProperties computeGlobalProperties(GlobalProperties gProps)
OperatorDescriptorSingle
computeGlobalProperties
in class OperatorDescriptorSingle
gProps
- The global properties on which the operator is applied.public LocalProperties computeLocalProperties(LocalProperties lProps)
OperatorDescriptorSingle
computeLocalProperties
in class OperatorDescriptorSingle
lProps
- The local properties on which the operator is applied.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.