com.yahoo.bullet.windowing

Class AdditiveTumbling

java.lang.Object

com.yahoo.bullet.windowing.Scheme

com.yahoo.bullet.windowing.Basic

com.yahoo.bullet.windowing.Tumbling

com.yahoo.bullet.windowing.AdditiveTumbling

All Implemented Interfaces:

Closable, Monoidal

public class AdditiveTumbling
extends Tumbling

Field Summary

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

NAME, nextCloseTime, 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
AdditiveTumbling(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	reset() Reset the data so far and make this the identity element for the Monoid with respect to inserting data.
void	resetForPartition() Resets the window when operating in partition mode.

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

getMetadata, isClosed, isClosedForPartition, name, start

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

combine, consume, count, getData, getRecords, getResult

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

Constructor Detail

AdditiveTumbling

public AdditiveTumbling(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

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 Tumbling

resetForPartition

public void resetForPartition()

Description copied from class: Scheme

Resets the window when operating in partition mode. If this window has been consuming slices of data (partitions) instead of the full data, you should use this method to reset the window to maintain the windowing invariant.

Overrides:

resetForPartition in class Basic