A B C D E F G H I J K L M N O P R S T U V W Z _

A

ack(Object) - Method in class backtype.storm.clojure.ClojureSpout

ack(Tuple) - Method in class backtype.storm.coordination.BatchOutputCollectorImpl

ack(Tuple) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

ack(Object) - Method in class backtype.storm.drpc.DRPCSpout

ack(Object) - Method in interface backtype.storm.spout.ISpout

Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed.

ack(Object) - Method in class backtype.storm.spout.ShellSpout

ack(Tuple) - Method in interface backtype.storm.task.IOutputCollector

ack(Tuple) - Method in class backtype.storm.task.OutputCollector

ack(Object) - Method in interface backtype.storm.testing.AckFailDelegate

ack(Object) - Method in class backtype.storm.testing.AckTracker

ack(Object) - Method in class backtype.storm.testing.FeederSpout

ack(Object) - Method in class backtype.storm.testing.FixedTupleSpout

ack(Object) - Method in class backtype.storm.testing.SpoutTracker

ack(Object) - Method in class backtype.storm.testing.TestPlannerSpout

ack(Object) - Method in class backtype.storm.testing.TestWordSpout

ack(Object) - Method in class backtype.storm.topology.base.BaseRichSpout

ack(Object) - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

AckFailDelegate - Interface in backtype.storm.testing

AckTracker - Class in backtype.storm.testing

AckTracker() - Constructor for class backtype.storm.testing.AckTracker

acquire() - Method in class backtype.storm.utils.ThreadResourceManager

acquireNewPort() - Static method in class backtype.storm.utils.InprocMessaging

add(int, Object, List<Object>) - Method in interface backtype.storm.state.ISynchronizeOutputCollector

add(int, Object, List<Object>) - Method in class backtype.storm.state.SynchronizeOutputCollector

add(Object, V) - Method in class backtype.storm.utils.KeyedRoundRobinQueue

add(Object) - Method in class backtype.storm.utils.ListDelegate

add(int, Object) - Method in class backtype.storm.utils.ListDelegate

addAll(Collection<? extends Object>) - Method in class backtype.storm.utils.ListDelegate

addAll(int, Collection<? extends Object>) - Method in class backtype.storm.utils.ListDelegate

addBolt(IBatchBolt, int) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IBatchBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IRichBolt, int) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

Deprecated.

