Class WindowTridentProcessor
java.lang.Object
org.apache.storm.trident.windowing.WindowTridentProcessor
- All Implemented Interfaces:
Serializable,TridentProcessor,TupleReceiver
TridentProcessor implementation for windowing operations on trident stream.- See Also:
-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionWindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore) -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanup()voidexecute(ProcessorContext processorContext, String streamId, TridentTuple tuple) voidfinishBatch(ProcessorContext processorContext) voidflush()static StringgenerateWindowTriggerKey(String windowTaskId, int triggerId) static ObjectgetBatchTxnId(Object batchId) static StringgetWindowTriggerInprocessIdPrefix(String windowTaskId) static StringgetWindowTriggerTaskPrefix(String windowTaskId) voidprepare(Map<String, Object> topoConf, TopologyContext context, TridentContext tridentContext) voidstartBatch(ProcessorContext processorContext) triggerKey(int triggerId)
-
Field Details
-
TRIGGER_INPROCESS_PREFIX
- See Also:
-
TRIGGER_PREFIX
- See Also:
-
TRIGGER_COUNT_PREFIX
- See Also:
-
TRIGGER_FIELD_NAME
- See Also:
-
DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT
public static final long DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT- See Also:
-
-
Constructor Details
-
WindowTridentProcessor
public WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)
-
-
Method Details
-
getWindowTriggerInprocessIdPrefix
-
getWindowTriggerTaskPrefix
-
getBatchTxnId
-
generateWindowTriggerKey
-
prepare
public void prepare(Map<String, Object> topoConf, TopologyContext context, TridentContext tridentContext) - Specified by:
preparein interfaceTridentProcessor
-
cleanup
public void cleanup()- Specified by:
cleanupin interfaceTridentProcessor
-
startBatch
- Specified by:
startBatchin interfaceTridentProcessor
-
execute
- Specified by:
executein interfaceTupleReceiver
-
flush
public void flush()- Specified by:
flushin interfaceTupleReceiver
-
finishBatch
- Specified by:
finishBatchin interfaceTridentProcessor
-
getOutputFactory
- Specified by:
getOutputFactoryin interfaceTridentProcessor
-
triggerKey
-