| Package | Description |
|---|---|
| backtype.storm.clojure | |
| backtype.storm.drpc | |
| backtype.storm.spout | |
| backtype.storm.testing | |
| backtype.storm.transactional | |
| storm.trident.spout | |
| storm.trident.topology |
| Modifier and Type | Method and Description |
|---|---|
void |
ClojureSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
DRPCSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShellSpout.open(Map stormConf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
ISpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TestPlannerSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
SpoutTracker.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TestEventLogSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
FixedTupleSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
FeederSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
PythonShellMetricsSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TestWordSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionalSpoutCoordinator.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
RichSpoutBatchTriggerer.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
MasterBatchCoordinator.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Copyright © 2015. All rights reserved.