com.yahoo.bullet.windowing

Class Tumbling

java.lang.Object

com.yahoo.bullet.windowing.Scheme

com.yahoo.bullet.windowing.Basic

com.yahoo.bullet.windowing.Tumbling

All Implemented Interfaces:

Closable, Monoidal

Direct Known Subclasses:

AdditiveTumbling

public class Tumbling
extends Basic

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME
protected long	nextCloseTime
protected long	windowLength

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
Tumbling(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
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.
void	start() Readies the window for querying.

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

combine, consume, count, getData, getRecords, getResult, resetForPartition

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 final String NAME

See Also:

Constant Field Values

nextCloseTime

protected long nextCloseTime

windowLength

protected long windowLength

Constructor Detail

Tumbling

public Tumbling(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.

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.

start

public void start()

Description copied from class: Scheme

Readies the window for querying. This is called in Querier.restart().

Overrides:

start in class Basic

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.