com.yahoo.bullet.querying.aggregations

Class RawStrategy

java.lang.Object

com.yahoo.bullet.querying.aggregations.RawStrategy

All Implemented Interfaces:

Closable, Monoidal, Strategy

public class RawStrategy
extends Object
implements Strategy

Implements the LIMIT operation on multiple raw BulletRecord. A call to getData() or getResult() will return the current collection of records, which is a List of BulletRecord. A call to combine(byte[]) with the result of getData() will combine records from the List till the aggregation size is reached. This Strategy will only consume or combine till the specified aggregation size is reached.

Constructor Summary

Constructors

Constructor and Description
RawStrategy(Aggregation aggregation, BulletConfig config) Constructor that takes in an Aggregation and a BulletConfig.

Method Summary

Modifier and Type	Method and Description
void	combine(byte[] data) Since getData() returns a List of BulletRecord, this method consumes that list.
void	consume(com.yahoo.bullet.record.BulletRecord data) Consumes a single BulletRecord into this Monoid.
byte[]	getData() Returns the serialized List of BulletRecord seen before the last call to reset().
List<com.yahoo.bullet.record.BulletRecord>	getRecords() Gets the aggregated records so far since the last call to reset().
Clip	getResult() Gets the aggregated records so far since the last call to reset().
boolean	isClosed() Returns false if more data should not be consumed or combined.
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

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

merge

Constructor Detail

RawStrategy

public RawStrategy(Aggregation aggregation,
                   BulletConfig config)

Constructor that takes in an Aggregation and a BulletConfig. The size of the aggregation is used as a LIMIT operation.

Parameters:

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

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

Method Detail

isClosed

public boolean isClosed()

Description copied from interface: Strategy

Returns false if more data should not be consumed or combined. This method can be used to avoid passing more data into this Strategy. By default, returns false unless overridden.

Specified by:

isClosed in interface Closable

Specified by:

isClosed in interface Strategy

Returns:

A boolean denoting whether the next consumption or combination should not occur.

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)

Since getData() returns a List of BulletRecord, this method consumes that list. If the deserialized List has a size that takes the aggregated records above the aggregation size, only the first X records in the List will be combined till the size is reached.

Specified by:

combine in interface Monoidal

Parameters:

data - A serialized List of BulletRecord.

getData

public byte[] getData()

Returns the serialized List of BulletRecord seen before the last call to reset().

Specified by:

getData in interface Monoidal

Returns:

the serialized byte[] representing the List of BulletRecord or null if it could not.

getResult

public Clip getResult()

Gets the aggregated records so far since the last call to reset(). The records have a size that is at most the maximum specified by the Aggregation.

Specified by:

getResult in interface Monoidal

Returns:

a Clip of the records so far.

getRecords

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

Gets the aggregated records so far since the last call to reset(). The records have a size that is at most the maximum specified by the Aggregation.

Specified by:

getRecords in interface Monoidal

Returns:

a List of the records 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