org.apache.flink.optimizer.plandump

Interface DumpableNode<T extends DumpableNode<T>>

All Known Implementing Classes:

AbstractPartialSolutionNode, BinaryUnionNode, BinaryUnionPlanNode, BulkIterationNode, BulkIterationPlanNode, BulkPartialSolutionNode, BulkPartialSolutionPlanNode, CoGroupNode, CoGroupRawNode, CrossNode, DataSinkNode, DataSourceNode, DualInputPlanNode, FilterNode, FlatMapNode, GroupCombineNode, GroupReduceNode, JoinNode, MapNode, MapPartitionNode, NAryUnionPlanNode, NoOpNode, OptimizerNode, OuterJoinNode, PartitionNode, PlanNode, ReduceNode, SingleInputNode, SingleInputPlanNode, SinkJoiner, SinkJoinerPlanNode, SinkPlanNode, SolutionSetNode, SolutionSetPlanNode, SortPartitionNode, SourcePlanNode, TwoInputNode, UnaryOperatorNode, WorksetIterationNode, WorksetIterationNode.SingleRootJoiner, WorksetIterationPlanNode, WorksetNode, WorksetPlanNode

public interface DumpableNode<T extends DumpableNode<T>>

Method Summary

Modifier and Type	Method and Description
Iterable<DumpableConnection<T>>	getDumpableInputs()
OptimizerNode	getOptimizerNode()
PlanNode	getPlanNode()
Iterable<T>	getPredecessors() Gets an iterator over the predecessors.

Method Detail

getPredecessors

Iterable<T> getPredecessors()

Gets an iterator over the predecessors.

Returns:

An iterator over the predecessors.

getDumpableInputs

Iterable<DumpableConnection<T>> getDumpableInputs()

getOptimizerNode

OptimizerNode getOptimizerNode()

getPlanNode

PlanNode getPlanNode()