Package org.apache.flink.optimizer

Class DataStatistics

java.lang.Object

org.apache.flink.optimizer.DataStatistics

public class DataStatistics
extends Object

The collection of access methods that can be used to retrieve statistical information about the data processed in a job. Currently this method acts as an entry point only for obtaining cached statistics.

Constructor Summary

Constructors

Constructor	Description
DataStatistics()	Creates a new statistics object, with an empty cache.

Method Summary

Modifier and Type	Method	Description
void	cacheBaseStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics statistics, String identifier)	Caches the given statistics.
org.apache.flink.api.common.io.statistics.BaseStatistics	getBaseStatistics(String inputIdentifier)	Gets the base statistics for the input identified by the given identifier.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataStatistics

public DataStatistics()

Creates a new statistics object, with an empty cache.

Method Detail

getBaseStatistics

public org.apache.flink.api.common.io.statistics.BaseStatistics getBaseStatistics(String inputIdentifier)

Gets the base statistics for the input identified by the given identifier.

Parameters:

inputIdentifier - The identifier for the input.

Returns:

The statistics that were cached for this input.

cacheBaseStatistics

public void cacheBaseStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics statistics,
                                String identifier)

Caches the given statistics. They are later retrievable under the given identifier.

Parameters:

statistics - The statistics to cache.

identifier - The identifier which may be later used to retrieve the statistics.