Package org.apache.flink.optimizer.operators

Class GroupCombineProperties

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorSingle

org.apache.flink.optimizer.operators.GroupCombineProperties

All Implemented Interfaces:

AbstractOperatorDescriptor

public final class GroupCombineProperties
extends OperatorDescriptorSingle

The properties file belonging to the GroupCombineNode. It translates the GroupCombine operation to the driver strategy SORTED_GROUP_COMBINE and sets the relevant grouping and sorting keys.

See Also:

GroupCombineNode

Field Summary

Fields inherited from class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

keyList, keys

Constructor Summary

Constructors

Constructor	Description
GroupCombineProperties(org.apache.flink.api.common.operators.util.FieldSet groupKeys, org.apache.flink.api.common.operators.Ordering additionalOrderKeys)

Method Summary

Modifier and Type	Method	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.
org.apache.flink.runtime.operators.DriverStrategy	getStrategy()	Gets the runtime strategy to be executed by this operator.
SingleInputPlanNode	instantiate(Channel in, SingleInputNode node)

Methods inherited from class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

getPossibleGlobalProperties, getPossibleLocalProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupCombineProperties

public GroupCombineProperties(org.apache.flink.api.common.operators.util.FieldSet groupKeys,
                              org.apache.flink.api.common.operators.Ordering additionalOrderKeys)

Method Detail

getStrategy

public org.apache.flink.runtime.operators.DriverStrategy getStrategy()

Description copied from interface: AbstractOperatorDescriptor

Gets the runtime strategy to be executed by this operator.

Returns:

The runtime strategy.

instantiate

public SingleInputPlanNode instantiate(Channel in,
                                       SingleInputNode node)

Specified by:

instantiate in class OperatorDescriptorSingle

createPossibleGlobalProperties

protected List<RequestedGlobalProperties> createPossibleGlobalProperties()

Description copied from class: OperatorDescriptorSingle

Returns a list of global properties that are required by this operator descriptor.

Specified by:

createPossibleGlobalProperties in class OperatorDescriptorSingle

Returns:

A list of global properties that are required by this operator descriptor.

createPossibleLocalProperties

protected List<RequestedLocalProperties> createPossibleLocalProperties()

Description copied from class: OperatorDescriptorSingle

Returns a list of local properties that are required by this operator descriptor.

Specified by:

createPossibleLocalProperties in class OperatorDescriptorSingle

Returns:

A list of local properties that are required by this operator descriptor.

computeGlobalProperties

public GlobalProperties computeGlobalProperties(GlobalProperties gProps)

Description copied from class: OperatorDescriptorSingle

Returns the global properties which are present after the operator was applied on the provided global properties.

Specified by:

computeGlobalProperties in class OperatorDescriptorSingle

Parameters:

gProps - The global properties on which the operator is applied.

Returns:

The global properties which are valid after the operator has been applied.

computeLocalProperties

public LocalProperties computeLocalProperties(LocalProperties lProps)

Description copied from class: OperatorDescriptorSingle

Returns the local properties which are present after the operator was applied on the provided local properties.

Specified by:

computeLocalProperties in class OperatorDescriptorSingle

Parameters:

lProps - The local properties on which the operator is applied.

Returns:

The local properties which are valid after the operator has been applied.