org.apache.flink.optimizer.dag

Interface EstimateProvider

All Known Implementing Classes:

AbstractPartialSolutionNode, BinaryUnionNode, BulkIterationNode, BulkPartialSolutionNode, Channel, CoGroupNode, CoGroupRawNode, CrossNode, DagConnection, DataSinkNode, DataSourceNode, FilterNode, FlatMapNode, GroupCombineNode, GroupReduceNode, JoinNode, MapNode, MapPartitionNode, NamedChannel, NoOpNode, OptimizerNode, OuterJoinNode, PartitionNode, ReduceNode, SingleInputNode, SinkJoiner, SolutionSetNode, SortPartitionNode, TwoInputNode, UnaryOperatorNode, WorksetIterationNode, WorksetIterationNode.SingleRootJoiner, WorksetNode

public interface EstimateProvider

Methods for operators / connections that provide estimated about data size and characteristics.

Method Summary

Modifier and Type	Method and Description
float	getEstimatedAvgWidthPerOutputRecord() Gets the estimated number of bytes per record.
long	getEstimatedNumRecords() Gets the estimated number of records in the output of this node.
long	getEstimatedOutputSize() Gets the estimated output size from this node.

Method Detail

getEstimatedOutputSize

long getEstimatedOutputSize()

Gets the estimated output size from this node.

Returns:

The estimated output size.

getEstimatedNumRecords

long getEstimatedNumRecords()

Gets the estimated number of records in the output of this node.

Returns:

The estimated number of records.

getEstimatedAvgWidthPerOutputRecord

float getEstimatedAvgWidthPerOutputRecord()

Gets the estimated number of bytes per record.

Returns:

The estimated number of bytes per record.