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 _