public static class ReachTopology.PartialUniquer extends BaseBatchBolt<Object>
| Constructor and Description |
|---|
PartialUniquer() |
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
execute(Tuple tuple) |
void |
finishBatch() |
void |
prepare(Map<String,Object> conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
getComponentConfigurationclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetComponentConfigurationpublic void prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, Object id)
public void execute(Tuple tuple)
public void finishBatch()
public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponentDeclare the output schema for all the streams of this topology.
declarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2021 The Apache Software Foundation. All rights reserved.