Modifier and Type | Method and Description |
---|---|
void |
JoinBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
BatchCassandraWriterBolt.prepare(Map stormConfig,
TopologyContext topologyContext,
OutputCollector outputCollector)
Called when a task for this component is initialized within a worker on the cluster.
|
void |
BaseCassandraBolt.prepare(Map stormConfig,
TopologyContext topologyContext,
OutputCollector outputCollector)
Called when a task for this component is initialized within a worker on the cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
ClojureSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
ClojureBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
IBatchBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
T id) |
void |
CoordinatedBolt.prepare(Map config,
TopologyContext context,
OutputCollector collector) |
void |
BatchBoltExecutor.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
DRPCSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
PrepareRequest.prepare(Map map,
TopologyContext context) |
void |
ReturnResults.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
KeyedFairBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
JoinResult.prepare(Map map,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
DruidBeamBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
EsIndexTopology.UserDataSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
EsPercolateBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector outputCollector) |
void |
EsIndexBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector outputCollector) |
void |
AbstractEsBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector outputCollector) |
Modifier and Type | Method and Description |
---|---|
void |
TridentEsTopology.FixedBatchSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
EventHubBolt.prepare(Map config,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
PartialCountBolt.prepare(Map stormConf,
TopologyContext context) |
void |
GlobalCountBolt.prepare(Map config,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
EventHubSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
IPartitionedTridentSpout.Coordinator<Partitions> |
TransactionalTridentEventHubSpout.getCoordinator(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Coordinator<Partitions> |
OpaqueTridentEventHubSpout.getCoordinator(Map conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map> |
TransactionalTridentEventHubSpout.getEmitter(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map> |
OpaqueTridentEventHubSpout.getEmitter(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseLookupBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
void |
HBaseBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
void |
AbstractHBaseBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
State |
HBaseKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WordSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
WordCounter.prepare(Map stormConf,
TopologyContext context) |
void |
TotalWordCounter.prepare(Map stormConf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceFileBolt.doPrepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
void |
HdfsBolt.doPrepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
protected void |
AvroGenericRecordBolt.doPrepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
protected abstract void |
AbstractHdfsBolt.doPrepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
void |
SequenceFileTopology.SentenceSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
HdfsFileTopology.SentenceSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
SequenceFileTopology.MyBolt.prepare(Map config,
TopologyContext context,
OutputCollector collector) |
void |
HdfsFileTopology.MyBolt.prepare(Map config,
TopologyContext context,
OutputCollector collector) |
void |
AbstractHdfsBolt.prepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector)
Marked as final to prevent override.
|
Modifier and Type | Method and Description |
---|---|
void |
SimpleFileNameFormat.prepare(Map conf,
TopologyContext topologyContext) |
void |
FileNameFormat.prepare(Map conf,
TopologyContext topologyContext) |
void |
DefaultFileNameFormat.prepare(Map conf,
TopologyContext topologyContext) |
Modifier and Type | Method and Description |
---|---|
void |
HdfsSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
HdfsSpoutTopology.ConstBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
FixedBatchSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
HiveTopologyPartitioned.UserDataSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
HiveTopology.UserDataSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
BucketTestHiveTopology.UserDataSpout.open(Map config,
TopologyContext context,
SpoutOutputCollector collector) |
void |
HiveBolt.prepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
TridentHiveTopology.FixedBatchSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ITaskHook.prepare(Map conf,
TopologyContext context) |
void |
BaseTaskHook.prepare(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcInsertBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
void |
AbstractJdbcBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector outputCollector)
Subclasses should call this to ensure output collector and connection provider are set up, and finally jdbcClient is initialized properly.
|
Modifier and Type | Method and Description |
---|---|
void |
UserSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
JmsBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
Initializes JMS resources.
|
Modifier and Type | Method and Description |
---|---|
void |
GenericBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
JmsSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector)
ISpout implementation. |
Modifier and Type | Method and Description |
---|---|
ITridentSpout.BatchCoordinator<JmsBatch> |
TridentJmsSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter<JmsBatch> |
TridentJmsSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaTupleListener.open(Map<String,Object> conf,
TopologyContext context)
Called during the initialization of the kafka spout.
|
void |
EmptyKafkaTupleListener.open(Map<String,Object> conf,
TopologyContext context) |
void |
KafkaSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
List<org.apache.kafka.common.TopicPartition> |
RoundRobinManualPartitioner.partition(List<org.apache.kafka.common.TopicPartition> allPartitions,
TopologyContext context) |
List<org.apache.kafka.common.TopicPartition> |
ManualPartitioner.partition(List<org.apache.kafka.common.TopicPartition> allPartitions,
TopologyContext context)
Get the partitions for this assignment
|
abstract <K,V> void |
Subscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener,
TopologyContext context)
Subscribe the KafkaConsumer to the proper topics.
|
<K,V> void |
PatternSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener,
TopologyContext unused)
Deprecated.
|
<K,V> void |
NamedSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener,
TopologyContext unused)
Deprecated.
|
<K,V> void |
ManualPartitionSubscription.subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener,
TopologyContext context) |
Constructor and Description |
---|
CommitMetadataManager(TopologyContext context,
KafkaSpoutConfig.ProcessingGuarantee processingGuarantee)
Create a manager with the given context.
|
Modifier and Type | Method and Description |
---|---|
IPartitionedTridentSpout.Coordinator |
KafkaTridentSpoutTransactional.getCoordinator(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>> |
KafkaTridentSpoutOpaque.getCoordinator(Map conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter |
KafkaTridentSpoutTransactional.getEmitter(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>> |
KafkaTridentSpoutOpaque.getEmitter(Map conf,
TopologyContext context) |
Constructor and Description |
---|
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager,
TopologyContext topologyContext)
Creates instance of this class with default 500 millisecond refresh subscription timer
|
KafkaTridentSpoutEmitter(KafkaTridentSpoutManager<K,V> kafkaManager,
TopologyContext topologyContext,
Timer refreshSubscriptionTimer)
Create a new Kafka spout emitter.
|
Modifier and Type | Method and Description |
---|---|
IPartitionedTridentSpout.Coordinator |
TransactionalTridentKafkaSpout.getCoordinator(Map conf,
TopologyContext context)
Deprecated.
|
IOpaquePartitionedTridentSpout.Coordinator |
OpaqueTridentKafkaSpout.getCoordinator(Map conf,
TopologyContext tc)
Deprecated.
|
IPartitionedTridentSpout.Emitter |
TransactionalTridentKafkaSpout.getEmitter(Map conf,
TopologyContext context)
Deprecated.
|
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map> |
OpaqueTridentKafkaSpout.getEmitter(Map conf,
TopologyContext context)
Deprecated.
|
Constructor and Description |
---|
TridentKafkaEmitter(Map conf,
TopologyContext context,
TridentKafkaConfig config,
String topologyInstanceId) |
Modifier and Type | Method and Description |
---|---|
void |
KinesisSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
IEventLogger.prepare(Map<String,Object> conf,
Map<String,Object> arguments,
TopologyContext context) |
void |
FileBasedEventLogger.prepare(Map<String,Object> stormConf,
Map<String,Object> arguments,
TopologyContext context) |
void |
LoggingMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
void |
HttpForwardingMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
void |
SystemBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
MetricsConsumerBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
EventLoggerBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
IMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
Modifier and Type | Method and Description |
---|---|
static String |
StormMetricRegistry.metricName(String name,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MongoInsertBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
AbstractMongoBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
WordSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
WordCounter.prepare(Map stormConf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MqttBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Field and Description |
---|---|
protected TopologyContext |
MqttSpout.context |
Modifier and Type | Method and Description |
---|---|
void |
MqttSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
Number |
JsonSerializer.connect(Map conf,
TopologyContext context) |
Number |
ISerializer.connect(Map conf,
TopologyContext context)
This method transmits the Storm config to the non-JVM process and receives its pid.
|
Modifier and Type | Method and Description |
---|---|
void |
MetricGenBatchSpout.open(Map conf,
TopologyContext context) |
void |
MetricGenSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
OpenTsdbBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
SplitSentenceBolt.prepare(Map stormConf,
TopologyContext context) |
void |
CountBolt.prepare(Map stormConf,
TopologyContext context) |
void |
IdBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
DevNullBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
StringGenSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
FileReadSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
ConstSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
IdentityBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
RawInputFromCSVSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
PMMLPredictorBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRedisBolt.prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster.
|
Modifier and Type | Method and Description |
---|---|
State |
RedisKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WordSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
WordCounter.prepare(Map stormConf,
TopologyContext context) |
void |
WhitelistWordCount.PrintWordTotalCountBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
LookupWordCount.PrintWordTotalCountBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
SolrUpdateBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
SolrJsonSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
SolrFieldsSpout.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.
|
void |
CheckpointSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
TridentSocketSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ThroughputVsLatency.FastRandomSentenceSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
InOrderDeliveryTest.InOrderSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
FastWordCountTopology.FastRandomSentenceSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
BlobStoreAPIWordCountTopology.RandomSentenceSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
AnchoredWordCount.RandomSentenceSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TransactionalGlobalCount.BatchCount.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
ReachTopology.PartialUniquer.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
ReachTopology.CountAggregator.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
TransactionalWords.KeyedCountUpdater.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
TransactionAttempt id) |
void |
TransactionalWords.BucketCountUpdater.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
TransactionAttempt attempt) |
void |
TransactionalGlobalCount.UpdateGlobalCount.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
TransactionAttempt attempt) |
void |
ResourceAwareExampleTopology.ExclamationBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
void |
MultipleLoggerTopology.ExclamationLoggingBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
void |
ExclamationTopology.ExclamationBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
SlidingWindowSumBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
SingleJoinBolt.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
void |
RollingCountBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
RollingCountAggBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
RandomNumberGeneratorSpout.open(Map conf,
TopologyContext context) |
void |
RandomSentenceSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
RandomIntegerSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
static State |
StateFactory.getState(String namespace,
Map stormConf,
TopologyContext context)
Returns a new state instance using the
Config.TOPOLOGY_STATE_PROVIDER or a InMemoryKeyValueState if no provider is configured. |
State |
StateProvider.newState(String namespace,
Map stormConf,
TopologyContext context)
Returns a new state instance.
|
State |
InMemoryKeyValueStateProvider.newState(String namespace,
Map stormConf,
TopologyContext context) |
void |
IStateSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ShellBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
IBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster.
|
Modifier and Type | Method and Description |
---|---|
IOpaquePartitionedTransactionalSpout.Coordinator |
OpaqueMemoryTransactionalSpout.getCoordinator(Map conf,
TopologyContext context) |
IPartitionedTransactionalSpout.Coordinator |
MemoryTransactionalSpout.getCoordinator(Map conf,
TopologyContext context) |
IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> |
OpaqueMemoryTransactionalSpout.getEmitter(Map conf,
TopologyContext context) |
IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> |
MemoryTransactionalSpout.getEmitter(Map conf,
TopologyContext context) |
void |
TestWordSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TestPlannerSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TestEventLogSpout.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
SpoutTracker.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
PythonShellMetricsSpout.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 |
ForwardingMetricsConsumer.prepare(Map stormConf,
Object registrationArgument,
TopologyContext context,
IErrorReporter errorReporter) |
void |
TestWordCounter.prepare(Map stormConf,
TopologyContext context) |
void |
TestConfBolt.prepare(Map conf,
TopologyContext context) |
void |
KeyedSummingBatchBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
KeyedCountingBatchBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
CountingBatchBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
BatchNumberList.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
Object id) |
void |
CountingCommitBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector,
TransactionAttempt id) |
void |
TupleCaptureBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
TestPlannerBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
TestGlobalCount.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
TestEventOrderCheckBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
TestAggregatesCounter.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
PythonShellMetricsBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
NonRichBoltTracker.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseStatefulBoltExecutor.init(TopologyContext context,
OutputCollector collector) |
void |
IBasicBolt.prepare(Map stormConf,
TopologyContext context) |
void |
WindowedBoltExecutor.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
StatefulWindowedBoltExecutor.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
StatefulBoltExecutor.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
IWindowedBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
This is similar to the
IBolt.prepare(Map, TopologyContext, OutputCollector) except that while emitting, the tuples are automatically anchored to the tuples in the inputWindow. |
void |
IStatefulBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
CheckpointTupleForwarder.prepare(Map stormConf,
TopologyContext context,
OutputCollector outputCollector) |
void |
BasicBoltExecutor.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
BaseBasicBolt.prepare(Map stormConf,
TopologyContext context) |
void |
BaseWindowedBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
void |
BaseStatefulBolt.prepare(Map stormConf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
ITransactionalSpout.Coordinator<T> |
ITransactionalSpout.getCoordinator(Map conf,
TopologyContext context)
The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit.
|
ITransactionalSpout.Emitter<T> |
ITransactionalSpout.getEmitter(Map conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster.
|
ICommitterTransactionalSpout.Emitter |
ICommitterTransactionalSpout.getEmitter(Map conf,
TopologyContext context) |
void |
TransactionalSpoutCoordinator.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TransactionalSpoutBatchExecutor.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Constructor and Description |
---|
Coordinator(Map conf,
TopologyContext context) |
Emitter(Map conf,
TopologyContext context) |
Constructor and Description |
---|
TridentOperationContext(TopologyContext topoContext,
TridentTuple.Factory factory) |
Modifier and Type | Method and Description |
---|---|
void |
SubtopologyBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector batchCollector) |
void |
TridentProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
Modifier and Type | Method and Description |
---|---|
void |
StateQueryProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
ProjectedProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
PartitionPersistProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
MultiReducerProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
MapProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
EachProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
void |
AggregateProcessor.prepare(Map conf,
TopologyContext context,
TridentContext tridentContext) |
Modifier and Type | Method and Description |
---|---|
IPartitionedTridentSpout.Coordinator<Partitions> |
IPartitionedTridentSpout.getCoordinator(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Coordinator<Partitions> |
IOpaquePartitionedTridentSpout.getCoordinator(Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator |
RichSpoutBatchExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator<Object> |
PartitionedTridentSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator<Object> |
OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator<T> |
ITridentSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context)
The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted.
|
ITridentSpout.BatchCoordinator |
BatchSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter<Partitions,Partition,T> |
IPartitionedTridentSpout.getEmitter(Map conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,M> |
IOpaquePartitionedTridentSpout.getEmitter(Map conf,
TopologyContext context) |
ITridentSpout.Emitter |
RichSpoutBatchExecutor.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter<Object> |
PartitionedTridentSpoutExecutor.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ICommitterTridentSpout.Emitter |
OpaquePartitionedTridentSpoutExecutor.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter<T> |
ITridentSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster.
|
ICommitterTridentSpout.Emitter |
ICommitterTridentSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter |
BatchSpoutExecutor.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
void |
IBatchSpout.open(Map conf,
TopologyContext context) |
void |
RichSpoutBatchTriggerer.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
TridentSpoutCoordinator.prepare(Map conf,
TopologyContext context) |
void |
TridentSpoutExecutor.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector) |
Constructor and Description |
---|
Coordinator(Map conf,
TopologyContext context) |
Emitter(String txStateId,
Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
ITridentSpout.BatchCoordinator |
FeederCommitterBatchSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator |
FeederBatchSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ICommitterTridentSpout.Emitter |
FeederCommitterBatchSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter |
FeederBatchSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
void |
FixedBatchSpout.open(Map conf,
TopologyContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MasterBatchCoordinator.open(Map conf,
TopologyContext context,
SpoutOutputCollector collector) |
void |
ITridentBatchBolt.prepare(Map conf,
TopologyContext context,
BatchOutputCollector collector) |
void |
TridentBoltExecutor.prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
WindowTridentProcessor.prepare(Map stormConf,
TopologyContext context,
TridentContext tridentContext) |
Modifier and Type | Method and Description |
---|---|
Number |
ShellProcess.launch(Map conf,
TopologyContext context) |
Number |
ShellProcess.launch(Map conf,
TopologyContext context,
boolean changeDirectory) |
void |
ShellLogHandler.setUpContext(Class<?> ownerCls,
ShellProcess process,
TopologyContext context)
Called at least once before
ShellLogHandler.log(org.apache.storm.multilang.ShellMsg) for each spout and bolt. |
void |
DefaultShellLogHandler.setUpContext(Class<?> ownerCls,
ShellProcess process,
TopologyContext context)
This default implementation saves the
ShellProcess so it can output the process info string later. |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.