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

Class HLLMergedStatistic

java.lang.Object

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

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

All Implemented Interfaces:

MergedStatistic, Statistic

public class HLLMergedStatistic
extends AbstractMergedStatistic

Nested Class Summary

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
HLLMergedStatistic()

Method Summary

Modifier and Type	Method	Description
void	configure(OptionManager optionsManager)
String	getInput()	Gets the name of the input statistic
String	getName()	Gets the name of the merged statistic
com.clearspring.analytics.stream.cardinality.HyperLogLog	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

HLLMergedStatistic

public HLLMergedStatistic()

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 com.clearspring.analytics.stream.cardinality.HyperLogLog 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(OptionManager optionsManager)