com.yahoo.bullet.querying.aggregations

Class GroupAllStrategy

java.lang.Object

com.yahoo.bullet.querying.aggregations.GroupAllStrategy

All Implemented Interfaces:

Closable, Monoidal, Strategy

public class GroupAllStrategy
extends Object
implements Strategy

Constructor Summary

Constructors

Constructor and Description
GroupAllStrategy(GroupAll aggregation, BulletConfig config) Constructor that requires an Aggregation.

Method Summary

Modifier and Type	Method and Description
void	combine(byte[] data) Combines a serialized piece of data into this Monoid.
void	consume(com.yahoo.bullet.record.BulletRecord data) Consumes a single BulletRecord into this Monoid.
byte[]	getData() Get the data serialized as a byte[].
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

getMetadata, isClosed

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

merge

Constructor Detail

GroupAllStrategy

public GroupAllStrategy(GroupAll aggregation,
                        BulletConfig config)

Constructor that requires an Aggregation.

Parameters:

aggregation - The Aggregation that specifies how and what this will compute.

config - The BulletConfig.

Method Detail

consume

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

Description copied from interface: Monoidal

Consumes a single BulletRecord into this Monoid.

Specified by:

consume in interface Monoidal

Parameters:

data - The BulletRecord to consume.

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.

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