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 Summary
Fields inherited from class org.apache.storm.trident.windowing.AbstractTridentWindowManager
aggregator, delegateCollector, pendingTriggers, triggerId, windowManager, windowStore, windowTaskId
-
Constructor Summary
ConstructorDescriptionInMemoryTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector) -
Method Summary
Modifier and TypeMethodDescriptionvoid
addTuplesBatch
(Object batchId, List<TridentTuple> tuples) Add received batch of tuples to cache/store and add them toWindowManager
.getBatchTxnId
(Object batchId) getTridentTuples
(List<TridentTuple> tridentBatchTuples) ReturnTridentTuple
s from giventupleEvents
.protected void
Load and initialize any resources into window manager before windowing for component/task is activated.void
onTuplesExpired
(List<TridentTuple> expiredTuples) Handle expired tuple events which can be removing from cache or store.Methods inherited from class org.apache.storm.trident.windowing.AbstractTridentWindowManager
getPendingTriggers, prepare, shutdown
-
Constructor Details
-
InMemoryTridentWindowManager
public InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
-
-
Method Details
-
initialize
protected void initialize()Description copied from class:AbstractTridentWindowManager
Load and initialize any resources into window manager before windowing for component/task is activated.- Specified by:
initialize
in classAbstractTridentWindowManager<TridentTuple>
-
getTridentTuples
Description copied from class:AbstractTridentWindowManager
ReturnTridentTuple
s from giventupleEvents
.- Specified by:
getTridentTuples
in classAbstractTridentWindowManager<TridentTuple>
-
onTuplesExpired
Description copied from class:AbstractTridentWindowManager
Handle expired tuple events which can be removing from cache or store.- Specified by:
onTuplesExpired
in classAbstractTridentWindowManager<TridentTuple>
-
addTuplesBatch
Description copied from interface:ITridentWindowManager
Add received batch of tuples to cache/store and add them toWindowManager
. -
getBatchTxnId
-