org.apache.flink.optimizer.operators

Class OperatorDescriptorSingle

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorSingle

All Implemented Interfaces:

AbstractOperatorDescriptor

Direct Known Subclasses:

AllGroupCombineProperties, AllGroupReduceProperties, AllGroupWithPartialPreGroupProperties, AllReduceProperties, FilterDescriptor, FlatMapDescriptor, GroupCombineProperties, GroupReduceProperties, GroupReduceWithCombineProperties, MapDescriptor, MapPartitionDescriptor, NoOpDescriptor, PartialGroupProperties, PartitionNode.PartitionDescriptor, ReduceProperties, SolutionSetDeltaOperator, SortPartitionNode.SortPartitionDescriptor

public abstract class OperatorDescriptorSingle
extends Object
implements AbstractOperatorDescriptor

Abstract base class for Operator descriptions which instantiates the node and sets the driver strategy and the sorting and grouping keys. Returns possible local and global properties and updates them after the operation has been performed.

See Also:

SingleInputNode

Field Summary

Fields

Modifier and Type	Field and Description
protected FieldList	keyList
protected FieldSet	keys

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OperatorDescriptorSingle()
protected	OperatorDescriptorSingle(FieldSet keys)

Method Summary

Modifier and Type	Method and Description
abstract GlobalProperties	computeGlobalProperties(GlobalProperties in) Returns the global properties which are present after the operator was applied on the provided global properties.
abstract LocalProperties	computeLocalProperties(LocalProperties in) Returns the local properties which are present after the operator was applied on the provided local properties.
protected abstract List<RequestedGlobalProperties>	createPossibleGlobalProperties() Returns a list of global properties that are required by this operator descriptor.
protected abstract List<RequestedLocalProperties>	createPossibleLocalProperties() Returns a list of local properties that are required by this operator descriptor.
List<RequestedGlobalProperties>	getPossibleGlobalProperties()
List<RequestedLocalProperties>	getPossibleLocalProperties()
abstract SingleInputPlanNode	instantiate(Channel in, SingleInputNode node)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.optimizer.operators.AbstractOperatorDescriptor

getStrategy

Field Detail

keys

protected final FieldSet keys

keyList

protected final FieldList keyList

Constructor Detail

OperatorDescriptorSingle

protected OperatorDescriptorSingle()

OperatorDescriptorSingle

protected OperatorDescriptorSingle(FieldSet keys)

Method Detail

getPossibleGlobalProperties

public List<RequestedGlobalProperties> getPossibleGlobalProperties()

getPossibleLocalProperties

public List<RequestedLocalProperties> getPossibleLocalProperties()

createPossibleGlobalProperties

protected abstract List<RequestedGlobalProperties> createPossibleGlobalProperties()

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

Returns:

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

createPossibleLocalProperties

protected abstract List<RequestedLocalProperties> createPossibleLocalProperties()

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

Returns:

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

instantiate

public abstract SingleInputPlanNode instantiate(Channel in,
                                                SingleInputNode node)

computeGlobalProperties

public abstract GlobalProperties computeGlobalProperties(GlobalProperties in)

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

Parameters:

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

Returns:

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

computeLocalProperties

public abstract LocalProperties computeLocalProperties(LocalProperties in)

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

Parameters:

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

Returns:

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