Class 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 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()