org.apache.hadoop.hive.common.ndv.fm

Class FMSketch

java.lang.Object

org.apache.hadoop.hive.common.ndv.fm.FMSketch

All Implemented Interfaces:

NumDistinctValueEstimator

public class FMSketch
extends Object
implements NumDistinctValueEstimator

Field Summary

Fields

Modifier and Type	Field and Description
static int	BIT_VECTOR_SIZE

Constructor Summary

Constructors

Constructor and Description
FMSketch(int numBitVectors)

Method Summary

Modifier and Type	Method and Description
void	addToEstimator(double d)
void	addToEstimator(org.apache.hadoop.hive.common.type.HiveDecimal decimal)
void	addToEstimator(long v)
void	addToEstimator(String s)
void	addToEstimatorPCSA(double d)
void	addToEstimatorPCSA(org.apache.hadoop.hive.common.type.HiveDecimal decimal)
void	addToEstimatorPCSA(long v)
boolean	canMerge(NumDistinctValueEstimator o)
NumDistinctValueEstimator	deserialize(byte[] buf)
long	estimateNumDistinctValues()
long	estimateNumDistinctValuesPCSA()
javolution.util.FastBitSet	getBitVector(int index)
int	getBitVectorSize()
int	getNumBitVectors()
int	lengthFor(org.apache.hadoop.hive.ql.util.JavaDataModel model)
void	mergeEstimators(FMSketch o)
void	mergeEstimators(NumDistinctValueEstimator o)
void	printNumDistinctValueEstimator()
void	reset() Resets a distinctValueEstimator object to its original state.
byte[]	serialize()
javolution.util.FastBitSet	setBitVector(javolution.util.FastBitSet fastBitSet, int index)

Methods inherited from class java.lang.Object

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

Field Detail

BIT_VECTOR_SIZE

public static final int BIT_VECTOR_SIZE

See Also:

Constant Field Values

Constructor Detail

FMSketch

public FMSketch(int numBitVectors)

Method Detail

reset

public void reset()

Resets a distinctValueEstimator object to its original state.

Specified by:

reset in interface NumDistinctValueEstimator

getBitVector

public javolution.util.FastBitSet getBitVector(int index)

setBitVector

public javolution.util.FastBitSet setBitVector(javolution.util.FastBitSet fastBitSet,
                                               int index)

getNumBitVectors

public int getNumBitVectors()

getBitVectorSize

public int getBitVectorSize()

printNumDistinctValueEstimator

public void printNumDistinctValueEstimator()

serialize

public byte[] serialize()

Specified by:

serialize in interface NumDistinctValueEstimator

deserialize

public NumDistinctValueEstimator deserialize(byte[] buf)

Specified by:

deserialize in interface NumDistinctValueEstimator

addToEstimator

public void addToEstimator(long v)

Specified by:

addToEstimator in interface NumDistinctValueEstimator

addToEstimatorPCSA

public void addToEstimatorPCSA(long v)

addToEstimator

public void addToEstimator(double d)

Specified by:

addToEstimator in interface NumDistinctValueEstimator

addToEstimatorPCSA

public void addToEstimatorPCSA(double d)

addToEstimator

public void addToEstimator(org.apache.hadoop.hive.common.type.HiveDecimal decimal)

Specified by:

addToEstimator in interface NumDistinctValueEstimator

addToEstimatorPCSA

public void addToEstimatorPCSA(org.apache.hadoop.hive.common.type.HiveDecimal decimal)

mergeEstimators

public void mergeEstimators(FMSketch o)

estimateNumDistinctValuesPCSA

public long estimateNumDistinctValuesPCSA()

estimateNumDistinctValues

public long estimateNumDistinctValues()

Specified by:

estimateNumDistinctValues in interface NumDistinctValueEstimator

lengthFor

public int lengthFor(org.apache.hadoop.hive.ql.util.JavaDataModel model)

Specified by:

lengthFor in interface NumDistinctValueEstimator

mergeEstimators

public void mergeEstimators(NumDistinctValueEstimator o)

Specified by:

mergeEstimators in interface NumDistinctValueEstimator

addToEstimator

public void addToEstimator(String s)

Specified by:

addToEstimator in interface NumDistinctValueEstimator

canMerge

public boolean canMerge(NumDistinctValueEstimator o)

Specified by:

canMerge in interface NumDistinctValueEstimator