Package org.apache.drill.exec.physical.impl.statistics

Class AbstractMergedStatistic

java.lang.Object

org.apache.drill.exec.physical.impl.statistics.AbstractMergedStatistic

All Implemented Interfaces:

MergedStatistic, Statistic

Direct Known Subclasses:

AvgWidthMergedStatistic, CntDupsMergedStatistic, ColTypeMergedStatistic, ColumnMergedStatistic, HLLMergedStatistic, NDVMergedStatistic, NNRowCountMergedStatistic, RowCountMergedStatistic, TDigestMergedStatistic

public abstract class AbstractMergedStatistic
extends Object
implements MergedStatistic, Statistic

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.metastore.statistics.Statistic

Statistic.State

Field Summary

Fields

Modifier and Type	Field	Description
protected String	inputName
protected String	name
protected double	samplePercent
protected Statistic.State	state

Fields inherited from interface org.apache.drill.metastore.statistics.Statistic

AVG_WIDTH, CNT_DUPS, COLNAME, COLTYPE, COMPUTED, HLL, HLL_MERGE, NDV, NNROWCOUNT, NO_COLUMN_STATS, ROWCOUNT, SCHEMA, SUM_DUPS, SUM_WIDTH, TDIGEST, TDIGEST_MERGE

Constructor Summary

Constructors

Constructor	Description
AbstractMergedStatistic()

Method Summary

Modifier and Type	Method	Description
abstract String	getInput()	Gets the name of the input statistic
abstract String	getName()	Gets the name of the merged statistic
abstract void	initialize(String inputName, double samplePercent)	Initialize the merged statistic
void	initialize(String name, String inputName, double samplePercent)
abstract void	merge(MapVector input)	Merges the input statistic (incoming value vector) into the existing merged statistic
abstract void	setOutput(MapVector output)	Sets the merged statistic value in the output (outgoing value vector)

Methods inherited from class java.lang.Object

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

Field Details

name

protected String name

inputName

protected String inputName

samplePercent

protected double samplePercent

state

protected Statistic.State state

Constructor Details

AbstractMergedStatistic

public AbstractMergedStatistic()

Method Details

initialize

public void initialize(String name,
 String inputName,
 double samplePercent)

initialize

public abstract void initialize(String inputName,
 double samplePercent)

Description copied from interface: MergedStatistic

Initialize the merged statistic

Specified by:

initialize in interface MergedStatistic

Parameters:

inputName - - the input StatisticsAggBatch statistic for this merged statistic

samplePercent - - the sample percentage used for extrapolation post merge phase

getName

public abstract String getName()

Description copied from interface: MergedStatistic

Gets the name of the merged statistic

Specified by:

getName in interface MergedStatistic

Returns:

- name of this merged statistic

getInput

public abstract String getInput()

Description copied from interface: MergedStatistic

Gets the name of the input statistic

Specified by:

getInput in interface MergedStatistic

Returns:

- name of the input StatisticsAggBatch statistic for this merged statistic

merge

public abstract void merge(MapVector input)

Description copied from interface: MergedStatistic

Merges the input statistic (incoming value vector) into the existing merged statistic

Specified by:

merge in interface MergedStatistic

Parameters:

input - - the input value vector to merge

setOutput

public abstract void setOutput(MapVector output)

Description copied from interface: MergedStatistic

Sets the merged statistic value in the output (outgoing value vector)

Specified by:

setOutput in interface MergedStatistic

Parameters:

output - - the output vector where to populate the statistic value