Class WindowState<T>
- All Implemented Interfaces:
- Iterable<Event<T>>,- Collection<Event<T>>
A wrapper around the window related states that are checkpointed.
- 
Nested Class SummaryNested Classes
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final intstatic final int
- 
Constructor SummaryConstructorsConstructorDescriptionWindowState(KeyValueState<Long, WindowState.WindowPartition<T>> windowPartitionsState, KeyValueState<String, Deque<Long>> partitionIdsState, KeyValueState<String, Optional<?>> windowSystemState, Supplier<Map<String, Optional<?>>> windowSystemStateSupplier, long maxEventsInMemory) 
- 
Method SummaryModifier and TypeMethodDescriptionbooleanvoidvoidcommit(long txid) Commits theWindowState.iterator()voidprepareCommit(long txid) Prepares theWindowStatefor commit.voidrollback(boolean reInit) Rolls back theWindowState.intsize()Methods inherited from class java.util.AbstractCollectionaddAll, clear, contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toStringMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface java.util.Collectionequals, hashCode, parallelStream, removeIf, spliterator, stream, toArray
- 
Field Details- 
MAX_PARTITION_EVENTSpublic static final int MAX_PARTITION_EVENTS- See Also:
 
- 
MIN_PARTITIONSpublic static final int MIN_PARTITIONS- See Also:
 
 
- 
- 
Constructor Details- 
WindowStatepublic WindowState(KeyValueState<Long, WindowState.WindowPartition<T>> windowPartitionsState, KeyValueState<String, Deque<Long>> partitionIdsState, KeyValueState<String, Optional<?>> windowSystemState, Supplier<Map<String, Optional<?>>> windowSystemStateSupplier, long maxEventsInMemory) 
 
- 
- 
Method Details- 
add- Specified by:
- addin interface- Collection<T>
- Overrides:
- addin class- AbstractCollection<Event<T>>
 
- 
iterator- Specified by:
- iteratorin interface- Collection<T>
- Specified by:
- iteratorin interface- Iterable<T>
- Specified by:
- iteratorin class- AbstractCollection<Event<T>>
 
- 
clearIteratorPinspublic void clearIteratorPins()
- 
sizepublic int size()- Specified by:
- sizein interface- Collection<T>
- Specified by:
- sizein class- AbstractCollection<Event<T>>
 
- 
prepareCommitpublic void prepareCommit(long txid) Prepares theWindowStatefor commit.- Parameters:
- txid- the transaction id
 
- 
commitpublic void commit(long txid) Commits theWindowState.- Parameters:
- txid- the transaction id
 
- 
rollbackpublic void rollback(boolean reInit) Rolls back theWindowState.- Parameters:
- reInit- if the members should be synced with the values from the state.
 
 
-