com.yahoo.bullet.querying.aggregations

Class ThetaSketchingStrategy

java.lang.Object

com.yahoo.bullet.querying.aggregations.SketchingStrategy<S>

com.yahoo.bullet.querying.aggregations.ThetaSketchingStrategy

All Implemented Interfaces:

Closable, Monoidal, Strategy

public class ThetaSketchingStrategy
extends SketchingStrategy<S>

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NOMINAL_ENTRIES
static String	DEFAULT_UPDATE_SKETCH_FAMILY

Fields inherited from class com.yahoo.bullet.querying.aggregations.SketchingStrategy

fields, metadataKeys, separator, sketch

Constructor Summary

Constructors

Constructor and Description
ThetaSketchingStrategy(CountDistinct aggregation, BulletConfig config) Constructor that requires an Aggregation and a BulletConfig configuration.

Method Summary

Modifier and Type	Method and Description
void	consume(com.yahoo.bullet.record.BulletRecord data) Consumes a single BulletRecord into this Monoid.
List<com.yahoo.bullet.record.BulletRecord>	getRecords() Get the data so far as a List of BulletRecord.
static com.yahoo.sketches.ResizeFactor	getResizeFactor(int factor) Converts a integer representing the resizing for Sketches into a ResizeFactor.
Clip	getResult() Get the data so far as a Clip.

Methods inherited from class com.yahoo.bullet.querying.aggregations.SketchingStrategy

combine, getData, getMetadata, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.yahoo.bullet.querying.aggregations.Strategy

isClosed

Methods inherited from interface com.yahoo.bullet.common.Monoidal

merge

Field Detail

DEFAULT_UPDATE_SKETCH_FAMILY

public static final String DEFAULT_UPDATE_SKETCH_FAMILY

DEFAULT_NOMINAL_ENTRIES

public static final int DEFAULT_NOMINAL_ENTRIES

See Also:

Constant Field Values

Constructor Detail

ThetaSketchingStrategy

public ThetaSketchingStrategy(CountDistinct aggregation,
                              BulletConfig config)

Constructor that requires an Aggregation and a BulletConfig configuration.

Parameters:

aggregation - An Aggregation with valid fields and attributes for this aggregation type.

config - The config that has relevant configs for this strategy.

Method Detail

consume

public void consume(com.yahoo.bullet.record.BulletRecord data)

Description copied from interface: Monoidal

Consumes a single BulletRecord into this Monoid.

Parameters:

data - The BulletRecord to consume.

getResult

public Clip getResult()

Description copied from interface: Monoidal

Get the data so far as a Clip.

Specified by:

getResult in interface Monoidal

Overrides:

getResult in class SketchingStrategy<ThetaSketch>

Returns:

The resulting Clip representing the data and the metadata so far.

getRecords

public List<com.yahoo.bullet.record.BulletRecord> getRecords()

Description copied from interface: Monoidal

Get the data so far as a List of BulletRecord.

Specified by:

getRecords in interface Monoidal

Overrides:

getRecords in class SketchingStrategy<ThetaSketch>

Returns:

The resulting list of records representing the data.

getResizeFactor

public static com.yahoo.sketches.ResizeFactor getResizeFactor(int factor)

Converts a integer representing the resizing for Sketches into a ResizeFactor.

Parameters:

factor - An int representing the scaling when the Sketch reaches its threshold. Supports 1, 2, 4 and 8.

Returns:

A ResizeFactor represented by the integer or ResizeFactor.X8 otherwise.