com.yahoo.bullet.querying.aggregations

Class SketchingStrategy<S extends Sketch>

java.lang.Object

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

Type Parameters:

S - A Sketch type.

All Implemented Interfaces:

Closable, Monoidal, Strategy

Direct Known Subclasses:

FrequentItemsSketchingStrategy, QuantileSketchingStrategy, ThetaSketchingStrategy, TupleSketchingStrategy

public abstract class SketchingStrategy<S extends Sketch>
extends Object
implements Strategy

The parent class for all Strategy that use Sketches.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<String>	fields
protected Map<String,String>	metadataKeys
protected String	separator
protected S	sketch

Constructor Summary

Constructors

Constructor and Description
SketchingStrategy(Aggregation aggregation, BulletConfig config) The constructor for creating a Sketch based strategy.

Method Summary

Modifier and Type	Method and Description
void	combine(byte[] data) Combines a serialized piece of data into this Monoid.
byte[]	getData() Get the data serialized as a byte[].
Meta	getMetadata() Get the Meta so far.
List<com.yahoo.bullet.record.BulletRecord>	getRecords() Get the data so far as a List of BulletRecord.
Clip	getResult() Get the data so far as a Clip.
void	reset() Reset the data so far and make this the identity element for the Monoid with respect to inserting data.

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

consume, merge

Field Detail

metadataKeys

protected final Map<String,String> metadataKeys

separator

protected final String separator

fields

protected final List<String> fields

sketch

protected S extends Sketch sketch

Constructor Detail

SketchingStrategy

public SketchingStrategy(Aggregation aggregation,
                         BulletConfig config)

The constructor for creating a Sketch based strategy.

Parameters:

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

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

Method Detail

combine

public void combine(byte[] data)

Description copied from interface: Monoidal

Combines a serialized piece of data into this Monoid.

Specified by:

combine in interface Monoidal

Parameters:

data - A serialized representation of the data produced by Monoidal.getData().

getData

public byte[] getData()

Description copied from interface: Monoidal

Get the data serialized as a byte[].

Specified by:

getData in interface Monoidal

Returns:

the serialized representation of the data so far.

getResult

public Clip getResult()

Description copied from interface: Monoidal

Get the data so far as a Clip.

Specified by:

getResult in interface Monoidal

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

Returns:

The resulting list of records representing the data.

getMetadata

public Meta getMetadata()

Description copied from interface: Strategy

Get the Meta so far. By default, returns an empty one.

Specified by:

getMetadata in interface Monoidal

Specified by:

getMetadata in interface Strategy

Returns:

The resulting metadata of the data aggregated so far.

reset

public void reset()

Description copied from interface: Monoidal

Reset the data so far and make this the identity element for the Monoid with respect to inserting data.

Specified by:

reset in interface Monoidal