| Package | Description |
|---|---|
| backtype.storm.drpc | |
| backtype.storm.testing | |
| backtype.storm.topology | |
| storm.trident.spout |
| Modifier and Type | Method and Description |
|---|---|
void |
PrepareRequest.execute(Tuple tuple,
BasicOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
BatchRepeatA.execute(Tuple input,
BasicOutputCollector collector) |
void |
TestConfBolt.execute(Tuple input,
BasicOutputCollector collector) |
void |
BatchProcessWord.execute(Tuple input,
BasicOutputCollector collector) |
void |
IdentityBolt.execute(Tuple input,
BasicOutputCollector collector) |
void |
TestWordCounter.execute(Tuple input,
BasicOutputCollector collector) |
void |
PrepareBatchBolt.execute(Tuple input,
BasicOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
IBasicBolt.execute(Tuple input,
BasicOutputCollector collector)
Process the input tuple and optionally emit new tuples based on the input tuple.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TridentSpoutCoordinator.execute(Tuple tuple,
BasicOutputCollector collector) |
Copyright © 2015. All rights reserved.