Package 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 EstimateProviderMethods for operators / connections that provide estimated about data size and characteristics.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description floatgetEstimatedAvgWidthPerOutputRecord()Gets the estimated number of bytes per record.longgetEstimatedNumRecords()Gets the estimated number of records in the output of this node.longgetEstimatedOutputSize()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.
-
-