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 _