Class InMemoryTridentWindowManager
java.lang.Object
org.apache.storm.trident.windowing.AbstractTridentWindowManager<TridentTuple>
org.apache.storm.trident.windowing.InMemoryTridentWindowManager
- All Implemented Interfaces:
- ITridentWindowManager
This 
ITridentWindowManager instance stores all the tuples and trigger related information inmemory.- 
Field SummaryFields inherited from class org.apache.storm.trident.windowing.AbstractTridentWindowManageraggregator, delegateCollector, pendingTriggers, triggerId, windowManager, windowStore, windowTaskId
- 
Constructor SummaryConstructorsConstructorDescriptionInMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidaddTuplesBatch(Object batchId, List<TridentTuple> tuples) Add received batch of tuples to cache/store and add them toWindowManager.getBatchTxnId(Object batchId) getTridentTuples(List<TridentTuple> tridentBatchTuples) ReturnTridentTuples from giventupleEvents.protected voidLoad and initialize any resources into window manager before windowing for component/task is activated.voidonTuplesExpired(List<TridentTuple> expiredTuples) Handle expired tuple events which can be removing from cache or store.Methods inherited from class org.apache.storm.trident.windowing.AbstractTridentWindowManagergetPendingTriggers, prepare, shutdown
- 
Constructor Details- 
InMemoryTridentWindowManagerpublic InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector) 
 
- 
- 
Method Details- 
initializeprotected void initialize()Description copied from class:AbstractTridentWindowManagerLoad and initialize any resources into window manager before windowing for component/task is activated.- Specified by:
- initializein class- AbstractTridentWindowManager<TridentTuple>
 
- 
getTridentTuplesDescription copied from class:AbstractTridentWindowManagerReturnTridentTuples from giventupleEvents.- Specified by:
- getTridentTuplesin class- AbstractTridentWindowManager<TridentTuple>
 
- 
onTuplesExpiredDescription copied from class:AbstractTridentWindowManagerHandle expired tuple events which can be removing from cache or store.- Specified by:
- onTuplesExpiredin class- AbstractTridentWindowManager<TridentTuple>
 
- 
addTuplesBatchDescription copied from interface:ITridentWindowManagerAdd received batch of tuples to cache/store and add them toWindowManager.
- 
getBatchTxnId
 
-