addBolt(IRichBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

Deprecated.

addBolt(IBasicBolt, int) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IBasicBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

addConfiguration(String, Object) - Method in class backtype.storm.topology.BaseConfigurationDeclarer

addConfiguration(String, Object) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer

addConfigurations(Map) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer

addConfigurations(Map) - Method in class backtype.storm.topology.TopologyBuilder.ConfigGetter

advanceTime(long) - Static method in class backtype.storm.utils.Time

all() - Static method in class backtype.storm.coordination.CoordinatedBolt.SourceArgs

allGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

allGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

allGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer

allGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer

allGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

allGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

ARGS_STREAM - Static variable in class backtype.storm.drpc.PrepareRequest

assoc(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap

assocEx(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap

B

backtype.storm - package backtype.storm

backtype.storm.clojure - package backtype.storm.clojure

backtype.storm.coordination - package backtype.storm.coordination

backtype.storm.daemon - package backtype.storm.daemon

backtype.storm.drpc - package backtype.storm.drpc

backtype.storm.grouping - package backtype.storm.grouping

backtype.storm.planner - package backtype.storm.planner

backtype.storm.serialization - package backtype.storm.serialization

backtype.storm.spout - package backtype.storm.spout

backtype.storm.state - package backtype.storm.state

backtype.storm.task - package backtype.storm.task

backtype.storm.testing - package backtype.storm.testing

backtype.storm.topology - package backtype.storm.topology

backtype.storm.topology.base - package backtype.storm.topology.base

backtype.storm.transactional - package backtype.storm.transactional

backtype.storm.transactional.partitioned - package backtype.storm.transactional.partitioned

backtype.storm.transactional.state - package backtype.storm.transactional.state

backtype.storm.tuple - package backtype.storm.tuple

backtype.storm.utils - package backtype.storm.utils

BaseBasicBolt - Class in backtype.storm.topology.base

BaseBasicBolt() - Constructor for class backtype.storm.topology.base.BaseBasicBolt

BaseBatchBolt<T> - Class in backtype.storm.topology.base

BaseBatchBolt() - Constructor for class backtype.storm.topology.base.BaseBatchBolt

BaseComponent - Class in backtype.storm.topology.base

BaseComponent() - Constructor for class backtype.storm.topology.base.BaseComponent

BaseConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Class in backtype.storm.topology

BaseConfigurationDeclarer() - Constructor for class backtype.storm.topology.BaseConfigurationDeclarer

BaseOpaquePartitionedTransactionalSpout<T> - Class in backtype.storm.topology.base

BaseOpaquePartitionedTransactionalSpout() - Constructor for class backtype.storm.topology.base.BaseOpaquePartitionedTransactionalSpout

BasePartitionedTransactionalSpout<T> - Class in backtype.storm.topology.base

BasePartitionedTransactionalSpout() - Constructor for class backtype.storm.topology.base.BasePartitionedTransactionalSpout

BaseRichBolt - Class in backtype.storm.topology.base

BaseRichBolt() - Constructor for class backtype.storm.topology.base.BaseRichBolt

BaseRichSpout - Class in backtype.storm.topology.base

BaseRichSpout() - Constructor for class backtype.storm.topology.base.BaseRichSpout

BaseTransactionalBolt - Class in backtype.storm.topology.base

BaseTransactionalBolt() - Constructor for class backtype.storm.topology.base.BaseTransactionalBolt

BaseTransactionalSpout<T> - Class in backtype.storm.topology.base

BaseTransactionalSpout() - Constructor for class backtype.storm.topology.base.BaseTransactionalSpout

BasicBoltExecutor - Class in backtype.storm.topology

BasicBoltExecutor(IBasicBolt) - Constructor for class backtype.storm.topology.BasicBoltExecutor

BasicOutputCollector - Class in backtype.storm.topology

BasicOutputCollector(OutputCollector) - Constructor for class backtype.storm.topology.BasicOutputCollector

BatchBoltExecutor - Class in backtype.storm.coordination

BatchBoltExecutor(IBatchBolt) - Constructor for class backtype.storm.coordination.BatchBoltExecutor

BatchOutputCollector - Class in backtype.storm.coordination

BatchOutputCollector() - Constructor for class backtype.storm.coordination.BatchOutputCollector

BatchOutputCollectorImpl - Class in backtype.storm.coordination

BatchOutputCollectorImpl(OutputCollector) - Constructor for class backtype.storm.coordination.BatchOutputCollectorImpl

BoltDeclarer - Interface in backtype.storm.topology

BoltTracker - Class in backtype.storm.testing

BoltTracker(IRichBolt, String) - Constructor for class backtype.storm.testing.BoltTracker

BufferFileInputStream - Class in backtype.storm.utils

BufferFileInputStream(String, int) - Constructor for class backtype.storm.utils.BufferFileInputStream

BufferFileInputStream(String) - Constructor for class backtype.storm.utils.BufferFileInputStream

buildTopology() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

buildTopologyBuilder() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

C

cleanup() - Method in class backtype.storm.clojure.ClojureBolt

cleanup() - Method in class backtype.storm.coordination.BatchBoltExecutor

cleanup() - Method in class backtype.storm.coordination.CoordinatedBolt

cleanup() - Method in class backtype.storm.drpc.KeyedFairBolt

cleanup() - Method in class backtype.storm.drpc.ReturnResults

cleanup() - Method in interface backtype.storm.task.IBolt

Called when an IBolt is going to be shutdown.

cleanup() - Method in class backtype.storm.task.ShellBolt

cleanup() - Method in class backtype.storm.testing.FixedTupleSpout

cleanup() - Method in class backtype.storm.testing.MemoryTransactionalSpout

cleanup() - Method in class backtype.storm.testing.NonRichBoltTracker

cleanup() - Method in class backtype.storm.testing.TestAggregatesCounter

cleanup() - Method in class backtype.storm.testing.TestGlobalCount

cleanup() - Method in class backtype.storm.testing.TestWordCounter

cleanup() - Method in class backtype.storm.testing.TupleCaptureBolt

cleanup() - Method in class backtype.storm.topology.base.BaseBasicBolt

cleanup() - Method in class backtype.storm.topology.base.BaseRichBolt

cleanup() - Method in class backtype.storm.topology.BasicBoltExecutor

cleanup() - Method in interface backtype.storm.topology.IBasicBolt

cleanup() - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

cleanup() - Method in class backtype.storm.utils.VersionedStore

cleanup(int) - Method in class backtype.storm.utils.VersionedStore

cleanupBefore(BigInteger) - Method in interface backtype.storm.transactional.ITransactionalSpout.Emitter

Any state for transactions prior to the provided transaction id can be safely cleaned up, so this method should clean up that state.

cleanupBefore(BigInteger) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

cleanupBefore(BigInteger) - Method in class backtype.storm.transactional.state.RotatingTransactionalState

clear(String) - Static method in class backtype.storm.testing.FixedTupleSpout

clear() - Method in class backtype.storm.utils.IndifferentAccessMap

clear() - Method in class backtype.storm.utils.ListDelegate

clearState(String) - Static method in class backtype.storm.utils.RegisteredGlobalState

ClojureBolt - Class in backtype.storm.clojure

ClojureBolt(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class backtype.storm.clojure.ClojureBolt

ClojureSpout - Class in backtype.storm.clojure

ClojureSpout(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class backtype.storm.clojure.ClojureSpout

ClojureTimerTask - Class in backtype.storm.utils

ClojureTimerTask(IFn) - Constructor for class backtype.storm.utils.ClojureTimerTask

close() - Method in class backtype.storm.clojure.ClojureSpout

close() - Method in class backtype.storm.drpc.DRPCInvocationsClient

close() - Method in class backtype.storm.drpc.DRPCSpout

close() - Method in interface backtype.storm.spout.ISpout

Called when an ISpout is going to be shutdown.

close() - Method in class backtype.storm.spout.ShellSpout

close() - Method in interface backtype.storm.state.IStateSpout

close() - Method in class backtype.storm.testing.FeederSpout

close() - Method in class backtype.storm.testing.FixedTupleSpout

close() - Method in class backtype.storm.testing.SpoutTracker

close() - Method in class backtype.storm.testing.TestPlannerSpout

close() - Method in class backtype.storm.testing.TestWordSpout

close() - Method in class backtype.storm.topology.base.BaseRichSpout

close() - Method in interface backtype.storm.transactional.ITransactionalSpout.Coordinator

Release any resources from this coordinator.

close() - Method in interface backtype.storm.transactional.ITransactionalSpout.Emitter

Release any resources held by this emitter.

close() - Method in interface backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Emitter

close() - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Coordinator

close() - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Emitter

close() - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

close() - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

close() - Method in class backtype.storm.transactional.state.TransactionalState

close() - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

close() - Method in class backtype.storm.utils.BufferFileInputStream

close() - Method in class backtype.storm.utils.DRPCClient

close() - Method in class backtype.storm.utils.NimbusClient

commit(TransactionAttempt) - Method in interface backtype.storm.transactional.ICommitterTransactionalSpout.Emitter

commit(TransactionAttempt) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Interface in backtype.storm.topology

componentId - Variable in class backtype.storm.planner.TaskBundle

CompoundSpout - Class in backtype.storm.planner

CompoundSpout() - Constructor for class backtype.storm.planner.CompoundSpout

CompoundTask - Class in backtype.storm.planner

CompoundTask() - Constructor for class backtype.storm.planner.CompoundTask

Config - Class in backtype.storm

Topology configs are specified as a plain old map.

Config() - Constructor for class backtype.storm.Config

cons(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

Constants - Class in backtype.storm

Constants() - Constructor for class backtype.storm.Constants

Container - Class in backtype.storm.utils

Container() - Constructor for class backtype.storm.utils.Container

contains(Object) - Method in class backtype.storm.utils.ListDelegate

containsAll(Collection<?>) - Method in class backtype.storm.utils.ListDelegate

containsKey(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

containsKey(K) - Method in class backtype.storm.utils.TimeCacheMap

containsValue(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

COORDINATED_STREAM_ID - Static variable in class backtype.storm.Constants

CoordinatedBolt - Class in backtype.storm.coordination

Coordination requires the request ids to be globally unique for awhile.

CoordinatedBolt(IRichBolt) - Constructor for class backtype.storm.coordination.CoordinatedBolt

CoordinatedBolt(IRichBolt, String, CoordinatedBolt.SourceArgs, CoordinatedBolt.IdStreamSpec) - Constructor for class backtype.storm.coordination.CoordinatedBolt

CoordinatedBolt(IRichBolt, Map<String, CoordinatedBolt.SourceArgs>, CoordinatedBolt.IdStreamSpec) - Constructor for class backtype.storm.coordination.CoordinatedBolt

CoordinatedBolt.CoordinatedOutputCollector - Class in backtype.storm.coordination

CoordinatedBolt.CoordinatedOutputCollector(IOutputCollector) - Constructor for class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

CoordinatedBolt.FinishedCallback - Interface in backtype.storm.coordination

CoordinatedBolt.IdStreamSpec - Class in backtype.storm.coordination

CoordinatedBolt.IdStreamSpec(String, String) - Constructor for class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec

CoordinatedBolt.SourceArgs - Class in backtype.storm.coordination

CoordinatedBolt.SourceArgs(boolean) - Constructor for class backtype.storm.coordination.CoordinatedBolt.SourceArgs

CoordinatedBolt.TimeoutCallback - Interface in backtype.storm.coordination

CoordinatedBolt.TrackingInfo - Class in backtype.storm.coordination

CoordinatedBolt.TrackingInfo() - Constructor for class backtype.storm.coordination.CoordinatedBolt.TrackingInfo

count() - Method in class backtype.storm.tuple.Tuple

count() - Method in class backtype.storm.utils.IndifferentAccessMap

CountingBatchBolt - Class in backtype.storm.testing

CountingBatchBolt() - Constructor for class backtype.storm.testing.CountingBatchBolt

CountingCommitBolt - Class in backtype.storm.testing

CountingCommitBolt() - Constructor for class backtype.storm.testing.CountingCommitBolt

crc32(Tuple) - Method in interface backtype.storm.serialization.ITupleSerializer

crc32(Tuple) - Method in class backtype.storm.serialization.KryoTupleSerializer

CRC32OutputStream - Class in backtype.storm.utils

CRC32OutputStream() - Constructor for class backtype.storm.utils.CRC32OutputStream

createLocalTopology(ILocalDRPC) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

createRemoteTopology() - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder

createTopology() - Method in class backtype.storm.topology.TopologyBuilder

createVersion() - Method in class backtype.storm.utils.VersionedStore

createVersion(long) - Method in class backtype.storm.utils.VersionedStore

currentTimeMillis() - Static method in class backtype.storm.utils.Time

customGrouping(String, CustomStreamGrouping) - Method in interface backtype.storm.topology.InputDeclarer

customGrouping(String, String, CustomStreamGrouping) - Method in interface backtype.storm.topology.InputDeclarer

customGrouping(String, CustomStreamGrouping) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

customGrouping(String, String, CustomStreamGrouping) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

CustomStreamGrouping - Interface in backtype.storm.grouping

D

declare(Fields) - Method in interface backtype.storm.topology.OutputFieldsDeclarer

Uses default stream id.

declare(boolean, Fields) - Method in interface backtype.storm.topology.OutputFieldsDeclarer

declare(Fields) - Method in class backtype.storm.topology.OutputFieldsGetter

declare(boolean, Fields) - Method in class backtype.storm.topology.OutputFieldsGetter

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.clojure.ClojureBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.clojure.ClojureSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.clojure.RichShellBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.coordination.BatchBoltExecutor

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.coordination.CoordinatedBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.drpc.DRPCSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.drpc.JoinResult

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.drpc.KeyedFairBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.drpc.PrepareRequest

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.drpc.ReturnResults

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.BoltTracker

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.CountingBatchBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.CountingCommitBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.FeederSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.IdentityBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.KeyedCountingBatchBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.KeyedSummingBatchBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.MemoryTransactionalSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.SpoutTracker

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestAggregatesCounter

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestConfBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestGlobalCount

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestPlannerBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestPlannerSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestWordCounter

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TestWordSpout

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.TupleCaptureBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.topology.BasicBoltExecutor

declareOutputFields(OutputFieldsDeclarer) - Method in interface backtype.storm.topology.IComponent

Declare the output schema for all the streams of this topology.

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

declareStream(String, Fields) - Method in interface backtype.storm.topology.OutputFieldsDeclarer

declareStream(String, boolean, Fields) - Method in interface backtype.storm.topology.OutputFieldsDeclarer

declareStream(String, Fields) - Method in class backtype.storm.topology.OutputFieldsGetter

declareStream(String, boolean, Fields) - Method in class backtype.storm.topology.OutputFieldsGetter

decodeVIntSize(byte) - Static method in class backtype.storm.utils.WritableUtils

Parse the first byte of a vint/vlong to determine the number of bytes

DEFAULT_STREAM_ID - Static variable in class backtype.storm.utils.Utils

delete(String) - Method in class backtype.storm.transactional.state.TransactionalState

deleteVersion(long) - Method in class backtype.storm.utils.VersionedStore

deserialize(byte[]) - Method in interface backtype.storm.serialization.ITupleDeserializer

deserialize(byte[]) - Method in class backtype.storm.serialization.KryoTupleDeserializer

deserialize(byte[]) - Method in class backtype.storm.serialization.KryoTupleDeserializer.Worker

deserialize(byte[]) - Method in class backtype.storm.serialization.KryoValuesDeserializer

deserialize(byte[]) - Method in class backtype.storm.spout.RawScheme

deserialize(byte[]) - Method in interface backtype.storm.spout.Scheme

deserialize(DataInputStream) - Static method in class backtype.storm.tuple.MessageId

deserialize(byte[]) - Static method in class backtype.storm.utils.Utils

deserializeFrom(InputStream) - Method in class backtype.storm.serialization.KryoValuesDeserializer

deserializeObject(byte[]) - Method in class backtype.storm.serialization.KryoValuesDeserializer

directGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

directGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

directGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer

directGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer

directGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

directGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

displayByteArray(byte[]) - Static method in class backtype.storm.utils.WritableUtils

downloadFromMaster(Map, String, String) - Static method in class backtype.storm.utils.Utils

DRPC_INVOCATIONS_PORT - Static variable in class backtype.storm.Config

This port on Storm DRPC is used by DRPC topologies to receive function invocations and send results back.

DRPC_PORT - Static variable in class backtype.storm.Config

This port is used by Storm DRPC for receiving DPRC requests from clients.

DRPC_SERVERS - Static variable in class backtype.storm.Config

List of DRPC servers so that the DRPCSpout knows who to talk to.

DRPCClient - Class in backtype.storm.utils

DRPCClient(String, int) - Constructor for class backtype.storm.utils.DRPCClient

DRPCInvocationsClient - Class in backtype.storm.drpc

DRPCInvocationsClient(String, int) - Constructor for class backtype.storm.drpc.DRPCInvocationsClient

DRPCSpout - Class in backtype.storm.drpc

DRPCSpout(String) - Constructor for class backtype.storm.drpc.DRPCSpout

DRPCSpout(String, ILocalDRPC) - Constructor for class backtype.storm.drpc.DRPCSpout

E

emit(List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollector

Emits a tuple to the default output stream.

emit(String, List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollector

emit(String, List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollectorImpl

emit(String, Collection<Tuple>, List<Object>) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

emit(String, List<Object>, Object) - Method in interface backtype.storm.spout.ISpoutOutputCollector

Returns the task ids that received the tuples.

emit(String, List<Object>, Object) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a new tuple to the specified output stream with the given message ID.

emit(List<Object>, Object) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a new tuple to the default output stream with the given message ID.

emit(List<Object>) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the default output stream with a null message id.

emit(String, List<Object>) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the specified output stream with a null message id.

emit(String, Collection<Tuple>, List<Object>) - Method in interface backtype.storm.task.IOutputCollector

Returns the task ids that received the tuples.

emit(String, Tuple, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a new tuple to a specific stream with a single anchor.

emit(String, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a new unanchored tuple to the specified stream.

emit(Collection<Tuple>, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a new tuple to the default stream anchored on a group of input tuples.

emit(Tuple, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a new tuple to the default stream anchored on a single tuple.

emit(List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a new unanchored tuple to the default stream.

emit(String, Collection<Tuple>, List<Object>) - Method in class backtype.storm.task.OutputCollector

emit(String, List<Object>) - Method in class backtype.storm.topology.BasicOutputCollector

emit(List<Object>) - Method in class backtype.storm.topology.BasicOutputCollector

emit(String, List<Object>) - Method in interface backtype.storm.topology.IBasicOutputCollector

emitBatch(TransactionAttempt, X, BatchOutputCollector) - Method in interface backtype.storm.transactional.ITransactionalSpout.Emitter

Emit a batch for the specified transaction attempt and metadata for the transaction.

emitBatch(TransactionAttempt, Object, BatchOutputCollector) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

emitDirect(int, List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollector

Emits a tuple to the specified task on the default output stream.

emitDirect(int, String, List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollector

emitDirect(int, String, List<Object>) - Method in class backtype.storm.coordination.BatchOutputCollectorImpl

emitDirect(int, String, Collection<Tuple>, List<Object>) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

emitDirect(int, String, List<Object>, Object) - Method in interface backtype.storm.spout.ISpoutOutputCollector

emitDirect(int, String, List<Object>, Object) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the specified task on the specified output stream.

emitDirect(int, List<Object>, Object) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the specified task on the default output stream.

emitDirect(int, String, List<Object>) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the specified task on the specified output stream.

emitDirect(int, List<Object>) - Method in class backtype.storm.spout.SpoutOutputCollector

Emits a tuple to the specified task on the default output stream.

emitDirect(int, String, Collection<Tuple>, List<Object>) - Method in interface backtype.storm.task.IOutputCollector

emitDirect(int, String, Tuple, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a tuple directly to the specified task id on the specified stream.

emitDirect(int, String, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a tuple directly to the specified task id on the specified stream.

emitDirect(int, Collection<Tuple>, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a tuple directly to the specified task id on the default stream.

emitDirect(int, Tuple, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a tuple directly to the specified task id on the default stream.

emitDirect(int, List<Object>) - Method in class backtype.storm.task.OutputCollector

Emits a tuple directly to the specified task id on the default stream.

emitDirect(int, String, Collection<Tuple>, List<Object>) - Method in class backtype.storm.task.OutputCollector

emitDirect(int, String, List<Object>) - Method in class backtype.storm.topology.BasicOutputCollector

emitDirect(int, List<Object>) - Method in class backtype.storm.topology.BasicOutputCollector

emitDirect(int, String, List<Object>) - Method in interface backtype.storm.topology.IBasicOutputCollector

emitPartitionBatch(TransactionAttempt, BatchOutputCollector, int, X) - Method in interface backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Emitter

Emit a batch of tuples for a partition/transaction.

emitPartitionBatch(TransactionAttempt, BatchOutputCollector, int, X) - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Emitter

Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.

emitPartitionBatchNew(TransactionAttempt, BatchOutputCollector, int, X) - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Emitter

Emit a batch of tuples for a partition/transaction that's never been emitted before.

emitted_tuples - Static variable in class backtype.storm.testing.TupleCaptureBolt

empty() - Method in class backtype.storm.utils.IndifferentAccessMap

entryAt(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

entrySet() - Method in class backtype.storm.utils.IndifferentAccessMap

equals(Object) - Method in class backtype.storm.testing.TestSerObject

equals(Object) - Method in class backtype.storm.transactional.TransactionAttempt

equals(Object) - Method in class backtype.storm.tuple.MessageId

equals(Object) - Method in class backtype.storm.tuple.Tuple

equiv(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

execute(Tuple) - Method in class backtype.storm.clojure.ClojureBolt

execute(Tuple) - Method in class backtype.storm.coordination.BatchBoltExecutor

execute(Tuple) - Method in class backtype.storm.coordination.CoordinatedBolt

execute(Tuple) - Method in interface backtype.storm.coordination.IBatchBolt

execute(Tuple) - Method in class backtype.storm.drpc.JoinResult

execute(Tuple) - Method in class backtype.storm.drpc.KeyedFairBolt

execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.drpc.PrepareRequest

execute(Tuple) - Method in class backtype.storm.drpc.ReturnResults

execute(Tuple) - Method in interface backtype.storm.task.IBolt

Process a single tuple of input.

execute(Tuple) - Method in class backtype.storm.task.ShellBolt

execute(Tuple) - Method in class backtype.storm.testing.CountingBatchBolt

execute(Tuple) - Method in class backtype.storm.testing.CountingCommitBolt

execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.testing.IdentityBolt

execute(Tuple) - Method in class backtype.storm.testing.KeyedCountingBatchBolt

execute(Tuple) - Method in class backtype.storm.testing.KeyedSummingBatchBolt

execute(Tuple) - Method in class backtype.storm.testing.NonRichBoltTracker

execute(Tuple) - Method in class backtype.storm.testing.TestAggregatesCounter

execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.testing.TestConfBolt

execute(Tuple) - Method in class backtype.storm.testing.TestGlobalCount

execute(Tuple) - Method in class backtype.storm.testing.TestPlannerBolt

execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.testing.TestWordCounter

execute(Tuple) - Method in class backtype.storm.testing.TupleCaptureBolt

execute(Tuple) - Method in class backtype.storm.topology.BasicBoltExecutor

execute(Tuple, BasicOutputCollector) - Method in interface backtype.storm.topology.IBasicBolt

execute(Tuple) - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

execute(String, String) - Method in class backtype.storm.utils.DRPCClient

expire(K, V) - Method in interface backtype.storm.utils.TimeCacheMap.ExpiredCallback

F

f1 - Variable in class backtype.storm.testing.TestSerObject

f2 - Variable in class backtype.storm.testing.TestSerObject

fail(Object) - Method in class backtype.storm.clojure.ClojureSpout

fail(Tuple) - Method in class backtype.storm.coordination.BatchOutputCollectorImpl

fail(Tuple) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

fail(Object) - Method in class backtype.storm.drpc.DRPCSpout

fail(Object) - Method in interface backtype.storm.spout.ISpout

The tuple emitted by this spout with the msgId identifier has failed to be fully processed.

fail(Object) - Method in class backtype.storm.spout.ShellSpout

fail(Tuple) - Method in interface backtype.storm.task.IOutputCollector

fail(Tuple) - Method in class backtype.storm.task.OutputCollector

fail(Object) - Method in interface backtype.storm.testing.AckFailDelegate

fail(Object) - Method in class backtype.storm.testing.AckTracker

fail(Object) - Method in class backtype.storm.testing.FeederSpout

fail(Object) - Method in class backtype.storm.testing.FixedTupleSpout

fail(Object) - Method in class backtype.storm.testing.SpoutTracker

fail(Object) - Method in class backtype.storm.testing.TestPlannerSpout

fail(Object) - Method in class backtype.storm.testing.TestWordSpout

fail(Object) - Method in class backtype.storm.topology.base.BaseRichSpout

fail(Object) - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

FailedException - Exception in backtype.storm.topology

FailedException() - Constructor for exception backtype.storm.topology.FailedException

FailedException(String) - Constructor for exception backtype.storm.topology.FailedException

FailedException(String, Throwable) - Constructor for exception backtype.storm.topology.FailedException

FailedException(Throwable) - Constructor for exception backtype.storm.topology.FailedException

failRequest(String) - Method in class backtype.storm.drpc.DRPCInvocationsClient

failVersion(String) - Method in class backtype.storm.utils.VersionedStore

feed(List<Object>) - Method in class backtype.storm.testing.FeederSpout

FeederSpout - Class in backtype.storm.testing

FeederSpout(Fields) - Constructor for class backtype.storm.testing.FeederSpout

fetchRequest(String) - Method in class backtype.storm.drpc.DRPCInvocationsClient

fieldIndex(String) - Method in class backtype.storm.tuple.Fields

fieldIndex(String) - Method in class backtype.storm.tuple.Tuple

Fields - Class in backtype.storm.tuple

Fields(String...) - Constructor for class backtype.storm.tuple.Fields

Fields(List<String>) - Constructor for class backtype.storm.tuple.Fields

fieldsGrouping(Fields) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

fieldsGrouping(String, Fields) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

fieldsGrouping(String, Fields) - Method in interface backtype.storm.topology.InputDeclarer

fieldsGrouping(String, String, Fields) - Method in interface backtype.storm.topology.InputDeclarer

fieldsGrouping(String, Fields) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

fieldsGrouping(String, String, Fields) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

finalize() - Method in class backtype.storm.utils.TimeCacheMap

findAndReadConfigFile(String, boolean) - Static method in class backtype.storm.utils.Utils

findAndReadConfigFile(String) - Static method in class backtype.storm.utils.Utils

finishBatch() - Method in interface backtype.storm.coordination.IBatchBolt

finishBatch() - Method in class backtype.storm.testing.CountingBatchBolt

finishBatch() - Method in class backtype.storm.testing.CountingCommitBolt

finishBatch() - Method in class backtype.storm.testing.KeyedCountingBatchBolt

finishBatch() - Method in class backtype.storm.testing.KeyedSummingBatchBolt

finishedId(Object) - Method in class backtype.storm.clojure.ClojureBolt

finishedId(Object) - Method in class backtype.storm.coordination.BatchBoltExecutor

finishedId(Object) - Method in interface backtype.storm.coordination.CoordinatedBolt.FinishedCallback

finishedId(Object) - Method in class backtype.storm.drpc.KeyedFairBolt

FixedTuple - Class in backtype.storm.testing

FixedTuple(List<Object>) - Constructor for class backtype.storm.testing.FixedTuple

FixedTuple(String, List<Object>) - Constructor for class backtype.storm.testing.FixedTuple

FixedTupleSpout - Class in backtype.storm.testing

FixedTupleSpout(List) - Constructor for class backtype.storm.testing.FixedTupleSpout

G

generateId() - Static method in class backtype.storm.tuple.MessageId

get(int) - Method in class backtype.storm.tuple.Fields

get(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

get(int) - Method in class backtype.storm.utils.ListDelegate

get(Object) - Method in class backtype.storm.utils.LocalState

get(K) - Method in class backtype.storm.utils.TimeCacheMap

get(Map<S, T>, S, T) - Static method in class backtype.storm.utils.Utils

getAllVersions() - Method in class backtype.storm.utils.VersionedStore

Sorted from most recent to oldest

getAnchors() - Method in class backtype.storm.tuple.MessageId

getAnchorsToIds() - Method in class backtype.storm.tuple.MessageId

getAndClearResults() - Method in class backtype.storm.testing.TupleCaptureBolt

getAndRemoveResults() - Method in class backtype.storm.testing.TupleCaptureBolt

getAttemptId() - Method in class backtype.storm.transactional.TransactionAttempt

getBinary(int) - Method in class backtype.storm.tuple.Tuple

Returns the byte array at position i in the tuple.

getBinaryByField(String) - Method in class backtype.storm.tuple.Tuple

getBoolean(int) - Method in class backtype.storm.tuple.Tuple

Returns the Boolean at position i in the tuple.

getBooleanByField(String) - Method in class backtype.storm.tuple.Tuple

getByte(int) - Method in class backtype.storm.tuple.Tuple

Returns the Byte at position i in the tuple.

getByteByField(String) - Method in class backtype.storm.tuple.Tuple

getClient() - Method in class backtype.storm.utils.NimbusClient

getCodeDir() - Method in class backtype.storm.task.TopologyContext

Gets the location of the external resources for this worker on the local filesystem.

getCompleted() - Method in class backtype.storm.testing.FixedTupleSpout

getComponentCommon(String) - Method in class backtype.storm.task.TopologyContext

getComponentCommon(StormTopology, String) - Static method in class backtype.storm.utils.ThriftTopologyUtils

getComponentCommon(StormTopology, String) - Static method in class backtype.storm.utils.Utils

getComponentConfiguration() - Method in class backtype.storm.clojure.ClojureBolt

getComponentConfiguration() - Method in class backtype.storm.clojure.ClojureSpout

getComponentConfiguration() - Method in class backtype.storm.clojure.RichShellBolt

getComponentConfiguration() - Method in class backtype.storm.coordination.BatchBoltExecutor

getComponentConfiguration() - Method in class backtype.storm.coordination.CoordinatedBolt

getComponentConfiguration() - Method in class backtype.storm.drpc.DRPCSpout

getComponentConfiguration() - Method in class backtype.storm.drpc.KeyedFairBolt

getComponentConfiguration() - Method in class backtype.storm.testing.BoltTracker

getComponentConfiguration() - Method in class backtype.storm.testing.FeederSpout

getComponentConfiguration() - Method in class backtype.storm.testing.MemoryTransactionalSpout

getComponentConfiguration() - Method in class backtype.storm.testing.TestConfBolt

getComponentConfiguration() - Method in class backtype.storm.testing.TestPlannerSpout

getComponentConfiguration() - Method in class backtype.storm.testing.TestWordSpout

getComponentConfiguration() - Method in class backtype.storm.testing.TupleCaptureBolt

getComponentConfiguration() - Method in class backtype.storm.topology.base.BaseComponent

getComponentConfiguration() - Method in class backtype.storm.topology.BasicBoltExecutor

getComponentConfiguration() - Method in interface backtype.storm.topology.IComponent

Declare configuration specific to this component.

getComponentConfiguration() - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

getComponentConfiguration() - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

getComponentConfiguration() - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

getComponentConfiguration() - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

getComponentId(int) - Method in class backtype.storm.task.TopologyContext

Gets the component id for the specified task id.

getComponentIds() - Method in class backtype.storm.task.TopologyContext

Gets a list of all component ids in this topology

getComponentIds(StormTopology) - Static method in class backtype.storm.utils.ThriftTopologyUtils

getComponentOutputFields(String, String) - Method in class backtype.storm.task.TopologyContext

Gets the declared output fields for the specified component/stream.

getComponentOutputFields(GlobalStreamId) - Method in class backtype.storm.task.TopologyContext

Gets the declared output fields for the specified global stream id.

getComponentStreams(String) - Method in class backtype.storm.task.TopologyContext

Gets the set of streams declared for the specified component.

getComponentTasks(String) - Method in class backtype.storm.task.TopologyContext

Gets the task ids allocated for the given component id.

getConfiguredClient(Map) - Static method in class backtype.storm.utils.NimbusClient

getCoordinator(Map, TopologyContext) - Method in class backtype.storm.testing.MemoryTransactionalSpout

getCoordinator(Map, TopologyContext) - Method in interface backtype.storm.transactional.ITransactionalSpout

The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit.

getCoordinator(Map, TopologyContext) - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout

getCoordinator(Map, TopologyContext) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

getCoordinator(Map, TopologyContext) - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

getData(String) - Method in class backtype.storm.transactional.state.TransactionalState

getDouble(int) - Method in class backtype.storm.tuple.Tuple

Returns the Double at position i in the tuple.

getDoubleByField(String) - Method in class backtype.storm.tuple.Tuple

getEmitter(Map, TopologyContext) - Method in class backtype.storm.testing.MemoryTransactionalSpout

getEmitter(Map, TopologyContext) - Method in interface backtype.storm.transactional.ICommitterTransactionalSpout

getEmitter(Map, TopologyContext) - Method in interface backtype.storm.transactional.ITransactionalSpout

The emitter for a TransactionalSpout runs as many tasks across the cluster.

getEmitter(Map, TopologyContext) - Method in interface backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout

getEmitter(Map, TopologyContext) - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout

getEmitter(Map, TopologyContext) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

getEmitter(Map, TopologyContext) - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

getFields() - Method in class backtype.storm.tuple.Tuple

Gets the names of the fields in this tuple.

getFieldsDeclaration() - Method in class backtype.storm.topology.OutputFieldsGetter

getFloat(int) - Method in class backtype.storm.tuple.Tuple

Returns the Float at position i in the tuple.

getFloatByField(String) - Method in class backtype.storm.tuple.Tuple

getGlobalStreamId() - Method in class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec

getHost() - Method in class backtype.storm.drpc.DRPCInvocationsClient

getHost() - Method in class backtype.storm.utils.DRPCClient

getInt(Object) - Static method in class backtype.storm.utils.Utils

getInteger(int) - Method in class backtype.storm.tuple.Tuple

Returns the Integer at position i in the tuple.

getIntegerByField(String) - Method in class backtype.storm.tuple.Tuple

getKryo(Map) - Static method in class backtype.storm.serialization.SerializationFactory

getLastState() - Method in class backtype.storm.transactional.state.RotatingTransactionalState

getLong(int) - Method in class backtype.storm.tuple.Tuple

Returns the Long at position i in the tuple.

getLongByField(String) - Method in class backtype.storm.tuple.Tuple

getMap() - Method in class backtype.storm.tuple.Tuple

getMap() - Method in class backtype.storm.utils.IndifferentAccessMap

getMessageId() - Method in class backtype.storm.tuple.Tuple

getNumAcked(String) - Static method in class backtype.storm.testing.FixedTupleSpout

getNumAcks() - Method in class backtype.storm.testing.AckTracker

getNumFailed(String) - Static method in class backtype.storm.testing.FixedTupleSpout

getOutputFields() - Method in class backtype.storm.spout.RawScheme

getOutputFields() - Method in interface backtype.storm.spout.Scheme

getOutputFields() - Method in class backtype.storm.testing.TestGlobalCount

getOutputFields() - Method in class backtype.storm.testing.TestPlannerBolt

getOutputFields() - Method in class backtype.storm.testing.TestPlannerSpout

getOutputter() - Method in class backtype.storm.topology.BasicOutputCollector

getPartitionedSpout() - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

getPIDDir() - Method in class backtype.storm.task.TopologyContext

If this task spawns any subprocesses, those subprocesses must immediately write their PID to this directory on the local filesystem to ensure that Storm properly destroys that process when the worker is shutdown.

getPort() - Method in class backtype.storm.drpc.DRPCInvocationsClient

getPort() - Method in class backtype.storm.utils.DRPCClient

getRawTopology() - Method in class backtype.storm.task.TopologyContext

Gets the Thrift object representing the topology.

getResults() - Method in class backtype.storm.testing.TupleCaptureBolt

getRoot() - Method in class backtype.storm.utils.VersionedStore

getService(String) - Static method in class backtype.storm.utils.ServiceRegistry

getServiceId() - Method in interface backtype.storm.ILocalDRPC

getSetComponentObject(ComponentObject) - Static method in class backtype.storm.utils.Utils

getShort(int) - Method in class backtype.storm.tuple.Tuple

Returns the Short at position i in the tuple.

getShortByField(String) - Method in class backtype.storm.tuple.Tuple

getSourceComponent() - Method in class backtype.storm.tuple.Tuple

Gets the id of the component that created this tuple.

getSourceGlobalStreamid() - Method in class backtype.storm.tuple.Tuple

Returns the global stream id (component + stream) of this tuple.

getSources(String) - Method in class backtype.storm.task.TopologyContext

Gets the declared inputs to the specified component.

getSourceStreamId() - Method in class backtype.storm.tuple.Tuple

Gets the id of the stream that this tuple was emitted to.

getSourceTask() - Method in class backtype.storm.tuple.Tuple

Gets the id of the task that created this tuple.

getSourceTuples() - Method in class backtype.storm.testing.FixedTupleSpout

getSpout() - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

getSpoutDeclarer() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

getState(BigInteger, RotatingTransactionalState.StateInitializer) - Method in class backtype.storm.transactional.state.RotatingTransactionalState

getState(String) - Static method in class backtype.storm.utils.RegisteredGlobalState

getStateOrCreate(BigInteger, RotatingTransactionalState.StateInitializer) - Method in class backtype.storm.transactional.state.RotatingTransactionalState

Returns null if it was created, the value otherwise.

getStormId() - Method in class backtype.storm.task.TopologyContext

Gets the unique id assigned to this topology.

getStreamId(String, String) - Method in class backtype.storm.serialization.SerializationFactory.IdDictionary

getStreamName(String, int) - Method in class backtype.storm.serialization.SerializationFactory.IdDictionary

getString(int) - Method in class backtype.storm.tuple.Tuple

Returns the String at position i in the tuple.

getStringByField(String) - Method in class backtype.storm.tuple.Tuple

getTargets(String) - Method in class backtype.storm.task.TopologyContext

Gets information about who is consuming the outputs of the specified component, and how.

getTaskData() - Method in class backtype.storm.task.TopologyContext

getTaskToComponent() - Method in class backtype.storm.task.TopologyContext

Gets a map from task id to component id.

getThisComponentId() - Method in class backtype.storm.task.TopologyContext

Gets the component id for this task.

getThisOutputFields(String) - Method in class backtype.storm.task.TopologyContext

Gets the declared output fields for the specified stream id for the component this task is a part of.

getThisSources() - Method in class backtype.storm.task.TopologyContext

Gets the declared inputs to this component.

getThisStreams() - Method in class backtype.storm.task.TopologyContext

Gets the set of streams declared for the component of this task.

getThisTargets() - Method in class backtype.storm.task.TopologyContext

Gets information about who is consuming the outputs of this component, and how.

getThisTaskId() - Method in class backtype.storm.task.TopologyContext

Gets the task id of this task.

getThisTaskIndex() - Method in class backtype.storm.task.TopologyContext

Gets the index of this task id in getComponentTasks(getThisComponentId()).

getTransactionId() - Method in class backtype.storm.transactional.TransactionAttempt

getTuple() - Method in class backtype.storm.tuple.Tuple

Deprecated.

getValue(int) - Method in class backtype.storm.tuple.Tuple

Gets the field at position i in the tuple.

getValue() - Method in class backtype.storm.utils.CRC32OutputStream

getValueByField(String) - Method in class backtype.storm.tuple.Tuple

getValues() - Method in class backtype.storm.tuple.Tuple

Gets all the values in this tuple.

getVIntSize(long) - Static method in class backtype.storm.utils.WritableUtils

Get the encoded length if an integer is stored in a variable-length format

globalGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

globalGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

globalGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer

globalGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer

globalGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

globalGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

globalLock() - Static method in class backtype.storm.utils.RegisteredGlobalState

grouping(GlobalStreamId, Grouping) - Method in interface backtype.storm.topology.InputDeclarer

grouping(GlobalStreamId, Grouping) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

H

hashCode() - Method in class backtype.storm.transactional.TransactionAttempt

hashCode() - Method in class backtype.storm.tuple.MessageId

hashCode() - Method in class backtype.storm.tuple.Tuple

I

IBasicBolt - Interface in backtype.storm.topology

IBasicOutputCollector - Interface in backtype.storm.topology

IBatchBolt<T> - Interface in backtype.storm.coordination

IBolt - Interface in backtype.storm.task

An IBolt represents a component that takes tuples as input and produces tuples as output.

ICommitter - Interface in backtype.storm.transactional

This marks an IBatchBolt within a transactional topology as a committer.

ICommitterTransactionalSpout<X> - Interface in backtype.storm.transactional

ICommitterTransactionalSpout.Emitter - Interface in backtype.storm.transactional

IComponent - Interface in backtype.storm.topology

Common methods for all possible components in a topology.

ID_STREAM - Static variable in class backtype.storm.drpc.PrepareRequest

IdentityBolt - Class in backtype.storm.testing

IdentityBolt(Fields) - Constructor for class backtype.storm.testing.IdentityBolt

ILocalCluster - Interface in backtype.storm

ILocalDRPC - Interface in backtype.storm

indexOf(Object) - Method in class backtype.storm.utils.ListDelegate

IndifferentAccessMap - Class in backtype.storm.utils

IndifferentAccessMap() - Constructor for class backtype.storm.utils.IndifferentAccessMap

IndifferentAccessMap(IPersistentMap) - Constructor for class backtype.storm.utils.IndifferentAccessMap

init(BigInteger, Object) - Method in interface backtype.storm.transactional.state.RotatingTransactionalState.StateInitializer

INIT_TXID - Static variable in class backtype.storm.transactional.TransactionalSpoutCoordinator

initializeTransaction(BigInteger, X) - Method in interface backtype.storm.transactional.ITransactionalSpout.Coordinator

Create metadata for this particular transaction id which has never been emitted before.

initializeTransaction(BigInteger, Object) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

InprocMessaging - Class in backtype.storm.utils

InprocMessaging() - Constructor for class backtype.storm.utils.InprocMessaging

InputDeclarer<T extends InputDeclarer> - Interface in backtype.storm.topology

integerDivided(int, int) - Static method in class backtype.storm.utils.Utils

(defn integer-divided [sum num-pieces] (let [base (int (/ sum num-pieces)) num-inc (mod sum num-pieces) num-bases (- num-pieces num-inc)] (if (= num-inc 0) {base num-bases} {base num-bases (inc base) num-inc} )))

invoke(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

invoke(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap

IOpaquePartitionedTransactionalSpout<T> - Interface in backtype.storm.transactional.partitioned

This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.

IOpaquePartitionedTransactionalSpout.Emitter<X> - Interface in backtype.storm.transactional.partitioned

IOutputCollector - Interface in backtype.storm.task

IPartitionedTransactionalSpout<T> - Interface in backtype.storm.transactional.partitioned

This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.

IPartitionedTransactionalSpout.Coordinator - Interface in backtype.storm.transactional.partitioned

IPartitionedTransactionalSpout.Emitter<X> - Interface in backtype.storm.transactional.partitioned

IRichBolt - Interface in backtype.storm.topology

When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology.

IRichSpout - Interface in backtype.storm.topology

When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology.

IRichStateSpout - Interface in backtype.storm.topology

isEmpty() - Method in class backtype.storm.utils.IndifferentAccessMap

isEmpty() - Method in class backtype.storm.utils.ListDelegate

isExhaustedTuples() - Method in class backtype.storm.testing.MemoryTransactionalSpout

isNegativeVInt(byte) - Static method in class backtype.storm.utils.WritableUtils

Given the first byte of a vint/vlong, determine the sign

ISpout - Interface in backtype.storm.spout

ISpout is the core interface for implementing spouts.

ISpoutOutputCollector - Interface in backtype.storm.spout

isSimulating() - Static method in class backtype.storm.utils.Time

isSystemId(String) - Static method in class backtype.storm.utils.Utils

IStateSpout - Interface in backtype.storm.state

IStateSpoutOutputCollector - Interface in backtype.storm.state

isThreadWaiting(Thread) - Static method in class backtype.storm.utils.Time

ISubscribedState - Interface in backtype.storm.state

ISynchronizeOutputCollector - Interface in backtype.storm.state

iterator() - Method in class backtype.storm.tuple.Fields

iterator() - Method in class backtype.storm.utils.IndifferentAccessMap

iterator() - Method in class backtype.storm.utils.ListDelegate

ITransactionalSpout<T> - Interface in backtype.storm.transactional

ITransactionalSpout.Coordinator<X> - Interface in backtype.storm.transactional

ITransactionalSpout.Emitter<X> - Interface in backtype.storm.transactional

ITupleDeserializer - Interface in backtype.storm.serialization

ITupleSerializer - Interface in backtype.storm.serialization

J

JAVA_LIBRARY_PATH - Static variable in class backtype.storm.Config

This value is passed to spawned JVMs (e.g., Nimbus, Supervisor, and Workers) for the java.library.path value.

join(Iterable<T>, String) - Static method in class backtype.storm.utils.Utils

JoinResult - Class in backtype.storm.drpc

JoinResult(String) - Constructor for class backtype.storm.drpc.JoinResult

K

KeyedCountingBatchBolt - Class in backtype.storm.testing

KeyedCountingBatchBolt() - Constructor for class backtype.storm.testing.KeyedCountingBatchBolt

KeyedCountingCommitterBolt - Class in backtype.storm.testing

KeyedCountingCommitterBolt() - Constructor for class backtype.storm.testing.KeyedCountingCommitterBolt

KeyedFairBolt - Class in backtype.storm.drpc

KeyedFairBolt(IRichBolt) - Constructor for class backtype.storm.drpc.KeyedFairBolt

KeyedFairBolt(IBasicBolt) - Constructor for class backtype.storm.drpc.KeyedFairBolt

KeyedRoundRobinQueue<V> - Class in backtype.storm.utils

KeyedRoundRobinQueue() - Constructor for class backtype.storm.utils.KeyedRoundRobinQueue

KeyedSummingBatchBolt - Class in backtype.storm.testing

KeyedSummingBatchBolt() - Constructor for class backtype.storm.testing.KeyedSummingBatchBolt

keySet() - Method in class backtype.storm.utils.IndifferentAccessMap

killTopology(String) - Method in interface backtype.storm.ILocalCluster

KryoTupleDeserializer - Class in backtype.storm.serialization

KryoTupleDeserializer(Map, TopologyContext) - Constructor for class backtype.storm.serialization.KryoTupleDeserializer

KryoTupleDeserializer.Worker - Class in backtype.storm.serialization

KryoTupleDeserializer.Worker(Map, TopologyContext) - Constructor for class backtype.storm.serialization.KryoTupleDeserializer.Worker

KryoTupleSerializer - Class in backtype.storm.serialization

KryoTupleSerializer(Map, TopologyContext) - Constructor for class backtype.storm.serialization.KryoTupleSerializer

KryoValuesDeserializer - Class in backtype.storm.serialization

KryoValuesDeserializer(Map) - Constructor for class backtype.storm.serialization.KryoValuesDeserializer

KryoValuesSerializer - Class in backtype.storm.serialization

KryoValuesSerializer(Map) - Constructor for class backtype.storm.serialization.KryoValuesSerializer

L

lastIndexOf(Object) - Method in class backtype.storm.utils.ListDelegate

LinearDRPCInputDeclarer - Interface in backtype.storm.drpc

LinearDRPCTopologyBuilder - Class in backtype.storm.drpc

LinearDRPCTopologyBuilder(String) - Constructor for class backtype.storm.drpc.LinearDRPCTopologyBuilder

list(String) - Method in class backtype.storm.transactional.state.TransactionalState

ListDelegate - Class in backtype.storm.utils

ListDelegate() - Constructor for class backtype.storm.utils.ListDelegate

listIterator() - Method in class backtype.storm.utils.ListDelegate

listIterator(int) - Method in class backtype.storm.utils.ListDelegate

loadClojureFn(String, String) - Static method in class backtype.storm.utils.Utils

LocalState - Class in backtype.storm.utils

A simple, durable, atomic K/V database.

LocalState(String) - Constructor for class backtype.storm.utils.LocalState

LOG - Static variable in class backtype.storm.coordination.BatchBoltExecutor

LOG - Static variable in class backtype.storm.coordination.CoordinatedBolt

LOG - Static variable in class backtype.storm.drpc.DRPCSpout

LOG - Static variable in class backtype.storm.drpc.JoinResult

LOG - Static variable in class backtype.storm.drpc.ReturnResults

LOG - Static variable in class backtype.storm.serialization.SerializationFactory

LOG - Static variable in class backtype.storm.StormSubmitter

LOG - Static variable in class backtype.storm.task.ShellBolt

LOG - Static variable in class backtype.storm.testing.TestAggregatesCounter

LOG - Static variable in class backtype.storm.testing.TestGlobalCount

LOG - Static variable in class backtype.storm.testing.TestWordCounter

LOG - Static variable in class backtype.storm.testing.TestWordSpout

LOG - Static variable in class backtype.storm.topology.BasicBoltExecutor

LOG - Static variable in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

LOG - Static variable in class backtype.storm.transactional.TransactionalSpoutCoordinator

LOG - Static variable in class backtype.storm.utils.Time

M

makeDetectSpec(String, String) - Static method in class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec

makeId(Map<Long, Long>) - Static method in class backtype.storm.tuple.MessageId

makeResource() - Method in interface backtype.storm.utils.ThreadResourceManager.ResourceFactory

makeRootId(long, long) - Static method in class backtype.storm.tuple.MessageId

makeUnanchored() - Static method in class backtype.storm.tuple.MessageId

maxTopologyMessageTimeout(Map<String, Object>) - Method in class backtype.storm.task.TopologyContext

MemoryTransactionalSpout - Class in backtype.storm.testing

This spout only works in local mode.

MemoryTransactionalSpout(Map<Integer, List<List<Object>>>, Fields, int) - Constructor for class backtype.storm.testing.MemoryTransactionalSpout

MemoryTransactionalSpoutMeta - Class in backtype.storm.testing

MemoryTransactionalSpoutMeta() - Constructor for class backtype.storm.testing.MemoryTransactionalSpoutMeta

MemoryTransactionalSpoutMeta(int, int) - Constructor for class backtype.storm.testing.MemoryTransactionalSpoutMeta

MessageId - Class in backtype.storm.tuple

MessageId(Map<Long, Long>) - Constructor for class backtype.storm.tuple.MessageId

meta() - Method in class backtype.storm.tuple.Tuple

mkdir(String) - Method in class backtype.storm.transactional.state.TransactionalState

mostRecentVersion() - Method in class backtype.storm.utils.VersionedStore

mostRecentVersion(long) - Method in class backtype.storm.utils.VersionedStore

mostRecentVersionPath() - Method in class backtype.storm.utils.VersionedStore

mostRecentVersionPath(long) - Method in class backtype.storm.utils.VersionedStore

N

newCoordinatorState(Map, String, Map) - Static method in class backtype.storm.transactional.state.TransactionalState

newCurator(Map, List<String>, Object, String) - Static method in class backtype.storm.utils.Utils

newCurator(Map, List<String>, Object) - Static method in class backtype.storm.utils.Utils

newCuratorStarted(Map, List<String>, Object, String) - Static method in class backtype.storm.utils.Utils

newCuratorStarted(Map, List<String>, Object) - Static method in class backtype.storm.utils.Utils

newDefaultSerializer(Class) - Method in class backtype.storm.serialization.SerializationFactory.KryoSerializableDefault

newUserState(Map, String, Map) - Static method in class backtype.storm.transactional.state.TransactionalState

nextTuple() - Method in class backtype.storm.clojure.ClojureSpout

nextTuple() - Method in class backtype.storm.drpc.DRPCSpout

nextTuple() - Method in interface backtype.storm.spout.ISpout

When this method is called, Storm is requesting that the Spout emit tuples to the output collector.

nextTuple() - Method in class backtype.storm.spout.ShellSpout

nextTuple(StateSpoutOutputCollector) - Method in interface backtype.storm.state.IStateSpout

nextTuple() - Method in class backtype.storm.testing.FeederSpout

nextTuple() - Method in class backtype.storm.testing.FixedTupleSpout

nextTuple() - Method in class backtype.storm.testing.SpoutTracker

nextTuple() - Method in class backtype.storm.testing.TestPlannerSpout

nextTuple() - Method in class backtype.storm.testing.TestWordSpout

nextTuple() - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

NGrouping - Class in backtype.storm.testing

NGrouping(int) - Constructor for class backtype.storm.testing.NGrouping

NIMBUS_CHILDOPTS - Static variable in class backtype.storm.Config

This parameter is used by the storm-deploy project to configure the jvm options for the nimbus daemon.

NIMBUS_CLEANUP_INBOX_FREQ_SECS - Static variable in class backtype.storm.Config

How often nimbus should wake the cleanup thread to clean the inbox.

NIMBUS_FILE_COPY_EXPIRATION_SECS - Static variable in class backtype.storm.Config

During upload/download with the master, how long an upload or download connection is idle before nimbus considers it dead and drops the connection.

NIMBUS_HOST - Static variable in class backtype.storm.Config

The host that the master server is running on.

NIMBUS_INBOX_JAR_EXPIRATION_SECS - Static variable in class backtype.storm.Config

The length of time a jar file lives in the inbox before being deleted by the cleanup thread.

NIMBUS_MONITOR_FREQ_SECS - Static variable in class backtype.storm.Config

How often nimbus should wake up to check heartbeats and do reassignments.

NIMBUS_REASSIGN - Static variable in class backtype.storm.Config

Whether or not nimbus should reassign tasks if it detects that a task goes down.

NIMBUS_SUPERVISOR_TIMEOUT_SECS - Static variable in class backtype.storm.Config

How long before a supervisor can go without heartbeating before nimbus considers it dead and stops assigning new work to it.

NIMBUS_TASK_LAUNCH_SECS - Static variable in class backtype.storm.Config

A special timeout used when a task is initially launched.

NIMBUS_TASK_TIMEOUT_SECS - Static variable in class backtype.storm.Config

How long without heartbeating a task can go before nimbus will consider the task dead and reassign it to another location.

NIMBUS_THRIFT_PORT - Static variable in class backtype.storm.Config

Which port the Thrift interface of Nimbus should run on.

NimbusClient - Class in backtype.storm.utils

NimbusClient(String) - Constructor for class backtype.storm.utils.NimbusClient

NimbusClient(String, int) - Constructor for class backtype.storm.utils.NimbusClient

noneGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

noneGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

noneGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer

noneGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer

noneGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

noneGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

NonRichBoltTracker - Class in backtype.storm.testing

NonRichBoltTracker(IBolt, String) - Constructor for class backtype.storm.testing.NonRichBoltTracker

nth(int) - Method in class backtype.storm.tuple.Tuple

nth(int, Object) - Method in class backtype.storm.tuple.Tuple

numPartitions() - Method in interface backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Emitter

numPartitions() - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Coordinator

Return the number of partitions currently in the source of data.

O

object - Variable in class backtype.storm.utils.Container

OpaquePartitionedTransactionalSpoutExecutor - Class in backtype.storm.transactional.partitioned

OpaquePartitionedTransactionalSpoutExecutor(IOpaquePartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor

OpaquePartitionedTransactionalSpoutExecutor.Coordinator - Class in backtype.storm.transactional.partitioned

OpaquePartitionedTransactionalSpoutExecutor.Coordinator() - Constructor for class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

OpaquePartitionedTransactionalSpoutExecutor.Emitter - Class in backtype.storm.transactional.partitioned

OpaquePartitionedTransactionalSpoutExecutor.Emitter(Map, TopologyContext) - Constructor for class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.clojure.ClojureSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.drpc.DRPCSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in interface backtype.storm.spout.ISpout

Called when a task for this component is initialized within a worker on the cluster.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.spout.ShellSpout

open(Map, TopologyContext) - Method in interface backtype.storm.state.IStateSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.testing.FeederSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.testing.FixedTupleSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.testing.SpoutTracker

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.testing.TestPlannerSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.testing.TestWordSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator

OutputCollector - Class in backtype.storm.task

This output collector exposes the API for emitting tuples from an IRichBolt.

OutputCollector(IOutputCollector) - Constructor for class backtype.storm.task.OutputCollector

OutputFieldsDeclarer - Interface in backtype.storm.topology

OutputFieldsGetter - Class in backtype.storm.topology

OutputFieldsGetter() - Constructor for class backtype.storm.topology.OutputFieldsGetter

overrideDefault(boolean) - Method in class backtype.storm.serialization.SerializationFactory.KryoSerializableDefault

overrideState(BigInteger, Object) - Method in class backtype.storm.transactional.state.RotatingTransactionalState

P

PartitionedTransactionalSpoutExecutor - Class in backtype.storm.transactional.partitioned

PartitionedTransactionalSpoutExecutor(IPartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor

pollMessage(int) - Static method in class backtype.storm.utils.InprocMessaging

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.clojure.ClojureBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.coordination.BatchBoltExecutor

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.coordination.CoordinatedBolt

prepare(Map, TopologyContext, BatchOutputCollector, T) - Method in interface backtype.storm.coordination.IBatchBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.drpc.JoinResult

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.drpc.KeyedFairBolt

prepare(Map, TopologyContext) - Method in class backtype.storm.drpc.PrepareRequest

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.drpc.ReturnResults

prepare(Fields, int) - Method in interface backtype.storm.grouping.CustomStreamGrouping

Tells the stream grouping at runtime the number of tasks in the target bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in interface backtype.storm.task.IBolt

Called when a task for this component is initialized within a worker on the cluster.

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.task.ShellBolt

prepare(Map, TopologyContext, BatchOutputCollector, Object) - Method in class backtype.storm.testing.CountingBatchBolt

prepare(Map, TopologyContext, BatchOutputCollector, TransactionAttempt) - Method in class backtype.storm.testing.CountingCommitBolt

prepare(Map, TopologyContext, BatchOutputCollector, Object) - Method in class backtype.storm.testing.KeyedCountingBatchBolt

prepare(Map, TopologyContext, BatchOutputCollector, Object) - Method in class backtype.storm.testing.KeyedSummingBatchBolt

prepare(Fields, int) - Method in class backtype.storm.testing.NGrouping

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.testing.NonRichBoltTracker

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.testing.TestAggregatesCounter

prepare(Map, TopologyContext) - Method in class backtype.storm.testing.TestConfBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.testing.TestGlobalCount

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.testing.TestPlannerBolt

prepare(Map, TopologyContext) - Method in class backtype.storm.testing.TestWordCounter

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.testing.TupleCaptureBolt

prepare(Map, TopologyContext) - Method in class backtype.storm.topology.base.BaseBasicBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.topology.BasicBoltExecutor

prepare(Map, TopologyContext) - Method in interface backtype.storm.topology.IBasicBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor

PrepareRequest - Class in backtype.storm.drpc

PrepareRequest() - Constructor for class backtype.storm.drpc.PrepareRequest

put(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap

put(Object, Object) - Method in class backtype.storm.utils.LocalState

put(K, V) - Method in class backtype.storm.utils.TimeCacheMap

putAll(Map) - Method in class backtype.storm.utils.IndifferentAccessMap

R

randomLong() - Static method in class backtype.storm.utils.Utils

RawScheme - Class in backtype.storm.spout

RawScheme() - Constructor for class backtype.storm.spout.RawScheme

read() - Method in class backtype.storm.utils.BufferFileInputStream

readCompressedByteArray(DataInput) - Static method in class backtype.storm.utils.WritableUtils

readCompressedString(DataInput) - Static method in class backtype.storm.utils.WritableUtils

readCompressedStringArray(DataInput) - Static method in class backtype.storm.utils.WritableUtils

readDefaultConfig() - Static method in class backtype.storm.utils.Utils

readStormConfig() - Static method in class backtype.storm.utils.Utils

readString(DataInput) - Static method in class backtype.storm.utils.WritableUtils

readStringArray(DataInput) - Static method in class backtype.storm.utils.WritableUtils

readVInt(DataInput) - Static method in class backtype.storm.utils.WritableUtils

Reads a zero-compressed encoded integer from input stream and returns it.

readVLong(DataInput) - Static method in class backtype.storm.utils.WritableUtils

Reads a zero-compressed encoded long from input stream and returns it.

RegisteredGlobalState - Class in backtype.storm.utils

This class is used as part of testing Storm.

RegisteredGlobalState() - Constructor for class backtype.storm.utils.RegisteredGlobalState

registerSerialization(Class) - Method in class backtype.storm.Config

registerSerialization(Class, Class<? extends Serializer>) - Method in class backtype.storm.Config

registerService(Object) - Static method in class backtype.storm.utils.ServiceRegistry

registerState(Object) - Static method in class backtype.storm.utils.RegisteredGlobalState

release(T) - Method in class backtype.storm.utils.ThreadResourceManager

remove(int, Object) - Method in interface backtype.storm.state.IStateSpoutOutputCollector

remove(Object) - Method in interface backtype.storm.state.ISubscribedState

remove(int, Object) - Method in class backtype.storm.state.StateSpoutOutputCollector

remove(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

remove(Object) - Method in class backtype.storm.utils.ListDelegate

remove(int) - Method in class backtype.storm.utils.ListDelegate

remove(K) - Method in class backtype.storm.utils.TimeCacheMap

removeAll(Collection<?>) - Method in class backtype.storm.utils.ListDelegate

removeState(BigInteger) - Method in class backtype.storm.transactional.state.RotatingTransactionalState

reportError(Throwable) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

reportError(Throwable) - Method in interface backtype.storm.task.IOutputCollector

reportError(Throwable) - Method in class backtype.storm.task.OutputCollector

resetNumAcks() - Method in class backtype.storm.testing.AckTracker

result(String, String) - Method in class backtype.storm.drpc.DRPCInvocationsClient

retainAll(Collection<?>) - Method in class backtype.storm.utils.ListDelegate

RETURN_STREAM - Static variable in class backtype.storm.drpc.PrepareRequest

ReturnResults - Class in backtype.storm.drpc

ReturnResults() - Constructor for class backtype.storm.drpc.ReturnResults

reverseMap(Map<K, V>) - Static method in class backtype.storm.utils.Utils

RichShellBolt - Class in backtype.storm.clojure

RichShellBolt(String, String, Map<String, StreamInfo>) - Constructor for class backtype.storm.clojure.RichShellBolt

RotatingTransactionalState - Class in backtype.storm.transactional.state

A map from txid to a value.

RotatingTransactionalState(TransactionalState, String, boolean) - Constructor for class backtype.storm.transactional.state.RotatingTransactionalState

RotatingTransactionalState(TransactionalState, String) - Constructor for class backtype.storm.transactional.state.RotatingTransactionalState

RotatingTransactionalState.StateInitializer - Interface in backtype.storm.transactional.state

run() - Method in class backtype.storm.utils.ClojureTimerTask

S

Scheme - Interface in backtype.storm.spout

select(Fields, List<Object>) - Method in class backtype.storm.tuple.Fields

select(Fields) - Method in class backtype.storm.tuple.Tuple

Returns a subset of the tuple based on the fields selector.

sendMessage(int, Object) - Static method in class backtype.storm.utils.InprocMessaging

seq() - Method in class backtype.storm.tuple.Tuple

seq() - Method in class backtype.storm.utils.IndifferentAccessMap

SerializationFactory - Class in backtype.storm.serialization

SerializationFactory() - Constructor for class backtype.storm.serialization.SerializationFactory

SerializationFactory.IdDictionary - Class in backtype.storm.serialization

SerializationFactory.IdDictionary(StormTopology) - Constructor for class backtype.storm.serialization.SerializationFactory.IdDictionary

SerializationFactory.KryoSerializableDefault - Class in backtype.storm.serialization

SerializationFactory.KryoSerializableDefault() - Constructor for class backtype.storm.serialization.SerializationFactory.KryoSerializableDefault

serialize(Tuple) - Method in interface backtype.storm.serialization.ITupleSerializer

serialize(Tuple) - Method in class backtype.storm.serialization.KryoTupleSerializer

serialize(List<Object>) - Method in class backtype.storm.serialization.KryoValuesSerializer

serialize(DataOutputStream) - Method in class backtype.storm.tuple.MessageId

serialize(Object) - Static method in class backtype.storm.utils.Utils

serializeInto(List<Object>, OutputStream) - Method in class backtype.storm.serialization.KryoValuesSerializer

serializeObject(Object) - Method in class backtype.storm.serialization.KryoValuesSerializer

ServiceRegistry - Class in backtype.storm.utils

ServiceRegistry() - Constructor for class backtype.storm.utils.ServiceRegistry

set(Object, Tuple) - Method in interface backtype.storm.state.ISubscribedState

set(int, Object) - Method in class backtype.storm.utils.ListDelegate

setAckFailDelegate(AckFailDelegate) - Method in class backtype.storm.testing.FeederSpout

setAllSubscribedState(T) - Method in class backtype.storm.task.TopologyContext

All state from all subscribed state spouts streams will be synced with the provided object.

setBolt(String, IRichBolt) - Method in class backtype.storm.topology.TopologyBuilder

Define a new bolt in this topology with parallelism of just one thread.

setBolt(String, IRichBolt, Integer) - Method in class backtype.storm.topology.TopologyBuilder

Define a new bolt in this topology with the specified amount of parallelism.

setBolt(String, IBasicBolt) - Method in class backtype.storm.topology.TopologyBuilder

Define a new bolt in this topology.

setBolt(String, IBasicBolt, Integer) - Method in class backtype.storm.topology.TopologyBuilder

Define a new bolt in this topology.

setBolt(String, IBatchBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setBolt(String, IBatchBolt, Integer) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setBolt(String, IBasicBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setBolt(String, IBasicBolt, Integer) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setCommitterBolt(String, IBatchBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setCommitterBolt(String, IBatchBolt, Integer) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder

setContext(Tuple) - Method in class backtype.storm.topology.BasicOutputCollector

setData(String, Object) - Method in class backtype.storm.transactional.state.TransactionalState

setDebug(boolean) - Method in class backtype.storm.Config

setDebug(boolean) - Method in class backtype.storm.topology.BaseConfigurationDeclarer

setDebug(boolean) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer

setDelegate(List<Object>) - Method in class backtype.storm.utils.ListDelegate

setFallBackOnJavaSerialization(boolean) - Method in class backtype.storm.Config

setLocalNimbus(Nimbus.Iface) - Static method in class backtype.storm.StormSubmitter

setMap(IPersistentMap) - Method in class backtype.storm.utils.IndifferentAccessMap

setMaxSpoutPending(int) - Method in class backtype.storm.Config

setMaxSpoutPending(Integer) - Method in class backtype.storm.topology.BaseConfigurationDeclarer

setMaxSpoutPending(Integer) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer

setMaxTaskParallelism(int) - Method in class backtype.storm.Config

setMaxTaskParallelism(Integer) - Method in class backtype.storm.topology.BaseConfigurationDeclarer

setMaxTaskParallelism(Integer) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer

setMessageTimeoutSecs(int) - Method in class backtype.storm.Config

setNumAckers(int) - Method in class backtype.storm.Config

setNumWorkers(int) - Method in class backtype.storm.Config

setOptimize(boolean) - Method in class backtype.storm.Config

setSkipMissingKryoRegistrations(boolean) - Method in class backtype.storm.Config

setSpout(String, IRichSpout) - Method in class backtype.storm.topology.TopologyBuilder

Define a new spout in this topology.

setSpout(String, IRichSpout, Integer) - Method in class backtype.storm.topology.TopologyBuilder

Define a new spout in this topology with the specified parallelism.

setState(String, Object) - Static method in class backtype.storm.utils.RegisteredGlobalState

setStateSpout(String, IRichStateSpout) - Method in class backtype.storm.topology.TopologyBuilder

setStateSpout(String, IRichStateSpout, Integer) - Method in class backtype.storm.topology.TopologyBuilder

setStatsSampleRate(double) - Method in class backtype.storm.Config

setSubscribedState(String, T) - Method in class backtype.storm.task.TopologyContext

Synchronizes the default stream from the specified state spout component id with the provided ISubscribedState object.

setSubscribedState(String, String, T) - Method in class backtype.storm.task.TopologyContext

Synchronizes the specified stream from the specified state spout component id with the provided ISubscribedState object.

setTaskData(Object) - Method in class backtype.storm.task.TopologyContext

ShellBolt - Class in backtype.storm.task

A bolt that shells out to another process to process tuples.

ShellBolt(ShellComponent) - Constructor for class backtype.storm.task.ShellBolt

ShellSpout - Class in backtype.storm.spout

ShellSpout(ShellComponent) - Constructor for class backtype.storm.spout.ShellSpout

ShellSpout(String, String) - Constructor for class backtype.storm.spout.ShellSpout

shuffleGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

shuffleGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer

shuffleGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer

shuffleGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer

shuffleGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

shuffleGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter

shutdown() - Method in interface backtype.storm.daemon.Shutdownable

shutdown() - Method in interface backtype.storm.ILocalCluster

Shutdownable - Interface in backtype.storm.daemon

single() - Static method in class backtype.storm.coordination.CoordinatedBolt.SourceArgs

singleCount - Variable in class backtype.storm.coordination.CoordinatedBolt.SourceArgs

size() - Method in class backtype.storm.tuple.Fields

size() - Method in class backtype.storm.tuple.Tuple

Returns the number of fields in this tuple.

size() - Method in class backtype.storm.utils.IndifferentAccessMap

size() - Method in class backtype.storm.utils.ListDelegate

size() - Method in class backtype.storm.utils.TimeCacheMap

skipCompressedByteArray(DataInput) - Static method in class backtype.storm.utils.WritableUtils

skipFully(DataInput, int) - Static method in class backtype.storm.utils.WritableUtils

Skip len number of bytes in input streamin

sleep(long) - Static method in class backtype.storm.utils.Time

sleep(long) - Static method in class backtype.storm.utils.Utils

sleepUntil(long) - Static method in class backtype.storm.utils.Time

snapshot() - Method in class backtype.storm.utils.LocalState

SpoutDeclarer - Interface in backtype.storm.topology

SpoutOutputCollector - Class in backtype.storm.spout

This output collector exposes the API for emitting tuples from an IRichSpout.

SpoutOutputCollector(ISpoutOutputCollector) - Constructor for class backtype.storm.spout.SpoutOutputCollector

SpoutTracker - Class in backtype.storm.testing

SpoutTracker(IRichSpout, String) - Constructor for class backtype.storm.testing.SpoutTracker

startSimulating() - Static method in class backtype.storm.utils.Time

startup() - Method in class backtype.storm.testing.MemoryTransactionalSpout

StateSpoutOutputCollector - Class in backtype.storm.state

StateSpoutOutputCollector() - Constructor for class backtype.storm.state.StateSpoutOutputCollector

stopSimulating() - Static method in class backtype.storm.utils.Time

STORM_CLUSTER_MODE - Static variable in class backtype.storm.Config

The mode this Storm cluster is running in.

STORM_ID - Static variable in class backtype.storm.Config

The id assigned to a running topology.

STORM_LOCAL_DIR - Static variable in class backtype.storm.Config

A directory on the local filesystem used by Storm for any local filesystem usage it needs.

STORM_LOCAL_MODE_ZMQ - Static variable in class backtype.storm.Config

Whether or not to use ZeroMQ for messaging in local mode.

STORM_ZOOKEEPER_PORT - Static variable in class backtype.storm.Config

The port Storm will use to connect to each of the ZooKeeper servers.

STORM_ZOOKEEPER_RETRY_INTERVAL - Static variable in class backtype.storm.Config

The interval between retries of a Zookeeper operation.

STORM_ZOOKEEPER_RETRY_TIMES - Static variable in class backtype.storm.Config

The number of times to retry a Zookeeper operation.

STORM_ZOOKEEPER_ROOT - Static variable in class backtype.storm.Config

The root location at which Storm stores data in ZooKeeper.

STORM_ZOOKEEPER_SERVERS - Static variable in class backtype.storm.Config

A list of hosts of ZooKeeper servers used to manage the cluster.

STORM_ZOOKEEPER_SESSION_TIMEOUT - Static variable in class backtype.storm.Config

The timeout for clients to ZooKeeper.

StormSubmitter - Class in backtype.storm

Use this class to submit topologies to run on the Storm cluster.

StormSubmitter() - Constructor for class backtype.storm.StormSubmitter

stream - Variable in class backtype.storm.testing.FixedTuple

subList(int, int) - Method in class backtype.storm.utils.ListDelegate

submitJar(Map, String) - Static method in class backtype.storm.StormSubmitter

submitTopology(String, Map, StormTopology) - Method in interface backtype.storm.ILocalCluster

submitTopology(String, Map, StormTopology) - Static method in class backtype.storm.StormSubmitter

Submits a topology to run on the cluster.

succeedVersion(String) - Method in class backtype.storm.utils.VersionedStore

SUPERVISOR_CHILDOPTS - Static variable in class backtype.storm.Config

This parameter is used by the storm-deploy project to configure the jvm options for the supervisor daemon.

SUPERVISOR_ENABLE - Static variable in class backtype.storm.Config

Whether or not the supervisor should launch workers assigned to it.

SUPERVISOR_HEARTBEAT_FREQUENCY_SECS - Static variable in class backtype.storm.Config

how often the supervisor sends a heartbeat to the master.

SUPERVISOR_MONITOR_FREQUENCY_SECS - Static variable in class backtype.storm.Config

How often the supervisor checks the worker heartbeats to see if any of them need to be restarted.

SUPERVISOR_SLOTS_PORTS - Static variable in class backtype.storm.Config

A list of ports that can run workers on this supervisor.

SUPERVISOR_WORKER_START_TIMEOUT_SECS - Static variable in class backtype.storm.Config

How long a worker can go without heartbeating during the initial launch before the supervisor tries to restart the worker process.

SUPERVISOR_WORKER_TIMEOUT_SECS - Static variable in class backtype.storm.Config

How long a worker can go without heartbeating before the supervisor tries to restart the worker process.

synchronize(SynchronizeOutputCollector) - Method in interface backtype.storm.state.IStateSpout

SynchronizeOutputCollector - Class in backtype.storm.state

SynchronizeOutputCollector() - Constructor for class backtype.storm.state.SynchronizeOutputCollector

T

take() - Method in class backtype.storm.utils.KeyedRoundRobinQueue

takeMessage(int) - Static method in class backtype.storm.utils.InprocMessaging

task - Variable in class backtype.storm.planner.TaskBundle

TASK_HEARTBEAT_FREQUENCY_SECS - Static variable in class backtype.storm.Config

How often a task should heartbeat its status to the master.

TASK_REFRESH_POLL_SECS - Static variable in class backtype.storm.Config

How often a task should sync its connections with other tasks (if a task is reassigned, the other tasks sending messages to it need to refresh their connections).

TaskBundle - Class in backtype.storm.planner

TaskBundle(IBolt, int) - Constructor for class backtype.storm.planner.TaskBundle

taskIndices(List<Object>) - Method in interface backtype.storm.grouping.CustomStreamGrouping

This function implements a custom stream grouping.

taskIndices(List<Object>) - Method in class backtype.storm.testing.NGrouping

TestAggregatesCounter - Class in backtype.storm.testing

TestAggregatesCounter() - Constructor for class backtype.storm.testing.TestAggregatesCounter

TestConfBolt - Class in backtype.storm.testing

TestConfBolt() - Constructor for class backtype.storm.testing.TestConfBolt

TestConfBolt(Map<String, Object>) - Constructor for class backtype.storm.testing.TestConfBolt

TestGlobalCount - Class in backtype.storm.testing

TestGlobalCount() - Constructor for class backtype.storm.testing.TestGlobalCount

TestPlannerBolt - Class in backtype.storm.testing

TestPlannerBolt() - Constructor for class backtype.storm.testing.TestPlannerBolt

TestPlannerSpout - Class in backtype.storm.testing

TestPlannerSpout(Fields, boolean) - Constructor for class backtype.storm.testing.TestPlannerSpout

TestPlannerSpout(boolean) - Constructor for class backtype.storm.testing.TestPlannerSpout

TestPlannerSpout(Fields) - Constructor for class backtype.storm.testing.TestPlannerSpout

TestSerObject - Class in backtype.storm.testing

TestSerObject(int, int) - Constructor for class backtype.storm.testing.TestSerObject

TestWordCounter - Class in backtype.storm.testing

TestWordCounter() - Constructor for class backtype.storm.testing.TestWordCounter

TestWordSpout - Class in backtype.storm.testing

TestWordSpout() - Constructor for class backtype.storm.testing.TestWordSpout

TestWordSpout(boolean) - Constructor for class backtype.storm.testing.TestWordSpout

ThreadResourceManager<T> - Class in backtype.storm.utils

ThreadResourceManager(ThreadResourceManager.ResourceFactory<T>) - Constructor for class backtype.storm.utils.ThreadResourceManager

ThreadResourceManager.ResourceFactory<X> - Interface in backtype.storm.utils

ThriftTopologyUtils - Class in backtype.storm.utils

ThriftTopologyUtils() - Constructor for class backtype.storm.utils.ThriftTopologyUtils

Time - Class in backtype.storm.utils

Time() - Constructor for class backtype.storm.utils.Time

TimeCacheMap<K,V> - Class in backtype.storm.utils

Expires keys that have not been updated in the configured number of seconds.

TimeCacheMap(int, int, TimeCacheMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.TimeCacheMap

TimeCacheMap(int, TimeCacheMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.TimeCacheMap

TimeCacheMap(int) - Constructor for class backtype.storm.utils.TimeCacheMap

TimeCacheMap(int, int) - Constructor for class backtype.storm.utils.TimeCacheMap

TimeCacheMap.ExpiredCallback<K,V> - Interface in backtype.storm.utils

timeoutId(Object) - Method in class backtype.storm.coordination.BatchBoltExecutor

timeoutId(Object) - Method in interface backtype.storm.coordination.CoordinatedBolt.TimeoutCallback

toArray() - Method in class backtype.storm.utils.ListDelegate

toArray(T[]) - Method in class backtype.storm.utils.ListDelegate

toByteArray(ByteBuffer) - Static method in class backtype.storm.utils.Utils

toJSONString() - Method in class backtype.storm.task.TopologyContext

toList() - Method in class backtype.storm.tuple.Fields

TOPOLOGY_ACKERS - Static variable in class backtype.storm.Config

How many acker tasks should be spawned for the topology.

TOPOLOGY_DEBUG - Static variable in class backtype.storm.Config

When set to true, Storm will log every message that's emitted.

TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION - Static variable in class backtype.storm.Config

Whether or not to use Java serialization in a topology.

TOPOLOGY_KRYO_REGISTER - Static variable in class backtype.storm.Config

A list of serialization registrations for Kryo ( http://code.google.com/p/kryo/ ), the underlying serialization framework for Storm.

TOPOLOGY_MAX_SPOUT_PENDING - Static variable in class backtype.storm.Config

The maximum number of tuples that can be pending on a spout task at any given time.

TOPOLOGY_MAX_TASK_PARALLELISM - Static variable in class backtype.storm.Config

The maximum parallelism allowed for a component in this topology.

TOPOLOGY_MESSAGE_TIMEOUT_SECS - Static variable in class backtype.storm.Config

The maximum amount of time given to the topology to fully process a message emitted by a spout.

TOPOLOGY_OPTIMIZE - Static variable in class backtype.storm.Config

Whether or not the master should optimize topologies by running multiple tasks in a single thread where appropriate.

TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS - Static variable in class backtype.storm.Config

Whether or not Storm should skip the loading of kryo registrations for which it does not know the class or have the serializer implementation.

TOPOLOGY_STATE_SYNCHRONIZATION_TIMEOUT_SECS - Static variable in class backtype.storm.Config

The maximum amount of time a component gives a source of state to synchronize before it requests synchronization again.

TOPOLOGY_STATS_SAMPLE_RATE - Static variable in class backtype.storm.Config

The percentage of tuples to sample to produce stats for a task.

TOPOLOGY_TRANSACTIONAL_ID - Static variable in class backtype.storm.Config

This config is available for TransactionalSpouts, and contains the id ( a String) for the transactional topology.

TOPOLOGY_WORKER_CHILDOPTS - Static variable in class backtype.storm.Config

Topology-specific options for the worker child process.

TOPOLOGY_WORKERS - Static variable in class backtype.storm.Config

How many processes should be spawned around the cluster to execute this topology.

TopologyBuilder - Class in backtype.storm.topology

TopologyBuilder exposes the Java API for specifying a topology for Storm to execute.

TopologyBuilder() - Constructor for class backtype.storm.topology.TopologyBuilder

TopologyBuilder.BoltGetter - Class in backtype.storm.topology

TopologyBuilder.BoltGetter(String) - Constructor for class backtype.storm.topology.TopologyBuilder.BoltGetter

TopologyBuilder.ConfigGetter<T extends ComponentConfigurationDeclarer> - Class in backtype.storm.topology

TopologyBuilder.ConfigGetter(String) - Constructor for class backtype.storm.topology.TopologyBuilder.ConfigGetter

TopologyBuilder.SpoutGetter - Class in backtype.storm.topology

TopologyBuilder.SpoutGetter(String) - Constructor for class backtype.storm.topology.TopologyBuilder.SpoutGetter

TopologyContext - Class in backtype.storm.task

A TopologyContext is given to bolts and spouts in their "prepare" and "open" methods, respectively.

TopologyContext(StormTopology, Map<Integer, String>, String, String, String, Integer) - Constructor for class backtype.storm.task.TopologyContext

toString() - Method in class backtype.storm.coordination.CoordinatedBolt.SourceArgs

toString() - Method in class backtype.storm.coordination.CoordinatedBolt.TrackingInfo

toString() - Method in class backtype.storm.testing.FixedTuple

toString() - Method in class backtype.storm.testing.MemoryTransactionalSpoutMeta

toString() - Method in class backtype.storm.transactional.TransactionAttempt

toString() - Method in class backtype.storm.tuple.MessageId

toString() - Method in class backtype.storm.tuple.Tuple

TRANSACTION_BATCH_STREAM_ID - Static variable in class backtype.storm.transactional.TransactionalSpoutCoordinator

TRANSACTION_COMMIT_STREAM_ID - Static variable in class backtype.storm.transactional.TransactionalSpoutCoordinator

TRANSACTIONAL_ZOOKEEPER_PORT - Static variable in class backtype.storm.Config

The port to use to connect to the transactional zookeeper servers.

TRANSACTIONAL_ZOOKEEPER_ROOT - Static variable in class backtype.storm.Config

The root directory in ZooKeeper for metadata about TransactionalSpouts.

TRANSACTIONAL_ZOOKEEPER_SERVERS - Static variable in class backtype.storm.Config

The list of zookeeper servers in which to keep the transactional state.

TransactionalSpoutBatchExecutor - Class in backtype.storm.transactional

TransactionalSpoutBatchExecutor(ITransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalSpoutBatchExecutor

TransactionalSpoutCoordinator - Class in backtype.storm.transactional

TransactionalSpoutCoordinator(ITransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalSpoutCoordinator

TransactionalState - Class in backtype.storm.transactional.state

TransactionalState(Map, String, Map, String) - Constructor for class backtype.storm.transactional.state.TransactionalState

TransactionalTopologyBuilder - Class in backtype.storm.transactional

TODO: check to see if there are two topologies active with the same transactional id essentially want to implement a file lock on top of zk (use ephemeral nodes?) or just use the topology name?

TransactionalTopologyBuilder(String, String, ITransactionalSpout, Integer) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionalTopologyBuilder(String, String, ITransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionalTopologyBuilder(String, String, IPartitionedTransactionalSpout, Integer) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionalTopologyBuilder(String, String, IPartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionalTopologyBuilder(String, String, IOpaquePartitionedTransactionalSpout, Integer) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionalTopologyBuilder(String, String, IOpaquePartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder

TransactionAttempt - Class in backtype.storm.transactional

TransactionAttempt() - Constructor for class backtype.storm.transactional.TransactionAttempt

TransactionAttempt(BigInteger, long) - Constructor for class backtype.storm.transactional.TransactionAttempt

Tuple - Class in backtype.storm.tuple

The tuple is the main data structure in Storm.

Tuple(TopologyContext, List<Object>, int, String, MessageId) - Constructor for class backtype.storm.tuple.Tuple

Tuple(TopologyContext, List<Object>, int, String) - Constructor for class backtype.storm.tuple.Tuple

tuple(Object...) - Static method in class backtype.storm.utils.Utils

TupleCaptureBolt - Class in backtype.storm.testing

TupleCaptureBolt() - Constructor for class backtype.storm.testing.TupleCaptureBolt

TX_FIELD - Static variable in class backtype.storm.testing.MemoryTransactionalSpout

U

UI_CHILDOPTS - Static variable in class backtype.storm.Config

Childopts for Storm UI Java process.

UI_PORT - Static variable in class backtype.storm.Config

Storm UI binds to this port.

unregisterService(String) - Static method in class backtype.storm.utils.ServiceRegistry

Utils - Class in backtype.storm.utils

Utils() - Constructor for class backtype.storm.utils.Utils

V

valAt(Object) - Method in class backtype.storm.tuple.Tuple

valAt(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

valAt(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap

values - Variable in class backtype.storm.testing.FixedTuple

Values - Class in backtype.storm.tuple

A convenience class for making tuple values using new Values("field1", 2, 3) syntax.

Values(Object...) - Constructor for class backtype.storm.tuple.Values

values() - Method in class backtype.storm.utils.IndifferentAccessMap

VersionedStore - Class in backtype.storm.utils

VersionedStore(String) - Constructor for class backtype.storm.utils.VersionedStore

versionPath(long) - Method in class backtype.storm.utils.VersionedStore

W

without(Object) - Method in class backtype.storm.utils.IndifferentAccessMap

WORKER_CHILDOPTS - Static variable in class backtype.storm.Config

The jvm opts provided to workers launched by this supervisor.

WORKER_HEARTBEAT_FREQUENCY_SECS - Static variable in class backtype.storm.Config

How often this worker should heartbeat to the supervisor.

WritableUtils - Class in backtype.storm.utils

WritableUtils() - Constructor for class backtype.storm.utils.WritableUtils

write(int) - Method in class backtype.storm.utils.CRC32OutputStream

write(byte[], int, int) - Method in class backtype.storm.utils.CRC32OutputStream

writeCompressedByteArray(DataOutput, byte[]) - Static method in class backtype.storm.utils.WritableUtils

writeCompressedString(DataOutput, String) - Static method in class backtype.storm.utils.WritableUtils

writeCompressedStringArray(DataOutput, String[]) - Static method in class backtype.storm.utils.WritableUtils

writeString(DataOutput, String) - Static method in class backtype.storm.utils.WritableUtils

writeStringArray(DataOutput, String[]) - Static method in class backtype.storm.utils.WritableUtils

writeVInt(DataOutput, int) - Static method in class backtype.storm.utils.WritableUtils

Serializes an integer to a binary stream with zero-compressed encoding.

writeVLong(DataOutput, long) - Static method in class backtype.storm.utils.WritableUtils

Serializes a long to a binary stream with zero-compressed encoding.

Z

ZMQ_LINGER_MILLIS - Static variable in class backtype.storm.Config

How long a connection should retry sending messages to a target host when the connection is closed.

ZMQ_THREADS - Static variable in class backtype.storm.Config

The number of threads that should be used by the zeromq context in each worker process.

_

_map - Variable in class backtype.storm.utils.IndifferentAccessMap

A B C D E F G H I J K L M N O P R S T U V W Z _