com.yahoo.bullet.windowing

Class SlidingRecord

java.lang.Object

com.yahoo.bullet.windowing.Scheme

com.yahoo.bullet.windowing.Basic

com.yahoo.bullet.windowing.SlidingRecord

All Implemented Interfaces:

Closable, Monoidal

public class SlidingRecord
extends Basic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SlidingRecord.Data

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Fields inherited from class com.yahoo.bullet.windowing.Basic

windowCount

Fields inherited from class com.yahoo.bullet.windowing.Scheme

aggregation, metadataKeys, window

Constructor Summary

Constructors

Constructor and Description
SlidingRecord(Strategy aggregation, Window window, BulletConfig config) Creates an instance of this windowing scheme with the provided Strategy and BulletConfig.

Method Summary

Modifier and Type	Method and Description
void	combine(byte[] data) This combines any data fed to it even if it is Basic.isClosed() or Basic.isClosedForPartition().
void	consume(com.yahoo.bullet.record.BulletRecord data) This consumes any data fed to it even if it is Basic.isClosed() or Basic.isClosedForPartition().
byte[]	getData() Get the data serialized as a byte[].
protected Map<String,Object>	getMetadata(Map<String,String> metadataKeys) Return any metadata for the windowing scheme with the given configured names for the metadata concepts.
boolean	isClosed() Returns true if this is currently closed.
boolean	isClosedForPartition() Returns true if this window is closed when operating in partition mode.
protected String	name() Gets the name of this windowing scheme.
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 com.yahoo.bullet.windowing.Basic

count, getRecords, getResult, resetForPartition, start

Methods inherited from class com.yahoo.bullet.windowing.Scheme

getMetadata

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.common.Monoidal

merge

Field Detail

NAME

public static String NAME

Constructor Detail

SlidingRecord

public SlidingRecord(Strategy aggregation,
                     Window window,
                     BulletConfig config)

Creates an instance of this windowing scheme with the provided Strategy and BulletConfig.

Parameters:

aggregation - The non-null initialized aggregation strategy that this window will operate.

window - The initialized, configured window to use.

config - The validated config to use.

Method Detail

getMetadata

protected Map<String,Object> getMetadata(Map<String,String> metadataKeys)

Description copied from class: Scheme

Return any metadata for the windowing scheme with the given configured names for the metadata concepts.

Overrides:

getMetadata in class Basic

Parameters:

metadataKeys - The mapping of metadata concepts to their names to get metadata for.

Returns:

A Map of strings to objects of the metadata.

consume

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

Description copied from class: Basic

This consumes any data fed to it even if it is Basic.isClosed() or Basic.isClosedForPartition().

Specified by:

consume in interface Monoidal

Overrides:

consume in class Basic

Parameters:

data - The BulletRecord to consume.

combine

public void combine(byte[] data)

Description copied from class: Basic

This combines any data fed to it even if it is Basic.isClosed() or Basic.isClosedForPartition().

Specified by:

combine in interface Monoidal

Overrides:

combine in class Basic

Parameters:

data - The BulletRecord to consume.

getData

public byte[] getData()

Description copied from interface: Monoidal

Get the data serialized as a byte[].

Specified by:

getData in interface Monoidal

Overrides:

getData in class Basic

Returns:

the serialized representation of the data 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

Overrides:

reset in class Basic

isClosed

public boolean isClosed()

Description copied from interface: Closable

Returns true if this is currently closed.

Specified by:

isClosed in interface Closable

Overrides:

isClosed in class Basic

Returns:

A boolean denoting whether this object is current closed.

isClosedForPartition

public boolean isClosedForPartition()

Description copied from class: Scheme

Returns true if this window is closed when operating in partition mode. If this window has been consuming slices of the data (partitions) instead of the full data, this can be used to determine whether the window could or needs to emit data to maintain the windowing invariant.

Overrides:

isClosedForPartition in class Basic

Returns:

A boolean whether this window is considered closed if it were consuming a slice of the data.

name

protected String name()

Description copied from class: Basic

Gets the name of this windowing scheme.

Overrides:

name in class Basic

Returns:

A String name for this window.