A B C D E F G H I J K L M N O P Q 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.NoOpSpout
 
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.AckFailMapTracker
 
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
 
ack(long) - Method in interface storm.trident.spout.IBatchSpout
 
ack(Object) - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
ack(long) - Method in class storm.trident.testing.FixedBatchSpout
 
ack(Object) - Method in class storm.trident.topology.MasterBatchCoordinator
 
ack(Tuple) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
AckFailDelegate - Interface in backtype.storm.testing
 
AckFailMapTracker - Class in backtype.storm.testing
 
AckFailMapTracker() - Constructor for class backtype.storm.testing.AckFailMapTracker
 
ackingTaskId - Variable in class backtype.storm.hooks.info.BoltAckInfo
 
AckTracker - Class in backtype.storm.testing
 
AckTracker() - Constructor for class backtype.storm.testing.AckTracker
 
acquireNewPort() - Static method in class backtype.storm.utils.InprocMessaging
 
activate() - Method in class backtype.storm.clojure.ClojureSpout
 
activate(String) - Method in interface backtype.storm.ILocalCluster
 
activate() - Method in interface backtype.storm.spout.ISpout
Called when a spout has been activated out of a deactivated mode.
activate() - Method in class backtype.storm.spout.NoOpSpout
 
activate() - Method in class backtype.storm.spout.ShellSpout
 
activate() - Method in class backtype.storm.testing.FixedTupleSpout
 
activate() - Method in class backtype.storm.topology.base.BaseRichSpout
 
