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.
State
WindowsState()
void
beginCommit(Long txId)
commit(Long txId)
Long
getCurrentTxId()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public WindowsState()
public void beginCommit(Long txId)
beginCommit
public void commit(Long txId)
commit
public Long getCurrentTxId()
Copyright © 2021 The Apache Software Foundation. All rights reserved.