org.apache.storm.trident.windowing

Class WindowsState

java.lang.Object

org.apache.storm.trident.windowing.WindowsState

All Implemented Interfaces:

State

public class WindowsState
extends Object
implements State

State implementation for windowing operation. This is mainly used to get callback of commit txId of batches in which triggers are emitted.

Constructor Summary

Constructors

Constructor and Description
WindowsState()

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long txId)
void	commit(Long txId)
Long	getCurrentTxId()

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowsState

public WindowsState()

Method Detail

beginCommit

public void beginCommit(Long txId)

Specified by:

beginCommit in interface State

commit

public void commit(Long txId)

Specified by:

commit in interface State

getCurrentTxId

public Long getCurrentTxId()