Package org.apache.flink.optimizer.dag

Class PartitionNode.PartitionDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorSingle

org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

Enclosing class:

PartitionNode

public static class PartitionNode.PartitionDescriptor
extends OperatorDescriptorSingle

Field Summary

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

keyList, keys

Constructor Summary

Constructors

Constructor	Description
PartitionDescriptor(org.apache.flink.api.common.operators.base.PartitionOperatorBase.PartitionMethod pMethod, org.apache.flink.api.common.operators.util.FieldSet pKeys, org.apache.flink.api.common.operators.Ordering ordering, org.apache.flink.api.common.functions.Partitioner<?> customPartitioner, org.apache.flink.api.common.distributions.DataDistribution distribution)

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

PartitionDescriptor

public PartitionDescriptor(org.apache.flink.api.common.operators.base.PartitionOperatorBase.PartitionMethod pMethod,
                           org.apache.flink.api.common.operators.util.FieldSet pKeys,
                           org.apache.flink.api.common.operators.Ordering ordering,
                           org.apache.flink.api.common.functions.Partitioner<?> customPartitioner,
                           org.apache.flink.api.common.distributions.DataDistribution distribution)

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.