public class WindowTridentProcessor extends Object implements TridentProcessor
TridentProcessor implementation for windowing operations on trident stream.
| Modifier and Type | Class and Description |
|---|---|
static class |
WindowTridentProcessor.TriggerInfo |
| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT |
static String |
TRIGGER_COUNT_PREFIX |
static String |
TRIGGER_FIELD_NAME |
static String |
TRIGGER_INPROCESS_PREFIX |
static String |
TRIGGER_PREFIX |
| Constructor and Description |
|---|
WindowTridentProcessor(WindowConfig windowConfig,
String uniqueWindowId,
WindowsStoreFactory windowStoreFactory,
Fields inputFields,
Aggregator aggregator,
boolean storeTuplesInStore) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
finishBatch(ProcessorContext processorContext) |
void |
flush() |
static String |
generateWindowTriggerKey(String windowTaskId,
int triggerId) |
static Object |
getBatchTxnId(Object batchId) |
TridentTuple.Factory |
getOutputFactory() |
static String |
getWindowTriggerInprocessIdPrefix(String windowTaskId) |
static String |
getWindowTriggerTaskPrefix(String windowTaskId) |
void |
prepare(Map<String,Object> topoConf,
TopologyContext context,
TridentContext tridentContext) |
void |
startBatch(ProcessorContext processorContext) |
String |
triggerKey(int triggerId) |
public static final String TRIGGER_INPROCESS_PREFIX
public static final String TRIGGER_PREFIX
public static final String TRIGGER_COUNT_PREFIX
public static final String TRIGGER_FIELD_NAME
public static final long DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT
public WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)
public static String getWindowTriggerInprocessIdPrefix(String windowTaskId)
public static String generateWindowTriggerKey(String windowTaskId, int triggerId)
public void prepare(Map<String,Object> topoConf, TopologyContext context, TridentContext tridentContext)
prepare in interface TridentProcessorpublic void cleanup()
cleanup in interface TridentProcessorpublic void startBatch(ProcessorContext processorContext)
startBatch in interface TridentProcessorpublic void execute(ProcessorContext processorContext, String streamId, TridentTuple tuple)
execute in interface TupleReceiverpublic void flush()
flush in interface TupleReceiverpublic void finishBatch(ProcessorContext processorContext)
finishBatch in interface TridentProcessorpublic TridentTuple.Factory getOutputFactory()
getOutputFactory in interface TridentProcessorpublic String triggerKey(int triggerId)
Copyright © 2021 The Apache Software Foundation. All rights reserved.