| 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 © 2021 The Apache Software Foundation. All rights reserved.