Package | Description |
---|---|
backtype.storm.coordination | |
backtype.storm.metric | |
backtype.storm.metric.api | |
backtype.storm.task | |
storm.trident.topology |
Modifier and Type | Class and Description |
---|---|
class |
CoordinatedBolt.CoordinatedOutputCollector |
Modifier and Type | Method and Description |
---|---|
void |
LoggingMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
Modifier and Type | Method and Description |
---|---|
void |
IMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
Modifier and Type | Interface and Description |
---|---|
interface |
IOutputCollector |
Modifier and Type | Class and Description |
---|---|
class |
OutputCollector
This output collector exposes the API for emitting tuples from an IRichBolt.
|
Modifier and Type | Class and Description |
---|---|
class |
TridentBoltExecutor.CoordinatedOutputCollector |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.