| Modifier and Type | Class and Description | 
|---|---|
class  | 
CoordinatedBolt.CoordinatedOutputCollector  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BoltOutputCollectorImpl  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SpoutOutputCollectorImpl
Methods are not thread safe. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HttpForwardingMetricsConsumer.prepare(Map<String,Object> topoConf,
       Object registrationArgument,
       TopologyContext context,
       IErrorReporter errorReporter)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
LoggingMetricsConsumer.prepare(Map<String,Object> topoConf,
       Object registrationArgument,
       TopologyContext context,
       IErrorReporter errorReporter)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
IMetricsConsumer.prepare(Map<String,Object> topoConf,
       Object registrationArgument,
       TopologyContext context,
       IErrorReporter errorReporter)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ISpoutOutputCollector
Methods are not expected to be thread safe. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SpoutOutputCollector
This output collector exposes the API for emitting tuples from an  
IRichSpout. | 
| 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 | Method and Description | 
|---|---|
void | 
ForwardingMetricsConsumer.prepare(Map<String,Object> topoConf,
       Object registrationArgument,
       TopologyContext context,
       IErrorReporter errorReporter)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
IBasicOutputCollector  | 
| Modifier and Type | Class and Description | 
|---|---|
protected static class  | 
BaseStatefulBoltExecutor.AnchoringOutputCollector  | 
class  | 
BasicOutputCollector  | 
Copyright © 2019 The Apache Software Foundation. All rights reserved.