public class PartitionPersistProcessor extends Object implements TridentProcessor
| Constructor and Description |
|---|
PartitionPersistProcessor(String stateId,
Fields inputFields,
StateUpdater updater) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
execute(ProcessorContext processorContext,
String streamId,
TridentTuple tuple) |
void |
finishBatch(ProcessorContext processorContext) |
void |
flush() |
TridentTuple.Factory |
getOutputFactory() |
void |
prepare(Map<String,Object> conf,
TopologyContext context,
TridentContext tridentContext) |
void |
startBatch(ProcessorContext processorContext) |
public PartitionPersistProcessor(String stateId, Fields inputFields, StateUpdater updater)
public void prepare(Map<String,Object> conf, 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 TridentProcessorCopyright © 2021 The Apache Software Foundation. All rights reserved.