Class StoreBasedTridentWindowManager
java.lang.Object
org.apache.storm.trident.windowing.AbstractTridentWindowManager<TridentBatchTuple>
org.apache.storm.trident.windowing.StoreBasedTridentWindowManager
- All Implemented Interfaces:
ITridentWindowManager
This window manager uses
WindowsStore for storing tuples and other trigger related information. It maintains tuples cache of
maxCachedTuplesSize without accessing store for getting them.-
Field Summary
Fields inherited from class org.apache.storm.trident.windowing.AbstractTridentWindowManager
aggregator, delegateCollector, pendingTriggers, triggerId, windowManager, windowStore, windowTaskId -
Constructor Summary
ConstructorsConstructorDescriptionStoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddTuplesBatch(Object batchId, List<TridentTuple> tuples) Add received batch of tuples to cache/store and add them toWindowManager.collectTridentTupleOrKey(TridentBatchTuple tridentBatchTuple, List<String> keys) getBatchTxnId(Object batchId) getTridentTuples(List<TridentBatchTuple> tridentBatchTuples) ReturnTridentTuples from giventupleEvents.protected voidLoad and initialize any resources into window manager before windowing for component/task is activated.voidonTuplesExpired(List<TridentBatchTuple> 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
-
StoreBasedTridentWindowManager
public StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)
-
-
Method Details
-
initialize
protected void initialize()Description copied from class:AbstractTridentWindowManagerLoad and initialize any resources into window manager before windowing for component/task is activated.- Specified by:
initializein classAbstractTridentWindowManager<TridentBatchTuple>
-
addTuplesBatch
Description copied from interface:ITridentWindowManagerAdd received batch of tuples to cache/store and add them toWindowManager. -
getBatchTxnId
-
keyOf
-
getTridentTuples
Description copied from class:AbstractTridentWindowManagerReturnTridentTuples from giventupleEvents.- Specified by:
getTridentTuplesin classAbstractTridentWindowManager<TridentBatchTuple>
-
collectTridentTupleOrKey
public TridentTuple collectTridentTupleOrKey(TridentBatchTuple tridentBatchTuple, List<String> keys) -
onTuplesExpired
Description copied from class:AbstractTridentWindowManagerHandle expired tuple events which can be removing from cache or store.- Specified by:
onTuplesExpiredin classAbstractTridentWindowManager<TridentBatchTuple>
-