public class InMemoryTridentWindowManager extends AbstractTridentWindowManager<TridentTuple>
This ITridentWindowManager instance stores all the tuples and trigger related information inmemory.
aggregator, delegateCollector, pendingTriggers, triggerId, windowManager, windowStore, windowTaskId| Constructor and Description |
|---|
InMemoryTridentWindowManager(WindowConfig windowConfig,
String windowTaskId,
WindowsStore windowStore,
Aggregator aggregator,
BatchOutputCollector delegateCollector) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTuplesBatch(Object batchId,
List<TridentTuple> tuples)
Add received batch of tuples to cache/store and add them to
WindowManager. |
String |
getBatchTxnId(Object batchId) |
List<TridentTuple> |
getTridentTuples(List<TridentTuple> tridentBatchTuples)
Return
TridentTuples from given tupleEvents. |
protected void |
initialize()
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.
|
getPendingTriggers, prepare, shutdownpublic InMemoryTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector)
protected void initialize()
AbstractTridentWindowManagerLoad and initialize any resources into window manager before windowing for component/task is activated.
initialize in class AbstractTridentWindowManager<TridentTuple>public List<TridentTuple> getTridentTuples(List<TridentTuple> tridentBatchTuples)
AbstractTridentWindowManagerReturn TridentTuples from given tupleEvents.
getTridentTuples in class AbstractTridentWindowManager<TridentTuple>public void onTuplesExpired(List<TridentTuple> expiredTuples)
AbstractTridentWindowManagerHandle expired tuple events which can be removing from cache or store.
onTuplesExpired in class AbstractTridentWindowManager<TridentTuple>public void addTuplesBatch(Object batchId, List<TridentTuple> tuples)
ITridentWindowManagerAdd received batch of tuples to cache/store and add them to WindowManager.
Copyright © 2021 The Apache Software Foundation. All rights reserved.