WindowsState (Storm 2.6.2 API)

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

Description

WindowsState()
Method Summary

Modifier and Type

Method

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 Details
- WindowsState
  
  public WindowsState()
Method Details
- 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()