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

Class NDVMergedStatistic

java.lang.Object

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

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

All Implemented Interfaces:

MergedStatistic, Statistic

public class NDVMergedStatistic
extends AbstractMergedStatistic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NDVMergedStatistic.NDVConfiguration

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

Statistic.State

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.statistics.AbstractMergedStatistic

inputName, name, samplePercent, 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
NDVMergedStatistic()

Method Summary

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

Methods inherited from class org.apache.drill.exec.physical.impl.statistics.AbstractMergedStatistic

initialize

Methods inherited from class java.lang.Object

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

Constructor Details

NDVMergedStatistic

public NDVMergedStatistic()

Method Details

initialize

public void initialize(String inputName,
 double samplePercent)

Description copied from interface: MergedStatistic

Initialize the merged statistic

Specified by:

initialize in interface MergedStatistic

Specified by:

initialize in class AbstractMergedStatistic

Parameters:

inputName - - the input StatisticsAggBatch statistic for this merged statistic

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

getName

public String getName()

Description copied from interface: MergedStatistic

Gets the name of the merged statistic

Specified by:

getName in interface MergedStatistic

Specified by:

getName in class AbstractMergedStatistic

Returns:

- name of this merged statistic

getInput

public String getInput()

Description copied from interface: MergedStatistic

Gets the name of the input statistic

Specified by:

getInput in interface MergedStatistic

Specified by:

getInput in class AbstractMergedStatistic

Returns:

- name of the input StatisticsAggBatch statistic for this merged statistic

merge

public 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

Specified by:

merge in class AbstractMergedStatistic

Parameters:

input - - the input value vector to merge

getStat

public long getStat(String colName)

setOutput

public 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

Specified by:

setOutput in class AbstractMergedStatistic

Parameters:

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

configure

public void configure(NDVMergedStatistic.NDVConfiguration ndvConfig)