activate() - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
activate() - Method in class storm.trident.topology.MasterBatchCoordinator
 
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, Number) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
addBolt(IBatchBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
addBolt(IRichBolt, Number) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated. 
addBolt(IRichBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated. 
addBolt(IBasicBolt, Number) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
addBolt(IBasicBolt) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
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
 
addGroup(Group) - Method in class storm.trident.graph.GraphGrouper
 
addMockData(String, String, Values...) - Method in class backtype.storm.testing.MockedSources
add mock data for the spout.
addMockData(String, Values...) - Method in class backtype.storm.testing.MockedSources
 
addNode(Node) - Method in class storm.trident.TridentTopology
 
addReceiver(TridentProcessor) - Method in class storm.trident.planner.SubtopologyBolt.InitialReceiver
 
addSourcedNode(List<Stream>, Node) - Method in class storm.trident.TridentTopology
 
addSourcedNode(Stream, Node) - Method in class storm.trident.TridentTopology
 
addSourcedStateNode(List<Stream>, Node) - Method in class storm.trident.TridentTopology
 
addSourcedStateNode(Stream, Node) - Method in class storm.trident.TridentTopology
 
addTaskHook(ITaskHook) - Method in class backtype.storm.task.TopologyContext
 
advanceTime(long) - Static method in class backtype.storm.utils.Time
 
aggPartition(S) - Method in interface storm.trident.fluent.GlobalAggregationScheme
 
aggPartition(GroupedStream) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(Aggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, Aggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(CombinerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(ReducerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Aggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, Aggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(CombinerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, CombinerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(ReducerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, ReducerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Aggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(Fields, Aggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
aggregate(T, TridentTuple, TridentCollector) - Method in interface storm.trident.operation.Aggregator
 
aggregate(FirstN.FirstNAgg.State, TridentTuple, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNAgg
 
aggregate(PriorityQueue, TridentTuple, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
aggregate(ChainedResult, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.ChainedAggregatorImpl
 
aggregate(Result, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
aggregate(Object[], TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.GroupedAggregator
 
aggregate(Result, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.ReducerAggregatorImpl
 
aggregate(SingleEmitAggregator.SingleEmitState, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.SingleEmitAggregator
 
aggregate(Aggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(Fields, Aggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
aggregate(CountAsAggregator.State, TridentTuple, TridentCollector) - Method in class storm.trident.testing.CountAsAggregator
 
AggregateProcessor - Class in storm.trident.planner.processor
 
AggregateProcessor(Fields, Aggregator) - Constructor for class storm.trident.planner.processor.AggregateProcessor
 
Aggregator<T> - Interface in storm.trident.operation
 
all() - Static method in class backtype.storm.coordination.CoordinatedBolt.SourceArgs
 
all() - Static method in class storm.trident.topology.TridentBoltExecutor.CoordType
 
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
 
allOutputFields - Variable in class storm.trident.planner.Node
 
AppendCollector - Class in storm.trident.planner.processor
 
AppendCollector(TridentContext) - Constructor for class storm.trident.planner.processor.AppendCollector
 
apply(Stream) - Method in interface storm.trident.operation.Assembly
 
apply(Stream) - Method in class storm.trident.operation.builtin.FirstN
 
applyAssembly(Assembly) - Method in class storm.trident.Stream
 
ARGS_STREAM - Static variable in class backtype.storm.drpc.PrepareRequest
 
ArrayListSerializer - Class in backtype.storm.serialization.types
 
ArrayListSerializer() - Constructor for class backtype.storm.serialization.types.ArrayListSerializer
 
Assembly - Interface in storm.trident.operation
 
assign(WorkerSlot, String, Collection<ExecutorDetails>) - Method in class backtype.storm.scheduler.Cluster
Assign the slot to the executors for this topology.
assign(WorkerSlot, Collection<ExecutorDetails>) - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
Assign the slot to executors.
assigned(Collection<Integer>) - Method in interface backtype.storm.scheduler.ISupervisor
 
assignSlots(Topologies, Collection<WorkerSlot>) - Method in interface backtype.storm.scheduler.INimbus
 
assoc(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
assocEx(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
availableSlots(Collection<SupervisorDetails>, Collection<WorkerSlot>, Topologies, Collection<String>) - Method in interface backtype.storm.scheduler.INimbus
 

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.hooks - package backtype.storm.hooks
 
backtype.storm.hooks.info - package backtype.storm.hooks.info
 
backtype.storm.planner - package backtype.storm.planner
 
backtype.storm.scheduler - package backtype.storm.scheduler
 
backtype.storm.serialization - package backtype.storm.serialization
 
backtype.storm.serialization.types - package backtype.storm.serialization.types
 
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
 
BaseAggregator<T> - Class in storm.trident.operation
 
BaseAggregator() - Constructor for class storm.trident.operation.BaseAggregator
 
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
 
BaseFilter - Class in storm.trident.operation
 
BaseFilter() - Constructor for class storm.trident.operation.BaseFilter
 
BaseFunction - Class in storm.trident.operation
 
BaseFunction() - Constructor for class storm.trident.operation.BaseFunction
 
BaseMultiReducer<T> - Class in storm.trident.operation
 
BaseMultiReducer() - Constructor for class storm.trident.operation.BaseMultiReducer
 
BaseOpaquePartitionedTransactionalSpout<T> - Class in backtype.storm.topology.base
 
BaseOpaquePartitionedTransactionalSpout() - Constructor for class backtype.storm.topology.base.BaseOpaquePartitionedTransactionalSpout
 
BaseOperation - Class in storm.trident.operation
 
BaseOperation() - Constructor for class storm.trident.operation.BaseOperation
 
BasePartitionedTransactionalSpout<T> - Class in backtype.storm.topology.base
 
BasePartitionedTransactionalSpout() - Constructor for class backtype.storm.topology.base.BasePartitionedTransactionalSpout
 
BaseQueryFunction<S extends State,T> - Class in storm.trident.state
 
BaseQueryFunction() - Constructor for class storm.trident.state.BaseQueryFunction
 
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
 
BaseStateUpdater<S extends State> - Class in storm.trident.state
 
BaseStateUpdater() - Constructor for class storm.trident.state.BaseStateUpdater
 
BaseTaskHook - Class in backtype.storm.hooks
 
BaseTaskHook() - Constructor for class backtype.storm.hooks.BaseTaskHook
 
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
 
BATCH_STREAM_ID - Static variable in class storm.trident.topology.MasterBatchCoordinator
 
BatchBoltExecutor - Class in backtype.storm.coordination
 
BatchBoltExecutor(IBatchBolt) - Constructor for class backtype.storm.coordination.BatchBoltExecutor
 
batchGlobal() - Method in class storm.trident.Stream
 
batchGroup - Variable in class storm.trident.topology.BatchInfo
 
batchId - Variable in class storm.trident.planner.ProcessorContext
 
batchId - Variable in class storm.trident.topology.BatchInfo
 
BatchInfo - Class in storm.trident.topology
 
BatchInfo(String, Object, Object) - Constructor for class storm.trident.topology.BatchInfo
 
BatchNumberList - Class in backtype.storm.testing
 
BatchNumberList(String) - Constructor for class backtype.storm.testing.BatchNumberList
 
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
 
BatchProcessWord - Class in backtype.storm.testing
 
BatchProcessWord() - Constructor for class backtype.storm.testing.BatchProcessWord
 
BatchRepeatA - Class in backtype.storm.testing
 
BatchRepeatA() - Constructor for class backtype.storm.testing.BatchRepeatA
 
batchRetrieve(ReadOnlyMapState, List<TridentTuple>) - Method in class storm.trident.operation.builtin.MapGet
 
batchRetrieve(ReadOnlySnapshottable, List<TridentTuple>) - Method in class storm.trident.operation.builtin.SnapshotGet
 
batchRetrieve(S, List<TridentTuple>) - Method in interface storm.trident.state.QueryFunction
 
BatchSpoutExecutor - Class in storm.trident.spout
 
BatchSpoutExecutor(IBatchSpout) - Constructor for class storm.trident.spout.BatchSpoutExecutor
 
BatchSpoutExecutor.BatchSpoutEmitter - Class in storm.trident.spout
 
BatchSpoutExecutor.BatchSpoutEmitter() - Constructor for class storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
BatchSpoutExecutor.EmptyCoordinator - Class in storm.trident.spout
 
BatchSpoutExecutor.EmptyCoordinator() - Constructor for class storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
BatchSubtopologyBuilder - Class in backtype.storm.coordination
 
BatchSubtopologyBuilder(String, IBasicBolt, Number) - Constructor for class backtype.storm.coordination.BatchSubtopologyBuilder
 
BatchSubtopologyBuilder(String, IBasicBolt) - Constructor for class backtype.storm.coordination.BatchSubtopologyBuilder
 
beginCommit(Long) - Method in class storm.trident.state.map.CachedBatchReadsMap
 
beginCommit(Long) - Method in class storm.trident.state.map.NonTransactionalMap
 
beginCommit(Long) - Method in class storm.trident.state.map.OpaqueMap
 
beginCommit(Long) - Method in class storm.trident.state.map.SnapshottableMap
 
beginCommit(Long) - Method in class storm.trident.state.map.TransactionalMap
 
beginCommit(Long) - Method in class storm.trident.state.ReadOnlyState
 
beginCommit(Long) - Method in interface storm.trident.state.State
 
boltAck(BoltAckInfo) - Method in class backtype.storm.hooks.BaseTaskHook
 
boltAck(BoltAckInfo) - Method in interface backtype.storm.hooks.ITaskHook
 
BoltAckInfo - Class in backtype.storm.hooks.info
 
BoltAckInfo(Tuple, int, Long) - Constructor for class backtype.storm.hooks.info.BoltAckInfo
 
BoltDeclarer - Interface in backtype.storm.topology
 
boltFail(BoltFailInfo) - Method in class backtype.storm.hooks.BaseTaskHook
 
boltFail(BoltFailInfo) - Method in interface backtype.storm.hooks.ITaskHook
 
BoltFailInfo - Class in backtype.storm.hooks.info
 
BoltFailInfo(Tuple, int, Long) - Constructor for class backtype.storm.hooks.info.BoltFailInfo
 
BoltTracker - Class in backtype.storm.testing
 
BoltTracker(IRichBolt, String) - Constructor for class backtype.storm.testing.BoltTracker
 
BridgeReceiver - Class in storm.trident.planner
 
BridgeReceiver(BatchOutputCollector) - Constructor for class storm.trident.planner.BridgeReceiver
 
broadcast() - Method in class storm.trident.Stream
 
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
 
build(IBackingMap<T>) - Static method in class storm.trident.state.map.NonTransactionalMap
 
build(IBackingMap<OpaqueValue>) - Static method in class storm.trident.state.map.OpaqueMap
 
build(IBackingMap<TransactionalValue>) - Static method in class storm.trident.state.map.TransactionalMap
 
build() - Method in class storm.trident.TridentTopology
 
buildFieldIndex(ValuePointer[]) - Static method in class storm.trident.tuple.ValuePointer
 
buildIndex(Fields, Map<String, ValuePointer>) - Static method in class storm.trident.tuple.ValuePointer
 
buildTopology() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
buildTopology() - Method in class storm.trident.topology.TridentTopologyBuilder
 
buildTopologyBuilder() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  

C

CachedBatchReadsMap<T> - Class in storm.trident.state.map
 
CachedBatchReadsMap(MapState<T>) - Constructor for class storm.trident.state.map.CachedBatchReadsMap
 
CachedMap<T> - Class in storm.trident.state.map
Useful to layer over a map that communicates with a database.
CachedMap(IBackingMap<T>, int) - Constructor for class storm.trident.state.map.CachedMap
 
CaptureCollector - Class in storm.trident.operation.impl
 
CaptureCollector() - Constructor for class storm.trident.operation.impl.CaptureCollector
 
captured - Variable in class storm.trident.operation.impl.CaptureCollector
 
chainedAgg() - Method in class storm.trident.fluent.GroupedStream
 
chainedAgg() - Method in class storm.trident.Stream
 
ChainedAggregatorDeclarer - Class in storm.trident.fluent
 
ChainedAggregatorDeclarer(IAggregatableStream, GlobalAggregationScheme) - Constructor for class storm.trident.fluent.ChainedAggregatorDeclarer
 
ChainedAggregatorDeclarer.AggregationPartition - Interface in storm.trident.fluent
 
ChainedAggregatorImpl - Class in storm.trident.operation.impl
 
ChainedAggregatorImpl(Aggregator[], Fields[], ComboList.Factory) - Constructor for class storm.trident.operation.impl.ChainedAggregatorImpl
 
ChainedFullAggregatorDeclarer - Interface in storm.trident.fluent
 
ChainedPartitionAggregatorDeclarer - Interface in storm.trident.fluent
 
ChainedResult - Class in storm.trident.operation.impl
 
ChainedResult(TridentCollector, int) - Constructor for class storm.trident.operation.impl.ChainedResult
 
chainEnd() - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
chainEnd() - Method in interface storm.trident.fluent.IChainedAggregatorDeclarer
 
chooseTasks(int, List<Object>) - Method in interface backtype.storm.grouping.CustomStreamGrouping
This function implements a custom stream grouping.
chooseTasks(int, List<Object>) - Method in class backtype.storm.testing.NGrouping
 
chooseTasks(int, List<Object>) - Method in class storm.trident.partition.GlobalGrouping
 
chooseTasks(int, List<Object>) - Method in class storm.trident.partition.IdentityGrouping
 
chooseTasks(int, List<Object>) - Method in class storm.trident.partition.IndexHashGrouping
 
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 class backtype.storm.hooks.BaseTaskHook
 
cleanup() - Method in interface backtype.storm.hooks.ITaskHook
 
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.OpaqueMemoryTransactionalSpout
 
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.TimeCacheMap
Deprecated.  
cleanup() - Method in class backtype.storm.utils.VersionedStore
 
cleanup(int) - Method in class backtype.storm.utils.VersionedStore
 
cleanup() - Method in class storm.trident.drpc.ReturnResultsReducer
 
cleanup() - Method in class storm.trident.operation.BaseMultiReducer
 
cleanup() - Method in class storm.trident.operation.BaseOperation
 
cleanup() - Method in class storm.trident.operation.builtin.Negate
 
cleanup() - Method in interface storm.trident.operation.GroupedMultiReducer
 
cleanup() - Method in class storm.trident.operation.impl.ChainedAggregatorImpl
 
cleanup() - Method in class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
cleanup() - Method in class storm.trident.operation.impl.CombinerAggregatorInitImpl
 
cleanup() - Method in class storm.trident.operation.impl.CombinerAggStateUpdater
 
cleanup() - Method in class storm.trident.operation.impl.FilterExecutor
 
cleanup() - Method in class storm.trident.operation.impl.GroupedAggregator
 
cleanup() - Method in class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
cleanup() - Method in class storm.trident.operation.impl.IdentityMultiReducer
 
cleanup() - Method in class storm.trident.operation.impl.JoinerMultiReducer
 
cleanup() - Method in class storm.trident.operation.impl.ReducerAggregatorImpl
 
cleanup() - Method in class storm.trident.operation.impl.ReducerAggStateUpdater
 
cleanup() - Method in class storm.trident.operation.impl.SingleEmitAggregator
 
cleanup() - Method in class storm.trident.operation.impl.TrueFilter
 
cleanup() - Method in interface storm.trident.operation.MultiReducer
 
cleanup() - Method in interface storm.trident.operation.Operation
 
cleanup() - Method in class storm.trident.planner.processor.AggregateProcessor
 
cleanup() - Method in class storm.trident.planner.processor.EachProcessor
 
cleanup() - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
cleanup() - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
cleanup() - Method in class storm.trident.planner.processor.ProjectedProcessor
 
cleanup() - Method in class storm.trident.planner.processor.StateQueryProcessor
 
cleanup() - Method in class storm.trident.planner.SubtopologyBolt
 
cleanup() - Method in interface storm.trident.planner.TridentProcessor
 
cleanup() - Method in class storm.trident.spout.TridentSpoutCoordinator
 
cleanup() - Method in class storm.trident.spout.TridentSpoutExecutor
 
cleanup() - Method in class storm.trident.state.map.MapCombinerAggStateUpdater
 
cleanup() - Method in class storm.trident.state.map.MapReducerAggStateUpdater
 
cleanup() - Method in interface storm.trident.topology.ITridentBatchBolt
 
cleanup() - Method in class storm.trident.topology.TridentBoltExecutor
 
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
 
cleanupBefore(long) - Method in class storm.trident.topology.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
 
clearAll() - Static method in class storm.trident.testing.LRUMemoryMapState
 
clearAll() - Static method in class storm.trident.testing.MemoryMapState
 
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.NoOpSpout
 
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.Coordinator
 
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
 
close() - Method in class storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
close() - Method in class storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
close() - Method in interface storm.trident.spout.IBatchSpout
 
close() - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout.Coordinator
 
close() - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter
 
close() - Method in interface storm.trident.spout.IPartitionedTridentSpout.Coordinator
 
close() - Method in interface storm.trident.spout.IPartitionedTridentSpout.Emitter
 
close() - Method in interface storm.trident.spout.ITridentSpout.BatchCoordinator
Release any resources from this coordinator.
close() - Method in interface storm.trident.spout.ITridentSpout.Emitter
Release any resources held by this emitter.
close() - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
close() - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
close() - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
close() - Method in class storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
close() - Method in class storm.trident.testing.FeederBatchSpout.FeederEmitter
 
close() - Method in class storm.trident.testing.FixedBatchSpout
 
close() - Method in class storm.trident.topology.MasterBatchCoordinator
 
close() - Method in class storm.trident.topology.state.TransactionalState
 
Cluster - Class in backtype.storm.scheduler
 
Cluster(Map<String, SupervisorDetails>, Map<String, SchedulerAssignmentImpl>) - Constructor for class backtype.storm.scheduler.Cluster
 
combine(Long, Long) - Method in class storm.trident.operation.builtin.Count
 
combine(Number, Number) - Method in class storm.trident.operation.builtin.Sum
 
combine(T, T) - Method in interface storm.trident.operation.CombinerAggregator
 
CombinerAggregator<T> - Interface in storm.trident.operation
 
CombinerAggregatorCombineImpl - Class in storm.trident.operation.impl
 
CombinerAggregatorCombineImpl(CombinerAggregator) - Constructor for class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
CombinerAggregatorInitImpl - Class in storm.trident.operation.impl
 
CombinerAggregatorInitImpl(CombinerAggregator) - Constructor for class storm.trident.operation.impl.CombinerAggregatorInitImpl
 
CombinerAggStateUpdater - Class in storm.trident.operation.impl
 
CombinerAggStateUpdater(CombinerAggregator) - Constructor for class storm.trident.operation.impl.CombinerAggStateUpdater
 
CombinerValueUpdater - Class in storm.trident.state
 
CombinerValueUpdater(CombinerAggregator, Object) - Constructor for class storm.trident.state.CombinerValueUpdater
 
ComboList - Class in storm.trident.tuple
 
ComboList(List[], ComboList.Pointer[]) - Constructor for class storm.trident.tuple.ComboList
 
ComboList.Factory - Class in storm.trident.tuple
 
ComboList.Factory(int...) - Constructor for class storm.trident.tuple.ComboList.Factory
 
commit(TransactionAttempt) - Method in interface backtype.storm.transactional.ICommitterTransactionalSpout.Emitter
 
commit(TransactionAttempt) - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter
 
commit(TransactionAttempt) - Method in interface storm.trident.spout.ICommitterTridentSpout.Emitter
 
commit(TransactionAttempt) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
commit(Long) - Method in class storm.trident.state.map.CachedBatchReadsMap
 
commit(Long) - Method in class storm.trident.state.map.NonTransactionalMap
 
commit(Long) - Method in class storm.trident.state.map.OpaqueMap
 
commit(Long) - Method in class storm.trident.state.map.SnapshottableMap
 
commit(Long) - Method in class storm.trident.state.map.TransactionalMap
 
commit(Long) - Method in class storm.trident.state.ReadOnlyState
 
commit(Long) - Method in interface storm.trident.state.State
 
COMMIT_STREAM_ID - Static variable in class storm.trident.topology.MasterBatchCoordinator
 
commitStream - Variable in class storm.trident.topology.TridentBoltExecutor.CoordCondition
 
commitStream - Variable in class storm.trident.topology.TridentBoltExecutor.CoordSpec
 
committer - Variable in class storm.trident.planner.ProcessorNode
 
compareTo(Object) - Method in class storm.trident.util.IndexedEdge
 
complete(ReturnResultsReducer.ReturnResultsState, TridentCollector) - Method in class storm.trident.drpc.ReturnResultsReducer
 
complete(T, TridentCollector) - Method in interface storm.trident.operation.Aggregator
 
complete(FirstN.FirstNAgg.State, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNAgg
 
complete(PriorityQueue, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
complete(T, TridentTuple, TridentCollector) - Method in interface storm.trident.operation.GroupedMultiReducer
 
complete(ChainedResult, TridentCollector) - Method in class storm.trident.operation.impl.ChainedAggregatorImpl
 
complete(Result, TridentCollector) - Method in class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
complete(Object[], TridentCollector) - Method in class storm.trident.operation.impl.GroupedAggregator
 
complete(Map<TridentTuple, Object>, TridentCollector) - Method in class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
complete(Object, TridentCollector) - Method in class storm.trident.operation.impl.IdentityMultiReducer
 
complete(JoinerMultiReducer.JoinState, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.JoinerMultiReducer
 
complete(Result, TridentCollector) - Method in class storm.trident.operation.impl.ReducerAggregatorImpl
 
complete(SingleEmitAggregator.SingleEmitState, TridentCollector) - Method in class storm.trident.operation.impl.SingleEmitAggregator
 
complete(T, TridentCollector) - Method in interface storm.trident.operation.MultiReducer
 
complete(CountAsAggregator.State, TridentCollector) - Method in class storm.trident.testing.CountAsAggregator
 
completeLatencyMs - Variable in class backtype.storm.hooks.info.SpoutAckInfo
 
CompleteTopologyParam - Class in backtype.storm.testing
The param class for the Testing.completeTopology.
CompleteTopologyParam() - Constructor for class backtype.storm.testing.CompleteTopologyParam
 
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
 
confirmAssigned(int) - Method in interface backtype.storm.scheduler.ISupervisor
 
cons(Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
ConsList - Class in storm.trident.tuple
 
ConsList(Object, List<Object>) - Constructor for class storm.trident.tuple.ConsList
 
Constants - Class in backtype.storm
 
Constants() - Constructor for class backtype.storm.Constants
 
consumeBatch(<any>) - Method in class backtype.storm.utils.DisruptorQueue
 
consumeBatchWhenAvailable(<any>) - Method in class backtype.storm.utils.DisruptorQueue
 
consumerStarted() - Method in class backtype.storm.utils.DisruptorQueue
 
Container - Class in backtype.storm.utils
 
Container() - Constructor for class backtype.storm.utils.Container
 
contains(String) - Method in class backtype.storm.tuple.Fields
Returns true if this contains the specified name of the field.
contains(String) - Method in interface backtype.storm.tuple.Tuple
Returns true if this tuple contains the specified name of the field.
contains(String) - Method in class backtype.storm.tuple.TupleImpl
 
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.RotatingMap
 
containsKey(K) - Method in class backtype.storm.utils.TimeCacheMap
Deprecated.  
containsValue(Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
COORD_STREAM(String) - Static method in class storm.trident.topology.TridentBoltExecutor
 
COORD_STREAM_PREFIX - Static variable in class storm.trident.topology.TridentBoltExecutor
 
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
 
coords - Variable in class storm.trident.topology.TridentBoltExecutor.CoordSpec
 
count() - Method in class backtype.storm.tuple.TupleImpl
 
count() - Method in class backtype.storm.utils.IndifferentAccessMap
 
Count - Class in storm.trident.operation.builtin
 
Count() - Constructor for class storm.trident.operation.builtin.Count
 
CountAsAggregator - Class in storm.trident.testing
 
CountAsAggregator() - Constructor for class storm.trident.testing.CountAsAggregator
 
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
 
CRC32OutputStream - Class in backtype.storm.utils
 
CRC32OutputStream() - Constructor for class backtype.storm.utils.CRC32OutputStream
 
create(Kryo, Input, Class<Collection>) - Method in class backtype.storm.serialization.types.ArrayListSerializer
 
create(Kryo, Input, Class<Map>) - Method in class backtype.storm.serialization.types.HashMapSerializer
 
create(Kryo, Input, Class<Collection>) - Method in class backtype.storm.serialization.types.HashSetSerializer
 
create(List[]) - Method in class storm.trident.tuple.ComboList.Factory
 
create(List<Object>) - Method in class storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
create(TridentTupleView, List<Object>) - Method in class storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
create(TridentTuple) - Method in class storm.trident.tuple.TridentTupleView.ProjectionFactory
 
create(Tuple) - Method in class storm.trident.tuple.TridentTupleView.RootFactory
 
createEdge(Object, Object) - Method in class storm.trident.util.ErrorEdgeFactory
 
createLocalTopology(ILocalDRPC) - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
createRemoteTopology() - Method in class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
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
 
creationIndex - Variable in class storm.trident.planner.Node
 
currentTimeMillis() - Static method in class backtype.storm.utils.Time
 
currentTimeSecs() - Static method in class backtype.storm.utils.Time
 
currGroup - Variable in class storm.trident.operation.impl.GroupCollector
 
customGrouping(CustomStreamGrouping) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer
 
customGrouping(String, CustomStreamGrouping) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer
 
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

deactivate() - Method in class backtype.storm.clojure.ClojureSpout
 
deactivate(String) - Method in interface backtype.storm.ILocalCluster
 
deactivate() - Method in interface backtype.storm.spout.ISpout
Called when a spout has been deactivated.
deactivate() - Method in class backtype.storm.spout.NoOpSpout
 
deactivate() - Method in class backtype.storm.spout.ShellSpout
 
deactivate() - Method in class backtype.storm.testing.FixedTupleSpout
 
deactivate() - Method in class backtype.storm.topology.base.BaseRichSpout
 
deactivate() - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
deactivate() - Method in class storm.trident.topology.MasterBatchCoordinator
 
Debug - Class in storm.trident.operation.builtin
 
Debug() - Constructor for class storm.trident.operation.builtin.Debug
 
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.clojure.RichShellSpout
 
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.BatchNumberList
 
declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.BatchProcessWord
 
declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.BatchRepeatA
 
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.OpaqueMemoryTransactionalSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class backtype.storm.testing.PrepareBatchBolt
 
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
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.planner.SubtopologyBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.spout.TridentSpoutCoordinator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.spout.TridentSpoutExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.topology.MasterBatchCoordinator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.trident.topology.TridentBoltExecutor
 
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
decorate(Kryo) - Method in interface backtype.storm.serialization.IKryoDecorator
 
decorate(Kryo) - Method in class backtype.storm.testing.TestKryoDecorator
 
DEFAULT_STREAM_ID - Static variable in class backtype.storm.utils.Utils
 
delegateIndex - Variable in class storm.trident.tuple.ValuePointer
 
delete(String) - Method in class backtype.storm.transactional.state.TransactionalState
 
delete(String) - Method in class storm.trident.topology.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.KryoValuesDeserializer
 
deserialize(byte[]) - Method in class backtype.storm.spout.RawScheme
 
deserialize(byte[]) - Method in interface backtype.storm.spout.Scheme
 
deserialize(Input) - Static method in class backtype.storm.tuple.MessageId
 
deserialize(byte[]) - Static method in class backtype.storm.utils.Utils
 
deserialize(byte[]) - Method in class storm.trident.state.JSONNonTransactionalSerializer
 
deserialize(byte[]) - Method in class storm.trident.state.JSONOpaqueSerializer
 
deserialize(byte[]) - Method in class storm.trident.state.JSONTransactionalSerializer
 
deserialize(byte[]) - Method in interface storm.trident.state.Serializer
 
deserializeFrom(Input) - Method in class backtype.storm.serialization.KryoValuesDeserializer
 
deserializeObject(byte[]) - Method in class backtype.storm.serialization.KryoValuesDeserializer
 
destroy() - Method in class backtype.storm.utils.ShellProcess
 
DEV_ZOOKEEPER_PATH - Static variable in class backtype.storm.Config
The path to use as the zookeeper dir when running a zookeeper server via "storm dev-zookeeper".
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
 
DisruptorQueue - Class in backtype.storm.utils
A single consumer queue that uses the LMAX Disruptor.
DisruptorQueue(ClaimStrategy, WaitStrategy) - Constructor for class backtype.storm.utils.DisruptorQueue
 
DisruptorQueue.ObjectEventFactory - Class in backtype.storm.utils
 
DisruptorQueue.ObjectEventFactory() - Constructor for class backtype.storm.utils.DisruptorQueue.ObjectEventFactory
 
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_REQUEST_TIMEOUT_SECS - Static variable in class backtype.storm.Config
The timeout on DRPC requests within the DRPC server.
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, Integer) - Constructor for class backtype.storm.utils.DRPCClient
 
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

each(Fields, Function, Fields) - Method in class storm.trident.fluent.GroupedStream
 
each(Fields, Function, Fields) - Method in interface storm.trident.fluent.IAggregatableStream
 
each(Fields, Function, Fields) - Method in class storm.trident.Stream
 
each(Function, Fields) - Method in class storm.trident.Stream
 
each(Fields, Filter) - Method in class storm.trident.Stream
 
EachOperation - Interface in storm.trident.operation
 
EachProcessor - Class in storm.trident.planner.processor
 
EachProcessor(Fields, Function) - Constructor for class storm.trident.planner.processor.EachProcessor
 
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(EmitInfo) - Method in class backtype.storm.hooks.BaseTaskHook
 
emit(EmitInfo) - Method in interface backtype.storm.hooks.ITaskHook
 
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
 
emit(List<Object>) - Method in class storm.trident.operation.impl.CaptureCollector
 
emit(List<Object>) - Method in class storm.trident.operation.impl.GroupCollector
 
emit(List<Object>) - Method in interface storm.trident.operation.TridentCollector
 
emit(List<Object>) - Method in class storm.trident.planner.processor.AppendCollector
 
emit(List<Object>) - Method in class storm.trident.planner.processor.FreshCollector
 
emit(String, Collection<Tuple>, List<Object>) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
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
 
emitBatch(TransactionAttempt, Object, TridentCollector) - Method in class storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
emitBatch(long, TridentCollector) - Method in interface storm.trident.spout.IBatchSpout
 
emitBatch(TransactionAttempt, X, TridentCollector) - Method in interface storm.trident.spout.ITridentSpout.Emitter
Emit a batch for the specified transaction attempt and metadata for the transaction.
emitBatch(TransactionAttempt, Object, TridentCollector) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
emitBatch(TransactionAttempt, Map<Integer, List<List<Object>>>, TridentCollector) - Method in class storm.trident.testing.FeederBatchSpout.FeederEmitter
 
emitBatch(long, TridentCollector) - Method in class storm.trident.testing.FixedBatchSpout
 
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
 
emitDirect(int, String, Collection<Tuple>, List<Object>) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
EmitInfo - Class in backtype.storm.hooks.info
 
EmitInfo(List<Object>, String, int, Collection<Integer>) - Constructor for class backtype.storm.hooks.info.EmitInfo
 
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.
emitPartitionBatch(TransactionAttempt, TridentCollector, int, X) - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter
Emit a batch of tuples for a partition/transaction.
emitPartitionBatch(TransactionAttempt, TridentCollector, int, X) - Method in interface storm.trident.spout.IPartitionedTridentSpout.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.
emitPartitionBatchNew(TransactionAttempt, TridentCollector, int, X) - Method in interface storm.trident.spout.IPartitionedTridentSpout.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
 
EMPTY_TUPLE - Static variable in class storm.trident.tuple.TridentTupleView
 
emptyEmit(long) - Method in interface backtype.storm.spout.ISpoutWaitStrategy
 
emptyEmit(long) - Method in class backtype.storm.spout.NothingEmptyEmitStrategy
 
emptyEmit(long) - Method in class backtype.storm.spout.SleepSpoutWaitStrategy
 
entryAt(Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
entrySet() - Method in class backtype.storm.utils.IndifferentAccessMap
 
equals(Object) - Method in class backtype.storm.scheduler.ExecutorDetails
 
equals(Object) - Method in class backtype.storm.scheduler.WorkerSlot
 
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.TupleImpl
 
equals(Object) - Method in class storm.trident.graph.Group
 
Equals - Class in storm.trident.operation.builtin
 
Equals() - Constructor for class storm.trident.operation.builtin.Equals
 
equals(Object) - Method in class storm.trident.planner.Node
 
equals(Object) - Method in class storm.trident.topology.TransactionAttempt
 
equals(Object) - Method in class storm.trident.topology.TridentBoltExecutor.CoordType
 
equals(Object) - Method in class storm.trident.util.IndexedEdge
 
equiv(Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
ErrorEdgeFactory - Class in storm.trident.util
 
ErrorEdgeFactory() - Constructor for class storm.trident.util.ErrorEdgeFactory
 
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.BatchNumberList
 
execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.testing.BatchProcessWord
 
execute(Tuple, BasicOutputCollector) - Method in class backtype.storm.testing.BatchRepeatA
 
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, BasicOutputCollector) - Method in class backtype.storm.testing.PrepareBatchBolt
 
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
Process the input tuple and optionally emit new tuples based on the input tuple.
execute(Tuple) - Method in class backtype.storm.transactional.TransactionalSpoutBatchExecutor
 
execute(String, String) - Method in class backtype.storm.utils.DRPCClient
 
execute(ReturnResultsReducer.ReturnResultsState, int, TridentTuple, TridentCollector) - Method in class storm.trident.drpc.ReturnResultsReducer
 
execute(TridentTuple, Object, TridentCollector) - Method in class storm.trident.operation.builtin.MapGet
 
execute(TridentTuple, Object, TridentCollector) - Method in class storm.trident.operation.builtin.SnapshotGet
 
execute(TridentTuple, TridentCollector) - Method in interface storm.trident.operation.Function
 
execute(T, int, TridentTuple, TridentTuple, TridentCollector) - Method in interface storm.trident.operation.GroupedMultiReducer
 
execute(TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.CombinerAggregatorInitImpl
 
execute(TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.FilterExecutor
 
execute(Map<TridentTuple, Object>, int, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
execute(Object, int, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.IdentityMultiReducer
 
execute(JoinerMultiReducer.JoinState, int, TridentTuple, TridentTuple, TridentCollector) - Method in class storm.trident.operation.impl.JoinerMultiReducer
 
execute(T, int, TridentTuple, TridentCollector) - Method in interface storm.trident.operation.MultiReducer
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.BridgeReceiver
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.AggregateProcessor
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.EachProcessor
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.ProjectedProcessor
 
execute(ProcessorContext, String, TridentTuple) - Method in class storm.trident.planner.processor.StateQueryProcessor
 
execute(BatchInfo, Tuple) - Method in class storm.trident.planner.SubtopologyBolt
 
execute(ProcessorContext, String, TridentTuple) - Method in interface storm.trident.planner.TupleReceiver
 
execute(Tuple, BasicOutputCollector) - Method in class storm.trident.spout.TridentSpoutCoordinator
 
execute(BatchInfo, Tuple) - Method in class storm.trident.spout.TridentSpoutExecutor
 
execute(TridentTuple, T, TridentCollector) - Method in interface storm.trident.state.QueryFunction
 
execute(TridentTuple, TridentCollector) - Method in class storm.trident.testing.Split
 
execute(TridentTuple, TridentCollector) - Method in class storm.trident.testing.StringLength
 
execute(TridentTuple, TridentCollector) - Method in class storm.trident.testing.TuplifyArgs
 
execute(BatchInfo, Tuple) - Method in interface storm.trident.topology.ITridentBatchBolt
 
execute(Tuple) - Method in class storm.trident.topology.TridentBoltExecutor
 
ExecutorDetails - Class in backtype.storm.scheduler
 
ExecutorDetails(int, int) - Constructor for class backtype.storm.scheduler.ExecutorDetails
 
expectedTaskReports - Variable in class storm.trident.topology.TridentBoltExecutor.CoordCondition
 
expire(K, V) - Method in interface backtype.storm.utils.RotatingMap.ExpiredCallback
 
expire(K, V) - Method in interface backtype.storm.utils.TimeCacheMap.ExpiredCallback
Deprecated.  
extendTopology(TopologyBuilder) - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 

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.NoOpSpout
 
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.AckFailMapTracker
 
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
 
fail(Object) - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
fail(Object) - Method in class storm.trident.topology.MasterBatchCoordinator
 
fail(Tuple) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
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
 
failingTaskId - Variable in class backtype.storm.hooks.info.BoltFailInfo
 
failLatencyMs - Variable in class backtype.storm.hooks.info.BoltFailInfo
 
failLatencyMs - Variable in class backtype.storm.hooks.info.SpoutFailInfo
 
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
 
feed(List<Object>, Object) - Method in class backtype.storm.testing.FeederSpout
 
feed(Object) - Method in class storm.trident.testing.FeederBatchSpout
 
feed(Object) - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
feed(Object) - Method in interface storm.trident.testing.IFeeder
 
FeederBatchSpout - Class in storm.trident.testing
 
FeederBatchSpout(List<String>) - Constructor for class storm.trident.testing.FeederBatchSpout
 
FeederBatchSpout.FeederCoordinator - Class in storm.trident.testing
 
FeederBatchSpout.FeederCoordinator(int) - Constructor for class storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
FeederBatchSpout.FeederEmitter - Class in storm.trident.testing
 
FeederBatchSpout.FeederEmitter(int) - Constructor for class storm.trident.testing.FeederBatchSpout.FeederEmitter
 
FeederCommitterBatchSpout - Class in storm.trident.testing
 
FeederCommitterBatchSpout(List<String>) - Constructor for class storm.trident.testing.FeederCommitterBatchSpout
 
FeederSpout - Class in backtype.storm.testing
 
FeederSpout(Fields) - Constructor for class backtype.storm.testing.FeederSpout
 
fetchRequest(String) - Method in class backtype.storm.drpc.DRPCInvocationsClient
 
field - Variable in class storm.trident.tuple.ValuePointer
 
fieldIndex(String) - Method in class backtype.storm.tuple.Fields
Returns the position of the specified field.
fieldIndex(String) - Method in interface backtype.storm.tuple.Tuple
Returns the position of the specified field in this tuple.
fieldIndex(String) - Method in class backtype.storm.tuple.TupleImpl
 
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
 
fieldsConcat(Fields...) - Static method in class storm.trident.util.TridentUtils
 
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
 
fieldsSubtract(Fields, Fields) - Static method in class storm.trident.util.TridentUtils
 
fieldsUnion(Fields...) - Static method in class storm.trident.util.TridentUtils
 
Filter - Interface in storm.trident.operation
 
FilterExecutor - Class in storm.trident.operation.impl
 
FilterExecutor(Filter) - Constructor for class storm.trident.operation.impl.FilterExecutor
 
FilterNull - Class in storm.trident.operation.builtin
 
FilterNull() - Constructor for class storm.trident.operation.builtin.FilterNull
 
findAndReadConfigFile(String, boolean) - Static method in class backtype.storm.utils.Utils
 
findAndReadConfigFile(String) - Static method in class backtype.storm.utils.Utils
 
findResources(String) - Static method in class backtype.storm.utils.Utils
 
finishBatch() - Method in interface backtype.storm.coordination.IBatchBolt
 
finishBatch() - Method in class backtype.storm.testing.BatchNumberList
 
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
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.AggregateProcessor
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.EachProcessor
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.ProjectedProcessor
 
finishBatch(ProcessorContext) - Method in class storm.trident.planner.processor.StateQueryProcessor
 
finishBatch(BatchInfo) - Method in class storm.trident.planner.SubtopologyBolt
 
finishBatch(ProcessorContext) - Method in interface storm.trident.planner.TridentProcessor
 
finishBatch(BatchInfo) - Method in class storm.trident.spout.TridentSpoutExecutor
 
finishBatch(BatchInfo) - Method in interface storm.trident.topology.ITridentBatchBolt
 
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
 
FirstN - Class in storm.trident.operation.builtin
 
FirstN(int, String) - Constructor for class storm.trident.operation.builtin.FirstN
 
FirstN(int, String, boolean) - Constructor for class storm.trident.operation.builtin.FirstN
 
FirstN.FirstNAgg - Class in storm.trident.operation.builtin
 
FirstN.FirstNAgg(int) - Constructor for class storm.trident.operation.builtin.FirstN.FirstNAgg
 
FirstN.FirstNSortedAgg - Class in storm.trident.operation.builtin
 
FirstN.FirstNSortedAgg(int, String, boolean) - Constructor for class storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
FixedBatchSpout - Class in storm.trident.testing
 
FixedBatchSpout(Fields, int, List<Object>...) - Constructor for class storm.trident.testing.FixedBatchSpout
 
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
 
freeSlot(WorkerSlot) - Method in class backtype.storm.scheduler.Cluster
Free the specified slot.
freeSlots(Collection<WorkerSlot>) - Method in class backtype.storm.scheduler.Cluster
free the slots.
FreshCollector - Class in storm.trident.planner.processor
 
FreshCollector(TridentContext) - Constructor for class storm.trident.planner.processor.FreshCollector
 
Function - Interface in storm.trident.operation
 

G

GeneralTopologyContext - Class in backtype.storm.task
 
GeneralTopologyContext(StormTopology, Map, Map<Integer, String>, Map<String, List<Integer>>, Map<String, Map<String, Fields>>, String) - Constructor for class backtype.storm.task.GeneralTopologyContext
 
generateId(Random) - 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() - Method in class backtype.storm.utils.MutableInt
 
get() - Method in class backtype.storm.utils.MutableLong
 
get(K) - Method in class backtype.storm.utils.RotatingMap
 
get(K) - Method in class backtype.storm.utils.TimeCacheMap
Deprecated.  
get(Map<S, T>, S, T) - Static method in class backtype.storm.utils.Utils
 
get() - Method in class storm.trident.state.map.SnapshottableMap
 
get(Long) - Method in class storm.trident.state.OpaqueValue
 
get() - Method in interface storm.trident.state.snapshot.ReadOnlySnapshottable
 
get(int) - Method in class storm.trident.tuple.ComboList
 
get(int) - Method in class storm.trident.tuple.ConsList
 
get(int) - Method in class storm.trident.tuple.TridentTupleView
 
getAckVal() - Method in class backtype.storm.tuple.TupleImpl
 
getAllGroups() - Method in class storm.trident.graph.GraphGrouper
 
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
 
getAssignedNumWorkers(TopologyDetails) - Method in class backtype.storm.scheduler.Cluster
Gets the number of workers assigned to this topology.
getAssignmentById(String) - Method in class backtype.storm.scheduler.Cluster
get the current assignment for the topology.
getAssignments() - Method in class backtype.storm.scheduler.Cluster
Get all the assignments.
getAttemptId() - Method in class backtype.storm.transactional.TransactionAttempt
 
getAttemptId() - Method in class storm.trident.topology.TransactionAttempt
 
getAvailablePorts(SupervisorDetails) - Method in class backtype.storm.scheduler.Cluster
Return the available ports of this supervisor.
getAvailableSlots(SupervisorDetails) - Method in class backtype.storm.scheduler.Cluster
Return all the available slots on this supervisor.
getAvailableSlots() - Method in class backtype.storm.scheduler.Cluster
Gets all the available slots in the cluster.
getBinary(int) - Method in interface backtype.storm.tuple.Tuple
Returns the byte array at position i in the tuple.
getBinary(int) - Method in class backtype.storm.tuple.TupleImpl
 
getBinary(int) - Method in interface storm.trident.tuple.TridentTuple
 
getBinary(int) - Method in class storm.trident.tuple.TridentTupleView
 
getBinaryByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getBinaryByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getBinaryByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getBinaryByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getBoolean(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Boolean at position i in the tuple.
getBoolean(int) - Method in class backtype.storm.tuple.TupleImpl
 
getBoolean(int) - Method in interface storm.trident.tuple.TridentTuple
 
getBoolean(int) - Method in class storm.trident.tuple.TridentTupleView
 
getBooleanByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getBooleanByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getBooleanByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getBooleanByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getById(String) - Method in class backtype.storm.scheduler.Topologies
 
getByName(String) - Method in class backtype.storm.scheduler.Topologies
 
getByte(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Byte at position i in the tuple.
getByte(int) - Method in class backtype.storm.tuple.TupleImpl
 
getByte(int) - Method in interface storm.trident.tuple.TridentTuple
 
getByte(int) - Method in class storm.trident.tuple.TridentTupleView
 
getByteByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getByteByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getByteByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getByteByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getChildren(DirectedGraph, T) - Static method in class storm.trident.util.TridentUtils
 
getCleanupState() - Method in class backtype.storm.testing.CompleteTopologyParam
 
getClient() - Method in class backtype.storm.utils.NimbusClient
 
getClusterInfo() - Method in interface backtype.storm.ILocalCluster
 
getCodeDir() - Method in class backtype.storm.task.WorkerTopologyContext
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.GeneralTopologyContext
 
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.clojure.RichShellSpout
 
getComponentConfiguration() - Method in class backtype.storm.coordination.BatchBoltExecutor
 
getComponentConfiguration() - Method in class backtype.storm.coordination.CoordinatedBolt
 
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.OpaqueMemoryTransactionalSpout
 
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
 
getComponentConfiguration() - Method in class storm.trident.planner.SubtopologyBolt
 
getComponentConfiguration() - Method in class storm.trident.spout.BatchSpoutExecutor
 
getComponentConfiguration() - Method in interface storm.trident.spout.IBatchSpout
 
getComponentConfiguration() - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout
 
getComponentConfiguration() - Method in interface storm.trident.spout.IPartitionedTridentSpout
 
getComponentConfiguration() - Method in interface storm.trident.spout.ITridentSpout
 
getComponentConfiguration() - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
 
getComponentConfiguration() - Method in class storm.trident.spout.PartitionedTridentSpoutExecutor
 
getComponentConfiguration() - Method in class storm.trident.spout.RichSpoutBatchExecutor
 
getComponentConfiguration() - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
getComponentConfiguration() - Method in class storm.trident.spout.TridentSpoutCoordinator
 
getComponentConfiguration() - Method in class storm.trident.spout.TridentSpoutExecutor
 
getComponentConfiguration() - Method in class storm.trident.testing.FeederBatchSpout
 
getComponentConfiguration() - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
getComponentConfiguration() - Method in class storm.trident.testing.FixedBatchSpout
 
getComponentConfiguration() - Method in class storm.trident.topology.MasterBatchCoordinator
 
getComponentConfiguration() - Method in class storm.trident.topology.TridentBoltExecutor
 
getComponentId(int) - Method in class backtype.storm.task.GeneralTopologyContext
Gets the component id for the specified task id.
getComponentIds() - Method in class backtype.storm.task.GeneralTopologyContext
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.GeneralTopologyContext
Gets the declared output fields for the specified component/stream.
getComponentOutputFields(GlobalStreamId) - Method in class backtype.storm.task.GeneralTopologyContext
Gets the declared output fields for the specified global stream id.
getComponentStreams(String) - Method in class backtype.storm.task.GeneralTopologyContext
Gets the set of streams declared for the specified component.
getComponentTasks(String) - Method in class backtype.storm.task.GeneralTopologyContext
Gets the task ids allocated for the given component id.
getConf() - Method in class backtype.storm.scheduler.TopologyDetails
 
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 class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
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.IOpaquePartitionedTransactionalSpout
 
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
 
getCoordinator(String, Map, TopologyContext) - Method in class storm.trident.spout.BatchSpoutExecutor
 
getCoordinator(Map, TopologyContext) - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout
 
getCoordinator(Map, TopologyContext) - Method in interface storm.trident.spout.IPartitionedTridentSpout
 
getCoordinator(String, Map, TopologyContext) - Method in interface storm.trident.spout.ITridentSpout
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(String, Map, TopologyContext) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
 
getCoordinator(String, Map, TopologyContext) - Method in class storm.trident.spout.PartitionedTridentSpoutExecutor
 
getCoordinator(String, Map, TopologyContext) - Method in class storm.trident.spout.RichSpoutBatchExecutor
 
getCoordinator(String, Map, TopologyContext) - Method in class storm.trident.testing.FeederBatchSpout
 
getCoordinator(String, Map, TopologyContext) - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
getCurr() - Method in class storm.trident.state.OpaqueValue
 
getCurrTxid() - Method in class storm.trident.state.OpaqueValue
 
getDaemonConf() - Method in class backtype.storm.testing.MkClusterParam
 
getData() - Method in class backtype.storm.testing.MockedSources
 
getData(String) - Method in class backtype.storm.transactional.state.TransactionalState
 
getData(String) - Method in class storm.trident.topology.state.TransactionalState
 
getDefaultSerializer(Class) - Method in class backtype.storm.serialization.SerializationFactory.KryoSerializableDefault
 
getDelegateCollector() - Method in class storm.trident.planner.processor.TridentContext
 
getDouble(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Double at position i in the tuple.
getDouble(int) - Method in class backtype.storm.tuple.TupleImpl
 
getDouble(int) - Method in interface storm.trident.tuple.TridentTuple
 
getDouble(int) - Method in class storm.trident.tuple.TridentTupleView
 
getDoubleByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getDoubleByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getDoubleByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getDoubleByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getEmitter(Map, TopologyContext) - Method in class backtype.storm.testing.MemoryTransactionalSpout
 
getEmitter(Map, TopologyContext) - Method in class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
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
 
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.spout.BatchSpoutExecutor
 
getEmitter(String, Map, TopologyContext) - Method in interface storm.trident.spout.ICommitterTridentSpout
 
getEmitter(Map, TopologyContext) - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout
 
getEmitter(Map, TopologyContext) - Method in interface storm.trident.spout.IPartitionedTridentSpout
 
getEmitter(String, Map, TopologyContext) - Method in interface storm.trident.spout.ITridentSpout
The emitter for a TransactionalSpout runs as many tasks across the cluster.
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
 
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.spout.PartitionedTridentSpoutExecutor
 
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.spout.RichSpoutBatchExecutor
 
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.testing.FeederBatchSpout
 
getEmitter(String, Map, TopologyContext) - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
getEndTask() - Method in class backtype.storm.scheduler.ExecutorDetails
 
getErrorsString() - Method in class backtype.storm.utils.ShellProcess
 
getExecutorData(String) - Method in class backtype.storm.task.TopologyContext
 
getExecutors() - Method in interface backtype.storm.scheduler.SchedulerAssignment
Return the executors covered by this assignments
getExecutors() - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
Return the executors covered by this assignments
getExecutors() - Method in class backtype.storm.scheduler.TopologyDetails
 
getExecutorToComponent() - Method in class backtype.storm.scheduler.TopologyDetails
 
getExecutorToSlot() - Method in interface backtype.storm.scheduler.SchedulerAssignment
get the executor -> slot map.
getExecutorToSlot() - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
 
getFieldIndex() - Method in interface storm.trident.tuple.TridentTuple.Factory
 
getFieldIndex() - Method in class storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
getFieldIndex() - Method in class storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
getFieldIndex() - Method in class storm.trident.tuple.TridentTupleView.ProjectionFactory
 
getFieldIndex() - Method in class storm.trident.tuple.TridentTupleView.RootFactory
 
getFields() - Method in interface backtype.storm.tuple.Tuple
Gets the names of the fields in this tuple.
getFields() - Method in class backtype.storm.tuple.TupleImpl
 
getFieldsDeclaration() - Method in class backtype.storm.topology.OutputFieldsGetter
 
getFloat(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Float at position i in the tuple.
getFloat(int) - Method in class backtype.storm.tuple.TupleImpl
 
getFloat(int) - Method in interface storm.trident.tuple.TridentTuple
 
getFloat(int) - Method in class storm.trident.tuple.TridentTupleView
 
getFloatByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getFloatByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getFloatByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getFloatByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getForcedScheduler() - Method in interface backtype.storm.scheduler.INimbus
 
getGlobalStreamId() - Method in class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec
 
getGroupFields() - Method in class storm.trident.fluent.GroupedStream
 
getHooks() - Method in class backtype.storm.task.TopologyContext
 
getHost() - Method in class backtype.storm.drpc.DRPCInvocationsClient
 
getHost() - Method in class backtype.storm.scheduler.SupervisorDetails
 
getHost() - Method in class backtype.storm.utils.DRPCClient
 
getHostName(Map<String, SupervisorDetails>, String) - Method in interface backtype.storm.scheduler.INimbus
 
getId() - Method in interface backtype.storm.scheduler.ISupervisor
 
getId() - Method in class backtype.storm.scheduler.SupervisorDetails
 
getId() - Method in class backtype.storm.scheduler.TopologyDetails
 
getInt(Object) - Static method in class backtype.storm.utils.Utils
 
getInteger(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Integer at position i in the tuple.
getInteger(int) - Method in class backtype.storm.tuple.TupleImpl
 
getInteger(int) - Method in interface storm.trident.tuple.TridentTuple
 
getInteger(int) - Method in class storm.trident.tuple.TridentTupleView
 
getIntegerByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getIntegerByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getIntegerByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getIntegerByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getKryo(Map) - Static method in class backtype.storm.serialization.SerializationFactory
 
getLastState() - Method in class backtype.storm.transactional.state.RotatingTransactionalState
 
getLastState() - Method in class storm.trident.topology.state.RotatingTransactionalState
 
getLong(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Long at position i in the tuple.
getLong(int) - Method in class backtype.storm.tuple.TupleImpl
 
getLong(int) - Method in interface storm.trident.tuple.TridentTuple
 
getLong(int) - Method in class storm.trident.tuple.TridentTupleView
 
getLongByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getLongByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getLongByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getLongByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getMap() - Method in class backtype.storm.tuple.TupleImpl
 
getMap() - Method in class backtype.storm.utils.IndifferentAccessMap
 
getMasterDeclarer() - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 
getMessageId() - Method in interface backtype.storm.tuple.Tuple
Gets the message id that associated with this tuple.
getMessageId() - Method in class backtype.storm.tuple.TupleImpl
 
getMeta() - Method in class backtype.storm.scheduler.SupervisorDetails
 
getMetadata() - Method in interface backtype.storm.scheduler.ISupervisor
 
getMockedSources() - Method in class backtype.storm.testing.CompleteTopologyParam
 
getName() - Method in class backtype.storm.scheduler.TopologyDetails
 
getNeedsSchedulingComponentToExecutors(TopologyDetails) - Method in class backtype.storm.scheduler.Cluster
Gets a component-id -> executors map which needs scheduling in this topology.
getNeedsSchedulingExecutorToComponents(TopologyDetails) - Method in class backtype.storm.scheduler.Cluster
Gets a executor -> component-id map which needs scheduling in this topology.
getNodeId() - Method in class backtype.storm.scheduler.WorkerSlot
 
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
 
getNumWorkers() - Method in class backtype.storm.scheduler.TopologyDetails
 
getObject() - Method in class backtype.storm.utils.MutableObject
 
getOutputFactory() - Method in class storm.trident.planner.processor.AggregateProcessor
 
getOutputFactory() - Method in class storm.trident.planner.processor.AppendCollector
 
getOutputFactory() - Method in class storm.trident.planner.processor.EachProcessor
 
getOutputFactory() - Method in class storm.trident.planner.processor.FreshCollector
 
getOutputFactory() - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
getOutputFactory() - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
getOutputFactory() - Method in class storm.trident.planner.processor.ProjectedProcessor
 
getOutputFactory() - Method in class storm.trident.planner.processor.StateQueryProcessor
 
getOutputFactory() - Method in class storm.trident.planner.SubtopologyBolt.InitialReceiver
 
getOutputFactory() - Method in interface storm.trident.planner.TridentProcessor
 
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
 
getOutputFields() - Method in class storm.trident.fluent.GroupedStream
 
getOutputFields() - Method in interface storm.trident.fluent.IAggregatableStream
 
getOutputFields() - Method in class storm.trident.spout.BatchSpoutExecutor
 
getOutputFields() - Method in interface storm.trident.spout.IBatchSpout
 
getOutputFields() - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout
 
getOutputFields() - Method in interface storm.trident.spout.IPartitionedTridentSpout
 
getOutputFields() - Method in interface storm.trident.spout.ITridentSpout
 
getOutputFields() - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
 
getOutputFields() - Method in class storm.trident.spout.PartitionedTridentSpoutExecutor
 
getOutputFields() - Method in class storm.trident.spout.RichSpoutBatchExecutor
 
getOutputFields() - Method in class storm.trident.Stream
 
getOutputFields() - Method in class storm.trident.testing.FeederBatchSpout
 
getOutputFields() - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
getOutputFields() - Method in class storm.trident.testing.FixedBatchSpout
 
getOutputFields() - Method in interface storm.trident.tuple.TridentTuple.Factory
 
getOutputFields() - Method in class storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
getOutputFields() - Method in class storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
getOutputFields() - Method in class storm.trident.tuple.TridentTupleView.ProjectionFactory
 
getOutputFields() - Method in class storm.trident.tuple.TridentTupleView.RootFactory
 
getOutputter() - Method in class backtype.storm.topology.BasicOutputCollector
 
getOutStreamId() - Method in class storm.trident.planner.processor.TridentContext
 
getParent(DirectedGraph, T) - Static method in class storm.trident.util.TridentUtils
 
getParents(DirectedGraph, T) - Static method in class storm.trident.util.TridentUtils
Assumes edge contains an index
getParentStreams() - Method in class storm.trident.planner.processor.TridentContext
 
getParentTupleFactories() - Method in class storm.trident.planner.processor.TridentContext
 
getPartitionedSpout() - Method in class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor
 
getPartitionedSpout() - Method in class storm.trident.spout.PartitionedTridentSpoutExecutor
 
getPartitionIndex() - Method in class storm.trident.operation.TridentOperationContext
 
getPIDDir() - Method in class backtype.storm.task.WorkerTopologyContext
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.scheduler.WorkerSlot
 
getPort() - Method in class backtype.storm.utils.DRPCClient
 
getPortsPerSupervisor() - Method in class backtype.storm.testing.MkClusterParam
 
getPrev() - Method in class storm.trident.state.OpaqueValue
 
getRawTopology() - Method in class backtype.storm.task.GeneralTopologyContext
Gets the Thrift object representing the topology.
getReceivers() - Method in class storm.trident.planner.processor.TridentContext
 
getResource(String) - Method in class backtype.storm.task.WorkerTopologyContext
 
getResults() - Method in class backtype.storm.testing.TupleCaptureBolt
 
getRoot() - Method in class backtype.storm.utils.VersionedStore
 
getSampleStartTime() - Method in class backtype.storm.tuple.TupleImpl
 
getSchedulerMeta() - Method in class backtype.storm.scheduler.SupervisorDetails
 
getScheme() - Method in interface backtype.storm.spout.ISchemableSpout
 
getSelfOutputFields() - Method in class storm.trident.planner.processor.TridentContext
 
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
 
getSharedExecutor() - Method in class backtype.storm.task.WorkerTopologyContext
 
getShort(int) - Method in interface backtype.storm.tuple.Tuple
Returns the Short at position i in the tuple.
getShort(int) - Method in class backtype.storm.tuple.TupleImpl
 
getShort(int) - Method in interface storm.trident.tuple.TridentTuple
 
getShort(int) - Method in class storm.trident.tuple.TridentTupleView
 
getShortByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getShortByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getShortByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getShortByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getSingleOutputStreamFields(IComponent) - Static method in class storm.trident.util.TridentUtils
 
getSourceComponent() - Method in interface backtype.storm.tuple.Tuple
Gets the id of the component that created this tuple.
getSourceComponent() - Method in class backtype.storm.tuple.TupleImpl
 
getSourceGlobalStreamid() - Method in interface backtype.storm.tuple.Tuple
Returns the global stream id (component + stream) of this tuple.
getSourceGlobalStreamid() - Method in class backtype.storm.tuple.TupleImpl
 
getSources(String) - Method in class backtype.storm.task.GeneralTopologyContext
Gets the declared inputs to the specified component.
getSourceStreamId() - Method in interface backtype.storm.tuple.Tuple
Gets the id of the stream that this tuple was emitted to.
getSourceStreamId() - Method in class backtype.storm.tuple.TupleImpl
 
getSourceTask() - Method in interface backtype.storm.tuple.Tuple
Gets the id of the task that created this tuple.
getSourceTask() - Method in class backtype.storm.tuple.TupleImpl
 
getSourceTuples() - Method in class backtype.storm.testing.FixedTupleSpout
 
getSpout() - Method in class backtype.storm.transactional.TransactionalSpoutCoordinator
 
getSpoutDeclarer() - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
getStartTask() - Method in class backtype.storm.scheduler.ExecutorDetails
 
getState() - Method in interface backtype.storm.ILocalCluster
 
getState(BigInteger, RotatingTransactionalState.StateInitializer) - Method in class backtype.storm.transactional.state.RotatingTransactionalState
 
getState(String) - Static method in class backtype.storm.utils.RegisteredGlobalState
 
getState(long, RotatingTransactionalState.StateInitializer) - Method in class storm.trident.topology.state.RotatingTransactionalState
 
getStateIndex() - Method in class storm.trident.planner.processor.TridentContext
 
getStateOrCreate(BigInteger, RotatingTransactionalState.StateInitializer) - Method in class backtype.storm.transactional.state.RotatingTransactionalState
Returns null if it was created, the value otherwise.
getStateOrCreate(long, RotatingTransactionalState.StateInitializer) - Method in class storm.trident.topology.state.RotatingTransactionalState
Returns null if it was created, the value otherwise.
getStormConf() - Method in class backtype.storm.testing.CompleteTopologyParam
 
getStormId() - Method in class backtype.storm.task.GeneralTopologyContext
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 interface backtype.storm.tuple.Tuple
Returns the String at position i in the tuple.
getString(int) - Method in class backtype.storm.tuple.TupleImpl
 
getString(int) - Method in interface storm.trident.tuple.TridentTuple
 
getString(int) - Method in class storm.trident.tuple.TridentTupleView
 
getStringByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getStringByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getStringByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getStringByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getSupervisorById(String) - Method in class backtype.storm.scheduler.Cluster
Get a specific supervisor with the nodeId
getSupervisors() - Method in class backtype.storm.scheduler.Cluster
Get all the supervisors.
getSupervisors() - Method in class backtype.storm.testing.MkClusterParam
 
getSupervisorsByHost(String) - Method in class backtype.storm.scheduler.Cluster
Get all the supervisors on the specified host.
getTargets(String) - Method in class backtype.storm.task.GeneralTopologyContext
Gets information about who is consuming the outputs of the specified component, and how.
getTaskData(String) - Method in class backtype.storm.task.TopologyContext
 
getTaskToComponent() - Method in class backtype.storm.task.GeneralTopologyContext
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()).
getThisWorkerPort() - Method in class backtype.storm.task.WorkerTopologyContext
 
getThisWorkerTasks() - Method in class backtype.storm.task.WorkerTopologyContext
Gets all the task ids that are running in this worker process (including the task for this task).
getTopologies() - Method in class backtype.storm.scheduler.Topologies
 
getTopology(String) - Method in interface backtype.storm.ILocalCluster
 
getTopology() - Method in class backtype.storm.scheduler.TopologyDetails
 
getTopology() - Method in class backtype.storm.testing.TrackedTopology
 
getTopologyConf(String) - Method in interface backtype.storm.ILocalCluster
 
getTopologyId() - Method in interface backtype.storm.scheduler.SchedulerAssignment
get the topology-id this assignment is for.
getTopologyId() - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
 
getTopologyInfo(String) - Method in interface backtype.storm.ILocalCluster
 
getTopologyName() - Method in class backtype.storm.testing.CompleteTopologyParam
 
getTransactionId() - Method in class backtype.storm.transactional.TransactionAttempt
 
getTransactionId() - Method in class storm.trident.topology.TransactionAttempt
 
getTxid() - Method in class storm.trident.state.TransactionalValue
 
getUnassignedExecutors(TopologyDetails) - Method in class backtype.storm.scheduler.Cluster
get the unassigned executors of the topology.
getUniqueStateId() - Method in class storm.trident.fluent.UniqueIdGen
 
getUniqueStateId() - Method in class storm.trident.TridentTopology
 
getUniqueStreamId() - Method in class storm.trident.fluent.UniqueIdGen
 
getUniqueStreamId() - Method in class storm.trident.TridentTopology
 
getUsedPorts(SupervisorDetails) - Method in class backtype.storm.scheduler.Cluster
Get all the used ports of this supervisor.
getVal() - Method in class storm.trident.state.TransactionalValue
 
getValue(int) - Method in interface backtype.storm.tuple.Tuple
Gets the field at position i in the tuple.
getValue(int) - Method in class backtype.storm.tuple.TupleImpl
 
getValue() - Method in class backtype.storm.utils.CRC32OutputStream
 
getValue(int) - Method in interface storm.trident.tuple.TridentTuple
 
getValue(int) - Method in class storm.trident.tuple.TridentTupleView
 
getValueByField(String) - Method in interface backtype.storm.tuple.Tuple
 
getValueByField(String) - Method in class backtype.storm.tuple.TupleImpl
 
getValueByField(String) - Method in interface storm.trident.tuple.TridentTuple
 
getValueByField(String) - Method in class storm.trident.tuple.TridentTupleView
 
getValues() - Method in interface backtype.storm.tuple.Tuple
Gets all the values in this tuple.
getValues() - Method in class backtype.storm.tuple.TupleImpl
 
getValues() - Method in interface storm.trident.tuple.TridentTuple
 
getValues() - Method in class storm.trident.tuple.TridentTupleView
 
getVIntSize(long) - Static method in class backtype.storm.utils.WritableUtils
Get the encoded length if an integer is stored in a variable-length format
global() - Method in class storm.trident.Stream
 
GlobalAggregationScheme<S extends IAggregatableStream> - Interface in storm.trident.fluent
 
GlobalBatchToPartition - Class in storm.trident.operation.impl
 
GlobalBatchToPartition() - Constructor for class storm.trident.operation.impl.GlobalBatchToPartition
 
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
 
GlobalGrouping - Class in storm.trident.partition
 
GlobalGrouping() - Constructor for class storm.trident.partition.GlobalGrouping
 
globalLock() - Static method in class backtype.storm.utils.RegisteredGlobalState
 
GraphGrouper - Class in storm.trident.graph
 
GraphGrouper(<any>, Collection<Group>) - Constructor for class storm.trident.graph.GraphGrouper
 
Group - Class in storm.trident.graph
 
Group(DirectedGraph, List<Node>) - Constructor for class storm.trident.graph.Group
 
Group(DirectedGraph, Node) - Constructor for class storm.trident.graph.Group
 
Group(Group, Group) - Constructor for class storm.trident.graph.Group
 
groupBy(Fields) - Method in class storm.trident.Stream
 
GroupCollector - Class in storm.trident.operation.impl
 
GroupCollector(TridentCollector, ComboList.Factory) - Constructor for class storm.trident.operation.impl.GroupCollector
 
GroupedAggregator - Class in storm.trident.operation.impl
 
GroupedAggregator(Aggregator, Fields, Fields, int) - Constructor for class storm.trident.operation.impl.GroupedAggregator
 
GroupedMultiReducer<T> - Interface in storm.trident.operation
 
GroupedMultiReducerExecutor - Class in storm.trident.operation.impl
 
GroupedMultiReducerExecutor(GroupedMultiReducer, List<Fields>, List<Fields>) - Constructor for class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
GroupedStream - Class in storm.trident.fluent
 
GroupedStream(Stream, Fields) - Constructor for class storm.trident.fluent.GroupedStream
 
grouping(GlobalStreamId, Grouping) - Method in interface backtype.storm.topology.InputDeclarer
 
grouping(GlobalStreamId, Grouping) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter
 

H

haltWithInterrupt() - Method in class backtype.storm.utils.DisruptorQueue
 
hasCache(BigInteger) - Method in class backtype.storm.transactional.state.RotatingTransactionalState
 
hasCache(long) - Method in class storm.trident.topology.state.RotatingTransactionalState
 
hashCode() - Method in class backtype.storm.scheduler.ExecutorDetails
 
hashCode() - Method in class backtype.storm.scheduler.WorkerSlot
 
hashCode() - Method in class backtype.storm.transactional.TransactionAttempt
 
hashCode() - Method in class backtype.storm.tuple.MessageId
 
hashCode() - Method in class backtype.storm.tuple.TupleImpl
 
hashCode() - Method in class storm.trident.graph.Group
 
hashCode() - Method in class storm.trident.planner.Node
 
hashCode() - Method in class storm.trident.topology.TransactionAttempt
 
hashCode() - Method in class storm.trident.util.IndexedEdge
 
HashMapSerializer - Class in backtype.storm.serialization.types
 
HashMapSerializer() - Constructor for class backtype.storm.serialization.types.HashMapSerializer
 
HashSetSerializer - Class in backtype.storm.serialization.types
 
HashSetSerializer() - Constructor for class backtype.storm.serialization.types.HashSetSerializer
 

I

IAggregatableStream - Interface in storm.trident.fluent
 
IBackingMap<T> - Interface in storm.trident.state.map
 
IBasicBolt - Interface in backtype.storm.topology
 
IBasicOutputCollector - Interface in backtype.storm.topology
 
IBatchBolt<T> - Interface in backtype.storm.coordination
 
IBatchSpout - Interface in storm.trident.spout
 
IBolt - Interface in backtype.storm.task
An IBolt represents a component that takes tuples as input and produces tuples as output.
IChainedAggregatorDeclarer - Interface in storm.trident.fluent
 
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
 
ICommitterTridentSpout<X> - Interface in storm.trident.spout
 
ICommitterTridentSpout.Emitter - Interface in storm.trident.spout
 
IComponent - Interface in backtype.storm.topology
Common methods for all possible components in a topology.
id - Variable in class storm.trident.planner.NodeStateInfo
 
ID_FIELD - Static variable in class storm.trident.spout.TridentSpoutExecutor
 
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
 
IdentityGrouping - Class in storm.trident.partition
 
IdentityGrouping() - Constructor for class storm.trident.partition.IdentityGrouping
 
IdentityMultiReducer - Class in storm.trident.operation.impl
 
IdentityMultiReducer() - Constructor for class storm.trident.operation.impl.IdentityMultiReducer
 
identityPartition() - Method in class storm.trident.Stream
 
IFeeder - Interface in storm.trident.testing
 
IKryoDecorator - Interface in backtype.storm.serialization
 
ILocalCluster - Interface in backtype.storm
 
ILocalDRPC - Interface in backtype.storm
 
incomingGroups(Group) - Method in class storm.trident.graph.GraphGrouper
 
incomingNodes() - Method in class storm.trident.graph.Group
 
increment() - Method in class backtype.storm.utils.MutableInt
 
increment(int) - Method in class backtype.storm.utils.MutableInt
 
increment() - Method in class backtype.storm.utils.MutableLong
 
increment(long) - Method in class backtype.storm.utils.MutableLong
 
index - Variable in class storm.trident.tuple.ValuePointer
 
index - Variable in class storm.trident.util.IndexedEdge
 
IndexedEdge<T> - Class in storm.trident.util
 
IndexedEdge(T, T, int) - Constructor for class storm.trident.util.IndexedEdge
 
IndexHashBatchToPartition - Class in storm.trident.operation.impl
 
IndexHashBatchToPartition() - Constructor for class storm.trident.operation.impl.IndexHashBatchToPartition
 
IndexHashGrouping - Class in storm.trident.partition
 
IndexHashGrouping(int) - Constructor for class storm.trident.partition.IndexHashGrouping
 
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
 
INimbus - Interface in backtype.storm.scheduler
 
init(BigInteger, Object) - Method in interface backtype.storm.transactional.state.RotatingTransactionalState.StateInitializer
 
init(TridentCollector) - Method in class storm.trident.drpc.ReturnResultsReducer
 
init(Object, TridentCollector) - Method in interface storm.trident.operation.Aggregator
 
init(TridentTuple) - Method in class storm.trident.operation.builtin.Count
 
init(Object, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNAgg
 
init(Object, TridentCollector) - Method in class storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
init(TridentTuple) - Method in class storm.trident.operation.builtin.Sum
 
init(TridentTuple) - Method in interface storm.trident.operation.CombinerAggregator
 
init(TridentCollector, TridentTuple) - Method in interface storm.trident.operation.GroupedMultiReducer
 
init(Object, TridentCollector) - Method in class storm.trident.operation.impl.ChainedAggregatorImpl
 
init(Object, TridentCollector) - Method in class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
init(Object, TridentCollector) - Method in class storm.trident.operation.impl.GroupedAggregator
 
init(TridentCollector) - Method in class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
init(TridentCollector) - Method in class storm.trident.operation.impl.IdentityMultiReducer
 
init(TridentCollector, TridentTuple) - Method in class storm.trident.operation.impl.JoinerMultiReducer
 
init(Object, TridentCollector) - Method in class storm.trident.operation.impl.ReducerAggregatorImpl
 
init(Object, TridentCollector) - Method in class storm.trident.operation.impl.SingleEmitAggregator
 
init(TridentCollector) - Method in interface storm.trident.operation.MultiReducer
 
init() - Method in interface storm.trident.operation.ReducerAggregator
 
init(Object, TridentCollector) - Method in class storm.trident.testing.CountAsAggregator
 
init(long, Object) - Method in interface storm.trident.topology.state.RotatingTransactionalState.StateInitializer
 
INIT_TXID - Static variable in class backtype.storm.transactional.TransactionalSpoutCoordinator
 
INIT_TXID - Static variable in class storm.trident.topology.MasterBatchCoordinator
 
initBatchState(String, Object) - Method in class storm.trident.planner.SubtopologyBolt
 
initBatchState(String, Object) - Method in class storm.trident.spout.TridentSpoutExecutor
 
initBatchState(String, Object) - Method in interface storm.trident.topology.ITridentBatchBolt
 
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
 
initializeTransaction(long, Object) - Method in class storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
initializeTransaction(long, X) - Method in interface storm.trident.spout.ITridentSpout.BatchCoordinator
Create metadata for this particular transaction id which has never been emitted before.
initializeTransaction(long, Object) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
initializeTransaction(long, Map<Integer, List<List<Object>>>) - Method in class storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
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.Coordinator - Interface in backtype.storm.transactional.partitioned
 
IOpaquePartitionedTransactionalSpout.Emitter<X> - Interface in backtype.storm.transactional.partitioned
 
IOpaquePartitionedTridentSpout<T> - Interface in storm.trident.spout
This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.
IOpaquePartitionedTridentSpout.Coordinator - Interface in storm.trident.spout
 
IOpaquePartitionedTridentSpout.Emitter<X> - Interface in storm.trident.spout
 
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
 
IPartitionedTridentSpout<T> - Interface in storm.trident.spout
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
IPartitionedTridentSpout.Coordinator - Interface in storm.trident.spout
 
IPartitionedTridentSpout.Emitter<X> - Interface in storm.trident.spout
 
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
 
isAcked(Object) - Method in class backtype.storm.testing.AckFailMapTracker
 
IScheduler - Interface in backtype.storm.scheduler
 
ISchemableSpout - Interface in backtype.storm.spout
 
isEmpty() - Method in class backtype.storm.utils.IndifferentAccessMap
 
isEmpty() - Method in class backtype.storm.utils.ListDelegate
 
isExecutorAssigned(ExecutorDetails) - Method in interface backtype.storm.scheduler.SchedulerAssignment
is the executor assigned?
isExecutorAssigned(ExecutorDetails) - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
 
isExhaustedTuples() - Method in class backtype.storm.testing.MemoryTransactionalSpout
 
isExhaustedTuples() - Method in class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
isFailed(Object) - Method in class backtype.storm.testing.AckFailMapTracker
 
isKeep(TridentTuple) - Method in class storm.trident.operation.builtin.Debug
 
isKeep(TridentTuple) - Method in class storm.trident.operation.builtin.Equals
 
isKeep(TridentTuple) - Method in class storm.trident.operation.builtin.FilterNull
 
isKeep(TridentTuple) - Method in class storm.trident.operation.builtin.Negate
 
isKeep(TridentTuple) - Method in interface storm.trident.operation.Filter
 
isKeep(TridentTuple) - Method in class storm.trident.operation.impl.TrueFilter
 
isKeep(TridentTuple) - Method in class storm.trident.testing.TrueFilter
 
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
 
ISpoutWaitStrategy - Interface in backtype.storm.spout
The strategy a spout needs to use when its waiting.
isReady() - Method in interface backtype.storm.transactional.ITransactionalSpout.Coordinator
Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).
isReady() - Method in interface backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Coordinator
Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).
isReady() - Method in interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout.Coordinator
Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).
isReady() - Method in class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator
 
isReady(long) - Method in class storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
isReady(long) - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout.Coordinator
 
isReady(long) - Method in interface storm.trident.spout.IPartitionedTridentSpout.Coordinator
 
isReady(long) - Method in interface storm.trident.spout.ITridentSpout.BatchCoordinator
 
isReady(long) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
isReady(long) - Method in class storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
isSimulating() - Static method in class backtype.storm.utils.Time
 
isSlotOccupied(WorkerSlot) - Method in class backtype.storm.scheduler.Cluster
Checks the specified slot is occupied.
isSlotOccupied(WorkerSlot) - Method in interface backtype.storm.scheduler.SchedulerAssignment
Does this slot occupied by this assignment?
isSlotOccupied(WorkerSlot) - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
Does this slot occupied by this assignment?
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
 
ISupervisor - Interface in backtype.storm.scheduler
 
isValidConf(Map<String, Object>) - Static method in class backtype.storm.utils.Utils
 
ISynchronizeOutputCollector - Interface in backtype.storm.state
 
ITaskHook - Interface in backtype.storm.hooks
 
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
 
ITridentBatchBolt - Interface in storm.trident.topology
 
ITridentSpout<T> - Interface in storm.trident.spout
 
ITridentSpout.BatchCoordinator<X> - Interface in storm.trident.spout
 
ITridentSpout.Emitter<X> - Interface in storm.trident.spout
 
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
 
join(Stream, Fields, Stream, Fields, Fields) - Method in class storm.trident.TridentTopology
 
join(List<Stream>, List<Fields>, Fields) - Method in class storm.trident.TridentTopology
 
join(Stream, Fields, Stream, Fields, Fields, JoinType) - Method in class storm.trident.TridentTopology
 
join(List<Stream>, List<Fields>, Fields, JoinType) - Method in class storm.trident.TridentTopology
 
join(Stream, Fields, Stream, Fields, Fields, List<JoinType>) - Method in class storm.trident.TridentTopology
 
join(List<Stream>, List<Fields>, Fields, List<JoinType>) - Method in class storm.trident.TridentTopology
 
JoinerMultiReducer - Class in storm.trident.operation.impl
 
JoinerMultiReducer(List<JoinType>, int, List<Fields>) - Constructor for class storm.trident.operation.impl.JoinerMultiReducer
 
JoinerMultiReducer.JoinState - Class in storm.trident.operation.impl
 
JoinerMultiReducer.JoinState(int, TridentTuple) - Constructor for class storm.trident.operation.impl.JoinerMultiReducer.JoinState
 
JoinResult - Class in backtype.storm.drpc
 
JoinResult(String) - Constructor for class backtype.storm.drpc.JoinResult
 
JoinType - Enum in storm.trident
 
JSONNonTransactionalSerializer - Class in storm.trident.state
 
JSONNonTransactionalSerializer() - Constructor for class storm.trident.state.JSONNonTransactionalSerializer
 
JSONOpaqueSerializer - Class in storm.trident.state
 
JSONOpaqueSerializer() - Constructor for class storm.trident.state.JSONOpaqueSerializer
 
JSONTransactionalSerializer - Class in storm.trident.state
 
JSONTransactionalSerializer() - Constructor for class storm.trident.state.JSONTransactionalSerializer
 

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
 
killedWorker(int) - Method in interface backtype.storm.scheduler.ISupervisor
 
killTopology(String) - Method in interface backtype.storm.ILocalCluster
 
killTopologyWithOpts(String, KillOptions) - Method in interface backtype.storm.ILocalCluster
 
KryoTupleDeserializer - Class in backtype.storm.serialization
 
KryoTupleDeserializer(Map, GeneralTopologyContext) - Constructor for class backtype.storm.serialization.KryoTupleDeserializer
 
KryoTupleSerializer - Class in backtype.storm.serialization
 
KryoTupleSerializer(Map, GeneralTopologyContext) - 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
 
launch(Map, TopologyContext) - Method in class backtype.storm.utils.ShellProcess
 
LinearDRPCInputDeclarer - Interface in backtype.storm.drpc
 
LinearDRPCTopologyBuilder - Class in backtype.storm.drpc
Deprecated. 
LinearDRPCTopologyBuilder(String) - Constructor for class backtype.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.  
list(String) - Method in class backtype.storm.transactional.state.TransactionalState
 
list(String) - Method in class storm.trident.topology.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
 
localOrShuffleGrouping() - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer
 
localOrShuffleGrouping(String) - Method in interface backtype.storm.drpc.LinearDRPCInputDeclarer
 
localOrShuffleGrouping(String) - Method in interface backtype.storm.topology.InputDeclarer
 
localOrShuffleGrouping(String, String) - Method in interface backtype.storm.topology.InputDeclarer
 
localOrShuffleGrouping(String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter
 
localOrShuffleGrouping(String, String) - Method in class backtype.storm.topology.TopologyBuilder.BoltGetter
 
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.spout.ShellSpout
 
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
 
LOG - Static variable in class storm.trident.spout.TridentSpoutCoordinator
 
LOG - Static variable in class storm.trident.spout.TridentSpoutExecutor
 
LOG - Static variable in class storm.trident.topology.MasterBatchCoordinator
 
LRUMap<A,B> - Class in storm.trident.util
 
LRUMap(int) - Constructor for class storm.trident.util.LRUMap
 
LRUMemoryMapState<T> - Class in storm.trident.testing
 
LRUMemoryMapState(int, String) - Constructor for class storm.trident.testing.LRUMemoryMapState
 
LRUMemoryMapState.Factory - Class in storm.trident.testing
 
LRUMemoryMapState.Factory(int) - Constructor for class storm.trident.testing.LRUMemoryMapState.Factory
 

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
 
makeProjectionFactory(int, Fields) - Method in class storm.trident.operation.TridentMultiReducerContext
 
makeProjectionFactory(Fields) - Method in class storm.trident.operation.TridentOperationContext
 
makeRootId(long, long) - Static method in class backtype.storm.tuple.MessageId
 
makeState(Map, int, int) - Method in interface storm.trident.state.StateFactory
 
makeState(Map, int, int) - Method in class storm.trident.testing.LRUMemoryMapState.Factory
 
makeState(Map, int, int) - Method in class storm.trident.testing.MemoryMapState.Factory
 
makeUnanchored() - Static method in class backtype.storm.tuple.MessageId
 
MapCombinerAggStateUpdater - Class in storm.trident.state.map
 
MapCombinerAggStateUpdater(CombinerAggregator, Fields, Fields) - Constructor for class storm.trident.state.map.MapCombinerAggStateUpdater
 
MapGet - Class in storm.trident.operation.builtin
 
MapGet() - Constructor for class storm.trident.operation.builtin.MapGet
 
MapReducerAggStateUpdater - Class in storm.trident.state.map
 
MapReducerAggStateUpdater(ReducerAggregator, Fields, Fields) - Constructor for class storm.trident.state.map.MapReducerAggStateUpdater
 
MapState<T> - Interface in storm.trident.state.map
 
MasterBatchCoordinator - Class in storm.trident.topology
 
MasterBatchCoordinator(List<String>, List<ITridentSpout>) - Constructor for class storm.trident.topology.MasterBatchCoordinator
 
MAX_BATCH_SIZE_CONF - Static variable in class storm.trident.spout.RichSpoutBatchExecutor
 
maxTopologyMessageTimeout() - Method in class backtype.storm.task.GeneralTopologyContext
 
MemoryMapState<T> - Class in storm.trident.testing
 
MemoryMapState(String) - Constructor for class storm.trident.testing.MemoryMapState
 
MemoryMapState.Factory - Class in storm.trident.testing
 
MemoryMapState.Factory() - Constructor for class storm.trident.testing.MemoryMapState.Factory
 
MemoryTransactionalSpout - Class in backtype.storm.testing
 
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
 
merge(Fields, Stream...) - Method in class storm.trident.TridentTopology
 
merge(Fields, List<Stream>) - Method in class storm.trident.TridentTopology
 
merge(Stream...) - Method in class storm.trident.TridentTopology
 
merge(List<Stream>) - Method in class storm.trident.TridentTopology
 
mergeFully() - Method in class storm.trident.graph.GraphGrouper
 
messageId - Variable in class backtype.storm.hooks.info.SpoutAckInfo
 
messageId - Variable in class backtype.storm.hooks.info.SpoutFailInfo
 
MessageId - Class in backtype.storm.tuple
 
MessageId(Map<Long, Long>) - Constructor for class backtype.storm.tuple.MessageId
 
meta() - Method in class backtype.storm.tuple.TupleImpl
 
mixed(JoinType...) - Static method in enum storm.trident.JoinType
 
MkClusterParam - Class in backtype.storm.testing
The param arg for Testing.withSimulatedTimeCluster and Testing.withTrackedCluster
MkClusterParam() - Constructor for class backtype.storm.testing.MkClusterParam
 
mkdir(String) - Method in class backtype.storm.transactional.state.TransactionalState
 
mkdir(String) - Method in class storm.trident.topology.state.TransactionalState
 
MockedSources - Class in backtype.storm.testing
 
MockedSources() - Constructor for class backtype.storm.testing.MockedSources
 
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
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.CachedBatchReadsMap
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.CachedMap
 
multiGet(List<List<Object>>) - Method in interface storm.trident.state.map.IBackingMap
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.NonTransactionalMap
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.OpaqueMap
 
multiGet(List<List<Object>>) - Method in interface storm.trident.state.map.ReadOnlyMapState
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.SnapshottableMap
 
multiGet(List<List<Object>>) - Method in class storm.trident.state.map.TransactionalMap
 
multiGet(List<List<Object>>) - Method in class storm.trident.testing.LRUMemoryMapState
 
multiGet(List<List<Object>>) - Method in class storm.trident.testing.MemoryMapState
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.CachedBatchReadsMap
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.CachedMap
 
multiPut(List<List<Object>>, List<T>) - Method in interface storm.trident.state.map.IBackingMap
 
multiPut(List<List<Object>>, List<T>) - Method in interface storm.trident.state.map.MapState
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.NonTransactionalMap
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.OpaqueMap
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.SnapshottableMap
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.state.map.TransactionalMap
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.testing.LRUMemoryMapState
 
multiPut(List<List<Object>>, List<T>) - Method in class storm.trident.testing.MemoryMapState
 
multiReduce(Stream, Stream, MultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(Fields, Stream, Fields, Stream, MultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(GroupedStream, GroupedStream, GroupedMultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(Fields, GroupedStream, Fields, GroupedStream, GroupedMultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(List<Stream>, MultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(List<GroupedStream>, GroupedMultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(List<Fields>, List<Stream>, MultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
multiReduce(List<Fields>, List<GroupedStream>, GroupedMultiReducer, Fields) - Method in class storm.trident.TridentTopology
 
MultiReducer<T> - Interface in storm.trident.operation
 
MultiReducerProcessor - Class in storm.trident.planner.processor
 
MultiReducerProcessor(List<Fields>, MultiReducer) - Constructor for class storm.trident.planner.processor.MultiReducerProcessor
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in class storm.trident.state.map.CachedBatchReadsMap
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in interface storm.trident.state.map.MapState
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in class storm.trident.state.map.NonTransactionalMap
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in class storm.trident.state.map.OpaqueMap
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in class storm.trident.state.map.SnapshottableMap
 
multiUpdate(List<List<Object>>, List<ValueUpdater>) - Method in class storm.trident.state.map.TransactionalMap
 
MutableInt - Class in backtype.storm.utils
 
MutableInt(int) - Constructor for class backtype.storm.utils.MutableInt
 
MutableLong - Class in backtype.storm.utils
 
MutableLong(long) - Constructor for class backtype.storm.utils.MutableLong
 
MutableObject - Class in backtype.storm.utils
 
MutableObject() - Constructor for class backtype.storm.utils.MutableObject
 
MutableObject(Object) - Constructor for class backtype.storm.utils.MutableObject
 

N

needsScheduling(TopologyDetails) - Method in class backtype.storm.scheduler.Cluster
Does the topology need scheduling? A topology needs scheduling if one of the following conditions holds: Although the topology is assigned slots, but is squeezed.
needsSchedulingTopologies(Topologies) - Method in class backtype.storm.scheduler.Cluster
Gets all the topologies which needs scheduling.
Negate - Class in storm.trident.operation.builtin
 
Negate(Filter) - Constructor for class storm.trident.operation.builtin.Negate
 
newCoordinatorState(Map, String, Map) - Static method in class backtype.storm.transactional.state.TransactionalState
 
newCoordinatorState(Map, String) - Static method in class storm.trident.topology.state.TransactionalState
 
newCurator(Map, List<String>, Object, String) - Static method in class backtype.storm.utils.Utils
 
newCurator(Map, List<String>, Object, String, ZookeeperAuthInfo) - 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
 
newDRPCStream(String) - Method in class storm.trident.TridentTopology
 
newDRPCStream(String, ILocalDRPC) - Method in class storm.trident.TridentTopology
 
newInstance() - Method in class backtype.storm.utils.DisruptorQueue.ObjectEventFactory
 
newStaticState(StateFactory) - Method in class storm.trident.TridentTopology
 
newStaticState(StateSpec) - Method in class storm.trident.TridentTopology
 
newStream(String, IRichSpout) - Method in class storm.trident.TridentTopology
 
newStream(String, IBatchSpout) - Method in class storm.trident.TridentTopology
 
newStream(String, ITridentSpout) - Method in class storm.trident.TridentTopology
 
newStream(String, IPartitionedTridentSpout) - Method in class storm.trident.TridentTopology
 
newStream(String, IOpaquePartitionedTridentSpout) - Method in class storm.trident.TridentTopology
 
newUserState(Map, String, Map) - Static method in class backtype.storm.transactional.state.TransactionalState
 
newUserState(Map, String) - Static method in class storm.trident.topology.state.TransactionalState
 
newValuesStream() - Method in class storm.trident.TridentState
 
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.NoOpSpout
 
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
 
nextTuple() - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
nextTuple() - Method in class storm.trident.topology.MasterBatchCoordinator
 
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
 
Node - Class in storm.trident.planner
 
Node(String, Fields) - Constructor for class storm.trident.planner.Node
 
nodeGroup(Node) - Method in class storm.trident.graph.GraphGrouper
 
nodes - Variable in class storm.trident.graph.Group
 
NodeStateInfo - Class in storm.trident.planner
 
NodeStateInfo(String, StateSpec) - Constructor for class storm.trident.planner.NodeStateInfo
 
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
 
NonTransactionalMap<T> - Class in storm.trident.state.map
 
NonTransactionalMap(IBackingMap<T>) - Constructor for class storm.trident.state.map.NonTransactionalMap
 
NoOpSpout - Class in backtype.storm.spout
 
NoOpSpout() - Constructor for class backtype.storm.spout.NoOpSpout
 
NothingEmptyEmitStrategy - Class in backtype.storm.spout
 
NothingEmptyEmitStrategy() - Constructor for class backtype.storm.spout.NothingEmptyEmitStrategy
 
nth(int) - Method in class backtype.storm.tuple.TupleImpl
 
nth(int, Object) - Method in class backtype.storm.tuple.TupleImpl
 
numDelegates() - Method in interface storm.trident.tuple.TridentTuple.Factory
 
numDelegates() - Method in class storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
numDelegates() - Method in class storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
numDelegates() - Method in class storm.trident.tuple.TridentTupleView.ProjectionFactory
 
numDelegates() - Method in class storm.trident.tuple.TridentTupleView.RootFactory
 
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.
numPartitions() - Method in class storm.trident.operation.TridentOperationContext
 
numPartitions() - Method in interface storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter
 
numPartitions() - Method in interface storm.trident.spout.IPartitionedTridentSpout.Coordinator
Return the number of partitions currently in the source of data.

O

obj - Variable in class storm.trident.operation.impl.Result
 
object - Variable in class backtype.storm.utils.Container
 
objectToIndex(Object, int) - Static method in class storm.trident.partition.IndexHashGrouping
 
OpaqueMap<T> - Class in storm.trident.state.map
 
OpaqueMap(IBackingMap<OpaqueValue>) - Constructor for class storm.trident.state.map.OpaqueMap
 
OpaqueMemoryTransactionalSpout - Class in backtype.storm.testing
This spout only works in local mode.
OpaqueMemoryTransactionalSpout(Map<Integer, List<List<Object>>>, Fields, int) - Constructor for class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
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(Map, TopologyContext) - 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
 
OpaquePartitionedTridentSpoutExecutor - Class in storm.trident.spout
 
OpaquePartitionedTridentSpoutExecutor(IOpaquePartitionedTridentSpout) - Constructor for class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
 
OpaquePartitionedTridentSpoutExecutor.Coordinator - Class in storm.trident.spout
 
OpaquePartitionedTridentSpoutExecutor.Coordinator(Map, TopologyContext) - Constructor for class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
OpaquePartitionedTridentSpoutExecutor.Emitter - Class in storm.trident.spout
 
OpaquePartitionedTridentSpoutExecutor.Emitter(String, Map, TopologyContext) - Constructor for class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
OpaqueValue<T> - Class in storm.trident.state
 
OpaqueValue(Long, T, T) - Constructor for class storm.trident.state.OpaqueValue
 
OpaqueValue(Long, T) - Constructor for class storm.trident.state.OpaqueValue
 
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.NoOpSpout
 
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
 
open(Map, TopologyContext) - Method in interface storm.trident.spout.IBatchSpout
 
open(Map, TopologyContext, SpoutOutputCollector) - Method in class storm.trident.spout.RichSpoutBatchTriggerer
 
open(Map, TopologyContext) - Method in class storm.trident.testing.FixedBatchSpout
 
open(Map, TopologyContext, SpoutOutputCollector) - Method in class storm.trident.topology.MasterBatchCoordinator
 
Operation - Interface in storm.trident.operation
 
outgoingGroups(Group) - Method in class storm.trident.graph.GraphGrouper
 
outgoingNodes() - Method in class storm.trident.graph.Group
 
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
 
outTasks - Variable in class backtype.storm.hooks.info.EmitInfo
 
overrideDefault(boolean) - Method in class backtype.storm.serialization.SerializationFactory.KryoSerializableDefault
 
overrideState(BigInteger, Object) - Method in class backtype.storm.transactional.state.RotatingTransactionalState
 
overrideState(long, Object) - Method in class storm.trident.topology.state.RotatingTransactionalState
 

P

parallelismHint - Variable in class storm.trident.planner.Node
 
parallelismHint(int) - Method in class storm.trident.Stream
 
parallelismHint(int) - Method in class storm.trident.TridentState
 
partition(Stream) - Method in interface storm.trident.fluent.ChainedAggregatorDeclarer.AggregationPartition
 
partition(CustomStreamGrouping) - Method in class storm.trident.Stream
 
partition(Grouping) - Method in class storm.trident.Stream
 
partitionAggregate(Aggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(Fields, Aggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(CombinerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(Fields, CombinerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(ReducerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(Fields, ReducerAggregator, Fields) - Method in class storm.trident.fluent.ChainedAggregatorDeclarer
 
partitionAggregate(Aggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(Fields, Aggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(CombinerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(Fields, CombinerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(ReducerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(Fields, ReducerAggregator, Fields) - Method in interface storm.trident.fluent.ChainedPartitionAggregatorDeclarer
 
partitionAggregate(Fields, Aggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
partitionAggregate(Fields, Aggregator, Fields) - Method in interface storm.trident.fluent.IAggregatableStream
 
partitionAggregate(Fields, Aggregator, Fields) - Method in class storm.trident.Stream
 
partitionAggregate(Aggregator, Fields) - Method in class storm.trident.Stream
 
partitionAggregate(CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
partitionAggregate(Fields, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
partitionAggregate(ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
partitionAggregate(Fields, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
partitionBy(Fields) - Method in class storm.trident.Stream
 
PartitionedTransactionalSpoutExecutor - Class in backtype.storm.transactional.partitioned
 
PartitionedTransactionalSpoutExecutor(IPartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor
 
PartitionedTridentSpoutExecutor - Class in storm.trident.spout
 
PartitionedTridentSpoutExecutor(IPartitionedTridentSpout) - Constructor for class storm.trident.spout.PartitionedTridentSpoutExecutor
 
partitionIndex(Object, int) - Method in class storm.trident.operation.impl.GlobalBatchToPartition
 
partitionIndex(Object, int) - Method in class storm.trident.operation.impl.IndexHashBatchToPartition
 
partitionIndex(Object, int) - Method in interface storm.trident.operation.impl.SingleEmitAggregator.BatchToPartition
 
PartitionNode - Class in storm.trident.planner
 
PartitionNode(String, Fields, Grouping) - Constructor for class storm.trident.planner.PartitionNode
 
partitionPersist(StateFactory, Fields, StateUpdater, Fields) - Method in class storm.trident.Stream
 
partitionPersist(StateSpec, Fields, StateUpdater, Fields) - Method in class storm.trident.Stream
 
partitionPersist(StateFactory, Fields, StateUpdater) - Method in class storm.trident.Stream
 
partitionPersist(StateSpec, Fields, StateUpdater) - Method in class storm.trident.Stream
 
partitionPersist(StateFactory, StateUpdater, Fields) - Method in class storm.trident.Stream
 
partitionPersist(StateSpec, StateUpdater, Fields) - Method in class storm.trident.Stream
 
partitionPersist(StateFactory, StateUpdater) - Method in class storm.trident.Stream
 
partitionPersist(StateSpec, StateUpdater) - Method in class storm.trident.Stream
 
PartitionPersistProcessor - Class in storm.trident.planner.processor
 
PartitionPersistProcessor(String, Fields, StateUpdater) - Constructor for class storm.trident.planner.processor.PartitionPersistProcessor
 
payload - Variable in class backtype.storm.utils.ZookeeperAuthInfo
 
persistentAggregate(StateFactory, CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateSpec, CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateFactory, Fields, CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateSpec, Fields, CombinerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateFactory, Fields, ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateSpec, Fields, ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateFactory, ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateSpec, ReducerAggregator, Fields) - Method in class storm.trident.fluent.GroupedStream
 
persistentAggregate(StateFactory, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateSpec, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateFactory, Fields, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateSpec, Fields, CombinerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateFactory, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateSpec, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateFactory, Fields, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
persistentAggregate(StateSpec, Fields, ReducerAggregator, Fields) - Method in class storm.trident.Stream
 
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(WorkerTopologyContext, GlobalStreamId, List<Integer>) - Method in interface backtype.storm.grouping.CustomStreamGrouping
Tells the stream grouping at runtime the tasks in the target bolt.
prepare(Map, TopologyContext) - Method in class backtype.storm.hooks.BaseTaskHook
 
prepare(Map, TopologyContext) - Method in interface backtype.storm.hooks.ITaskHook
 
prepare(Map, String) - Method in interface backtype.storm.scheduler.INimbus
 
prepare(Map, String) - Method in interface backtype.storm.scheduler.ISupervisor
 
prepare(Map) - Method in interface backtype.storm.spout.ISpoutWaitStrategy
 
prepare(Map) - Method in class backtype.storm.spout.NothingEmptyEmitStrategy
 
prepare(Map) - Method in class backtype.storm.spout.SleepSpoutWaitStrategy
 
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.BatchNumberList
 
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(WorkerTopologyContext, GlobalStreamId, List<Integer>) - 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
 
prepare(Map, TridentMultiReducerContext) - Method in class storm.trident.drpc.ReturnResultsReducer
 
prepare(Map, TridentMultiReducerContext) - Method in class storm.trident.operation.BaseMultiReducer
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.BaseOperation
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.builtin.Negate
 
prepare(Map, TridentMultiReducerContext) - Method in interface storm.trident.operation.GroupedMultiReducer
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.ChainedAggregatorImpl
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.CombinerAggregatorInitImpl
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.CombinerAggStateUpdater
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.FilterExecutor
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.GroupedAggregator
 
prepare(Map, TridentMultiReducerContext) - Method in class storm.trident.operation.impl.GroupedMultiReducerExecutor
 
prepare(Map, TridentMultiReducerContext) - Method in class storm.trident.operation.impl.IdentityMultiReducer
 
prepare(Map, TridentMultiReducerContext) - Method in class storm.trident.operation.impl.JoinerMultiReducer
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.ReducerAggregatorImpl
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.ReducerAggStateUpdater
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.SingleEmitAggregator
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.operation.impl.TrueFilter
 
prepare(Map, TridentMultiReducerContext) - Method in interface storm.trident.operation.MultiReducer
 
prepare(Map, TridentOperationContext) - Method in interface storm.trident.operation.Operation
 
prepare(WorkerTopologyContext, GlobalStreamId, List<Integer>) - Method in class storm.trident.partition.GlobalGrouping
 
prepare(WorkerTopologyContext, GlobalStreamId, List<Integer>) - Method in class storm.trident.partition.IdentityGrouping
 
prepare(WorkerTopologyContext, GlobalStreamId, List<Integer>) - Method in class storm.trident.partition.IndexHashGrouping
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.AggregateProcessor
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.EachProcessor
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.ProjectedProcessor
 
prepare(Map, TopologyContext, TridentContext) - Method in class storm.trident.planner.processor.StateQueryProcessor
 
prepare(Map, TopologyContext, BatchOutputCollector) - Method in class storm.trident.planner.SubtopologyBolt
 
prepare(Map, TopologyContext, TridentContext) - Method in interface storm.trident.planner.TridentProcessor
 
prepare(Map, TopologyContext) - Method in class storm.trident.spout.TridentSpoutCoordinator
 
prepare(Map, TopologyContext, BatchOutputCollector) - Method in class storm.trident.spout.TridentSpoutExecutor
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.state.map.MapCombinerAggStateUpdater
 
prepare(Map, TridentOperationContext) - Method in class storm.trident.state.map.MapReducerAggStateUpdater
 
prepare(Map, TopologyContext, BatchOutputCollector) - Method in interface storm.trident.topology.ITridentBatchBolt
 
prepare(Map, TopologyContext, OutputCollector) - Method in class storm.trident.topology.TridentBoltExecutor
 
PrepareBatchBolt - Class in backtype.storm.testing
 
PrepareBatchBolt(Fields) - Constructor for class backtype.storm.testing.PrepareBatchBolt
 
PrepareRequest - Class in backtype.storm.drpc
 
PrepareRequest() - Constructor for class backtype.storm.drpc.PrepareRequest
 
processLatencyMs - Variable in class backtype.storm.hooks.info.BoltAckInfo
 
processor - Variable in class storm.trident.planner.ProcessorNode
 
ProcessorContext - Class in storm.trident.planner
 
ProcessorContext(Object, Object[]) - Constructor for class storm.trident.planner.ProcessorContext
 
ProcessorNode - Class in storm.trident.planner
 
ProcessorNode(String, Fields, Fields, TridentProcessor) - Constructor for class storm.trident.planner.ProcessorNode
 
project(Fields) - Method in class storm.trident.Stream
 
ProjectedProcessor - Class in storm.trident.planner.processor
 
ProjectedProcessor(Fields) - Constructor for class storm.trident.planner.processor.ProjectedProcessor
 
publish(Object) - Method in class backtype.storm.utils.DisruptorQueue
 
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.RotatingMap
 
put(K, V) - Method in class backtype.storm.utils.TimeCacheMap
Deprecated.  
putAll(Map) - Method in class backtype.storm.utils.IndifferentAccessMap
 

Q

QueryFunction<S extends State,T> - Interface in storm.trident.state
 

R

RawScheme - Class in backtype.storm.spout
 
RawScheme() - Constructor for class backtype.storm.spout.RawScheme
 
read(Kryo, Input, Class) - Method in class backtype.storm.serialization.SerializableSerializer
 
read() - Method in class backtype.storm.utils.BufferFileInputStream
 
readCommandLineOpts() - Static method in class backtype.storm.utils.Utils
 
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
 
readMessage() - Method in class backtype.storm.utils.ShellProcess
 
ReadOnlyMapState<T> - Interface in storm.trident.state.map
 
ReadOnlySnapshottable<T> - Interface in storm.trident.state.snapshot
 
ReadOnlyState - Class in storm.trident.state
 
ReadOnlyState() - Constructor for class storm.trident.state.ReadOnlyState
 
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.
rebalance(String, RebalanceOptions) - Method in interface backtype.storm.ILocalCluster
 
receive(ProcessorContext, Tuple) - Method in class storm.trident.planner.SubtopologyBolt.InitialReceiver
 
reduce(T, TridentTuple) - Method in interface storm.trident.operation.ReducerAggregator
 
ReducerAggregator<T> - Interface in storm.trident.operation
 
ReducerAggregatorImpl - Class in storm.trident.operation.impl
 
ReducerAggregatorImpl(ReducerAggregator) - Constructor for class storm.trident.operation.impl.ReducerAggregatorImpl
 
ReducerAggStateUpdater - Class in storm.trident.operation.impl
 
ReducerAggStateUpdater(ReducerAggregator) - Constructor for class storm.trident.operation.impl.ReducerAggStateUpdater
 
ReducerValueUpdater - Class in storm.trident.state
 
ReducerValueUpdater(ReducerAggregator, List<TridentTuple>) - Constructor for class storm.trident.state.ReducerValueUpdater
 
registerDecorator(Class<? extends IKryoDecorator>) - Method in class backtype.storm.Config
 
RegisteredGlobalState - Class in backtype.storm.utils
This class is used as part of testing Storm.
RegisteredGlobalState() - Constructor for class backtype.storm.utils.RegisteredGlobalState
 
registerNode(Node) - Method in class storm.trident.TridentTopology
 
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
 
registerSourcedNode(List<Stream>, Node) - Method in class storm.trident.TridentTopology
 
registerState(Object) - Static method in class backtype.storm.utils.RegisteredGlobalState
 
reindex() - Method in class storm.trident.graph.GraphGrouper
 
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(Object) - Method in class backtype.storm.utils.LocalState
 
remove(K) - Method in class backtype.storm.utils.RotatingMap
 
remove(K) - Method in class backtype.storm.utils.TimeCacheMap
Deprecated.  
removeAll(Collection<?>) - Method in class backtype.storm.utils.ListDelegate
 
removeEldestEntry(Map.Entry<A, B>) - Method in class storm.trident.util.LRUMap
 
removeState(BigInteger) - Method in class backtype.storm.transactional.state.RotatingTransactionalState
 
removeState(long) - Method in class storm.trident.topology.state.RotatingTransactionalState
 
reportError(Throwable) - Method in class backtype.storm.coordination.BatchOutputCollector
 
reportError(Throwable) - Method in class backtype.storm.coordination.BatchOutputCollectorImpl
 
reportError(Throwable) - Method in class backtype.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
 
reportError(Throwable) - Method in interface backtype.storm.spout.ISpoutOutputCollector
 
reportError(Throwable) - Method in class backtype.storm.spout.SpoutOutputCollector
 
reportError(Throwable) - Method in interface backtype.storm.task.IOutputCollector
 
reportError(Throwable) - Method in class backtype.storm.task.OutputCollector
 
reportError(Throwable) - Method in class backtype.storm.topology.BasicOutputCollector
 
reportError(Throwable) - Method in interface backtype.storm.topology.IBasicOutputCollector
 
reportError(Throwable) - Method in class storm.trident.operation.impl.CaptureCollector
 
reportError(Throwable) - Method in class storm.trident.operation.impl.GroupCollector
 
reportError(Throwable) - Method in interface storm.trident.operation.TridentCollector
 
reportError(Throwable) - Method in class storm.trident.planner.processor.AppendCollector
 
reportError(Throwable) - Method in class storm.trident.planner.processor.FreshCollector
 
reportError(Throwable) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
requiredNumPartitions - Variable in class storm.trident.state.StateSpec
 
resetNumAcks() - Method in class backtype.storm.testing.AckTracker
 
result(String, String) - Method in class backtype.storm.drpc.DRPCInvocationsClient
 
Result - Class in storm.trident.operation.impl
 
Result() - Constructor for class storm.trident.operation.impl.Result
 
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
 
ReturnResultsReducer - Class in storm.trident.drpc
 
ReturnResultsReducer() - Constructor for class storm.trident.drpc.ReturnResultsReducer
 
ReturnResultsReducer.ReturnResultsState - Class in storm.trident.drpc
 
ReturnResultsReducer.ReturnResultsState() - Constructor for class storm.trident.drpc.ReturnResultsReducer.ReturnResultsState
 
reverseMap(Map<K, V>) - Static method in class backtype.storm.utils.Utils
 
RichShellBolt - Class in backtype.storm.clojure
 
RichShellBolt(String[], Map<String, StreamInfo>) - Constructor for class backtype.storm.clojure.RichShellBolt
 
RichShellSpout - Class in backtype.storm.clojure
 
RichShellSpout(String[], Map<String, StreamInfo>) - Constructor for class backtype.storm.clojure.RichShellSpout
 
RichSpoutBatchExecutor - Class in storm.trident.spout
 
RichSpoutBatchExecutor(IRichSpout) - Constructor for class storm.trident.spout.RichSpoutBatchExecutor
 
RichSpoutBatchTriggerer - Class in storm.trident.spout
 
RichSpoutBatchTriggerer(IRichSpout, String, String) - Constructor for class storm.trident.spout.RichSpoutBatchTriggerer
 
rotate() - Method in class backtype.storm.utils.RotatingMap
 
RotatingMap<K,V> - Class in backtype.storm.utils
Expires keys that have not been updated in the configured number of seconds.
RotatingMap(int, RotatingMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.RotatingMap
 
RotatingMap(RotatingMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.RotatingMap
 
RotatingMap(int) - Constructor for class backtype.storm.utils.RotatingMap
 
RotatingMap.ExpiredCallback<K,V> - Interface in backtype.storm.utils
 
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 - Class in storm.trident.topology.state
 
RotatingTransactionalState(TransactionalState, String) - Constructor for class storm.trident.topology.state.RotatingTransactionalState
 
RotatingTransactionalState.StateInitializer - Interface in backtype.storm.transactional.state
 
RotatingTransactionalState.StateInitializer - Interface in storm.trident.topology.state
 
run(ILocalCluster) - Method in interface backtype.storm.testing.TestJob
run the testing logic with the cluster.
run() - Method in class backtype.storm.utils.ClojureTimerTask
 

S

schedule(Topologies, Cluster) - Method in interface backtype.storm.scheduler.IScheduler
Set assignments for the topologies which needs scheduling.
SchedulerAssignment - Interface in backtype.storm.scheduler
 
SchedulerAssignmentImpl - Class in backtype.storm.scheduler
 
SchedulerAssignmentImpl(String, Map<ExecutorDetails, WorkerSlot>) - Constructor for class backtype.storm.scheduler.SchedulerAssignmentImpl
 
Scheme - Interface in backtype.storm.spout
 
scheme - Variable in class backtype.storm.utils.ZookeeperAuthInfo
 
secureRandomLong() - Static method in class backtype.storm.utils.Utils
 
select(Fields, List<Object>) - Method in class backtype.storm.tuple.Fields
 
select(Fields) - Method in interface backtype.storm.tuple.Tuple
Returns a subset of the tuple based on the fields selector.
select(Fields) - Method in class backtype.storm.tuple.TupleImpl
 
selectExecutorToComponent(Collection<ExecutorDetails>) - Method in class backtype.storm.scheduler.TopologyDetails
 
selfOutFields - Variable in class storm.trident.planner.ProcessorNode
 
sendMessage(int, Object) - Static method in class backtype.storm.utils.InprocMessaging
 
seq() - Method in class backtype.storm.tuple.TupleImpl
 
seq() - Method in class backtype.storm.utils.IndifferentAccessMap
 
SerializableSerializer - Class in backtype.storm.serialization
 
SerializableSerializer() - Constructor for class backtype.storm.serialization.SerializableSerializer
 
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(Output) - Method in class backtype.storm.tuple.MessageId
 
serialize(Object) - Static method in class backtype.storm.utils.Utils
 
serialize(Object) - Method in class storm.trident.state.JSONNonTransactionalSerializer
 
serialize(OpaqueValue) - Method in class storm.trident.state.JSONOpaqueSerializer
 
serialize(TransactionalValue) - Method in class storm.trident.state.JSONTransactionalSerializer
 
serialize(T) - Method in interface storm.trident.state.Serializer
 
serializeInto(List<Object>, Output) - Method in class backtype.storm.serialization.KryoValuesSerializer
 
serializeObject(Object) - Method in class backtype.storm.serialization.KryoValuesSerializer
 
Serializer<T> - Interface in storm.trident.state
 
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
 
set(int) - Method in class backtype.storm.utils.MutableInt
 
set(long) - Method in class backtype.storm.utils.MutableLong
 
set(T) - Method in class storm.trident.state.map.SnapshottableMap
 
set(T) - Method in interface storm.trident.state.snapshot.Snapshottable
 
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.
setBatchPerTupleSpout(String, String, IRichSpout, Integer, String) - Method in class storm.trident.topology.TridentTopologyBuilder
 
setBolt(String, IBatchBolt) - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 
setBolt(String, IBatchBolt, Number) - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 
setBolt(String, IBasicBolt) - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 
setBolt(String, IBasicBolt, Number) - Method in class backtype.storm.coordination.BatchSubtopologyBuilder
 
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, Number) - 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, Number) - Method in class backtype.storm.topology.TopologyBuilder
Define a new bolt in this topology.
setBolt(String, IBatchBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setBolt(String, IBatchBolt, Number) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setBolt(String, IBasicBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setBolt(String, IBasicBolt, Number) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setBolt(String, ITridentBatchBolt, Integer, Set<String>, Map<String, String>) - Method in class storm.trident.topology.TridentTopologyBuilder
 
setCleanupState(Boolean) - Method in class backtype.storm.testing.CompleteTopologyParam
 
setCollector(TridentCollector) - Method in class storm.trident.operation.impl.CaptureCollector
 
setCommitterBolt(String, IBatchBolt) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setCommitterBolt(String, IBatchBolt, Number) - Method in class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
setContext(Tuple) - Method in class backtype.storm.topology.BasicOutputCollector
 
setContext(ProcessorContext, TridentTuple) - Method in class storm.trident.planner.processor.AppendCollector
 
setContext(ProcessorContext) - Method in class storm.trident.planner.processor.FreshCollector
 
setCurrBatch(TridentBoltExecutor.TrackedBatch) - Method in class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
setCycle(boolean) - Method in class storm.trident.testing.FixedBatchSpout
 
setDaemonConf(Map) - Method in class backtype.storm.testing.MkClusterParam
 
setData(String, Object) - Method in class backtype.storm.transactional.state.TransactionalState
 
setData(String, Object) - Method in class storm.trident.topology.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
 
setDisabled(Integer, boolean) - Method in class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
setExecutorData(String, Object) - Method in class backtype.storm.task.TopologyContext
 
setFallBackOnJavaSerialization(boolean) - Method in class backtype.storm.Config
 
setFollowThroughCollector(TridentCollector) - Method in class storm.trident.operation.impl.ChainedResult
 
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(Number) - Method in class backtype.storm.topology.BaseConfigurationDeclarer
 
setMaxSpoutPending(Number) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer
 
setMaxTaskParallelism(int) - Method in class backtype.storm.Config
 
setMaxTaskParallelism(Number) - Method in class backtype.storm.topology.BaseConfigurationDeclarer
 
setMaxTaskParallelism(Number) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer
 
setMessageTimeoutSecs(int) - Method in class backtype.storm.Config
 
setMockedSources(MockedSources) - Method in class backtype.storm.testing.CompleteTopologyParam
 
setNumAckers(int) - Method in class backtype.storm.Config
 
setNumTasks(Number) - Method in class backtype.storm.topology.BaseConfigurationDeclarer
 
setNumTasks(Number) - Method in interface backtype.storm.topology.ComponentConfigurationDeclarer
 
setNumWorkers(int) - Method in class backtype.storm.Config
 
setObject(Object) - Method in class backtype.storm.utils.MutableObject
 
setOptimize(boolean) - Method in class backtype.storm.Config
 
setPortsPerSupervisor(Integer) - Method in class backtype.storm.testing.MkClusterParam
 
setSampleStartTime(long) - Method in class backtype.storm.tuple.TupleImpl
 
setScheme(Scheme) - Method in interface backtype.storm.spout.ISchemableSpout
 
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, Number) - Method in class backtype.storm.topology.TopologyBuilder
Define a new spout in this topology with the specified parallelism.
setSpout(String, String, String, IBatchSpout, Integer, String) - Method in class storm.trident.topology.TridentTopologyBuilder
 
setSpout(String, String, String, ITridentSpout, Integer, String) - Method in class storm.trident.topology.TridentTopologyBuilder
 
setState(String, Object) - Static method in class backtype.storm.utils.RegisteredGlobalState
 
setStateSpout(String, IRichStateSpout) - Method in class backtype.storm.topology.TopologyBuilder
 
setStateSpout(String, IRichStateSpout, Number) - Method in class backtype.storm.topology.TopologyBuilder
 
setStatsSampleRate(double) - Method in class backtype.storm.Config
 
setStormConf(Config) - Method in class backtype.storm.testing.CompleteTopologyParam
 
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.
setSupervisors(Integer) - Method in class backtype.storm.testing.MkClusterParam
 
setTaskData(String, Object) - Method in class backtype.storm.task.TopologyContext
 
setTopologyName(String) - Method in class backtype.storm.testing.CompleteTopologyParam
 
setWaitToEmit(boolean) - Method in class storm.trident.testing.FeederBatchSpout
 
setWaitToEmit(boolean) - Method in class storm.trident.testing.FeederCommitterBatchSpout
 
SHARED_EXECUTOR - Static variable in class backtype.storm.task.WorkerTopologyContext
 
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
 
ShellProcess - Class in backtype.storm.utils
 
ShellProcess(String[]) - Constructor for class backtype.storm.utils.ShellProcess
 
ShellSpout - Class in backtype.storm.spout
 
ShellSpout(ShellComponent) - Constructor for class backtype.storm.spout.ShellSpout
 
shuffle() - Method in class storm.trident.Stream
 
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
 
single() - Static method in class storm.trident.topology.TridentBoltExecutor.CoordType
 
singleCount - Variable in class backtype.storm.coordination.CoordinatedBolt.SourceArgs
 
singleCount - Variable in class storm.trident.topology.TridentBoltExecutor.CoordType
 
SingleEmitAggregator - Class in storm.trident.operation.impl
 
SingleEmitAggregator(Aggregator, SingleEmitAggregator.BatchToPartition) - Constructor for class storm.trident.operation.impl.SingleEmitAggregator
 
SingleEmitAggregator.BatchToPartition - Interface in storm.trident.operation.impl
 
singleEmitPartitioner() - Method in interface storm.trident.fluent.GlobalAggregationScheme
 
singleEmitPartitioner() - Method in class storm.trident.fluent.GroupedStream
 
size() - Method in class backtype.storm.tuple.Fields
 
size() - Method in interface backtype.storm.tuple.Tuple
Returns the number of fields in this tuple.
size() - Method in class backtype.storm.tuple.TupleImpl
 
size() - Method in class backtype.storm.utils.IndifferentAccessMap
 
size() - Method in class backtype.storm.utils.ListDelegate
 
size() - Method in class backtype.storm.utils.RotatingMap
 
size() - Method in class backtype.storm.utils.TimeCacheMap
Deprecated.  
size() - Method in class storm.trident.tuple.ComboList
 
size() - Method in class storm.trident.tuple.ConsList
 
size() - Method in class storm.trident.tuple.TridentTupleView
 
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
 
SleepSpoutWaitStrategy - Class in backtype.storm.spout
 
SleepSpoutWaitStrategy() - Constructor for class backtype.storm.spout.SleepSpoutWaitStrategy
 
sleepUntil(long) - Static method in class backtype.storm.utils.Time
 
snapshot() - Method in class backtype.storm.utils.LocalState
 
SnapshotGet - Class in storm.trident.operation.builtin
 
SnapshotGet() - Constructor for class storm.trident.operation.builtin.SnapshotGet
 
Snapshottable<T> - Interface in storm.trident.state.snapshot
 
SnapshottableMap<T> - Class in storm.trident.state.map
 
SnapshottableMap(MapState<T>, List<Object>) - Constructor for class storm.trident.state.map.SnapshottableMap
 
source - Variable in class storm.trident.util.IndexedEdge
 
spec - Variable in class storm.trident.planner.NodeStateInfo
 
Split - Class in storm.trident.testing
 
Split() - Constructor for class storm.trident.testing.Split
 
spout - Variable in class storm.trident.planner.SpoutNode
 
spoutAck(SpoutAckInfo) - Method in class backtype.storm.hooks.BaseTaskHook
 
spoutAck(SpoutAckInfo) - Method in interface backtype.storm.hooks.ITaskHook
 
SpoutAckInfo - Class in backtype.storm.hooks.info
 
SpoutAckInfo(Object, int, Long) - Constructor for class backtype.storm.hooks.info.SpoutAckInfo
 
spoutCoordinator(String) - Static method in class storm.trident.topology.TridentTopologyBuilder
 
SpoutDeclarer - Interface in backtype.storm.topology
 
spoutFail(SpoutFailInfo) - Method in class backtype.storm.hooks.BaseTaskHook
 
spoutFail(SpoutFailInfo) - Method in interface backtype.storm.hooks.ITaskHook
 
SpoutFailInfo - Class in backtype.storm.hooks.info
 
SpoutFailInfo(Object, int, Long) - Constructor for class backtype.storm.hooks.info.SpoutFailInfo
 
spoutIdFromCoordinatorId(String) - Static method in class storm.trident.topology.TridentTopologyBuilder
 
SpoutNode - Class in storm.trident.planner
 
SpoutNode(String, Fields, String, Object, SpoutNode.SpoutType) - Constructor for class storm.trident.planner.SpoutNode
 
SpoutNode.SpoutType - Enum in storm.trident.planner
 
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
 
spoutTaskId - Variable in class backtype.storm.hooks.info.SpoutAckInfo
 
spoutTaskId - Variable in class backtype.storm.hooks.info.SpoutFailInfo
 
SpoutTracker - Class in backtype.storm.testing
 
SpoutTracker(IRichSpout, String) - Constructor for class backtype.storm.testing.SpoutTracker
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.AggregateProcessor
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.EachProcessor
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.MultiReducerProcessor
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.PartitionPersistProcessor
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.ProjectedProcessor
 
startBatch(ProcessorContext) - Method in class storm.trident.planner.processor.StateQueryProcessor
 
startBatch(ProcessorContext) - Method in interface storm.trident.planner.TridentProcessor
 
startSimulating() - Static method in class backtype.storm.utils.Time
 
startup() - Method in class backtype.storm.testing.MemoryTransactionalSpout
 
startup() - Method in class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
state - Variable in class storm.trident.planner.ProcessorContext
 
State - Interface in storm.trident.state
There's 3 different kinds of state: 1.
state - Variable in class storm.trident.topology.BatchInfo
 
StateFactory - Interface in storm.trident.state
 
stateFactory - Variable in class storm.trident.state.StateSpec
 
stateInfo - Variable in class storm.trident.planner.Node
 
stateQuery(TridentState, Fields, QueryFunction, Fields) - Method in class storm.trident.fluent.GroupedStream
 
stateQuery(TridentState, QueryFunction, Fields) - Method in class storm.trident.fluent.GroupedStream
 
stateQuery(TridentState, Fields, QueryFunction, Fields) - Method in class storm.trident.Stream
 
stateQuery(TridentState, QueryFunction, Fields) - Method in class storm.trident.Stream
 
StateQueryProcessor - Class in storm.trident.planner.processor
 
StateQueryProcessor(String, Fields, QueryFunction) - Constructor for class storm.trident.planner.processor.StateQueryProcessor
 
StateSpec - Class in storm.trident.state
 
StateSpec(StateFactory) - Constructor for class storm.trident.state.StateSpec
 
StateSpoutOutputCollector - Class in backtype.storm.state
 
StateSpoutOutputCollector() - Constructor for class backtype.storm.state.StateSpoutOutputCollector
 
StateType - Enum in storm.trident.state
 
StateUpdater<S extends State> - Interface in storm.trident.state
 
stopSimulating() - Static method in class backtype.storm.utils.Time
 
storm.trident - package storm.trident
 
storm.trident.drpc - package storm.trident.drpc
 
storm.trident.fluent - package storm.trident.fluent
 
storm.trident.graph - package storm.trident.graph
 
storm.trident.operation - package storm.trident.operation
 
storm.trident.operation.builtin - package storm.trident.operation.builtin
 
storm.trident.operation.impl - package storm.trident.operation.impl
 
storm.trident.partition - package storm.trident.partition
 
storm.trident.planner - package storm.trident.planner
 
storm.trident.planner.processor - package storm.trident.planner.processor
 
storm.trident.spout - package storm.trident.spout
 
storm.trident.state - package storm.trident.state
 
storm.trident.state.map - package storm.trident.state.map
 
storm.trident.state.snapshot - package storm.trident.state.snapshot
 
storm.trident.testing - package storm.trident.testing
 
storm.trident.topology - package storm.trident.topology
 
storm.trident.topology.state - package storm.trident.topology.state
 
storm.trident.tuple - package storm.trident.tuple
 
storm.trident.util - package storm.trident.util
 
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_HOSTNAME - Static variable in class backtype.storm.Config
The hostname the supervisors/workers should report to nimbus.
STORM_LOCAL_MODE_ZMQ - Static variable in class backtype.storm.Config
Whether or not to use ZeroMQ for messaging in local mode.
STORM_SCHEDULER - Static variable in class backtype.storm.Config
A global task scheduler used to assign topologies's tasks to supervisors' wokers.
STORM_ZOOKEEPER_AUTH_PAYLOAD - Static variable in class backtype.storm.Config
A string representing the payload for Zookeeper authentication.
STORM_ZOOKEEPER_AUTH_SCHEME - Static variable in class backtype.storm.Config
The Zookeeper authentication scheme to use, e.g.
STORM_ZOOKEEPER_CONNECTION_TIMEOUT - Static variable in class backtype.storm.Config
The connection timeout for clients to ZooKeeper.
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 session 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.hooks.info.EmitInfo
 
stream - Variable in class backtype.storm.testing.FixedTuple
 
Stream - Class in storm.trident
 
Stream(TridentTopology, Node) - Constructor for class storm.trident.Stream
 
streamId - Variable in class storm.trident.planner.Node
 
StringLength - Class in storm.trident.testing
 
StringLength() - Constructor for class storm.trident.testing.StringLength
 
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.
SubtopologyBolt - Class in storm.trident.planner
 
SubtopologyBolt(DirectedGraph, Set<Node>, Map<Node, String>) - Constructor for class storm.trident.planner.SubtopologyBolt
 
SubtopologyBolt.InitialReceiver - Class in storm.trident.planner
 
SubtopologyBolt.InitialReceiver(String, Fields) - Constructor for class storm.trident.planner.SubtopologyBolt.InitialReceiver
 
succeedVersion(String) - Method in class backtype.storm.utils.VersionedStore
 
success(TransactionAttempt) - Method in class storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
success(long) - Method in class storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
success(long) - Method in interface storm.trident.spout.ITridentSpout.BatchCoordinator
 
success(TransactionAttempt) - Method in interface storm.trident.spout.ITridentSpout.Emitter
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
success(long) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
success(TransactionAttempt) - Method in class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
success(long) - Method in class storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
success(TransactionAttempt) - Method in class storm.trident.testing.FeederBatchSpout.FeederEmitter
 
SUCCESS_STREAM_ID - Static variable in class storm.trident.topology.MasterBatchCoordinator
 
Sum - Class in storm.trident.operation.builtin
 
Sum() - Constructor for class storm.trident.operation.builtin.Sum
 
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_SCHEDULER_META - Static variable in class backtype.storm.Config
the metadata configed on the supervisor
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.
SupervisorDetails - Class in backtype.storm.scheduler
 
SupervisorDetails(String, Object) - Constructor for class backtype.storm.scheduler.SupervisorDetails
 
SupervisorDetails(String, Object, Collection<Number>) - Constructor for class backtype.storm.scheduler.SupervisorDetails
 
SupervisorDetails(String, String, Object, Collection<Number>) - Constructor for class backtype.storm.scheduler.SupervisorDetails
 
synchronize(SynchronizeOutputCollector) - Method in interface backtype.storm.state.IStateSpout
 
SynchronizeOutputCollector - Class in backtype.storm.state
 
SynchronizeOutputCollector() - Constructor for class backtype.storm.state.SynchronizeOutputCollector
 
SYSTEM_COMPONENT_ID - Static variable in class backtype.storm.Constants
 
SYSTEM_TICK_STREAM_ID - Static variable in class backtype.storm.Constants
 

T

take() - Method in class backtype.storm.utils.KeyedRoundRobinQueue
 
takeMessage(int) - Static method in class backtype.storm.utils.InprocMessaging
 
target - Variable in class storm.trident.util.IndexedEdge
 
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
 
taskId - Variable in class backtype.storm.hooks.info.EmitInfo
 
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
 
TestJob - Interface in backtype.storm.testing
This is the core interface for the storm java testing, usually we put our java unit testing logic in the run method.
TestKryoDecorator - Class in backtype.storm.testing
 
TestKryoDecorator() - Constructor for class backtype.storm.testing.TestKryoDecorator
 
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
 
thriftDeserialize(Class, byte[]) - Static method in class storm.trident.util.TridentUtils
 
thriftGrouping - Variable in class storm.trident.planner.PartitionNode
 
thriftSerialize(TBase) - Static method in class storm.trident.util.TridentUtils
 
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
Deprecated. 
TimeCacheMap(int, int, TimeCacheMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.TimeCacheMap
Deprecated.  
TimeCacheMap(int, TimeCacheMap.ExpiredCallback<K, V>) - Constructor for class backtype.storm.utils.TimeCacheMap
Deprecated.  
TimeCacheMap(int) - Constructor for class backtype.storm.utils.TimeCacheMap
Deprecated.  
TimeCacheMap(int, int) - Constructor for class backtype.storm.utils.TimeCacheMap
Deprecated.  
TimeCacheMap.ExpiredCallback<K,V> - Interface in backtype.storm.utils
Deprecated.  
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.GeneralTopologyContext
 
toList() - Method in class backtype.storm.tuple.Fields
 
Topologies - Class in backtype.storm.scheduler
 
Topologies(Map<String, TopologyDetails>) - Constructor for class backtype.storm.scheduler.Topologies
 
TOPOLOGY_ACKER_EXECUTORS - Static variable in class backtype.storm.Config
How many executors to spawn for ackers.
TOPOLOGY_AUTO_TASK_HOOKS - Static variable in class backtype.storm.Config
A list of task hooks that are automatically added to every spout and bolt in the topology.
TOPOLOGY_DEBUG - Static variable in class backtype.storm.Config
When set to true, Storm will log every message that's emitted.
TOPOLOGY_DISRUPTOR_WAIT_STRATEGY - Static variable in class backtype.storm.Config
Configure the wait strategy used for internal queuing.
TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS - Static variable in class backtype.storm.Config
True if Storm should timeout messages or not.
TOPOLOGY_EXECUTOR_RECEIVE_BUFFER_SIZE - Static variable in class backtype.storm.Config
The size of the Disruptor receive queue for each executor.
TOPOLOGY_EXECUTOR_SEND_BUFFER_SIZE - Static variable in class backtype.storm.Config
The size of the Disruptor send queue for each executor.
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_DECORATORS - Static variable in class backtype.storm.Config
A list of classes that customize storm's kryo instance during start-up.
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_NAME - Static variable in class backtype.storm.Config
Name of the topology.
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_RECEIVER_BUFFER_SIZE - Static variable in class backtype.storm.Config
The maximum number of messages to batch from the thread receiving off the network to the executor queues.
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_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS - Static variable in class backtype.storm.Config
The amount of milliseconds the SleepEmptyEmitStrategy should sleep for.
TOPOLOGY_SPOUT_WAIT_STRATEGY - Static variable in class backtype.storm.Config
A class that implements a strategy for what to do when a spout needs to wait.
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_TASKS - Static variable in class backtype.storm.Config
How many instances to create for a spout/bolt.
TOPOLOGY_TICK_TUPLE_FREQ_SECS - Static variable in class backtype.storm.Config
How often a tick tuple from the "__system" component and "__tick" stream should be sent to tasks.
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_TRANSFER_BUFFER_SIZE - Static variable in class backtype.storm.Config
The size of the Disruptor transfer queue for each worker.
TOPOLOGY_WORKER_CHILDOPTS - Static variable in class backtype.storm.Config
Topology-specific options for the worker child process.
TOPOLOGY_WORKER_SHARED_THREAD_POOL_SIZE - Static variable in class backtype.storm.Config
The size of the shared thread pool for worker tasks to make use of.
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, Map<Integer, String>, Map<String, List<Integer>>, Map<String, Map<String, Fields>>, String, String, String, Integer, Integer, List<Integer>, Map<String, Object>, Map<String, Object>, Map<String, Object>) - Constructor for class backtype.storm.task.TopologyContext
 
TopologyDetails - Class in backtype.storm.scheduler
 
TopologyDetails(String, Map, StormTopology, int) - Constructor for class backtype.storm.scheduler.TopologyDetails
 
TopologyDetails(String, Map, StormTopology, int, Map<ExecutorDetails, String>) - Constructor for class backtype.storm.scheduler.TopologyDetails
 
toStream() - Method in class storm.trident.fluent.GroupedStream
 
toStream() - Method in interface storm.trident.fluent.IAggregatableStream
 
toStream() - Method in class storm.trident.Stream
 
toString() - Method in class backtype.storm.coordination.CoordinatedBolt.SourceArgs
 
toString() - Method in class backtype.storm.coordination.CoordinatedBolt.TrackingInfo
 
toString() - Method in class backtype.storm.scheduler.ExecutorDetails
 
toString() - Method in class backtype.storm.scheduler.WorkerSlot
 
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.Fields
 
toString() - Method in class backtype.storm.tuple.MessageId
 
toString() - Method in class backtype.storm.tuple.TupleImpl
 
toString() - Method in class storm.trident.drpc.ReturnResultsReducer.ReturnResultsState
 
toString() - Method in class storm.trident.graph.Group
 
toString() - Method in class storm.trident.operation.impl.ChainedResult
 
toString() - Method in class storm.trident.operation.impl.Result
 
toString() - Method in class storm.trident.planner.Node
 
toString() - Method in class storm.trident.state.OpaqueValue
 
toString() - Method in class storm.trident.state.TransactionalValue
 
toString() - Method in class storm.trident.topology.TransactionAttempt
 
toString() - Method in class storm.trident.topology.TridentBoltExecutor.CoordCondition
 
toString() - Method in class storm.trident.topology.TridentBoltExecutor.CoordType
 
toString() - Method in class storm.trident.topology.TridentBoltExecutor.TrackedBatch
 
toString() - Method in class storm.trident.tuple.ValuePointer
 
TrackedTopology - Class in backtype.storm.testing
 
TrackedTopology(Map) - Constructor for class backtype.storm.testing.TrackedTopology
 
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.
TransactionalMap<T> - Class in storm.trident.state.map
 
TransactionalMap(IBackingMap<TransactionalValue>) - Constructor for class storm.trident.state.map.TransactionalMap
 
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
 
TransactionalState - Class in storm.trident.topology.state
 
TransactionalState(Map, String, String) - Constructor for class storm.trident.topology.state.TransactionalState
 
TransactionalTopologyBuilder - Class in backtype.storm.transactional
Deprecated. 
TransactionalTopologyBuilder(String, String, ITransactionalSpout, Number) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalTopologyBuilder(String, String, ITransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalTopologyBuilder(String, String, IPartitionedTransactionalSpout, Number) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalTopologyBuilder(String, String, IPartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalTopologyBuilder(String, String, IOpaquePartitionedTransactionalSpout, Number) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalTopologyBuilder(String, String, IOpaquePartitionedTransactionalSpout) - Constructor for class backtype.storm.transactional.TransactionalTopologyBuilder
Deprecated.  
TransactionalValue<T> - Class in storm.trident.state
 
TransactionalValue(Long, T) - Constructor for class storm.trident.state.TransactionalValue
 
TransactionAttempt - Class in backtype.storm.transactional
 
TransactionAttempt() - Constructor for class backtype.storm.transactional.TransactionAttempt
 
TransactionAttempt(BigInteger, long) - Constructor for class backtype.storm.transactional.TransactionAttempt
 
TransactionAttempt - Class in storm.trident.topology
 
TransactionAttempt() - Constructor for class storm.trident.topology.TransactionAttempt
 
TransactionAttempt(Long, long) - Constructor for class storm.trident.topology.TransactionAttempt
 
TridentBoltExecutor - Class in storm.trident.topology
 
TridentBoltExecutor(ITridentBatchBolt, Map<GlobalStreamId, String>, Map<String, TridentBoltExecutor.CoordSpec>) - Constructor for class storm.trident.topology.TridentBoltExecutor
 
TridentBoltExecutor.CoordCondition - Class in storm.trident.topology
 
TridentBoltExecutor.CoordCondition() - Constructor for class storm.trident.topology.TridentBoltExecutor.CoordCondition
 
TridentBoltExecutor.CoordinatedOutputCollector - Class in storm.trident.topology
 
TridentBoltExecutor.CoordinatedOutputCollector(IOutputCollector) - Constructor for class storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector
 
TridentBoltExecutor.CoordSpec - Class in storm.trident.topology
 
TridentBoltExecutor.CoordSpec() - Constructor for class storm.trident.topology.TridentBoltExecutor.CoordSpec
 
TridentBoltExecutor.CoordType - Class in storm.trident.topology
 
TridentBoltExecutor.CoordType(boolean) - Constructor for class storm.trident.topology.TridentBoltExecutor.CoordType
 
TridentBoltExecutor.TrackedBatch - Class in storm.trident.topology
 
TridentBoltExecutor.TrackedBatch(BatchInfo, TridentBoltExecutor.CoordCondition) - Constructor for class storm.trident.topology.TridentBoltExecutor.TrackedBatch
 
TridentCollector - Interface in storm.trident.operation
 
TridentContext - Class in storm.trident.planner.processor
 
TridentContext(Fields, List<TridentTuple.Factory>, List<String>, List<TupleReceiver>, String, int, BatchOutputCollector) - Constructor for class storm.trident.planner.processor.TridentContext
 
TridentMultiReducerContext - Class in storm.trident.operation
 
TridentMultiReducerContext(List<TridentTuple.Factory>) - Constructor for class storm.trident.operation.TridentMultiReducerContext
 
TridentOperationContext - Class in storm.trident.operation
 
TridentOperationContext(TopologyContext, TridentTuple.Factory) - Constructor for class storm.trident.operation.TridentOperationContext
 
TridentOperationContext(TridentOperationContext, TridentTuple.Factory) - Constructor for class storm.trident.operation.TridentOperationContext
 
TridentProcessor - Interface in storm.trident.planner
 
TridentSpoutCoordinator - Class in storm.trident.spout
 
TridentSpoutCoordinator(String, ITridentSpout) - Constructor for class storm.trident.spout.TridentSpoutCoordinator
 
TridentSpoutExecutor - Class in storm.trident.spout
 
TridentSpoutExecutor(String, String, ITridentSpout) - Constructor for class storm.trident.spout.TridentSpoutExecutor
 
TridentState - Class in storm.trident
 
TridentState(TridentTopology, Node) - Constructor for class storm.trident.TridentState
 
TridentTopology - Class in storm.trident
 
TridentTopology() - Constructor for class storm.trident.TridentTopology
 
TridentTopologyBuilder - Class in storm.trident.topology
 
TridentTopologyBuilder() - Constructor for class storm.trident.topology.TridentTopologyBuilder
 
TridentTuple - Interface in storm.trident.tuple
 
TridentTuple.Factory - Interface in storm.trident.tuple
 
TridentTupleView - Class in storm.trident.tuple
 
TridentTupleView(IPersistentVector, ValuePointer[], Map<String, ValuePointer>) - Constructor for class storm.trident.tuple.TridentTupleView
 
TridentTupleView.FreshOutputFactory - Class in storm.trident.tuple
 
TridentTupleView.FreshOutputFactory(Fields) - Constructor for class storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
TridentTupleView.OperationOutputFactory - Class in storm.trident.tuple
 
TridentTupleView.OperationOutputFactory(TridentTuple.Factory, Fields) - Constructor for class storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
TridentTupleView.ProjectionFactory - Class in storm.trident.tuple
 
TridentTupleView.ProjectionFactory(TridentTuple.Factory, Fields) - Constructor for class storm.trident.tuple.TridentTupleView.ProjectionFactory
 
TridentTupleView.RootFactory - Class in storm.trident.tuple
 
TridentTupleView.RootFactory(Fields) - Constructor for class storm.trident.tuple.TridentTupleView.RootFactory
 
TridentUtils - Class in storm.trident.util
 
TridentUtils() - Constructor for class storm.trident.util.TridentUtils
 
TrueFilter - Class in storm.trident.operation.impl
 
TrueFilter() - Constructor for class storm.trident.operation.impl.TrueFilter
 
TrueFilter - Class in storm.trident.testing
 
TrueFilter() - Constructor for class storm.trident.testing.TrueFilter
 
tuple - Variable in class backtype.storm.hooks.info.BoltAckInfo
 
tuple - Variable in class backtype.storm.hooks.info.BoltFailInfo
 
Tuple - Interface in backtype.storm.tuple
The tuple is the main data structure in Storm.
tuple(Object...) - Static method in class backtype.storm.utils.Utils
 
TupleCaptureBolt - Class in backtype.storm.testing
 
TupleCaptureBolt() - Constructor for class backtype.storm.testing.TupleCaptureBolt
 
TupleImpl - Class in backtype.storm.tuple
 
TupleImpl(GeneralTopologyContext, List<Object>, int, String, MessageId) - Constructor for class backtype.storm.tuple.TupleImpl
 
TupleImpl(GeneralTopologyContext, List<Object>, int, String) - Constructor for class backtype.storm.tuple.TupleImpl
 
TupleReceiver - Interface in storm.trident.planner
 
TuplifyArgs - Class in storm.trident.testing
 
TuplifyArgs() - Constructor for class storm.trident.testing.TuplifyArgs
 
TX_FIELD - Static variable in class backtype.storm.testing.MemoryTransactionalSpout
 
TX_FIELD - Static variable in class backtype.storm.testing.OpaqueMemoryTransactionalSpout
 
txId - Variable in class storm.trident.planner.SpoutNode
 
type - Variable in class storm.trident.planner.SpoutNode
 

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.
unassignBySlot(WorkerSlot) - Method in class backtype.storm.scheduler.SchedulerAssignmentImpl
Release the slot occupied by this assignment.
UniqueIdGen - Class in storm.trident.fluent
 
UniqueIdGen() - Constructor for class storm.trident.fluent.UniqueIdGen
 
unregisterService(String) - Static method in class backtype.storm.utils.ServiceRegistry
 
update(Object) - Method in class storm.trident.state.CombinerValueUpdater
 
update(ValueUpdater) - Method in class storm.trident.state.map.SnapshottableMap
 
update(Long, T) - Method in class storm.trident.state.OpaqueValue
 
update(Object) - Method in class storm.trident.state.ReducerValueUpdater
 
update(ValueUpdater) - Method in interface storm.trident.state.snapshot.Snapshottable
 
update(T) - Method in interface storm.trident.state.ValueUpdater
 
updateAckVal(long) - Method in class backtype.storm.tuple.TupleImpl
 
updateState(Snapshottable, List<TridentTuple>, TridentCollector) - Method in class storm.trident.operation.impl.CombinerAggStateUpdater
 
updateState(Snapshottable, List<TridentTuple>, TridentCollector) - Method in class storm.trident.operation.impl.ReducerAggStateUpdater
 
updateState(MapState, List<TridentTuple>, TridentCollector) - Method in class storm.trident.state.map.MapCombinerAggStateUpdater
 
updateState(MapState, List<TridentTuple>, TridentCollector) - Method in class storm.trident.state.map.MapReducerAggStateUpdater
 
updateState(S, List<TridentTuple>, TridentCollector) - Method in interface storm.trident.state.StateUpdater
 
Utils - Class in backtype.storm.utils
 
Utils() - Constructor for class backtype.storm.utils.Utils
 

V

valAt(Object) - Method in class backtype.storm.tuple.TupleImpl
 
valAt(Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
valAt(Object, Object) - Method in class backtype.storm.utils.IndifferentAccessMap
 
valueOf(String) - Static method in enum storm.trident.JoinType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum storm.trident.planner.SpoutNode.SpoutType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum storm.trident.state.StateType
Returns the enum constant of this type with the specified name.
ValuePointer - Class in storm.trident.tuple
 
ValuePointer(int, int, String) - Constructor for class storm.trident.tuple.ValuePointer
 
values - Variable in class backtype.storm.hooks.info.EmitInfo
 
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() - Constructor for class backtype.storm.tuple.Values
 
Values(Object...) - Constructor for class backtype.storm.tuple.Values
 
values() - Method in class backtype.storm.utils.IndifferentAccessMap
 
values() - Static method in enum storm.trident.JoinType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum storm.trident.planner.SpoutNode.SpoutType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum storm.trident.state.StateType
Returns an array containing the constants of this enum type, in the order they are declared.
ValueUpdater<T> - Interface in storm.trident.state
 
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.
WorkerSlot - Class in backtype.storm.scheduler
 
WorkerSlot(String, int) - Constructor for class backtype.storm.scheduler.WorkerSlot
 
WorkerTopologyContext - Class in backtype.storm.task
 
WorkerTopologyContext(StormTopology, Map, Map<Integer, String>, Map<String, List<Integer>>, Map<String, Map<String, Fields>>, String, String, String, Integer, List<Integer>, Map<String, Object>, Map<String, Object>) - Constructor for class backtype.storm.task.WorkerTopologyContext
 
WritableUtils - Class in backtype.storm.utils
 
WritableUtils() - Constructor for class backtype.storm.utils.WritableUtils
 
write(Kryo, Output, Object) - Method in class backtype.storm.serialization.SerializableSerializer
 
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
 
writeMessage(Object) - Method in class backtype.storm.utils.ShellProcess
 
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

zero() - Method in class storm.trident.operation.builtin.Count
 
zero() - Method in class storm.trident.operation.builtin.Sum
 
zero() - Method in interface storm.trident.operation.CombinerAggregator
 
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.
ZookeeperAuthInfo - Class in backtype.storm.utils
 
ZookeeperAuthInfo(Map) - Constructor for class backtype.storm.utils.ZookeeperAuthInfo
 
ZookeeperAuthInfo(String, byte[]) - Constructor for class backtype.storm.utils.ZookeeperAuthInfo
 

_

_delegate - Variable in class storm.trident.state.map.CachedBatchReadsMap
 
_map - Variable in class backtype.storm.utils.IndifferentAccessMap
 
_stormConf - Variable in class backtype.storm.task.GeneralTopologyContext
 

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