streamcruncher.api
Class TimeWindowSizeProvider

java.lang.Object
  streamcruncher.api.WindowSizeProvider
      streamcruncher.api.TimeWindowSizeProvider

All Implemented Interfaces:

Provider

Direct Known Subclasses:

TimeWFPartitionWinSizeProviderTest.CustomWindowSizeProvider

public class TimeWindowSizeProvider
extends WindowSizeProvider

Window Size Provider for Time based Windows. Instances of this class are used to provide the Window size in milliseconds using provideSizeMillis(Object[]). If the Time based Window is configured to use the "Max Events" constraint, then the WindowSizeProvider.provideSize(Object[]) returns the appropriate size.

Note: This object is not Thread-safe.

Field Summary

static java.lang.String

name2

Fields inherited from class streamcruncher.api.WindowSizeProvider

name

Constructor Summary

TimeWindowSizeProvider()

Method Summary

static java.lang.String	getName()
java.lang.Long	getSizeMillis()
long	provideSizeMillis(java.lang.Object[] levelValues)
void	setSizeMillis(java.lang.Long sizeMillis)

Methods inherited from class streamcruncher.api.WindowSizeProvider

getSize, provideSize, setSize

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

name2

public static final java.lang.String name2

See Also:

Constant Field Values

Constructor Detail

TimeWindowSizeProvider

public TimeWindowSizeProvider()

Method Detail

getName

public static java.lang.String getName()

Returns:

"TimeWindowSize/Default".

getSizeMillis

public java.lang.Long getSizeMillis()

setSizeMillis

public void setSizeMillis(java.lang.Long sizeMillis)

provideSizeMillis

public long provideSizeMillis(java.lang.Object[] levelValues)

Parameters:

levelValues -

Returns:

sizeMillis

See Also:

WindowSizeProvider.provideSize(Object[])