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

A

A - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
abort() - Method in class org.apache.storm.hive.common.HiveWriter
Aborts the current Txn and switches to next Txn.
abort() - Method in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule
 
ABS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ABSOLUTE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
absoluteStormLocalDir(Map) - Static method in class org.apache.storm.daemon.metrics.MetricsUtils
 
AbstractAvroSerializer - Class in org.apache.storm.hdfs.avro
This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects across a Topology.
AbstractAvroSerializer() - Constructor for class org.apache.storm.hdfs.avro.AbstractAvroSerializer
 
AbstractChannelHandler - Class in org.apache.storm.sql.runtime
 
AbstractChannelHandler() - Constructor for class org.apache.storm.sql.runtime.AbstractChannelHandler
 
AbstractDNSToSwitchMapping - Class in org.apache.storm.networktopography
This is a base class for DNS to Switch mappings.
AbstractDNSToSwitchMapping() - Constructor for class org.apache.storm.networktopography.AbstractDNSToSwitchMapping
Create an unconfigured instance
AbstractEsBolt - Class in org.apache.storm.elasticsearch.bolt
 
AbstractEsBolt(EsConfig) - Constructor for class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
 
AbstractExecutionResultHandler - Class in org.apache.storm.cassandra
Default interface to define strategies to apply when a query is either succeed or failed.
AbstractExecutionResultHandler() - Constructor for class org.apache.storm.cassandra.AbstractExecutionResultHandler
 
AbstractHBaseBolt - Class in org.apache.storm.hbase.bolt
 
AbstractHBaseBolt(String, HBaseMapper) - Constructor for class org.apache.storm.hbase.bolt.AbstractHBaseBolt
 
AbstractHdfsBolt - Class in org.apache.storm.hdfs.bolt
 
AbstractHdfsBolt() - Constructor for class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
AbstractJdbcBolt - Class in org.apache.storm.jdbc.bolt
 
AbstractJdbcBolt(ConnectionProvider) - Constructor for class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
AbstractMongoBolt - Class in org.apache.storm.mongodb.bolt
 
AbstractMongoBolt(String, String) - Constructor for class org.apache.storm.mongodb.bolt.AbstractMongoBolt
 
AbstractRankerBolt - Class in org.apache.storm.starter.bolt
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
AbstractRankerBolt() - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt
 
AbstractRankerBolt(int) - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt
 
AbstractRankerBolt(int, int) - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt
 
AbstractRedisBolt - Class in org.apache.storm.redis.bolt
AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.
AbstractRedisBolt(JedisPoolConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt
Constructor for single Redis environment (JedisPool)
AbstractRedisBolt(JedisClusterConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt
Constructor for Redis Cluster environment (JedisCluster)
AbstractRedisMapState<T> - Class in org.apache.storm.redis.trident.state
AbstractRedisMapState is base class of any RedisMapState, which implements IBackingMap.
AbstractRedisMapState() - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisMapState
 
AbstractRedisStateQuerier<T extends State> - Class in org.apache.storm.redis.trident.state
AbstractRedisStateQuerier is base class of any RedisStateQuerier, which implements BaseQueryFunction.
AbstractRedisStateQuerier(RedisLookupMapper) - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
Constructor
AbstractRedisStateUpdater<T extends State> - Class in org.apache.storm.redis.trident.state
AbstractRedisStateUpdater is base class of any RedisStateUpdater, which implements BaseStateUpdater.
AbstractRedisStateUpdater(RedisStoreMapper) - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater
Constructor
AbstractSaslClientCallbackHandler - Class in org.apache.storm.security.auth
 
AbstractSaslClientCallbackHandler() - Constructor for class org.apache.storm.security.auth.AbstractSaslClientCallbackHandler
 
AbstractSaslServerCallbackHandler - Class in org.apache.storm.security.auth
 
AbstractSaslServerCallbackHandler() - Constructor for class org.apache.storm.security.auth.AbstractSaslServerCallbackHandler
 
AbstractTridentProcessor - Class in org.apache.storm.sql.runtime.trident
 
AbstractTridentProcessor() - Constructor for class org.apache.storm.sql.runtime.trident.AbstractTridentProcessor
 
AbstractTridentWindowManager<T> - Class in org.apache.storm.trident.windowing
Basic functionality to manage trident tuple events using WindowManager and WindowsStore for storing tuples and triggers related information.
AbstractTridentWindowManager(WindowConfig, String, WindowsStore, Aggregator, BatchOutputCollector) - Constructor for class org.apache.storm.trident.windowing.AbstractTridentWindowManager
 
AbstractValuesProcessor - Class in org.apache.storm.sql.runtime
Subclass of AbstractTupleProcessor provides a series of tuple.
AbstractValuesProcessor() - Constructor for class org.apache.storm.sql.runtime.AbstractValuesProcessor
 
accept(TridentTuple) - Method in interface org.apache.storm.trident.operation.Consumer
Performs the operation on the input trident tuple.
AccessControl - Class in org.apache.storm.generated
 
AccessControl() - Constructor for class org.apache.storm.generated.AccessControl
 
AccessControl(AccessControlType, int) - Constructor for class org.apache.storm.generated.AccessControl
 
AccessControl(AccessControl) - Constructor for class org.apache.storm.generated.AccessControl
Performs a deep copy on other.
AccessControl._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
accessControlToString(AccessControl) - Static method in class org.apache.storm.blobstore.BlobStoreAclHandler
 
AccessControlType - Enum in org.apache.storm.generated
 
AccessLoggingFilter - Class in org.apache.storm.logging.filters
 
AccessLoggingFilter() - Constructor for class org.apache.storm.logging.filters.AccessLoggingFilter
 
ack(Object) - Method in class org.apache.storm.clojure.ClojureSpout
 
ack(Tuple) - Method in class org.apache.storm.coordination.BatchOutputCollectorImpl
 
ack(Tuple) - Method in class org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
 
ack(Object) - Method in class org.apache.storm.drpc.DRPCSpout
 
ack(Object) - Method in class org.apache.storm.eventhubs.spout.EventHubSpout
 
ack(String) - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager
 
ack(String) - Method in class org.apache.storm.eventhubs.spout.PartitionManager
 
ack(String) - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager
 
ack(Object) - Method in class org.apache.storm.hdfs.spout.HdfsSpout
 
ack(Object) - Method in class org.apache.storm.kafka.KafkaSpout
 
ack(Long) - Method in class org.apache.storm.kafka.PartitionManager
 
ack(Object) - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
ack(Object) - Method in class org.apache.storm.mqtt.spout.MqttSpout
Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed.
ack(Object) - Method in class org.apache.storm.spout.CheckpointSpout
 
ack(Object) - Method in interface org.apache.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 org.apache.storm.spout.ShellSpout
 
ack(Object) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout
 
ack(Object) - Method in class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout
 
ack(Object) - Method in class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout
 
ack(Object) - Method in class org.apache.storm.starter.spout.RandomIntegerSpout
 
ack(long) - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout
 
ack(Object) - Method in class org.apache.storm.starter.spout.RandomSentenceSpout
 
ack(Object) - Method in class org.apache.storm.starter.spout.TwitterSampleSpout
 
ack(Object) - Method in class org.apache.storm.starter.ThroughputVsLatency.FastRandomSentenceSpout
 
ack(Tuple) - Method in interface org.apache.storm.task.IOutputCollector
 
ack(Tuple) - Method in class org.apache.storm.task.OutputCollector
 
ack(Object) - Method in interface org.apache.storm.testing.AckFailDelegate
 
ack(Object) - Method in class org.apache.storm.testing.AckFailMapTracker
 
ack(Object) - Method in class org.apache.storm.testing.AckTracker
 
ack(Object) - Method in class org.apache.storm.testing.FeederSpout
 
ack(Object) - Method in class org.apache.storm.testing.FixedTupleSpout
 
ack(Object) - Method in class org.apache.storm.testing.SpoutTracker
 
ack(Object) - Method in class org.apache.storm.testing.TestEventLogSpout
 
ack(Object) - Method in class org.apache.storm.testing.TestPlannerSpout
 
ack(Object) - Method in class org.apache.storm.testing.TestWordSpout
 
ack(Object) - Method in class org.apache.storm.topology.base.BaseRichSpout
 
ack(Object) - Method in class org.apache.storm.transactional.TransactionalSpoutCoordinator
 
ack(long) - Method in interface org.apache.storm.trident.spout.IBatchSpout
 
ack(Object) - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
 
ack(long) - Method in class org.apache.storm.trident.testing.FixedBatchSpout
 
ack(Object) - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
ack() - Method in class org.apache.storm.utils.BatchHelper
 
acked(Long) - Method in class org.apache.storm.kafka.ExponentialBackoffMsgRetryManager
 
acked(Long) - Method in interface org.apache.storm.kafka.FailedMsgRetryManager
Message corresponding to the offset, was acked to kafka spout.
AckFailDelegate - Interface in org.apache.storm.testing
 
AckFailMapTracker - Class in org.apache.storm.testing
 
AckFailMapTracker() - Constructor for class org.apache.storm.testing.AckFailMapTracker
 
ackingTaskId - Variable in class org.apache.storm.hooks.info.BoltAckInfo
 
AckTracker - Class in org.apache.storm.testing
 
AckTracker() - Constructor for class org.apache.storm.testing.AckTracker
 
AclFunctionEntry(Collection<String>, String) - Constructor for class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry
 
acquireNewPort() - Static method in class org.apache.storm.utils.InprocMessaging
 
acquireOldestExpiredLock(FileSystem, Path, int, String) - Static method in class org.apache.storm.hdfs.spout.FileLock
Finds a oldest expired lock file (using modification timestamp), then takes ownership of the lock file Impt: Assumes access to lockFilesDir has been externally synchronized such that only one thread accessing the same thread
ACTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
activate() - Method in class org.apache.storm.clojure.ClojureSpout
 
activate(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
activate(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
activate() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.activate
 
activate(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
activate(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
activate() - Constructor for class org.apache.storm.generated.Nimbus.Processor.activate
 
activate(String) - Method in interface org.apache.storm.ILocalCluster
 
activate() - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
activate() - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
activate() - Method in interface org.apache.storm.spout.ISpout
Called when a spout has been activated out of a deactivated mode.
activate() - Method in class org.apache.storm.spout.ShellSpout
 
activate() - Method in class org.apache.storm.testing.FixedTupleSpout
 
activate() - Method in class org.apache.storm.topology.base.BaseRichSpout
 
activate() - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
 
activate() - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
activate_args() - Constructor for class org.apache.storm.generated.Nimbus.activate_args
 
activate_args(String) - Constructor for class org.apache.storm.generated.Nimbus.activate_args
 
activate_args(Nimbus.activate_args) - Constructor for class org.apache.storm.generated.Nimbus.activate_args
Performs a deep copy on other.
activate_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.activate_call
 
activate_result() - Constructor for class org.apache.storm.generated.Nimbus.activate_result
 
activate_result(NotAliveException, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.activate_result
 
activate_result(Nimbus.activate_result) - Constructor for class org.apache.storm.generated.Nimbus.activate_result
Performs a deep copy on other.
ADA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
add(TaskMessage) - Method in class org.apache.storm.messaging.netty.MessageBuffer
 
ADD - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
add(int, Object, List<Object>) - Method in interface org.apache.storm.state.ISynchronizeOutputCollector
 
add(int, Object, List<Object>) - Method in class org.apache.storm.state.SynchronizeOutputCollector
 
add(int, Object) - Method in class org.apache.storm.trident.tuple.ConsList
 
add(Object, V) - Method in class org.apache.storm.utils.KeyedRoundRobinQueue
 
add(Object) - Method in class org.apache.storm.utils.ListDelegate
 
add(int, Object) - Method in class org.apache.storm.utils.ListDelegate
 
add(HashMap<Integer, ArrayList<TaskMessage>>) - Method in class org.apache.storm.utils.TransferDrainer
 
add(T) - Method in class org.apache.storm.windowing.WindowManager
Add an event into the window, with System.currentTimeMillis() as the tracking ts.
add(T, long) - Method in class org.apache.storm.windowing.WindowManager
Add an event into the window, with the given ts as the tracking ts.
add(Event<T>) - Method in class org.apache.storm.windowing.WindowManager
Tracks a window event
add_escapes(String) - Method in exception org.apache.storm.sql.parser.impl.ParseException
Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.
add_listener(ClusterStateListener) - Method in interface org.apache.storm.cluster.ClusterState
Add a ClusterStateListener to the connection.
add_to_acl(AccessControl) - Method in class org.apache.storm.generated.SettableBlobMeta
 
add_to_args_list(JavaObjectArg) - Method in class org.apache.storm.generated.JavaObject
 
add_to_errors(ErrorInfo) - Method in class org.apache.storm.generated.ComponentPageInfo
 
add_to_exec_stats(ExecutorAggregateStats) - Method in class org.apache.storm.generated.ComponentPageInfo
 
add_to_executors(ExecutorInfo) - Method in class org.apache.storm.generated.LocalAssignment
 
add_to_executors(ExecutorInfo) - Method in class org.apache.storm.generated.LSWorkerHeartbeat
 
add_to_executors(ExecutorSummary) - Method in class org.apache.storm.generated.TopologyInfo
 
add_to_groups(String) - Method in class org.apache.storm.generated.LSTopoHistory
 
add_to_keys(String) - Method in class org.apache.storm.generated.ListBlobsResult
 
add_to_meta(long) - Method in class org.apache.storm.generated.SupervisorInfo
 
add_to_nimbuses(NimbusSummary) - Method in class org.apache.storm.generated.ClusterSummary
 
add_to_output_fields(String) - Method in class org.apache.storm.generated.StreamInfo
 
add_to_port(long) - Method in class org.apache.storm.generated.NodeInfo
 
add_to_pulseIds(String) - Method in class org.apache.storm.generated.HBNodes
 
add_to_pulses(HBPulse) - Method in class org.apache.storm.generated.HBRecords
 
add_to_success(ProfileRequest) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
 
add_to_supervisors(SupervisorSummary) - Method in class org.apache.storm.generated.ClusterSummary
 
add_to_topo_history(LSTopoHistory) - Method in class org.apache.storm.generated.LSTopoHistoryList
 
add_to_topo_ids(String) - Method in class org.apache.storm.generated.TopologyHistoryInfo
 
add_to_topologies(TopologySummary) - Method in class org.apache.storm.generated.ClusterSummary
 
add_to_used_ports(long) - Method in class org.apache.storm.generated.SupervisorInfo
 
add_to_users(String) - Method in class org.apache.storm.generated.LSTopoHistory
 
add_to_worker_hooks(ByteBuffer) - Method in class org.apache.storm.generated.StormTopology
 
addAll(Collection<?>) - Method in class org.apache.storm.utils.ListDelegate
 
addAll(int, Collection<?>) - Method in class org.apache.storm.utils.ListDelegate
 
addAllBolts(List<BoltDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
 
addAllComponents(List<BeanDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
 
addAllSpouts(List<SpoutDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
 
addAllStreams(List<StreamDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
 
addAnchor(String) - Method in class org.apache.storm.multilang.ShellMsg
 
addAvroKryoSerializations(Config) - Static method in class org.apache.storm.hdfs.avro.AvroUtils
A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary.
addBatch(Tuple) - Method in class org.apache.storm.utils.BatchHelper
 
addBolt(IBatchBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
addBolt(IBatchBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
addBolt(IRichBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
addBolt(IRichBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
addBolt(IBasicBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
addBolt(IBasicBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
addBolt(String, Object) - Method in class org.apache.storm.flux.model.ExecutionContext
 
addColumn(HBaseProjectionCriteria.ColumnMetaData) - Method in class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria
Only this column from the the columnFamily will be included as result of HBase lookup.
addColumn(byte[], byte[], long, byte[]) - Method in class org.apache.storm.hbase.common.ColumnList
Add a standard HBase column.
addColumn(byte[], byte[], byte[]) - Method in class org.apache.storm.hbase.common.ColumnList
Add a standard HBase column
addColumn(IColumn) - Method in class org.apache.storm.hbase.common.ColumnList
Add a standard HBase column given an instance of a class that implements the IColumn interface.
addColumnFamily(String) - Method in class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria
all columns from this family will be included as result of HBase lookup.
addComponent(String, Object) - Method in class org.apache.storm.flux.model.ExecutionContext
 
addConfiguration(String, Object) - Method in class org.apache.storm.topology.BaseConfigurationDeclarer
 
addConfiguration(String, Object) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer
 
addConfigurations(Map<String, Object>) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer
 
addConfigurations(Map<String, Object>) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter
 
addCounter(byte[], byte[], long) - Method in class org.apache.storm.hbase.common.ColumnList
Add an HBase counter column.
addCounter(ICounter) - Method in class org.apache.storm.hbase.common.ColumnList
Add an HBase counter column given an instance of a class that implements the ICounter interface.
addEscapes(String) - Static method in error org.apache.storm.sql.parser.impl.TokenMgrError
Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string
addGroup(Group) - Method in class org.apache.storm.trident.graph.GraphGrouper
 
additionalKey - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
 
additionalKey - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater
 
addLocalizedResourceInDir(String, LocalizedResourceSet, boolean) - Method in class org.apache.storm.localizer.Localizer
 
addMockData(String, String, Values...) - Method in class org.apache.storm.testing.MockedSources
add mock data for the spout.
addMockData(String, Values...) - Method in class org.apache.storm.testing.MockedSources
 
addNode(Node) - Method in class org.apache.storm.trident.TridentTopology
 
addPartition(Partition) - Method in class org.apache.storm.eventhubs.trident.Partitions
 
addPartition(int, Broker) - Method in class org.apache.storm.kafka.trident.GlobalPartitionInformation
 
addReceiver(TridentProcessor) - Method in class org.apache.storm.trident.planner.SubtopologyBolt.InitialReceiver
 
addReference(String) - Method in class org.apache.storm.localizer.LocalizedResource
 
addReferences(List<LocalResource>, String, String) - Method in class org.apache.storm.localizer.Localizer
 
addResource(String, LocalizedResource, boolean) - Method in class org.apache.storm.localizer.LocalizedResourceSet
 
addResources(LocalizedResourceSet) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet
 
addResourcesForExec(ExecutorDetails, Map<String, Double>) - Method in class org.apache.storm.scheduler.TopologyDetails
add resource requirements for a executor
addResourcesForSet(Iterator<LocalizedResource>, LocalizedResourceSet) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet
 
AddressedTuple - Class in org.apache.storm.tuple
A Tuple that is addressed to a destination.
AddressedTuple(int, Tuple) - Constructor for class org.apache.storm.tuple.AddressedTuple
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
Deprecated.
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
addSourcedNode(List<Stream>, Node) - Method in class org.apache.storm.trident.TridentTopology
 
addSourcedNode(Stream, Node) - Method in class org.apache.storm.trident.TridentTopology
 
addSourcedStateNode(List<Stream>, Node) - Method in class org.apache.storm.trident.TridentTopology
 
addSourcedStateNode(Stream, Node) - Method in class org.apache.storm.trident.TridentTopology
 
addSpout(String, IRichSpout) - Method in class org.apache.storm.flux.model.ExecutionContext
 
addStream(KafkaSpoutStream) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Adds this stream to the state representing the streams associated with each topic
addStream(Fields, String...) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Please refer to javadoc in #Builder(Fields, String...)
addStream(Fields, String, String...) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Please refer to javadoc in #Builder(Fields, String, String...)
addTaskHook(ITaskHook) - Method in class org.apache.storm.task.TopologyContext
 
addTokensToUGI(Subject) - Method in class org.apache.storm.hbase.security.AutoHBase
 
addTokensToUGI(Subject) - Method in class org.apache.storm.hdfs.common.security.AutoHDFS
 
addToLeaderLockQueue() - Method in interface org.apache.storm.nimbus.ILeaderElector
queue up for leadership lock.
addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.DefaultPool
 
addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.FreePool
 
addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.IsolatedPool
 
addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.NodePool
Add a topology to the pool
addTopologyToAttemptedQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User
 
addTopologyToInvalidQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User
 
addTopologyToPendingQueue(TopologyDetails, Cluster) - Method in class org.apache.storm.scheduler.resource.User
 
addTopologyToPendingQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User
 
addTopologyToRunningQueue(TopologyDetails, Cluster) - Method in class org.apache.storm.scheduler.resource.User
 
addTopologyToRunningQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User
 
addTuple(Object) - Method in class org.apache.storm.multilang.ShellMsg
 
addTuplesBatch(Object, List<TridentTuple>) - Method in class org.apache.storm.trident.windowing.InMemoryTridentWindowManager
 
addTuplesBatch(Object, List<TridentTuple>) - Method in interface org.apache.storm.trident.windowing.ITridentWindowManager
Add received batch of tuples to cache/store and add them to WindowManager
addTuplesBatch(Object, List<TridentTuple>) - Method in class org.apache.storm.trident.windowing.StoreBasedTridentWindowManager
 
addWorkerHook(IWorkerHook) - Method in class org.apache.storm.topology.TopologyBuilder
Add a new worker lifecycle hook
adjustBeginLineColumn(int, int) - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream
Method to adjust line and column numbers for the start of a token.
ADMIN - Static variable in class org.apache.storm.blobstore.BlobStoreAclHandler
 
ADMIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
advanceTime(long) - Static method in class org.apache.storm.utils.Time
 
AFTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
afterExecute(Runnable, Throwable) - Method in class org.apache.storm.utils.ExtendedThreadPoolExecutor
 
aggPartition(S) - Method in interface org.apache.storm.trident.fluent.GlobalAggregationScheme
 
aggPartition(GroupedStream) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
aggregate(Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Fields, ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
 
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
 
aggregate(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator
 
aggregate(ComparisonAggregator.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator
 
aggregate(FirstN.FirstNAgg.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg
 
aggregate(PriorityQueue, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
aggregate(ChainedResult, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
 
aggregate(Result, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
aggregate(Object[], TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator
 
aggregate(Result, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl
 
aggregate(SingleEmitAggregator.SingleEmitState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator
 
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
 
aggregate(CountAsAggregator.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator
 
AggregateProcessor - Class in org.apache.storm.trident.planner.processor
 
AggregateProcessor(Fields, Aggregator) - Constructor for class org.apache.storm.trident.planner.processor.AggregateProcessor
 
Aggregator<T> - Interface in org.apache.storm.trident.operation
 
aggregator - Variable in class org.apache.storm.trident.windowing.AbstractTridentWindowManager
 
all() - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder
Includes all tuple fields.
all() - Static method in class org.apache.storm.coordination.CoordinatedBolt.SourceArgs
 
all(NullStruct) - Static method in class org.apache.storm.generated.Grouping
 
ALL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
all() - Static method in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType
 
allGrouping() - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer
 
allGrouping(String) - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer
 
allGrouping(String) - Method in interface org.apache.storm.topology.InputDeclarer
The stream is replicated across all the bolt’s tasks.
allGrouping(String, String) - Method in interface org.apache.storm.topology.InputDeclarer
The stream is replicated across all the bolt’s tasks.
allGrouping(String) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
 
allGrouping(String, String) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
 
ALLOCATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
allOutputFields - Variable in class org.apache.storm.trident.planner.Node
 
ALLOW - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
allSlotsAvailableForScheduling(Collection<SupervisorDetails>, Topologies, Set<String>) - Method in interface org.apache.storm.scheduler.INimbus
Returns all slots that are available for the next round of scheduling.
AlreadyAliveException - Exception in org.apache.storm.generated
 
AlreadyAliveException() - Constructor for exception org.apache.storm.generated.AlreadyAliveException
 
AlreadyAliveException(String) - Constructor for exception org.apache.storm.generated.AlreadyAliveException
 
AlreadyAliveException(AlreadyAliveException) - Constructor for exception org.apache.storm.generated.AlreadyAliveException
Performs a deep copy on other.
AlreadyAliveException._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ALTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AlternateRackDNSToSwitchMapping - Class in org.apache.storm.testing
This class implements the DNSToSwitchMapping interface It alternates bewteen RACK1 and RACK2 for the hosts.
AlternateRackDNSToSwitchMapping() - Constructor for class org.apache.storm.testing.AlternateRackDNSToSwitchMapping
 
ALWAYS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AND - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ANY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AppendCollector - Class in org.apache.storm.trident.planner.processor
 
AppendCollector(TridentContext) - Constructor for class org.apache.storm.trident.planner.processor.AppendCollector
 
apply(PreparedStatement, List<Column>) - Method in interface org.apache.storm.cassandra.query.impl.PreparedStatementBinder
 
apply(PreparedStatement, List<Column>) - Method in class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.CQL3NamedSettersBinder
apply(PreparedStatement, List<Column>) - Method in class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.DefaultBinder
apply(Stream) - Method in interface org.apache.storm.trident.operation.Assembly
Applies the Assembly to a given Stream
apply(Stream) - Method in class org.apache.storm.trident.operation.builtin.FirstN
 
applyAssembly(Assembly) - Method in class org.apache.storm.trident.Stream
Applies an Assembly to this Stream.
applyToSourceContent(String) - Method in interface org.apache.storm.hack.relocation.Relocator
 
applyToSourceContent(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator
 
APPROX_NUMERIC_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ARCHIVE_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs
 
ARCHIVESDIR - Static variable in class org.apache.storm.localizer.Localizer
 
ARE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
areTaskIdsNeeded() - Method in class org.apache.storm.multilang.ShellMsg
 
ARGS_STREAM - Static variable in class org.apache.storm.drpc.PrepareRequest
 
ARRAY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ArrayConstructor() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses an ARRAY constructor
ArrayListSerializer - Class in org.apache.storm.serialization.types
 
ArrayListSerializer() - Constructor for class org.apache.storm.serialization.types.ArrayListSerializer
 
as(String) - Method in class org.apache.storm.cassandra.query.selector.FieldSelector
Sets an alias for this field.
AS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ASC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ASENSITIVE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
asOpaqueEmitter() - Method in class org.apache.storm.kafka.trident.TridentKafkaEmitter
 
Assembly - Interface in org.apache.storm.trident.operation
The Assembly interface provides a means to encapsulate logic applied to a Stream.
ASSERTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
assign(WorkerSlot, String, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.Cluster
Assign the slot to the executors for this topology.
assign(String, Collection<ExecutorDetails>, Cluster) - Method in class org.apache.storm.scheduler.multitenant.Node
Assign a free slot on the node to the following topology and executors.
assign(WorkerSlot, TopologyDetails, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.resource.RAS_Node
Assigns a worker to a node
assign(WorkerSlot, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.SchedulerAssignmentImpl
Assign the slot to executors.
AssignableMetric - Class in org.apache.storm.metric.api
 
AssignableMetric(Object) - Constructor for class org.apache.storm.metric.api.AssignableMetric
 
AssignableShellMetric - Class in org.apache.storm.metric.api.rpc
 
AssignableShellMetric(Object) - Constructor for class org.apache.storm.metric.api.rpc.AssignableShellMetric
 
assigned(Collection<Integer>) - Method in interface org.apache.storm.scheduler.ISupervisor
 
Assignment - Class in org.apache.storm.generated
 
Assignment() - Constructor for class org.apache.storm.generated.Assignment
 
Assignment(String) - Constructor for class org.apache.storm.generated.Assignment
 
Assignment(Assignment) - Constructor for class org.apache.storm.generated.Assignment
Performs a deep copy on other.
ASSIGNMENT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
Assignment._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
assignSlots(Topologies, Map<String, Collection<WorkerSlot>>) - Method in interface org.apache.storm.scheduler.INimbus
this is called after the assignment is changed in ZK
assignSlotTo(Node) - Method in class org.apache.storm.scheduler.multitenant.NodePool.RoundRobinSlotScheduler
Assign a slot to the given node.
assoc(Object, Object) - Method in class org.apache.storm.utils.IndifferentAccessMap
 
assocEx(Object, Object) - Method in class org.apache.storm.utils.IndifferentAccessMap
 
asTransactionalEmitter() - Method in class org.apache.storm.kafka.trident.TridentKafkaEmitter
 
ASYMMETRIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
async(CQLStatementBuilder...) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder
Builds multiple statements which will be executed asynchronously.
AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncClient
 
AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncClient
 
AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient
 
AsyncExecutor<T> - Class in org.apache.storm.cassandra.executor
Service to asynchronously executes cassandra statements.
AsyncExecutor(Session, AsyncResultHandler<T>) - Constructor for class org.apache.storm.cassandra.executor.AsyncExecutor
Creates a new AsyncExecutor instance.
AsyncExecutorProvider - Class in org.apache.storm.cassandra.executor
This class must be used to obtain a single instance of AsyncExecutor per storm executor.
AsyncExecutorProvider() - Constructor for class org.apache.storm.cassandra.executor.AsyncExecutorProvider
 
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor
 
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor
 
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor
 
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor
 
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor
 
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor
 
AsyncResultHandler<T> - Interface in org.apache.storm.cassandra.executor
Default handler for batch asynchronous execution.
AT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AtMostOnceEventCount - Class in org.apache.storm.eventhubs.samples
 
AtMostOnceEventCount() - Constructor for class org.apache.storm.eventhubs.samples.AtMostOnceEventCount
 
ATOMIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AtomicOutputStream - Class in org.apache.storm.blobstore
An output stream where all of the data is committed on close, or can be canceled with cancel.
AtomicOutputStream() - Constructor for class org.apache.storm.blobstore.AtomicOutputStream
 
AtomicRowExpression() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses an atomic row expression.
ATTRIBUTE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ATTRIBUTES - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
authenticate(String, String) - Static method in class org.apache.storm.hive.common.HiveUtils
 
authenticated(Channel) - Method in interface org.apache.storm.messaging.netty.ISaslServer
 
AuthenticationFailed(String, Exception) - Constructor for exception org.apache.storm.hive.common.HiveUtils.AuthenticationFailed
 
AUTHORIZATION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AuthorizationException - Exception in org.apache.storm.generated
 
AuthorizationException() - Constructor for exception org.apache.storm.generated.AuthorizationException
 
AuthorizationException(String) - Constructor for exception org.apache.storm.generated.AuthorizationException
 
AuthorizationException(AuthorizationException) - Constructor for exception org.apache.storm.generated.AuthorizationException
Performs a deep copy on other.
AuthorizationException._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
authorizedGroups - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL
 
authorizedHosts - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL
 
AuthUtils - Class in org.apache.storm.security.auth
 
AuthUtils() - Constructor for class org.apache.storm.security.auth.AuthUtils
 
AUTO_COMMIT_INTERVAL_MS - Static variable in interface org.apache.storm.kafka.spout.KafkaSpoutConfig.Consumer
 
autoCreatePartitions - Variable in class org.apache.storm.hive.common.HiveOptions
 
AutoHBase - Class in org.apache.storm.hbase.security
Automatically get hbase delegation tokens and push it to user’s topology.
AutoHBase() - Constructor for class org.apache.storm.hbase.security.AutoHBase
 
AutoHDFS - Class in org.apache.storm.hdfs.common.security
Automatically get HDFS delegation tokens and push it to user’s topology.
AutoHDFS() - Constructor for class org.apache.storm.hdfs.common.security.AutoHDFS
 
AutoTGT - Class in org.apache.storm.security.auth.kerberos
Automatically take a user’s TGT, and push it, and renew it in Nimbus.
AutoTGT() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGT
 
AutoTGTKrb5LoginModule - Class in org.apache.storm.security.auth.kerberos
Custom LoginModule to enable Auto Login based on cached ticket
AutoTGTKrb5LoginModule() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule
 
AutoTGTKrb5LoginModuleTest - Class in org.apache.storm.security.auth.kerberos
Custom LoginModule extended for testing.
AutoTGTKrb5LoginModuleTest() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModuleTest
 
available() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream
 
available() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusDownloadInputStream
 
AVG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
AvroGenericRecordBolt - Class in org.apache.storm.hdfs.bolt
 
AvroGenericRecordBolt() - Constructor for class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt
 
AvroSchemaRegistry - Interface in org.apache.storm.hdfs.avro
 
AvroUtils - Class in org.apache.storm.hdfs.avro
 
AvroUtils() - Constructor for class org.apache.storm.hdfs.avro.AvroUtils
 

B

BACK_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BACKPRESSURE_DISRUPTOR_HIGH_WATERMARK - Static variable in class org.apache.storm.Config
This signifies the tuple congestion in a disruptor queue.
BACKPRESSURE_DISRUPTOR_LOW_WATERMARK - Static variable in class org.apache.storm.Config
This signifies a state that a disruptor queue has left the congestion.
backup(int) - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
BAD_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs
 
BASE_BLOBS_DIR_NAME - Static variable in class org.apache.storm.blobstore.BlobStore
 
BaseAggregator<T> - Class in org.apache.storm.trident.operation
 
BaseAggregator() - Constructor for class org.apache.storm.trident.operation.BaseAggregator
 
BaseBasicBolt - Class in org.apache.storm.topology.base
 
BaseBasicBolt() - Constructor for class org.apache.storm.topology.base.BaseBasicBolt
 
BaseBatchBolt<T> - Class in org.apache.storm.topology.base
 
BaseBatchBolt() - Constructor for class org.apache.storm.topology.base.BaseBatchBolt
 
BaseBeanFactory<T> - Class in org.apache.storm.cassandra.context
Base BeanProvider implementation.
BaseBeanFactory() - Constructor for class org.apache.storm.cassandra.context.BaseBeanFactory
 
BaseCassandraBolt<T> - Class in org.apache.storm.cassandra.bolt
A base cassandra bolt.
BaseCassandraBolt(CQLStatementTupleMapper, SimpleClientProvider) - Constructor for class org.apache.storm.cassandra.bolt.BaseCassandraBolt
Creates a new CassandraWriterBolt instance.
BaseCassandraBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.BaseCassandraBolt
Creates a new CassandraWriterBolt instance.
BaseComponent - Class in org.apache.storm.topology.base
 
BaseComponent() - Constructor for class org.apache.storm.topology.base.BaseComponent
 
BaseConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Class in org.apache.storm.topology
 
BaseConfigurationDeclarer() - Constructor for class org.apache.storm.topology.BaseConfigurationDeclarer
 
BaseCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query
Default interface to map a ITuple to a CQL Statement.
BaseCQLStatementTupleMapper() - Constructor for class org.apache.storm.cassandra.query.BaseCQLStatementTupleMapper
 
BaseExecutionResultHandler - Class in org.apache.storm.cassandra
Simple ExecutionResultHandler which fail the incoming tuple when an DriverException is thrown.
BaseExecutionResultHandler() - Constructor for class org.apache.storm.cassandra.BaseExecutionResultHandler
 
BaseFilter - Class in org.apache.storm.trident.operation
 
BaseFilter() - Constructor for class org.apache.storm.trident.operation.BaseFilter
 
BaseFunction - Class in org.apache.storm.trident.operation
 
BaseFunction() - Constructor for class org.apache.storm.trident.operation.BaseFunction
 
BaseMultiReducer<T> - Class in org.apache.storm.trident.operation
 
BaseMultiReducer() - Constructor for class org.apache.storm.trident.operation.BaseMultiReducer
 
BaseOpaquePartitionedTransactionalSpout<T> - Class in org.apache.storm.topology.base
 
BaseOpaquePartitionedTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BaseOpaquePartitionedTransactionalSpout
 
BaseOperation - Class in org.apache.storm.trident.operation
Convenience implementation of the Operation interface.
BaseOperation() - Constructor for class org.apache.storm.trident.operation.BaseOperation
 
BasePartitionedTransactionalSpout<T> - Class in org.apache.storm.topology.base
 
BasePartitionedTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BasePartitionedTransactionalSpout
 
BaseQueryFunction<S extends State,T> - Class in org.apache.storm.trident.state
 
BaseQueryFunction() - Constructor for class org.apache.storm.trident.state.BaseQueryFunction
 
BaseRichBolt - Class in org.apache.storm.topology.base
 
BaseRichBolt() - Constructor for class org.apache.storm.topology.base.BaseRichBolt
 
BaseRichSpout - Class in org.apache.storm.topology.base
 
BaseRichSpout() - Constructor for class org.apache.storm.topology.base.BaseRichSpout
 
BaseStatefulBolt<T extends State> - Class in org.apache.storm.topology.base
 
BaseStatefulBolt() - Constructor for class org.apache.storm.topology.base.BaseStatefulBolt
 
BaseStatefulBoltExecutor - Class in org.apache.storm.topology
Base class that abstracts the common logic for executing bolts in a stateful topology.
BaseStatefulBoltExecutor() - Constructor for class org.apache.storm.topology.BaseStatefulBoltExecutor
 
BaseStatefulBoltExecutor.AnchoringOutputCollector - Class in org.apache.storm.topology
 
BaseStatefulWindowedBolt<T extends State> - Class in org.apache.storm.topology.base
 
BaseStatefulWindowedBolt() - Constructor for class org.apache.storm.topology.base.BaseStatefulWindowedBolt
 
BaseStateUpdater<S extends State> - Class in org.apache.storm.trident.state
 
BaseStateUpdater() - Constructor for class org.apache.storm.trident.state.BaseStateUpdater
 
BaseTaskHook - Class in org.apache.storm.hooks
 
BaseTaskHook() - Constructor for class org.apache.storm.hooks.BaseTaskHook
 
BaseTransactionalBolt - Class in org.apache.storm.topology.base
 
BaseTransactionalBolt() - Constructor for class org.apache.storm.topology.base.BaseTransactionalBolt
 
BaseTransactionalSpout<T> - Class in org.apache.storm.topology.base
 
BaseTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BaseTransactionalSpout
 
BaseWindowConfig - Class in org.apache.storm.trident.windowing.config
 
BaseWindowConfig(int, int) - Constructor for class org.apache.storm.trident.windowing.config.BaseWindowConfig
 
BaseWindowedBolt - Class in org.apache.storm.topology.base
 
BaseWindowedBolt() - Constructor for class org.apache.storm.topology.base.BaseWindowedBolt
 
BaseWindowedBolt.Count - Class in org.apache.storm.topology.base
Holds a count value for count based windows and sliding intervals.
BaseWindowedBolt.Duration - Class in org.apache.storm.topology.base
Holds a Time duration for time based windows and sliding intervals.
BaseWindowStrategy<T> - Class in org.apache.storm.trident.windowing.strategy
 
BaseWindowStrategy(WindowConfig) - Constructor for class org.apache.storm.trident.windowing.strategy.BaseWindowStrategy
 
BaseWorkerHook - Class in org.apache.storm.hooks
A BaseWorkerHook is a noop implementation of IWorkerHook.
BaseWorkerHook() - Constructor for class org.apache.storm.hooks.BaseWorkerHook
 
BasicBoltExecutor - Class in org.apache.storm.topology
 
BasicBoltExecutor(IBasicBolt) - Constructor for class org.apache.storm.topology.BasicBoltExecutor
 
BasicDRPCTopology - Class in org.apache.storm.starter
This topology is a basic example of doing distributed RPC on top of Storm.
BasicDRPCTopology() - Constructor for class org.apache.storm.starter.BasicDRPCTopology
 
BasicDRPCTopology.ExclaimBolt - Class in org.apache.storm.starter
 
BasicOutputCollector - Class in org.apache.storm.topology
 
BasicOutputCollector(OutputCollector) - Constructor for class org.apache.storm.topology.BasicOutputCollector
 
BATCH_STREAM_ID - Static variable in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
BatchAsyncResultHandler - Class in org.apache.storm.cassandra.executor.impl
 
BatchAsyncResultHandler(ExecutionResultHandler) - Constructor for class org.apache.storm.cassandra.executor.impl.BatchAsyncResultHandler
Creates a new BatchAsyncResultHandler instance.
BatchBoltExecutor - Class in org.apache.storm.coordination
 
BatchBoltExecutor(IBatchBolt) - Constructor for class org.apache.storm.coordination.BatchBoltExecutor
 
BatchCassandraWriterBolt - Class in org.apache.storm.cassandra.bolt
 
BatchCassandraWriterBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt
Creates a new CassandraWriterBolt instance.
BatchCassandraWriterBolt(CQLStatementTupleMapper, int) - Constructor for class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt
Creates a new CassandraWriterBolt instance.
BatchCount() - Constructor for class org.apache.storm.starter.TransactionalGlobalCount.BatchCount
 
BatchCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query.impl
 
BatchCQLStatementTupleMapper(BatchStatement.Type, List<CQLStatementTupleMapper>) - Constructor for class org.apache.storm.cassandra.query.impl.BatchCQLStatementTupleMapper
Creates a new BatchCQLStatementTupleMapper instance.
batchGet(List<Get>) - Method in class org.apache.storm.hbase.common.HBaseClient
 
batchGlobal() - Method in class org.apache.storm.trident.Stream
Repartitioning Operation
batchGroup - Variable in class org.apache.storm.trident.topology.BatchInfo
 
BatchHelper - Class in org.apache.storm.utils
 
BatchHelper(int, OutputCollector) - Constructor for class org.apache.storm.utils.BatchHelper
 
batchId - Variable in class org.apache.storm.trident.planner.ProcessorContext
 
batchId - Variable in class org.apache.storm.trident.topology.BatchInfo
 
BatchInfo - Class in org.apache.storm.trident.topology
 
BatchInfo(String, IBatchID, Object) - Constructor for class org.apache.storm.trident.topology.BatchInfo
 
batchMutate(List<Mutation>) - Method in class org.apache.storm.hbase.common.HBaseClient
 
BatchNumberList - Class in org.apache.storm.testing
 
BatchNumberList(String) - Constructor for class org.apache.storm.testing.BatchNumberList
 
BatchOutputCollector - Class in org.apache.storm.coordination
 
BatchOutputCollector() - Constructor for class org.apache.storm.coordination.BatchOutputCollector
 
BatchOutputCollectorImpl - Class in org.apache.storm.coordination
 
BatchOutputCollectorImpl(OutputCollector) - Constructor for class org.apache.storm.coordination.BatchOutputCollectorImpl
 
BatchProcessWord - Class in org.apache.storm.testing
 
BatchProcessWord() - Constructor for class org.apache.storm.testing.BatchProcessWord
 
BatchRepeatA - Class in org.apache.storm.testing
 
BatchRepeatA() - Constructor for class org.apache.storm.testing.BatchRepeatA
 
batchRetrieve(CassandraState, List<TridentTuple>) - Method in class org.apache.storm.cassandra.trident.state.CassandraQuery
 
batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.cassandra.trident.state.CassandraState
 
batchRetrieve(HBaseState, List<TridentTuple>) - Method in class org.apache.storm.hbase.trident.state.HBaseQuery
 
batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.hbase.trident.state.HBaseState
 
batchRetrieve(JdbcState, List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcQuery
 
batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcState
 
batchRetrieve(T, List<TridentTuple>) - Method in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
batchRetrieve(ReadOnlyMapState, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.MapGet
 
batchRetrieve(ReadOnlySnapshottable, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.SnapshotGet
 
batchRetrieve(State, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.TupleCollectionGet
 
batchRetrieve(S, List<TridentTuple>) - Method in interface org.apache.storm.trident.state.QueryFunction
 
batchSize - Variable in class org.apache.storm.hive.common.HiveOptions
 
BatchSpoutEmitter() - Constructor for class org.apache.storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
BatchSpoutExecutor - Class in org.apache.storm.trident.spout
 
BatchSpoutExecutor(IBatchSpout) - Constructor for class org.apache.storm.trident.spout.BatchSpoutExecutor
 
BatchSpoutExecutor.BatchSpoutEmitter - Class in org.apache.storm.trident.spout
 
BatchSpoutExecutor.EmptyCoordinator - Class in org.apache.storm.trident.spout
 
BatchSubtopologyBuilder - Class in org.apache.storm.coordination
 
BatchSubtopologyBuilder(String, IBasicBolt, Number) - Constructor for class org.apache.storm.coordination.BatchSubtopologyBuilder
 
BatchSubtopologyBuilder(String, IBasicBolt) - Constructor for class org.apache.storm.coordination.BatchSubtopologyBuilder
 
BeanDef - Class in org.apache.storm.flux.model
A representation of a Java object that is uniquely identifyable, and given a className, constructor arguments, and properties, can be instantiated.
BeanDef() - Constructor for class org.apache.storm.flux.model.BeanDef
 
BeanFactory<T> - Interface in org.apache.storm.cassandra.context
Simple interface used for providing services based on the storm configuration.
BeanReference - Class in org.apache.storm.flux.model
A bean reference is simply a string pointer to another id.
BeanReference() - Constructor for class org.apache.storm.flux.model.BeanReference
 
BeanReference(String) - Constructor for class org.apache.storm.flux.model.BeanReference
 
BEFORE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BEGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
beginBlobDownload(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
beginBlobDownload(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginBlobDownload
 
beginBlobDownload(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
beginBlobDownload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginBlobDownload
 
beginBlobDownload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args
 
beginBlobDownload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args
 
beginBlobDownload_args(Nimbus.beginBlobDownload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args
Performs a deep copy on other.
beginBlobDownload_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginBlobDownload_call
 
beginBlobDownload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result
 
beginBlobDownload_result(BeginDownloadResult, AuthorizationException, KeyNotFoundException) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result
 
beginBlobDownload_result(Nimbus.beginBlobDownload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result
Performs a deep copy on other.
beginColumn - Variable in class org.apache.storm.sql.parser.impl.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
beginCommit(Long) - Method in class org.apache.storm.cassandra.trident.state.CassandraState
 
beginCommit(Long) - Method in class org.apache.storm.hbase.trident.state.HBaseState
 
beginCommit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState
 
beginCommit(Long) - Method in class org.apache.storm.hive.trident.HiveState
 
beginCommit(Long) - Method in class org.apache.storm.jdbc.trident.state.JdbcState
 
beginCommit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState
 
beginCommit(Long) - Method in class org.apache.storm.mongodb.trident.state.MongoState
 
beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisClusterState
beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisState
beginCommit(Long) - Method in class org.apache.storm.solr.trident.SolrState
 
beginCommit(Long) - Method in class org.apache.storm.trident.state.map.NonTransactionalMap
 
beginCommit(Long) - Method in class org.apache.storm.trident.state.map.OpaqueMap
 
beginCommit(Long) - Method in class org.apache.storm.trident.state.map.SnapshottableMap
 
beginCommit(Long) - Method in class org.apache.storm.trident.state.map.TransactionalMap
 
beginCommit(Long) - Method in class org.apache.storm.trident.state.ReadOnlyState
 
beginCommit(Long) - Method in interface org.apache.storm.trident.state.State
 
beginCommit(Long) - Method in class org.apache.storm.trident.testing.LRUMemoryMapState
 
beginCommit(Long) - Method in class org.apache.storm.trident.testing.MemoryMapState
 
beginCommit(Long) - Method in class org.apache.storm.trident.windowing.WindowsState
 
beginCreateBlob(String, SettableBlobMeta, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
beginCreateBlob(String, SettableBlobMeta, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
beginCreateBlob() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginCreateBlob
 
beginCreateBlob(String, SettableBlobMeta) - Method in class org.apache.storm.generated.Nimbus.Client
 
beginCreateBlob(String, SettableBlobMeta) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
beginCreateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginCreateBlob
 
beginCreateBlob_args() - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args
 
beginCreateBlob_args(String, SettableBlobMeta) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args
 
beginCreateBlob_args(Nimbus.beginCreateBlob_args) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args
Performs a deep copy on other.
beginCreateBlob_call(String, SettableBlobMeta, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginCreateBlob_call
 
beginCreateBlob_result() - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result
 
beginCreateBlob_result(String, AuthorizationException, KeyAlreadyExistsException) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result
 
beginCreateBlob_result(Nimbus.beginCreateBlob_result) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result
Performs a deep copy on other.
BeginDownloadResult - Class in org.apache.storm.generated
 
BeginDownloadResult() - Constructor for class org.apache.storm.generated.BeginDownloadResult
 
BeginDownloadResult(long, String) - Constructor for class org.apache.storm.generated.BeginDownloadResult
 
BeginDownloadResult(BeginDownloadResult) - Constructor for class org.apache.storm.generated.BeginDownloadResult
Performs a deep copy on other.
BeginDownloadResult._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
beginFileDownload(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
beginFileDownload(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
beginFileDownload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginFileDownload
 
beginFileDownload(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
beginFileDownload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
beginFileDownload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginFileDownload
 
beginFileDownload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args
 
beginFileDownload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args
 
beginFileDownload_args(Nimbus.beginFileDownload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args
Performs a deep copy on other.
beginFileDownload_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginFileDownload_call
 
beginFileDownload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result
 
beginFileDownload_result(String, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result
 
beginFileDownload_result(Nimbus.beginFileDownload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result
Performs a deep copy on other.
beginFileUpload(AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
beginFileUpload(AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginFileUpload
 
beginFileUpload() - Method in class org.apache.storm.generated.Nimbus.Client
 
beginFileUpload() - Method in interface org.apache.storm.generated.Nimbus.Iface
 
beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginFileUpload
 
beginFileUpload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_args
 
beginFileUpload_args(Nimbus.beginFileUpload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_args
Performs a deep copy on other.
beginFileUpload_call(AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginFileUpload_call
 
beginFileUpload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result
 
beginFileUpload_result(String, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result
 
beginFileUpload_result(Nimbus.beginFileUpload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result
Performs a deep copy on other.
beginLine - Variable in class org.apache.storm.sql.parser.impl.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
BeginToken() - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
beginUpdateBlob(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
beginUpdateBlob(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginUpdateBlob
 
beginUpdateBlob(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
beginUpdateBlob(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginUpdateBlob
 
beginUpdateBlob_args() - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
 
beginUpdateBlob_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
 
beginUpdateBlob_args(Nimbus.beginUpdateBlob_args) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
Performs a deep copy on other.
beginUpdateBlob_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginUpdateBlob_call
 
beginUpdateBlob_result() - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
 
beginUpdateBlob_result(String, AuthorizationException, KeyNotFoundException) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
 
beginUpdateBlob_result(Nimbus.beginUpdateBlob_result) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
Performs a deep copy on other.
BEL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BERNOULLI - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BETWEEN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BIGINT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BINARY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
binary_arg(ByteBuffer) - Static method in class org.apache.storm.generated.JavaObjectArg
 
binary_arg(byte[]) - Static method in class org.apache.storm.generated.JavaObjectArg
 
BINARY_STRING_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BinaryMultisetOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a binary multiset operator.
BinaryQueryOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a binary query operator like UNION.
BinaryRowOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a binary row operator like AND.
bind(FieldSelector...) - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
Includes only the specified tuple fields.
bind(CqlMapper) - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
Includes only the specified tuple fields.
bind(String, int) - Method in interface org.apache.storm.messaging.IContext
This method establishes a server side connection
bind(String, int) - Method in class org.apache.storm.messaging.local.Context
 
bind(String, int) - Method in class org.apache.storm.messaging.netty.Context
establish a server with a binding port
BIT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
bitXorVals(List<Long>) - Static method in class org.apache.storm.utils.Utils
 
blacklistHost(String) - Method in class org.apache.storm.scheduler.Cluster
 
BLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BlobKeySequenceInfo - Class in org.apache.storm.blobstore
 
BlobKeySequenceInfo() - Constructor for class org.apache.storm.blobstore.BlobKeySequenceInfo
 
BlobStore - Class in org.apache.storm.blobstore
Provides a way to store blobs that can be downloaded.
BlobStore() - Constructor for class org.apache.storm.blobstore.BlobStore
 
BlobStore.BlobStoreFileInputStream - Class in org.apache.storm.blobstore
Input stream implementation used for writing both the metadata containing the acl information and the blob data.
BlobStore.BlobStoreFileOutputStream - Class in org.apache.storm.blobstore
Output stream implementation used for reading the metadata and data information.
BlobStore.KeyTranslationIterator - Class in org.apache.storm.blobstore
Blob store implements its own version of iterator to list the blobs
BLOBSTORE_CLEANUP_ENABLE - Static variable in class org.apache.storm.Config
Enable the blobstore cleaner.
BLOBSTORE_DATA_FILE - Static variable in class org.apache.storm.blobstore.BlobStoreFile
 
BLOBSTORE_DIR - Static variable in class org.apache.storm.Config
What directory to use for the blobstore.
BLOBSTORE_DIR_PERMISSION - Static variable in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreImpl
 
BLOBSTORE_FILE_PERMISSION - Static variable in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile
 
BLOBSTORE_HDFS_KEYTAB - Static variable in class org.apache.storm.Config
keytab for nimbus/supervisor to use to access secure hdfs for the blobstore.
BLOBSTORE_HDFS_PRINCIPAL - Static variable in class org.apache.storm.Config
principal for nimbus/supervisor to use to access secure hdfs for the blobstore.
BLOBSTORE_SUPERUSER - Static variable in class org.apache.storm.Config
The blobstore super user has all read/write/admin permissions to all blobs - user running the blobstore.
BlobStoreAclHandler - Class in org.apache.storm.blobstore
Provides common handling of acls for Blobstores.
BlobStoreAclHandler(Map) - Constructor for class org.apache.storm.blobstore.BlobStoreAclHandler
 
BlobStoreAPIWordCountTopology - Class in org.apache.storm.starter
 
BlobStoreAPIWordCountTopology() - Constructor for class org.apache.storm.starter.BlobStoreAPIWordCountTopology
 
BlobStoreAPIWordCountTopology.FilterWords - Class in org.apache.storm.starter
 
BlobStoreAPIWordCountTopology.RandomSentenceSpout - Class in org.apache.storm.starter
 
BlobStoreAPIWordCountTopology.SplitSentence - Class in org.apache.storm.starter
 
BlobStoreFile - Class in org.apache.storm.blobstore
Provides an base implementation for creating a blobstore based on file backed storage.
BlobStoreFile() - Constructor for class org.apache.storm.blobstore.BlobStoreFile
 
BlobStoreFileInputStream(BlobStoreFile) - Constructor for class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream
 
BlobStoreFileOutputStream(BlobStoreFile) - Constructor for class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream
 
BlobStoreUtils - Class in org.apache.storm.blobstore
 
BlobStoreUtils() - Constructor for class org.apache.storm.blobstore.BlobStoreUtils
 
BlobSynchronizer - Class in org.apache.storm.blobstore
Is called periodically and updates the nimbus with blobs based on the state stored inside the zookeeper for a non leader nimbus trying to be in sync with the operations performed on the leader nimbus.
BlobSynchronizer(BlobStore, Map) - Constructor for class org.apache.storm.blobstore.BlobSynchronizer
 
BlowfishTupleSerializer - Class in org.apache.storm.security.serialization
Apply Blowfish encryption for tuple communication to bolts
BlowfishTupleSerializer(Kryo, Map) - Constructor for class org.apache.storm.security.serialization.BlowfishTupleSerializer
 
Bolt - Class in org.apache.storm.generated
 
Bolt() - Constructor for class org.apache.storm.generated.Bolt
 
Bolt(ComponentObject, ComponentCommon) - Constructor for class org.apache.storm.generated.Bolt
 
Bolt(Bolt) - Constructor for class org.apache.storm.generated.Bolt
Performs a deep copy on other.
bolt(BoltStats) - Static method in class org.apache.storm.generated.ExecutorSpecificStats
 
bolt(BoltAggregateStats) - Static method in class org.apache.storm.generated.SpecificAggregateStats
 
Bolt._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BOLT_ID - Static variable in class storm.starter.HdfsSpoutTopology
 
BOLT_KEY - Static variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper
 
BOLT_MESSAGE - Static variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper
 
boltAck(BoltAckInfo) - Method in class org.apache.storm.hooks.BaseTaskHook
 
boltAck(BoltAckInfo) - Method in interface org.apache.storm.hooks.ITaskHook
 
BoltAckInfo - Class in org.apache.storm.hooks.info
 
BoltAckInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltAckInfo
 
BoltAggregateStats - Class in org.apache.storm.generated
 
BoltAggregateStats() - Constructor for class org.apache.storm.generated.BoltAggregateStats
 
BoltAggregateStats(BoltAggregateStats) - Constructor for class org.apache.storm.generated.BoltAggregateStats
Performs a deep copy on other.
BoltAggregateStats._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
boltConfig - Variable in class org.apache.storm.eventhubs.bolt.EventHubBolt
 
BoltDeclarer - Interface in org.apache.storm.topology
BoltDeclarer includes grouping APIs for storm topology.
BoltDef - Class in org.apache.storm.flux.model
Bean representation of a Storm bolt.
BoltDef() - Constructor for class org.apache.storm.flux.model.BoltDef
 
boltExecute(BoltExecuteInfo) - Method in class org.apache.storm.hooks.BaseTaskHook
 
boltExecute(BoltExecuteInfo) - Method in interface org.apache.storm.hooks.ITaskHook
 
BoltExecuteInfo - Class in org.apache.storm.hooks.info
 
BoltExecuteInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltExecuteInfo
 
boltFail(BoltFailInfo) - Method in class org.apache.storm.hooks.BaseTaskHook
 
boltFail(BoltFailInfo) - Method in interface org.apache.storm.hooks.ITaskHook
 
BoltFailInfo - Class in org.apache.storm.hooks.info
 
BoltFailInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltFailInfo
 
BoltGetter(String) - Constructor for class org.apache.storm.topology.TopologyBuilder.BoltGetter
 
boltKeyField - Variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper
 
boltMessageField - Variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper
 
BoltMsg - Class in org.apache.storm.multilang
BoltMsg is an object that represents the data sent from a shell component to a bolt process that implements a multi-language protocol.
BoltMsg() - Constructor for class org.apache.storm.multilang.BoltMsg
 
BoltStats - Class in org.apache.storm.generated
 
BoltStats() - Constructor for class org.apache.storm.generated.BoltStats
 
BoltStats(Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Double>>, Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Double>>) - Constructor for class org.apache.storm.generated.BoltStats
 
BoltStats(BoltStats) - Constructor for class org.apache.storm.generated.BoltStats
Performs a deep copy on other.
BoltStats._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BoltTracker - Class in org.apache.storm.testing
 
BoltTracker(IRichBolt, String) - Constructor for class org.apache.storm.testing.BoltTracker
 
bool_arg(boolean) - Static method in class org.apache.storm.generated.JavaObjectArg
 
BOOLEAN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BooleanValidator() - Constructor for class org.apache.storm.validation.ConfigValidation.BooleanValidator
 
boolval(boolean) - Static method in class org.apache.storm.generated.HBMessageData
 
BOOTSTRAP_SERVERS - Static variable in interface org.apache.storm.kafka.spout.KafkaSpoutConfig.Consumer
 
BOTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BoundCQLStatementMapperBuilder - Class in org.apache.storm.cassandra.query.builder
 
BoundCQLStatementMapperBuilder(String) - Constructor for class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
Creates a new BoundCQLStatementMapperBuilder instance.
BoundCQLStatementMapperBuilder(ContextQuery) - Constructor for class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
Creates a new BoundCQLStatementMapperBuilder instance.
BoundCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query.impl
 
BoundCQLStatementTupleMapper(ContextQuery, CqlMapper, RoutingKeyGenerator, PreparedStatementBinder) - Constructor for class org.apache.storm.cassandra.query.impl.BoundCQLStatementTupleMapper
Creates a new BoundCQLStatementTupleMapper instance.
boundQuery(String) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder
Builds a new bound statement based on the specified query.
boundQuery(ContextQuery) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder
Builds a new bound statement identified by the given field.
BoundQueryContext(String) - Constructor for class org.apache.storm.cassandra.query.ContextQuery.BoundQueryContext
 
BoundQueryNamedByFieldContext(String) - Constructor for class org.apache.storm.cassandra.query.ContextQuery.BoundQueryNamedByFieldContext
 
BRACKET_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BREADTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BridgeReceiver - Class in org.apache.storm.trident.planner
 
BridgeReceiver(BatchOutputCollector) - Constructor for class org.apache.storm.trident.planner.BridgeReceiver
 
broadcast() - Method in class org.apache.storm.trident.Stream
Repartitioning Operation
BROADCAST_DEST - Static variable in class org.apache.storm.tuple.AddressedTuple
Destination used when broadcasting a tuple.
Broker - Class in org.apache.storm.kafka
 
Broker(String, int) - Constructor for class org.apache.storm.kafka.Broker
 
Broker(String) - Constructor for class org.apache.storm.kafka.Broker
 
BrokerHosts - Interface in org.apache.storm.kafka
 
brokerPath() - Method in class org.apache.storm.kafka.DynamicBrokersReader
 
brokerZkPath - Variable in class org.apache.storm.kafka.ZkHosts
 
brokerZkStr - Variable in class org.apache.storm.kafka.ZkHosts
 
BTID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
BUCKET_DATABASE - Static variable in class org.apache.storm.starter.TransactionalWords
 
BUCKET_SIZE - Static variable in class org.apache.storm.starter.TransactionalWords
 
BucketCountUpdater() - Constructor for class org.apache.storm.starter.TransactionalWords.BucketCountUpdater
 
Bucketize() - Constructor for class org.apache.storm.starter.TransactionalWords.Bucketize
 
BucketValue() - Constructor for class org.apache.storm.starter.TransactionalWords.BucketValue
 
bufcolumn - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
buffer() - Method in enum org.apache.storm.messaging.netty.ControlMessage
encode the current Control Message into a channel buffer
buffer() - Method in interface org.apache.storm.messaging.netty.INettySerializable
 
buffer() - Method in class org.apache.storm.messaging.netty.SaslMessageToken
encode the current SaslToken Message into a channel buffer SaslTokenMessageRequest is encoded as: identifier ….
buffer - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
buffer_for_binary_arg() - Method in class org.apache.storm.generated.JavaObjectArg
 
buffer_for_bits() - Method in class org.apache.storm.generated.ThriftSerializedObject
 
buffer_for_chunk() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args
 
buffer_for_chunk() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args
 
buffer_for_custom_serialized() - Method in class org.apache.storm.generated.Grouping
 
buffer_for_details() - Method in class org.apache.storm.generated.HBPulse
 
buffer_for_message_blob() - Method in class org.apache.storm.generated.HBMessageData
 
buffer_for_serialized_java() - Method in class org.apache.storm.generated.ComponentObject
 
buffer_for_success() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result
 
buffer_for_success() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result
 
BUFFER_SIZE - Static variable in class org.apache.storm.hdfs.spout.SequenceFileReader
 
BUFFER_SIZE - Static variable in class org.apache.storm.hdfs.spout.TextFileReader
 
BufferFileInputStream - Class in org.apache.storm.utils
 
BufferFileInputStream(String, int) - Constructor for class org.apache.storm.utils.BufferFileInputStream
 
BufferFileInputStream(String) - Constructor for class org.apache.storm.utils.BufferFileInputStream
 
BufferInputStream - Class in org.apache.storm.utils
 
BufferInputStream(InputStream, int) - Constructor for class org.apache.storm.utils.BufferInputStream
 
BufferInputStream(InputStream) - Constructor for class org.apache.storm.utils.BufferInputStream
 
bufferSizeBytes - Variable in class org.apache.storm.kafka.KafkaConfig
 
bufline - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
bufpos - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
build() - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
Builds a new CQLStatementTupleMapper instance.
build() - Method in class org.apache.storm.cassandra.query.builder.SimpleCQLStatementMapperBuilder
Builds a new CQLStatementTupleMapper instance.
build() - Method in interface org.apache.storm.cassandra.query.CQLStatementBuilder
Builds a new CQLStatementTupleMapper instance.
build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
 
build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutTuplesBuilderNamedTopics.Builder
 
build() - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder
 
build() - Method in class org.apache.storm.redis.common.config.JedisClusterConfig.Builder
Builds JedisClusterConfig.
build() - Method in class org.apache.storm.redis.common.config.JedisPoolConfig.Builder
Builds JedisPoolConfig.
build(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder
Builds container for single Redis environment.
build(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder
Builds container for Redis Cluster environment.
build(List<Object>) - Method in interface org.apache.storm.redis.trident.state.KeyFactory
Converts state key to Redis key.
build(List<Object>) - Method in class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory
Converts state key to Redis key.
build() - Method in class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder
 
build() - Method in class org.apache.storm.solr.mapper.SolrJsonMapper.Builder
 
build() - Method in class org.apache.storm.sql.compiler.CompilerUtil.TableBuilderInfo
 
build(Map<String, ISqlTridentDataSource>) - Method in class org.apache.storm.sql.runtime.trident.AbstractTridentProcessor
Construct the trident topology based on the SQL.
build(IBackingMap<T>) - Static method in class org.apache.storm.trident.state.map.NonTransactionalMap
 
build(IBackingMap<OpaqueValue>) - Static method in class org.apache.storm.trident.state.map.OpaqueMap
 
build(IBackingMap<TransactionalValue>) - Static method in class org.apache.storm.trident.state.map.TransactionalMap
 
build() - Method in class org.apache.storm.trident.TridentTopology
 
buildAndLaunchWordCountTopology(String[]) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology
 
buildConfig(TopologyDef) - Static method in class org.apache.storm.flux.FluxBuilder
Given a topology definition, return a populated org.apache.storm.Config instance.
buildConsumerTopology(LocalDRPC) - Method in class org.apache.storm.starter.trident.TridentKafkaWordCount
Creates a trident topology that consumes sentences from the kafka “test” topic using a TransactionalTridentKafkaSpout computes the word count and stores it in a MemoryMapState.
buildDevicesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology
Creates a topology with device-id and count (which are whole numbers) as tuple fields in a stream and it finally generates result stream based on min amd max with device-id and count values.
Builder(Map<String, Object>, KafkaSpoutStreams, KafkaSpoutTuplesBuilder<K, V>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
Please refer to javadoc in #Builder(Map, KafkaSpoutStreams, KafkaSpoutTuplesBuilder, KafkaSpoutRetryService).

This constructor uses by the default the following implementation for KafkaSpoutRetryService:

new KafkaSpoutRetryExponentialBackoff(TimeInterval.seconds(0), TimeInterval.milliSeconds(2), DEFAULT_MAX_RETRIES, TimeInterval.seconds(10)))

Builder(Map<String, Object>, KafkaSpoutStreams, KafkaSpoutTuplesBuilder<K, V>, KafkaSpoutRetryService) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics The optional configuration can be specified using the set methods of this builder
Builder(Fields, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Creates a KafkaSpoutStream with the given output Fields for each topic specified.
Builder(Fields, String, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Creates a KafkaSpoutStream with this particular stream for each topic specified.
Builder(KafkaSpoutStream) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics.Builder
Adds this stream to the state representing the streams associated with each topic
Builder(KafkaSpoutTupleBuilder<K, V>...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutTuplesBuilderNamedTopics.Builder
 
Builder() - Constructor for class org.apache.storm.mqtt.common.MqttOptions.Builder
 
Builder() - Constructor for class org.apache.storm.redis.common.config.JedisClusterConfig.Builder
 
Builder() - Constructor for class org.apache.storm.redis.common.config.JedisPoolConfig.Builder
 
Builder(SchemaBuilder, String) - Constructor for class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder
SolrFieldsMapper builder class.
Builder(SchemaBuilder, SolrClient) - Constructor for class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder
SolrFieldsMapper builder class.
Builder(String, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder
SolrJsonMapper builder class.
Builder(SolrClient, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder
SolrJsonMapper builder class.
buildFieldIndex(ValuePointer[]) - Static method in class org.apache.storm.trident.tuple.ValuePointer
 
buildIndex(Fields, Map<String, ValuePointer>) - Static method in class org.apache.storm.trident.tuple.ValuePointer
 
buildProducerTopology(Properties) - Method in class org.apache.storm.starter.trident.TridentKafkaWordCount
A topology that produces random sentences using RandomSentenceSpout and publishes the sentences using a KafkaBolt to kafka “test” topic.
buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.EventCount
 
buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.EventHubLoop
 
buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.OpaqueTridentEventCount
 
buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.TransactionalTridentEventCount
 
buildTopology(ExecutionContext) - Static method in class org.apache.storm.flux.FluxBuilder
Given a topology definition, return a Storm topology that can be run either locally or remotely.
buildTopology(WindowsStoreFactory) - Static method in class org.apache.storm.starter.trident.TridentHBaseWindowingStoreTopology
 
buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentMapExample
 
buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentReach
 
buildTopology(WindowsStoreFactory, WindowConfig) - Static method in class org.apache.storm.starter.trident.TridentWindowingInmemoryStoreTopology
 
buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentWordCount
 
buildTopology() - Method in class org.apache.storm.transactional.TransactionalTopologyBuilder
Deprecated.
 
buildTopology() - Method in class org.apache.storm.trident.topology.TridentTopologyBuilder
 
buildTopologyBuilder() - Method in class org.apache.storm.transactional.TransactionalTopologyBuilder
Deprecated.
 
buildTuple(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.KafkaSpoutTupleBuilder
Builds a list of tuples using the ConsumerRecord specified as parameter
buildTuple(ConsumerRecord<K, V>) - Method in interface org.apache.storm.kafka.spout.KafkaSpoutTuplesBuilder
 
buildTuple(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.KafkaSpoutTuplesBuilderNamedTopics
 
buildTuple(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.KafkaSpoutTuplesBuilderWildcardTopics
 
buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfDevicesTopology.Vehicle and TridentMinMaxOfDevicesTopology.Driver respectively.
buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfVehiclesTopology
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.
BuiltinFunctionCall() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a call to a builtin function with special syntax.
BY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
byNamedSetters() - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
 
ByteArrayMessageMapper - Class in org.apache.storm.mqtt.mappers
 
ByteArrayMessageMapper() - Constructor for class org.apache.storm.mqtt.mappers.ByteArrayMessageMapper
 
ByteBufferSerializer - Class in org.apache.storm.kafka
 
ByteBufferSerializer() - Constructor for class org.apache.storm.kafka.ByteBufferSerializer
 

C

C - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
C(Map) - Constructor for class org.apache.storm.starter.ThroughputVsLatency.C
 
cached - Variable in class org.apache.storm.trident.state.map.CachedBatchReadsMap.RetVal
 
CachedBatchReadsMap<T> - Class in org.apache.storm.trident.state.map
 
CachedBatchReadsMap(IBackingMap<T>) - Constructor for class org.apache.storm.trident.state.map.CachedBatchReadsMap
 
CachedBatchReadsMap.RetVal<T> - Class in org.apache.storm.trident.state.map
 
cachedGroups - Variable in class org.apache.storm.security.auth.ShellBasedGroupsMapping
 
CachedMap<T> - Class in org.apache.storm.trident.state.map
Useful to layer over a map that communicates with a database.
CachedMap(IBackingMap<T>, int) - Constructor for class org.apache.storm.trident.state.map.CachedMap
 
cacheSize - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options
 
calculateParititionIdsToOwn() - Method in class org.apache.storm.eventhubs.spout.StaticPartitionCoordinator
 
calculatePartitionsForTask(List<GlobalPartitionInformation>, int, int) - Static method in class org.apache.storm.kafka.KafkaUtils
 
CALL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
callbackHandler - Variable in class org.apache.storm.messaging.netty.Login
 
CALLED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
callTimeout - Variable in class org.apache.storm.hive.common.HiveOptions
 
canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.DefaultPool
 
canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.FreePool
 
canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.IsolatedPool
 
canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.NodePool
Check if this topology can be added to this pool
cancel() - Method in class org.apache.storm.blobstore.AtomicOutputStream
Cancel all of the writes associated with this stream and close it.
cancel() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream
 
cancel() - Method in class org.apache.storm.blobstore.BlobStoreFile
 
cancel() - Method in class org.apache.storm.blobstore.LocalFsBlobStoreFile
 
cancel() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusUploadAtomicOutputStream
 
cancel() - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile
 
cancelBlobUpload(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
cancelBlobUpload(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
cancelBlobUpload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.cancelBlobUpload
 
cancelBlobUpload(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
cancelBlobUpload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
cancelBlobUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.cancelBlobUpload
 
cancelBlobUpload_args() - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
 
cancelBlobUpload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
 
cancelBlobUpload_args(Nimbus.cancelBlobUpload_args) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
Performs a deep copy on other.
cancelBlobUpload_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.cancelBlobUpload_call
 
cancelBlobUpload_result() - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
 
cancelBlobUpload_result(AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
 
cancelBlobUpload_result(Nimbus.cancelBlobUpload_result) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
Performs a deep copy on other.
canRelocateClass(String) - Method in interface org.apache.storm.hack.relocation.Relocator
 
canRelocateClass(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator
 
canRelocatePath(String) - Method in interface org.apache.storm.hack.relocation.Relocator
 
canRelocatePath(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator
 
canTransformResource(String) - Method in class org.apache.storm.hack.resource.ClojureTransformer
 
canTransformResource(String) - Method in interface org.apache.storm.hack.resource.ResourceTransformer
 
canTransformResource(String) - Method in class org.apache.storm.maven.shade.clojure.ClojureTransformer
 
canUserReadBlob(ReadableBlobMeta, String) - Static method in class org.apache.storm.utils.Utils
 
capacity() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics
 
CaptureCollector - Class in org.apache.storm.trident.operation.impl
 
CaptureCollector() - Constructor for class org.apache.storm.trident.operation.impl.CaptureCollector
 
captured - Variable in class org.apache.storm.trident.operation.impl.CaptureCollector
 
CARDINALITY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CASCADE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CASCADED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CASE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CaseExpression() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
CASSANDRA_BATCH_SIZE_ROWS - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_CONSISTENCY_LEVEL - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_KEYSPACE - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_NODES - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_PASSWORD - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_PORT - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_RECONNECT_POLICY_BASE_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_RECONNECT_POLICY_MAX_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_RETRY_POLICY - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CASSANDRA_USERNAME - Static variable in class org.apache.storm.cassandra.client.CassandraConf
 
CassandraConf - Class in org.apache.storm.cassandra.client
Configuration used by cassandra storm components.
CassandraConf() - Constructor for class org.apache.storm.cassandra.client.CassandraConf
Creates a new CassandraConf instance.
CassandraConf(Map<String, Object>) - Constructor for class org.apache.storm.cassandra.client.CassandraConf
Creates a new CassandraConf instance.
cassandraConfConfig - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
 
CassandraConfFactory() - Constructor for class org.apache.storm.cassandra.CassandraContext.CassandraConfFactory
 
CassandraContext - Class in org.apache.storm.cassandra
 
CassandraContext() - Constructor for class org.apache.storm.cassandra.CassandraContext
Creates a new CassandraContext instance.
CassandraContext.CassandraConfFactory - Class in org.apache.storm.cassandra
Simple class to make CassandraConf from a Storm topology configuration.
CassandraContext.ClientFactory - Class in org.apache.storm.cassandra
Simple class to make CassandraContext.ClientFactory from a Storm topology configuration.
CassandraQuery - Class in org.apache.storm.cassandra.trident.state
 
CassandraQuery() - Constructor for class org.apache.storm.cassandra.trident.state.CassandraQuery
 
CassandraState - Class in org.apache.storm.cassandra.trident.state
 
CassandraState(Map, CassandraState.Options) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraState
 
CassandraState.Options - Class in org.apache.storm.cassandra.trident.state
 
CassandraStateFactory - Class in org.apache.storm.cassandra.trident.state
 
CassandraStateFactory(CassandraState.Options) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateFactory
 
CassandraStateFactory(CQLStatementTupleMapper, CQLResultSetValuesMapper) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateFactory
 
CassandraStateUpdater - Class in org.apache.storm.cassandra.trident.state
 
CassandraStateUpdater() - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateUpdater
 
CassandraWriterBolt - Class in org.apache.storm.cassandra.bolt
 
CassandraWriterBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.CassandraWriterBolt
Creates a new CassandraWriterBolt instance.
CAST - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CATALOG_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CEIL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CEILING - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHAIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
chain(ChannelContext, ChannelHandler) - Static method in class org.apache.storm.sql.runtime.Channels
 
chainedAgg() - Method in class org.apache.storm.trident.fluent.GroupedStream
 
chainedAgg() - Method in class org.apache.storm.trident.Stream
 
ChainedAggregatorDeclarer - Class in org.apache.storm.trident.fluent
 
ChainedAggregatorDeclarer(IAggregatableStream, GlobalAggregationScheme) - Constructor for class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
ChainedAggregatorDeclarer.AggregationPartition - Interface in org.apache.storm.trident.fluent
 
ChainedAggregatorImpl - Class in org.apache.storm.trident.operation.impl
 
ChainedAggregatorImpl(Aggregator[], Fields[], ComboList.Factory) - Constructor for class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
 
ChainedFullAggregatorDeclarer - Interface in org.apache.storm.trident.fluent
 
ChainedPartitionAggregatorDeclarer - Interface in org.apache.storm.trident.fluent
 
ChainedResult - Class in org.apache.storm.trident.operation.impl
 
ChainedResult(TridentCollector, int) - Constructor for class org.apache.storm.trident.operation.impl.ChainedResult
 
chainEnd() - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
 
chainEnd() - Method in interface org.apache.storm.trident.fluent.IChainedAggregatorDeclarer
 
channelConnected(Channel) - Method in class org.apache.storm.messaging.netty.Client
ISaslClient interface
channelConnected(Channel) - Method in interface org.apache.storm.messaging.netty.ISaslClient
 
channelConnected(Channel) - Method in interface org.apache.storm.messaging.netty.IServer
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.SaslStormClientHandler
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.StormServerHandler
 
channelConnected(Channel) - Method in class org.apache.storm.pacemaker.PacemakerClient
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.pacemaker.PacemakerClientHandler
 
ChannelContext - Interface in org.apache.storm.sql.runtime
 
ChannelHandler - Interface in org.apache.storm.sql.runtime
DataListener provides an event-driven interface for the user to process series of events.
channelInactive(ChannelContext) - Method in class org.apache.storm.sql.runtime.AbstractChannelHandler
 
channelInactive(ChannelContext) - Method in interface org.apache.storm.sql.runtime.ChannelHandler
The producer of the data has indicated that the channel is no longer active.
channelInterestChanged(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.StormClientHandler
 
channelReady() - Method in class org.apache.storm.messaging.netty.Client
 
channelReady() - Method in interface org.apache.storm.messaging.netty.ISaslClient
 
channelReady() - Method in class org.apache.storm.pacemaker.PacemakerClient
 
Channels - Class in org.apache.storm.sql.runtime
 
Channels() - Constructor for class org.apache.storm.sql.runtime.Channels
 
CHAR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHAR_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTER_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTER_SET_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTER_SET_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTER_SET_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTERISTICS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARACTERS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHARSET - Static variable in class org.apache.storm.hdfs.spout.TextFileReader
 
CHARSETNAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CHECK - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
Check() - Constructor for class org.apache.storm.starter.InOrderDeliveryTest.Check
 
checkFileExists(String, String) - Static method in class org.apache.storm.utils.Utils
 
checkForBlobOrDownload(String) - Method in class org.apache.storm.blobstore.LocalFsBlobStore
 
checkForBlobUpdate(String) - Method in class org.apache.storm.blobstore.LocalFsBlobStore
 
checkForValidUsers(Subject, int) - Method in class org.apache.storm.blobstore.BlobStoreAclHandler
 
checkInitCPU(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils
 
checkInitMem(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils
 
checkIntialization(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils
 
checkpoint() - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager
 
checkpoint() - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager
 
CHECKPOINT_COMPONENT_ID - Static variable in class org.apache.storm.spout.CheckpointSpout
 
CHECKPOINT_FIELD_ACTION - Static variable in class org.apache.storm.spout.CheckpointSpout
 
CHECKPOINT_FIELD_TXID - Static variable in class org.apache.storm.spout.CheckpointSpout
 
CHECKPOINT_STREAM_ID - Static variable in class org.apache.storm.spout.CheckpointSpout
 
CheckpointSpout - Class in org.apache.storm.spout
Emits checkpoint tuples which is used to save the state of the IStatefulComponent across the topology.
CheckpointSpout() - Constructor for class org.apache.storm.spout.CheckpointSpout
 
CheckPointState - Class in org.apache.storm.spout
Captures the current state of the transaction in CheckpointSpout.
CheckPointState(long, CheckPointState.State) - Constructor for class org.apache.storm.spout.CheckPointState
 
CheckPointState() - Constructor for class org.apache.storm.spout.CheckPointState
 
CheckPointState.Action - Enum in org.apache.storm.spout
 
CheckPointState.State - Enum in org.apache.storm.spout
 
CheckpointTupleForwarder - Class in org.apache.storm.topology
Wraps IRichBolt and forwards checkpoint tuples in a stateful topology.
CheckpointTupleForwarder(IRichBolt) - Constructor for class org.apache.storm.topology.CheckpointTupleForwarder
 
checkSslConfig(String, KeyStoreLoader) - Static method in class org.apache.storm.mqtt.common.SslUtils
 
checkType(ComponentObject._Fields, Object) - Method in class org.apache.storm.generated.ComponentObject
 
checkType(ExecutorSpecificStats._Fields, Object) - Method in class org.apache.storm.generated.ExecutorSpecificStats
 
checkType(Grouping._Fields, Object) - Method in class org.apache.storm.generated.Grouping
 
checkType(HBMessageData._Fields, Object) - Method in class org.apache.storm.generated.HBMessageData
 
checkType(JavaObjectArg._Fields, Object) - Method in class org.apache.storm.generated.JavaObjectArg
 
checkType(SpecificAggregateStats._Fields, Object) - Method in class org.apache.storm.generated.SpecificAggregateStats
 
checkType(TopologyActionOptions._Fields, Object) - Method in class org.apache.storm.generated.TopologyActionOptions
 
children - Variable in class org.apache.storm.scheduler.resource.Component
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.cassandra.Murmur3StreamGrouping
This function implements a custom stream grouping.
chooseTasks(int, List<Object>) - Method in interface org.apache.storm.grouping.CustomStreamGrouping
This function implements a custom stream grouping.
chooseTasks(int, List<Object>, LoadMapping) - Method in interface org.apache.storm.grouping.LoadAwareCustomStreamGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.LoadAwareShuffleGrouping
 
chooseTasks(int, List<Object>, LoadMapping) - Method in class org.apache.storm.grouping.LoadAwareShuffleGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.PartialKeyGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.ShuffleGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.testing.NGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.GlobalGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.IdentityGrouping
 
chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.IndexHashGrouping
 
CLASS_ORIGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
className() - Method in class org.apache.storm.sql.parser.SqlCreateFunction
 
cleanConnection(boolean) - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder
 
cleanup() - Method in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
Called when an IBolt is going to be shutdown.
cleanup() - Method in class org.apache.storm.cassandra.trident.state.CassandraState
 
cleanup() - Method in class org.apache.storm.clojure.ClojureBolt
 
cleanup() - Method in class org.apache.storm.coordination.BatchBoltExecutor
 
cleanup() - Method in class org.apache.storm.coordination.CoordinatedBolt
 
cleanup() - Method in class org.apache.storm.drpc.KeyedFairBolt
 
cleanup() - Method in class org.apache.storm.drpc.ReturnResults
 
cleanup() - Method in class org.apache.storm.flux.examples.WordCounter
 
cleanup() - Method in class org.apache.storm.hbase.bolt.AbstractHBaseBolt
 
cleanup() - Method in class org.apache.storm.hive.bolt.HiveBolt
 
cleanup() - Method in class org.apache.storm.hive.trident.HiveState
 
cleanup() - Method in class org.apache.storm.hooks.BaseTaskHook
 
cleanup() - Method in interface org.apache.storm.hooks.ITaskHook
 
cleanup() - Method in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
cleanup() - Method in interface org.apache.storm.jdbc.common.ConnectionProvider
called once when the system is shutting down, should be idempotent.
cleanup() - Method in class org.apache.storm.jdbc.common.HikariCPConnectionProvider
 
cleanup() - Method in class org.apache.storm.kafka.bolt.KafkaBolt
 
cleanup() - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet
 
cleanup() - Method in interface org.apache.storm.metric.api.IMetricsConsumer
 
cleanup() - Method in class org.apache.storm.metric.EventLoggerBolt
 
cleanup() - Method in class org.apache.storm.metric.HttpForwardingMetricsConsumer
 
cleanup() - Method in class org.apache.storm.metric.LoggingMetricsConsumer
 
cleanup() - Method in class org.apache.storm.metric.MetricsConsumerBolt
 
cleanup() - Method in class org.apache.storm.metric.SystemBolt
 
cleanup() - Method in class org.apache.storm.mongodb.bolt.AbstractMongoBolt
 
cleanup() - Method in interface org.apache.storm.nimbus.ITopologyActionNotifierPlugin
called during shutdown.
cleanup() - Method in interface org.apache.storm.task.IBolt
Called when an IBolt is going to be shutdown.
cleanup() - Method in class org.apache.storm.task.ShellBolt
 
cleanup() - Method in class org.apache.storm.testing.FixedTupleSpout
 
cleanup() - Method in class org.apache.storm.testing.ForwardingMetricsConsumer
 
cleanup() - Method in class org.apache.storm.testing.MemoryTransactionalSpout
 
cleanup() - Method in class org.apache.storm.testing.NonRichBoltTracker
 
cleanup() - Method in class org.apache.storm.testing.OpaqueMemoryTransactionalSpout
 
cleanup() - Method in class org.apache.storm.testing.TestAggregatesCounter
 
cleanup() - Method in class org.apache.storm.testing.TestEventLogSpout
 
cleanup() - Method in class org.apache.storm.testing.TestEventOrderCheckBolt
 
cleanup() - Method in class org.apache.storm.testing.TestGlobalCount
 
cleanup() - Method in class org.apache.storm.testing.TestWordCounter
 
cleanup() - Method in class org.apache.storm.testing.TupleCaptureBolt
 
cleanup() - Method in class org.apache.storm.topology.base.BaseBasicBolt
 
cleanup() - Method in class org.apache.storm.topology.base.BaseRichBolt
 
cleanup() - Method in class org.apache.storm.topology.base.BaseStatefulBolt
 
cleanup() - Method in class org.apache.storm.topology.base.BaseWindowedBolt
 
cleanup() - Method in class org.apache.storm.topology.BasicBoltExecutor
 
cleanup() - Method in class org.apache.storm.topology.CheckpointTupleForwarder
 
cleanup() - Method in interface org.apache.storm.topology.IBasicBolt
 
cleanup() - Method in interface org.apache.storm.topology.IStatefulBolt
 
cleanup() - Method in interface org.apache.storm.topology.IWindowedBolt
 
cleanup() - Method in class org.apache.storm.topology.StatefulBoltExecutor
 
cleanup() - Method in class org.apache.storm.topology.WindowedBoltExecutor
 
cleanup() - Method in class org.apache.storm.transactional.TransactionalSpoutBatchExecutor
 
cleanup() - Method in class org.apache.storm.trident.drpc.ReturnResultsReducer
 
cleanup() - Method in class org.apache.storm.trident.operation.BaseMultiReducer
 
cleanup() - Method in class org.apache.storm.trident.operation.BaseOperation
No-op implemnation.
cleanup() - Method in class org.apache.storm.trident.operation.builtin.Negate
 
cleanup() - Method in interface org.apache.storm.trident.operation.GroupedMultiReducer
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.FilterExecutor
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.IdentityMultiReducer
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.JoinerMultiReducer
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.TrueFilter
 
cleanup() - Method in interface org.apache.storm.trident.operation.MultiReducer
 
cleanup() - Method in interface org.apache.storm.trident.operation.Operation
When running in local mode, called when the local cluster is being shut down.
cleanup() - Method in class org.apache.storm.trident.planner.processor.AggregateProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.EachProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.MapProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.MultiReducerProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.PartitionPersistProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.ProjectedProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.processor.StateQueryProcessor
 
cleanup() - Method in class org.apache.storm.trident.planner.SubtopologyBolt
 
cleanup() - Method in interface org.apache.storm.trident.planner.TridentProcessor
 
cleanup() - Method in class org.apache.storm.trident.spout.TridentSpoutCoordinator
 
cleanup() - Method in class org.apache.storm.trident.spout.TridentSpoutExecutor
 
cleanup() - Method in class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater
 
cleanup() - Method in class org.apache.storm.trident.state.map.MapReducerAggStateUpdater
 
cleanup() - Method in interface org.apache.storm.trident.topology.ITridentBatchBolt
 
cleanup() - Method in class org.apache.storm.trident.topology.TridentBoltExecutor
 
cleanup() - Method in class org.apache.storm.trident.windowing.WindowsStateUpdater
 
cleanup() - Method in class org.apache.storm.trident.windowing.WindowTridentProcessor
 
cleanup(int) - Method in class org.apache.storm.utils.LocalState
 
cleanup() - Method in class org.apache.storm.utils.TimeCacheMap
Deprecated.
 
cleanup() - Method in class org.apache.storm.utils.VersionedStore
 
cleanup(int) - Method in class org.apache.storm.utils.VersionedStore
 
cleanupBefore(BigInteger) - Method in interface org.apache.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 org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter
 
cleanupBefore(BigInteger) - Method in class org.apache.storm.transactional.state.RotatingTransactionalState
 
cleanupBefore(long) - Method in class org.apache.storm.trident.topology.state.RotatingTransactionalState
 
clear() - Method in class org.apache.storm.generated.AccessControl
 
clear() - Method in exception org.apache.storm.generated.AlreadyAliveException
 
clear() - Method in class org.apache.storm.generated.Assignment
 
clear() - Method in exception org.apache.storm.generated.AuthorizationException
 
clear() - Method in class org.apache.storm.generated.BeginDownloadResult
 
clear() - Method in class org.apache.storm.generated.Bolt
 
clear() - Method in class org.apache.storm.generated.BoltAggregateStats
 
clear() - Method in class org.apache.storm.generated.BoltStats
 
clear() - Method in class org.apache.storm.generated.ClusterSummary
 
clear() - Method in class org.apache.storm.generated.ClusterWorkerHeartbeat
 
clear() - Method in class org.apache.storm.generated.CommonAggregateStats
 
clear() - Method in class org.apache.storm.generated.ComponentAggregateStats
 
clear() - Method in class org.apache.storm.generated.ComponentCommon
 
clear() - Method in class org.apache.storm.generated.ComponentPageInfo
 
clear() - Method in class org.apache.storm.generated.Credentials
 
clear() - Method in class org.apache.storm.generated.DebugOptions
 
clear() - Method in class org.apache.storm.generated.DistributedRPC.execute_args
 
clear() - Method in class org.apache.storm.generated.DistributedRPC.execute_result
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_args
 
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_result
 
clear() - Method in exception org.apache.storm.generated.DRPCExecutionException
 
clear() - Method in class org.apache.storm.generated.DRPCRequest
 
clear() - Method in class org.apache.storm.generated.ErrorInfo
 
clear() - Method in class org.apache.storm.generated.ExecutorAggregateStats
 
clear() - Method in class org.apache.storm.generated.ExecutorInfo
 
clear() - Method in class org.apache.storm.generated.ExecutorStats
 
clear() - Method in class org.apache.storm.generated.ExecutorSummary
 
clear() - Method in class org.apache.storm.generated.GetInfoOptions
 
clear() - Method in class org.apache.storm.generated.GlobalStreamId
 
clear() - Method in exception org.apache.storm.generated.HBAuthorizationException
 
clear() - Method in exception org.apache.storm.generated.HBExecutionException
 
clear() - Method in class org.apache.storm.generated.HBMessage
 
clear() - Method in class org.apache.storm.generated.HBNodes
 
clear() - Method in class org.apache.storm.generated.HBPulse
 
clear() - Method in class org.apache.storm.generated.HBRecords
 
clear() - Method in exception org.apache.storm.generated.InvalidTopologyException
 
clear() - Method in class org.apache.storm.generated.JavaObject
 
clear() - Method in exception org.apache.storm.generated.KeyAlreadyExistsException
 
clear() - Method in exception org.apache.storm.generated.KeyNotFoundException
 
clear() - Method in class org.apache.storm.generated.KillOptions
 
clear() - Method in class org.apache.storm.generated.ListBlobsResult
 
clear() - Method in class org.apache.storm.generated.LocalAssignment
 
clear() - Method in class org.apache.storm.generated.LocalStateData
 
clear() - Method in class org.apache.storm.generated.LogConfig
 
clear() - Method in class org.apache.storm.generated.LogLevel
 
clear() - Method in class org.apache.storm.generated.LSApprovedWorkers
 
clear() - Method in class org.apache.storm.generated.LSSupervisorAssignments
 
clear() - Method in class org.apache.storm.generated.LSSupervisorId
 
clear() - Method in class org.apache.storm.generated.LSTopoHistory
 
clear() - Method in class org.apache.storm.generated.LSTopoHistoryList
 
clear() - Method in class org.apache.storm.generated.LSWorkerHeartbeat
 
clear() - Method in class org.apache.storm.generated.Nimbus.activate_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.activate_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.deactivate_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.deactivate_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.debug_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.debug_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopology_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopology_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.killTopology_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.killTopology_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.listBlobs_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.listBlobs_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.rebalance_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.rebalance_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.submitTopology_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.submitTopology_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_result
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_result
 
clear() - Method in class org.apache.storm.generated.NimbusSummary
 
clear() - Method in class org.apache.storm.generated.NodeInfo
 
clear() - Method in exception org.apache.storm.generated.NotAliveException
 
clear() - Method in class org.apache.storm.generated.NullStruct
 
clear() - Method in class org.apache.storm.generated.ProfileRequest
 
clear() - Method in class org.apache.storm.generated.ReadableBlobMeta
 
clear() - Method in class org.apache.storm.generated.RebalanceOptions
 
clear() - Method in class org.apache.storm.generated.SettableBlobMeta
 
clear() - Method in class org.apache.storm.generated.ShellComponent
 
clear() - Method in class org.apache.storm.generated.SpoutAggregateStats
 
clear() - Method in class org.apache.storm.generated.SpoutSpec
 
clear() - Method in class org.apache.storm.generated.SpoutStats
 
clear() - Method in class org.apache.storm.generated.StateSpoutSpec
 
clear() - Method in class org.apache.storm.generated.StormBase
 
clear() - Method in class org.apache.storm.generated.StormTopology
 
clear() - Method in class org.apache.storm.generated.StreamInfo
 
clear() - Method in class org.apache.storm.generated.SubmitOptions
 
clear() - Method in class org.apache.storm.generated.SupervisorInfo
 
clear() - Method in class org.apache.storm.generated.SupervisorSummary
 
clear() - Method in class org.apache.storm.generated.ThriftSerializedObject
 
clear() - Method in class org.apache.storm.generated.TopologyHistoryInfo
 
clear() - Method in class org.apache.storm.generated.TopologyInfo
 
clear() - Method in class org.apache.storm.generated.TopologyPageInfo
 
clear() - Method in class org.apache.storm.generated.TopologyStats
 
clear() - Method in class org.apache.storm.generated.TopologySummary
 
clear() - Method in class org.apache.storm.generated.WorkerResources
 
clear() - Method in class org.apache.storm.kafka.DynamicPartitionConnections
 
clear(String) - Static method in class org.apache.storm.testing.FixedTupleSpout
 
clear() - Method in class org.apache.storm.utils.IndifferentAccessMap
 
clear() - Method in class org.apache.storm.utils.ListDelegate
 
clear() - Method in class org.apache.storm.utils.TransferDrainer
 
clearCredentials(Subject, KerberosTicket) - Static method in class org.apache.storm.security.auth.kerberos.AutoTGT
 
clearOffsetsBefore(Long) - Method in class org.apache.storm.kafka.ExponentialBackoffMsgRetryManager
 
clearOffsetsBefore(Long) - Method in interface org.apache.storm.kafka.FailedMsgRetryManager
Clear any offsets before kafkaOffset.
clearState(String) - Static method in class org.apache.storm.utils.RegisteredGlobalState
 
client - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
 
client - Static variable in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
 
Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client
 
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client
 
Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client
 
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client
 
Client(TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client
 
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client
 
Client - Class in org.apache.storm.messaging.netty
A Netty client for sending task messages to a remote destination (Netty server).
client - Variable in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModuleTest
 
CLIENT_BLOBSTORE - Static variable in class org.apache.storm.Config
What blobstore implementation the storm client should use.
CLIENT_JAR_TRANSFORMER - Static variable in class org.apache.storm.Config
An implementation of @{link org.apache.storm.daemon.JarTransformer} that will can be used to transform a jar file before storm jar runs with it.
CLIENT_USERS_KEY - Static variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer
 
ClientBlobStore - Class in org.apache.storm.blobstore
The ClientBlobStore has two concrete implementations 1.
ClientBlobStore() - Constructor for class org.apache.storm.blobstore.ClientBlobStore
 
ClientCallbackHandler - Class in org.apache.storm.security.auth.digest
client side callback handler.
ClientCallbackHandler(Configuration) - Constructor for class org.apache.storm.security.auth.digest.ClientCallbackHandler
Constructor based on a JAAS configuration
ClientCallbackHandler - Class in org.apache.storm.security.auth.kerberos
SASL client side callback handler.
ClientCallbackHandler(Configuration) - Constructor for class org.apache.storm.security.auth.kerberos.ClientCallbackHandler
Constructor based on a JAAS configuration
ClientFactory() - Constructor for class org.apache.storm.cassandra.CassandraContext.ClientFactory
 
clientId - Variable in class org.apache.storm.kafka.KafkaConfig
 
ClientJarTransformerRunner - Class in org.apache.storm.daemon
Main executable to load and run a jar transformer
ClientJarTransformerRunner() - Constructor for class org.apache.storm.daemon.ClientJarTransformerRunner
 
clientProvider - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
 
clientUsers - Variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry
 
CLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CLOCKS_INSYNC - Static variable in class org.apache.storm.hdfs.spout.Configs
 
ClojureBolt - Class in org.apache.storm.clojure
 
ClojureBolt(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureBolt
 
ClojureSpout - Class in org.apache.storm.clojure
 
ClojureSpout(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureSpout
 
ClojureTimerTask - Class in org.apache.storm.utils
 
ClojureTimerTask(IFn) - Constructor for class org.apache.storm.utils.ClojureTimerTask
 
ClojureTransformer - Class in org.apache.storm.hack.resource
 
ClojureTransformer() - Constructor for class org.apache.storm.hack.resource.ClojureTransformer
 
ClojureTransformer - Class in org.apache.storm.maven.shade.clojure
 
ClojureTransformer() - Constructor for class org.apache.storm.maven.shade.clojure.ClojureTransformer
 
clone() - Method in class org.apache.storm.hdfs.spout.SequenceFileReader.Offset
 
clone() - Method in class org.apache.storm.hdfs.spout.TextFileReader.Offset
 
cloneKerberosTicket(KerberosTicket) - Static method in class org.apache.storm.security.auth.AuthUtils
 
close() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream
 
close() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream
 
close() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusUploadAtomicOutputStream
 
close() - Method in class org.apache.storm.cassandra.client.impl.DefaultClient
Close the underlying Cluster instance.
close() - Method in interface org.apache.storm.cassandra.client.SimpleClient
Close the underlying Cluster instance.
close() - Method in class org.apache.storm.clojure.ClojureSpout
 
close() - Method in interface org.apache.storm.cluster.ClusterState
Close the connection to the data store.
close() - Method in class org.apache.storm.drpc.DRPCSpout
 
close() - Method in class org.apache.storm.eventhubs.spout.EventHubReceiverImpl
 
close() - Method in class org.apache.storm.eventhubs.spout.EventHubSpout
 
close() - Method in interface org.apache.storm.eventhubs.spout.IEventHubReceiver
 
close() - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager
 
close() - Method in interface org.apache.storm.eventhubs.spout.IStateStore
 
close() - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager
 
close() - Method in class org.apache.storm.eventhubs.spout.ZookeeperStateStore
 
close() - Method in class org.apache.storm.eventhubs.trident.Coordinator
 
close() - Method in interface org.apache.storm.eventhubs.trident.ITridentPartitionManager
 
close() - Method in class org.apache.storm.eventhubs.trident.OpaqueTridentEventHubEmitter
 
close() - Method in class org.apache.storm.eventhubs.trident.TransactionalTridentEventHubEmitter
 
close() - Method in class org.apache.storm.eventhubs.trident.TridentPartitionManager
 
close() - Method in class org.apache.storm.hbase.common.HBaseClient
 
close() - Method in class org.apache.storm.hdfs.spout.SequenceFileReader
 
close() - Method in class org.apache.storm.hdfs.spout.TextFileReader
 
close() - Method in class org.apache.storm.hive.common.HiveWriter
Close the Transaction Batch and connection
close() - Method in class org.apache.storm.kafka.ByteBufferSerializer
 
close() - Method in class org.apache.storm.kafka.DynamicBrokersReader
 
close() - Method in class org.apache.storm.kafka.IntSerializer
 
close() - Method in class org.apache.storm.kafka.KafkaSpout
 
close() - Method in class org.apache.storm.kafka.PartitionManager
 
close() - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
close() - Method in class org.apache.storm.kafka.StaticPartitionConnections
 
close() - Method in class org.apache.storm.kafka.trident.DefaultCoordinator
 
close() - Method in interface org.apache.storm.kafka.trident.IBatchCoordinator
 
close() - Method in interface org.apache.storm.kafka.trident.IBrokerReader
 
close() - Method in class org.apache.storm.kafka.trident.StaticBrokerReader
 
close() - Method in class org.apache.storm.kafka.trident.ZkBrokerReader
 
close() - Method in class org.apache.storm.kafka.ZkState
 
close() - Method in class org.apache.storm.LogWriter
 
close() - Method in interface org.apache.storm.messaging.IConnection
close this connection
close() - Method in class org.apache.storm.messaging.netty.Client
Gracefully close this client.
close() - Method in class org.apache.storm.metric.FileBasedEventLogger
 
close() - Method in interface org.apache.storm.metric.IEventLogger
 
close() - Method in class org.apache.storm.metric.internal.CountStatAndMetric
 
close() - Method in class org.apache.storm.metric.internal.LatencyStatAndMetric
 
close() - Method in class org.apache.storm.metric.internal.MultiCountStatAndMetric
 
close() - Method in class org.apache.storm.metric.internal.MultiLatencyStatAndMetric
 
close() - Method in class org.apache.storm.metric.internal.RateTracker
 
close() - Method in class org.apache.storm.mongodb.common.MongoDBClient
Closes all resources associated with this instance.
close() - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
close() - Method in interface org.apache.storm.nimbus.ILeaderElector
Method called to allow for cleanup.
close() - Method in class org.apache.storm.pacemaker.PacemakerClient
 
close() - Method in class org.apache.storm.redis.common.container.JedisClusterContainer
close() - Method in class org.apache.storm.redis.common.container.JedisContainer
close() - Method in class org.apache.storm.security.auth.kerberos.NoOpTTrasport
 
close() - Method in class org.apache.storm.security.auth.ThriftClient
 
close() - Method in interface org.apache.storm.spout.ISpout
Called when an ISpout is going to be shutdown.
close() - Method in class org.apache.storm.spout.ShellSpout
 
CLOSE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
close() - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout
 
close() - Method in class org.apache.storm.starter.spout.TwitterSampleSpout
 
close() - Method in interface org.apache.storm.state.IStateSpout
 
close() - Method in class org.apache.storm.testing.FeederSpout
 
close() - Method in class org.apache.storm.testing.FixedTupleSpout
 
close() - Method in class org.apache.storm.testing.SpoutTracker
 
close() - Method in class org.apache.storm.testing.TestEventLogSpout
 
close() - Method in class org.apache.storm.testing.TestPlannerSpout
 
close() - Method in class org.apache.storm.testing.TestWordSpout
 
close() - Method in class org.apache.storm.topology.base.BaseRichSpout
 
close() - Method in interface org.apache.storm.transactional.ITransactionalSpout.Coordinator
Release any resources from this coordinator.
close() - Method in interface org.apache.storm.transactional.ITransactionalSpout.Emitter
Release any resources held by this emitter.
close() - Method in interface org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Coordinator
 
close() - Method in interface org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Emitter
 
close() - Method in interface org.apache.storm.transactional.partitioned.IPartitionedTransactionalSpout.Coordinator
 
close() - Method in interface org.apache.storm.transactional.partitioned.IPartitionedTransactionalSpout.Emitter
 
close() - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator
 
close() - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter
 
close() - Method in class org.apache.storm.transactional.state.TransactionalState
 
close() - Method in class org.apache.storm.transactional.TransactionalSpoutCoordinator
 
close() - Method in class org.apache.storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter
 
close() - Method in class org.apache.storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator
 
close() - Method in interface org.apache.storm.trident.spout.IBatchSpout
 
close() - Method in interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout.Coordinator
 
close() - Method in interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter
 
close() - Method in interface org.apache.storm.trident.spout.IPartitionedTridentSpout.Coordinator
 
close() - Method in interface org.apache.storm.trident.spout.IPartitionedTridentSpout.Emitter
 
close() - Method in interface org.apache.storm.trident.spout.ITridentSpout.BatchCoordinator
Release any resources from this coordinator.
close() - Method in interface org.apache.storm.trident.spout.ITridentSpout.Emitter
Release any resources held by this emitter.
close() - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
close() - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
close() - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
 
close() - Method in class org.apache.storm.trident.testing.FeederBatchSpout.FeederCoordinator
 
close() - Method in class org.apache.storm.trident.testing.FixedBatchSpout
 
close() - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
close() - Method in class org.apache.storm.trident.topology.state.TransactionalState
 
close() - Method in class org.apache.storm.utils.BufferFileInputStream
 
close() - Method in class org.apache.storm.utils.BufferInputStream
 
close() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics
 
closeChannel(Channel) - Method in interface org.apache.storm.messaging.netty.IServer
 
closed - Variable in class org.apache.storm.hive.common.HiveWriter
 
closeOutputFile() - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
closeOutputFile() - Method in class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt
 
closeOutputFile() - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
closeOutputFile() - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
Cluster - Class in org.apache.storm.scheduler
 
Cluster(INimbus, Map<String, SupervisorDetails>, Map<String, SchedulerAssignmentImpl>, Map) - Constructor for class org.apache.storm.scheduler.Cluster
 
Cluster(Cluster) - Constructor for class org.apache.storm.scheduler.Cluster
Copy constructor
cluster - Variable in class org.apache.storm.scheduler.resource.SchedulingState
 
ClusterFactory - Class in org.apache.storm.cassandra.client
Default interface to build cassandra Cluster from the a Storm Topology configuration.
ClusterFactory() - Constructor for class org.apache.storm.cassandra.client.ClusterFactory
 
ClusterState - Interface in org.apache.storm.cluster
ClusterState provides the API for the pluggable state store used by the Storm daemons.
ClusterStateContext - Class in org.apache.storm.cluster
This class is intended to provide runtime-context to ClusterStateFactory implementors, giving information such as what daemon is creating it.
ClusterStateContext() - Constructor for class org.apache.storm.cluster.ClusterStateContext
 
ClusterStateContext(DaemonType) - Constructor for class org.apache.storm.cluster.ClusterStateContext
 
ClusterStateFactory - Interface in org.apache.storm.cluster
 
ClusterStateListener - Interface in org.apache.storm.cluster
 
ClusterSummary - Class in org.apache.storm.generated
 
ClusterSummary() - Constructor for class org.apache.storm.generated.ClusterSummary
 
ClusterSummary(List<SupervisorSummary>, List<TopologySummary>, List<NimbusSummary>) - Constructor for class org.apache.storm.generated.ClusterSummary
 
ClusterSummary(ClusterSummary) - Constructor for class org.apache.storm.generated.ClusterSummary
Performs a deep copy on other.
ClusterSummary._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ClusterWorkerHeartbeat - Class in org.apache.storm.generated
 
ClusterWorkerHeartbeat() - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat
 
ClusterWorkerHeartbeat(String, Map<ExecutorInfo, ExecutorStats>, int, int) - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat
 
ClusterWorkerHeartbeat(ClusterWorkerHeartbeat) - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat
Performs a deep copy on other.
ClusterWorkerHeartbeat._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
COALESCE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COBOL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CollateClause() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a COLLATE clause
COLLATION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLATION_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLATION_ID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLATION_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLATION_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CollectionsTypeName() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
collector - Variable in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
 
collector - Variable in class org.apache.storm.eventhubs.bolt.EventHubBolt
 
collector - Variable in class org.apache.storm.hbase.bolt.AbstractHBaseBolt
 
collector - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
collector - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
collector - Variable in class org.apache.storm.kafka.spout.KafkaSpout
 
collector - Variable in class org.apache.storm.mongodb.bolt.AbstractMongoBolt
 
collector - Variable in class org.apache.storm.mqtt.spout.MqttSpout
 
collector - Variable in class org.apache.storm.redis.bolt.AbstractRedisBolt
 
collector - Variable in class org.apache.storm.topology.BaseStatefulBoltExecutor
 
collectTridentTupleOrKey(TridentBatchTuple, List<String>) - Method in class org.apache.storm.trident.windowing.StoreBasedTridentWindowManager
 
COLON - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
Column<T> - Class in org.apache.storm.cassandra.query
 
Column(String, T) - Constructor for class org.apache.storm.cassandra.query.Column
 
Column<T> - Class in org.apache.storm.jdbc.common
A database table can be defined as a list of rows and each row can be defined as a list of columns where each column instance has a name, a value and a type.
Column(String, T, int) - Constructor for class org.apache.storm.jdbc.common.Column
 
Column(String, int) - Constructor for class org.apache.storm.jdbc.common.Column
 
column - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
 
COLUMN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLUMN_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ColumnConstraint - Class in org.apache.storm.sql.parser
 
ColumnConstraint.PrimaryKey - Class in org.apache.storm.sql.parser
 
ColumnDefinition - Class in org.apache.storm.sql.parser
 
ColumnDefinition(SqlIdentifier, SqlDataTypeSpec, ColumnConstraint, SqlParserPos) - Constructor for class org.apache.storm.sql.parser.ColumnDefinition
 
ColumnDefinitionList() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
columnFamily - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options
 
ColumnList - Class in org.apache.storm.hbase.common
Represents a list of HBase columns.
ColumnList() - Constructor for class org.apache.storm.hbase.common.ColumnList
 
ColumnList.AbstractColumn - Class in org.apache.storm.hbase.common
 
ColumnList.Column - Class in org.apache.storm.hbase.common
 
ColumnList.Counter - Class in org.apache.storm.hbase.common
 
ColumnMetaData(String, String) - Constructor for class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria.ColumnMetaData
 
columns(Tuple) - Method in interface org.apache.storm.hbase.bolt.mapper.HBaseMapper
Given a tuple, return a list of HBase columns to insert.
columns(Tuple) - Method in class org.apache.storm.hbase.bolt.mapper.SimpleHBaseMapper
 
columns(TridentTuple) - Method in class org.apache.storm.hbase.trident.mapper.SimpleTridentHBaseMapper
 
columns(TridentTuple) - Method in interface org.apache.storm.hbase.trident.mapper.TridentHBaseMapper
Given a tuple, return a list of HBase columns to insert.
ColumnType(List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
combine(Long, Long) - Method in class org.apache.storm.kafka.trident.MaxMetric
 
combine(T, T) - Method in interface org.apache.storm.metric.api.ICombiner
 
combine(Integer, Integer) - Method in class org.apache.storm.starter.trident.TridentReach.One
 
combine(Long, Long) - Method in class org.apache.storm.trident.operation.builtin.Count
 
combine(Number, Number) - Method in class org.apache.storm.trident.operation.builtin.Sum
 
combine(T, T) - Method in interface org.apache.storm.trident.operation.CombinerAggregator
 
CombinedMetric - Class in org.apache.storm.metric.api
 
CombinedMetric(ICombiner) - Constructor for class org.apache.storm.metric.api.CombinedMetric
 
CombinedShellMetric - Class in org.apache.storm.metric.api.rpc
 
CombinedShellMetric(ICombiner) - Constructor for class org.apache.storm.metric.api.rpc.CombinedShellMetric
 
CombinerAggregator<T> - Interface in org.apache.storm.trident.operation
 
CombinerAggregatorCombineImpl - Class in org.apache.storm.trident.operation.impl
 
CombinerAggregatorCombineImpl(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
CombinerAggregatorInitImpl - Class in org.apache.storm.trident.operation.impl
 
CombinerAggregatorInitImpl(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl
 
CombinerAggStateUpdater - Class in org.apache.storm.trident.operation.impl
 
CombinerAggStateUpdater(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater
 
CombinerValueUpdater - Class in org.apache.storm.trident.state
 
CombinerValueUpdater(CombinerAggregator, Object) - Constructor for class org.apache.storm.trident.state.CombinerValueUpdater
 
ComboList - Class in org.apache.storm.trident.tuple
 
ComboList(List[], ComboList.Pointer[]) - Constructor for class org.apache.storm.trident.tuple.ComboList
 
ComboList.Factory - Class in org.apache.storm.trident.tuple
 
COMMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COMMAND_FUNCTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COMMAND_FUNCTION_CODE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CommandExec - Class in org.apache.storm.maven.plugin.util
 
CommandExec(Mojo) - Constructor for class org.apache.storm.maven.plugin.util.CommandExec
 
commit() - Method in class org.apache.storm.blobstore.BlobStoreFile
 
commit() - Method in class org.apache.storm.blobstore.LocalFsBlobStoreFile
 
commit(Long) - Method in class org.apache.storm.cassandra.trident.state.CassandraState
 
commit(Long) - Method in class org.apache.storm.hbase.trident.state.HBaseState
 
commit() - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile
 
commit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState
 
commit(Long) - Method in class org.apache.storm.hive.trident.HiveState
 
commit(Long) - Method in class org.apache.storm.jdbc.trident.state.JdbcState
 
commit() - Method in class org.apache.storm.kafka.PartitionManager
 
commit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState
 
commit(Long) - Method in class org.apache.storm.mongodb.trident.state.MongoState
 
commit(long) - Method in class org.apache.storm.redis.state.RedisKeyValueState
 
commit() - Method in class org.apache.storm.redis.state.RedisKeyValueState
 
commit(Long) - Method in class org.apache.storm.redis.trident.state.RedisClusterState
commit(Long) - Method in class org.apache.storm.redis.trident.state.RedisState
commit() - Method in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule
 
commit() - Method in class org.apache.storm.solr.config.CountBasedCommit
 
commit() - Method in interface org.apache.storm.solr.config.SolrCommitStrategy
 
commit(Long) - Method in class org.apache.storm.solr.trident.SolrState
 
COMMIT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
commit() - Method in class org.apache.storm.state.InMemoryKeyValueState
 
commit(long) - Method in class org.apache.storm.state.InMemoryKeyValueState
 
commit(long) - Method in interface org.apache.storm.state.State
Commit a previously prepared transaction.
commit() - Method in interface org.apache.storm.state.State
Persist the current state.
commit(TransactionAttempt) - Method in interface org.apache.storm.transactional.ICommitterTransactionalSpout.Emitter
 
commit(TransactionAttempt) - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter
 
commit(TransactionAttempt) - Method in interface org.apache.storm.trident.spout.ICommitterTridentSpout.Emitter
 
commit(TransactionAttempt) - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
 
commit(Long) - Method in class org.apache.storm.trident.state.map.NonTransactionalMap
 
commit(Long) - Method in class org.apache.storm.trident.state.map.OpaqueMap
 
commit(Long) - Method in class org.apache.storm.trident.state.map.SnapshottableMap
 
commit(Long) - Method in class org.apache.storm.trident.state.map.TransactionalMap
 
commit(Long) - Method in class org.apache.storm.trident.state.ReadOnlyState
 
commit(Long) - Method in interface org.apache.storm.trident.state.State
 
commit(Long) - Method in class org.apache.storm.trident.testing.LRUMemoryMapState
 
commit(Long) - Method in class org.apache.storm.trident.testing.MemoryMapState
 
commit(Long) - Method in class org.apache.storm.trident.windowing.WindowsState
 
COMMIT_FREQ_COUNT - Static variable in class org.apache.storm.hdfs.spout.Configs
 
COMMIT_FREQ_SEC - Static variable in class org.apache.storm.hdfs.spout.Configs
 
COMMIT_STREAM_ID - Static variable in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
CommitFailure(HiveEndPoint, Long, Throwable) - Constructor for exception org.apache.storm.hive.common.HiveWriter.CommitFailure
 
commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition
 
commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec
 
COMMITTED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
committedOffset - Variable in class org.apache.storm.eventhubs.spout.SimplePartitionManager
 
committer - Variable in class org.apache.storm.trident.planner.ProcessorNode
 
CommonAggregateStats - Class in org.apache.storm.generated
 
CommonAggregateStats() - Constructor for class org.apache.storm.generated.CommonAggregateStats
 
CommonAggregateStats(CommonAggregateStats) - Constructor for class org.apache.storm.generated.CommonAggregateStats
Performs a deep copy on other.
CommonAggregateStats._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
CommonNonReservedKeyWord() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a non-reserved keyword for use as an identifier.
compare(FileStatus, FileStatus) - Method in class org.apache.storm.hdfs.common.ModifTimeComparator
 
compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator
 
compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Max
 
compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.MaxWithComparator
 
compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Min
 
compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.MinWithComparator
 
compareTo(EventData) - Method in class org.apache.storm.eventhubs.spout.EventData
 
compareTo(AccessControl) - Method in class org.apache.storm.generated.AccessControl
 
compareTo(AlreadyAliveException) - Method in exception org.apache.storm.generated.AlreadyAliveException
 
compareTo(Assignment) - Method in class org.apache.storm.generated.Assignment
 
compareTo(AuthorizationException) - Method in exception org.apache.storm.generated.AuthorizationException
 
compareTo(BeginDownloadResult) - Method in class org.apache.storm.generated.BeginDownloadResult
 
compareTo(Bolt) - Method in class org.apache.storm.generated.Bolt
 
compareTo(BoltAggregateStats) - Method in class org.apache.storm.generated.BoltAggregateStats
 
compareTo(BoltStats) - Method in class org.apache.storm.generated.BoltStats
 
compareTo(ClusterSummary) - Method in class org.apache.storm.generated.ClusterSummary
 
compareTo(ClusterWorkerHeartbeat) - Method in class org.apache.storm.generated.ClusterWorkerHeartbeat
 
compareTo(CommonAggregateStats) - Method in class org.apache.storm.generated.CommonAggregateStats
 
compareTo(ComponentAggregateStats) - Method in class org.apache.storm.generated.ComponentAggregateStats
 
compareTo(ComponentCommon) - Method in class org.apache.storm.generated.ComponentCommon
 
compareTo(ComponentObject) - Method in class org.apache.storm.generated.ComponentObject
 
compareTo(ComponentPageInfo) - Method in class org.apache.storm.generated.ComponentPageInfo
 
compareTo(Credentials) - Method in class org.apache.storm.generated.Credentials
 
compareTo(DebugOptions) - Method in class org.apache.storm.generated.DebugOptions
 
compareTo(DistributedRPC.execute_args) - Method in class org.apache.storm.generated.DistributedRPC.execute_args
 
compareTo(DistributedRPC.execute_result) - Method in class org.apache.storm.generated.DistributedRPC.execute_result
 
compareTo(DistributedRPCInvocations.failRequest_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args
 
compareTo(DistributedRPCInvocations.failRequest_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result
 
compareTo(DistributedRPCInvocations.fetchRequest_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args
 
compareTo(DistributedRPCInvocations.fetchRequest_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result
 
compareTo(DistributedRPCInvocations.result_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_args
 
compareTo(DistributedRPCInvocations.result_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_result
 
compareTo(DRPCExecutionException) - Method in exception org.apache.storm.generated.DRPCExecutionException
 
compareTo(DRPCRequest) - Method in class org.apache.storm.generated.DRPCRequest
 
compareTo(ErrorInfo) - Method in class org.apache.storm.generated.ErrorInfo
 
compareTo(ExecutorAggregateStats) - Method in class org.apache.storm.generated.ExecutorAggregateStats
 
compareTo(ExecutorInfo) - Method in class org.apache.storm.generated.ExecutorInfo
 
compareTo(ExecutorSpecificStats) - Method in class org.apache.storm.generated.ExecutorSpecificStats
 
compareTo(ExecutorStats) - Method in class org.apache.storm.generated.ExecutorStats
 
compareTo(ExecutorSummary) - Method in class org.apache.storm.generated.ExecutorSummary
 
compareTo(GetInfoOptions) - Method in class org.apache.storm.generated.GetInfoOptions
 
compareTo(GlobalStreamId) - Method in class org.apache.storm.generated.GlobalStreamId
 
compareTo(Grouping) - Method in class org.apache.storm.generated.Grouping
 
compareTo(HBAuthorizationException) - Method in exception org.apache.storm.generated.HBAuthorizationException
 
compareTo(HBExecutionException) - Method in exception org.apache.storm.generated.HBExecutionException
 
compareTo(HBMessage) - Method in class org.apache.storm.generated.HBMessage
 
compareTo(HBMessageData) - Method in class org.apache.storm.generated.HBMessageData
 
compareTo(HBNodes) - Method in class org.apache.storm.generated.HBNodes
 
compareTo(HBPulse) - Method in class org.apache.storm.generated.HBPulse
 
compareTo(HBRecords) - Method in class org.apache.storm.generated.HBRecords
 
compareTo(InvalidTopologyException) - Method in exception org.apache.storm.generated.InvalidTopologyException
 
compareTo(JavaObject) - Method in class org.apache.storm.generated.JavaObject
 
compareTo(JavaObjectArg) - Method in class org.apache.storm.generated.JavaObjectArg
 
compareTo(KeyAlreadyExistsException) - Method in exception org.apache.storm.generated.KeyAlreadyExistsException
 
compareTo(KeyNotFoundException) - Method in exception org.apache.storm.generated.KeyNotFoundException
 
compareTo(KillOptions) - Method in class org.apache.storm.generated.KillOptions
 
compareTo(ListBlobsResult) - Method in class org.apache.storm.generated.ListBlobsResult
 
compareTo(LocalAssignment) - Method in class org.apache.storm.generated.LocalAssignment
 
compareTo(LocalStateData) - Method in class org.apache.storm.generated.LocalStateData
 
compareTo(LogConfig) - Method in class org.apache.storm.generated.LogConfig
 
compareTo(LogLevel) - Method in class org.apache.storm.generated.LogLevel
 
compareTo(LSApprovedWorkers) - Method in class org.apache.storm.generated.LSApprovedWorkers
 
compareTo(LSSupervisorAssignments) - Method in class org.apache.storm.generated.LSSupervisorAssignments
 
compareTo(LSSupervisorId) - Method in class org.apache.storm.generated.LSSupervisorId
 
compareTo(LSTopoHistory) - Method in class org.apache.storm.generated.LSTopoHistory
 
compareTo(LSTopoHistoryList) - Method in class org.apache.storm.generated.LSTopoHistoryList
 
compareTo(LSWorkerHeartbeat) - Method in class org.apache.storm.generated.LSWorkerHeartbeat
 
compareTo(Nimbus.activate_args) - Method in class org.apache.storm.generated.Nimbus.activate_args
 
compareTo(Nimbus.activate_result) - Method in class org.apache.storm.generated.Nimbus.activate_result
 
compareTo(Nimbus.beginBlobDownload_args) - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_args
 
compareTo(Nimbus.beginBlobDownload_result) - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_result
 
compareTo(Nimbus.beginCreateBlob_args) - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_args
 
compareTo(Nimbus.beginCreateBlob_result) - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_result
 
compareTo(Nimbus.beginFileDownload_args) - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_args
 
compareTo(Nimbus.beginFileDownload_result) - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_result
 
compareTo(Nimbus.beginFileUpload_args) - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_args
 
compareTo(Nimbus.beginFileUpload_result) - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_result
 
compareTo(Nimbus.beginUpdateBlob_args) - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
 
compareTo(Nimbus.beginUpdateBlob_result) - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
 
compareTo(Nimbus.cancelBlobUpload_args) - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
 
compareTo(Nimbus.cancelBlobUpload_result) - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
 
compareTo(Nimbus.createStateInZookeeper_args) - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
 
compareTo(Nimbus.createStateInZookeeper_result) - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
 
compareTo(Nimbus.deactivate_args) - Method in class org.apache.storm.generated.Nimbus.deactivate_args
 
compareTo(Nimbus.deactivate_result) - Method in class org.apache.storm.generated.Nimbus.deactivate_result
 
compareTo(Nimbus.debug_args) - Method in class org.apache.storm.generated.Nimbus.debug_args
 
compareTo(Nimbus.debug_result) - Method in class org.apache.storm.generated.Nimbus.debug_result
 
compareTo(Nimbus.deleteBlob_args) - Method in class org.apache.storm.generated.Nimbus.deleteBlob_args
 
compareTo(Nimbus.deleteBlob_result) - Method in class org.apache.storm.generated.Nimbus.deleteBlob_result
 
compareTo(Nimbus.downloadBlobChunk_args) - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_args
 
compareTo(Nimbus.downloadBlobChunk_result) - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result
 
compareTo(Nimbus.downloadChunk_args) - Method in class org.apache.storm.generated.Nimbus.downloadChunk_args
 
compareTo(Nimbus.downloadChunk_result) - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result
 
compareTo(Nimbus.finishBlobUpload_args) - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_args
 
compareTo(Nimbus.finishBlobUpload_result) - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_result
 
compareTo(Nimbus.finishFileUpload_args) - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_args
 
compareTo(Nimbus.finishFileUpload_result) - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_result
 
compareTo(Nimbus.getBlobMeta_args) - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_args
 
compareTo(Nimbus.getBlobMeta_result) - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_result
 
compareTo(Nimbus.getBlobReplication_args) - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_args
 
compareTo(Nimbus.getBlobReplication_result) - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_result
 
compareTo(Nimbus.getClusterInfo_args) - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_args
 
compareTo(Nimbus.getClusterInfo_result) - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_result
 
compareTo(Nimbus.getComponentPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_args
 
compareTo(Nimbus.getComponentPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_result
 
compareTo(Nimbus.getComponentPendingProfileActions_args) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args
 
compareTo(Nimbus.getComponentPendingProfileActions_result) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
 
compareTo(Nimbus.getLogConfig_args) - Method in class org.apache.storm.generated.Nimbus.getLogConfig_args
 
compareTo(Nimbus.getLogConfig_result) - Method in class org.apache.storm.generated.Nimbus.getLogConfig_result
 
compareTo(Nimbus.getNimbusConf_args) - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_args
 
compareTo(Nimbus.getNimbusConf_result) - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_result
 
compareTo(Nimbus.getTopology_args) - Method in class org.apache.storm.generated.Nimbus.getTopology_args
 
compareTo(Nimbus.getTopology_result) - Method in class org.apache.storm.generated.Nimbus.getTopology_result
 
compareTo(Nimbus.getTopologyConf_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_args
 
compareTo(Nimbus.getTopologyConf_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_result
 
compareTo(Nimbus.getTopologyHistory_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_args
 
compareTo(Nimbus.getTopologyHistory_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_result
 
compareTo(Nimbus.getTopologyInfo_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_args
 
compareTo(Nimbus.getTopologyInfo_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_result
 
compareTo(Nimbus.getTopologyInfoWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args
 
compareTo(Nimbus.getTopologyInfoWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result
 
compareTo(Nimbus.getTopologyPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args
 
compareTo(Nimbus.getTopologyPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result
 
compareTo(Nimbus.getUserTopology_args) - Method in class org.apache.storm.generated.Nimbus.getUserTopology_args
 
compareTo(Nimbus.getUserTopology_result) - Method in class org.apache.storm.generated.Nimbus.getUserTopology_result
 
compareTo(Nimbus.killTopology_args) - Method in class org.apache.storm.generated.Nimbus.killTopology_args
 
compareTo(Nimbus.killTopology_result) - Method in class org.apache.storm.generated.Nimbus.killTopology_result
 
compareTo(Nimbus.killTopologyWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args
 
compareTo(Nimbus.killTopologyWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result
 
compareTo(Nimbus.listBlobs_args) - Method in class org.apache.storm.generated.Nimbus.listBlobs_args
 
compareTo(Nimbus.listBlobs_result) - Method in class org.apache.storm.generated.Nimbus.listBlobs_result
 
compareTo(Nimbus.rebalance_args) - Method in class org.apache.storm.generated.Nimbus.rebalance_args
 
compareTo(Nimbus.rebalance_result) - Method in class org.apache.storm.generated.Nimbus.rebalance_result
 
compareTo(Nimbus.setBlobMeta_args) - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_args
 
compareTo(Nimbus.setBlobMeta_result) - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_result
 
compareTo(Nimbus.setLogConfig_args) - Method in class org.apache.storm.generated.Nimbus.setLogConfig_args
 
compareTo(Nimbus.setLogConfig_result) - Method in class org.apache.storm.generated.Nimbus.setLogConfig_result
 
compareTo(Nimbus.setWorkerProfiler_args) - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_args
 
compareTo(Nimbus.setWorkerProfiler_result) - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_result
 
compareTo(Nimbus.submitTopology_args) - Method in class org.apache.storm.generated.Nimbus.submitTopology_args
 
compareTo(Nimbus.submitTopology_result) - Method in class org.apache.storm.generated.Nimbus.submitTopology_result
 
compareTo(Nimbus.submitTopologyWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args
 
compareTo(Nimbus.submitTopologyWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result
 
compareTo(Nimbus.updateBlobReplication_args) - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_args
 
compareTo(Nimbus.updateBlobReplication_result) - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_result
 
compareTo(Nimbus.uploadBlobChunk_args) - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args
 
compareTo(Nimbus.uploadBlobChunk_result) - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_result
 
compareTo(Nimbus.uploadChunk_args) - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args
 
compareTo(Nimbus.uploadChunk_result) - Method in class org.apache.storm.generated.Nimbus.uploadChunk_result
 
compareTo(Nimbus.uploadNewCredentials_args) - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_args
 
compareTo(Nimbus.uploadNewCredentials_result) - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_result
 
compareTo(NimbusSummary) - Method in class org.apache.storm.generated.NimbusSummary
 
compareTo(NodeInfo) - Method in class org.apache.storm.generated.NodeInfo
 
compareTo(NotAliveException) - Method in exception org.apache.storm.generated.NotAliveException
 
compareTo(NullStruct) - Method in class org.apache.storm.generated.NullStruct
 
compareTo(ProfileRequest) - Method in class org.apache.storm.generated.ProfileRequest
 
compareTo(ReadableBlobMeta) - Method in class org.apache.storm.generated.ReadableBlobMeta
 
compareTo(RebalanceOptions) - Method in class org.apache.storm.generated.RebalanceOptions
 
compareTo(SettableBlobMeta) - Method in class org.apache.storm.generated.SettableBlobMeta
 
compareTo(ShellComponent) - Method in class org.apache.storm.generated.ShellComponent
 
compareTo(SpecificAggregateStats) - Method in class org.apache.storm.generated.SpecificAggregateStats
 
compareTo(SpoutAggregateStats) - Method in class org.apache.storm.generated.SpoutAggregateStats
 
compareTo(SpoutSpec) - Method in class org.apache.storm.generated.SpoutSpec
 
compareTo(SpoutStats) - Method in class org.apache.storm.generated.SpoutStats
 
compareTo(StateSpoutSpec) - Method in class org.apache.storm.generated.StateSpoutSpec
 
compareTo(StormBase) - Method in class org.apache.storm.generated.StormBase
 
compareTo(StormTopology) - Method in class org.apache.storm.generated.StormTopology
 
compareTo(StreamInfo) - Method in class org.apache.storm.generated.StreamInfo
 
compareTo(SubmitOptions) - Method in class org.apache.storm.generated.SubmitOptions
 
compareTo(SupervisorInfo) - Method in class org.apache.storm.generated.SupervisorInfo
 
compareTo(SupervisorSummary) - Method in class org.apache.storm.generated.SupervisorSummary
 
compareTo(ThriftSerializedObject) - Method in class org.apache.storm.generated.ThriftSerializedObject
 
compareTo(TopologyActionOptions) - Method in class org.apache.storm.generated.TopologyActionOptions
 
compareTo(TopologyHistoryInfo) - Method in class org.apache.storm.generated.TopologyHistoryInfo
 
compareTo(TopologyInfo) - Method in class org.apache.storm.generated.TopologyInfo
 
compareTo(TopologyPageInfo) - Method in class org.apache.storm.generated.TopologyPageInfo
 
compareTo(TopologyStats) - Method in class org.apache.storm.generated.TopologyStats
 
compareTo(TopologySummary) - Method in class org.apache.storm.generated.TopologySummary
 
compareTo(WorkerResources) - Method in class org.apache.storm.generated.WorkerResources
 
compareTo(FileOffset) - Method in class org.apache.storm.hdfs.spout.SequenceFileReader.Offset
 
compareTo(FileOffset) - Method in class org.apache.storm.hdfs.spout.TextFileReader.Offset
 
compareTo(Broker) - Method in class org.apache.storm.kafka.Broker
 
compareTo(Rankable) - Method in class org.apache.storm.starter.tools.RankableObjectWithFields
 
compareTo(Object) - Method in class org.apache.storm.trident.util.IndexedEdge
 
ComparisonAggregator<T> - Class in org.apache.storm.trident.operation.builtin
Abstract Aggregator for comparing two values in a stream.
ComparisonAggregator(String) - Constructor for class org.apache.storm.trident.operation.builtin.ComparisonAggregator
 
ComparisonAggregator.State - Class in org.apache.storm.trident.operation.builtin
 
compile(RelNode) - Method in class org.apache.storm.sql.compiler.backends.standalone.PlanCompiler
 
compile(RelNode) - Method in class org.apache.storm.sql.compiler.backends.trident.PlanCompiler
 
CompilerException(String) - Constructor for exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerException
 
CompilerUtil - Class in org.apache.storm.sql.compiler
 
CompilerUtil() - Constructor for class org.apache.storm.sql.compiler.CompilerUtil
 
CompilerUtil.TableBuilderInfo - Class in org.apache.storm.sql.compiler
 
CompilingClassLoader - Class in org.apache.storm.sql.javac
This is a Java ClassLoader that will attempt to load a class from a string of source code.
CompilingClassLoader(ClassLoader, String, String, DiagnosticListener<JavaFileObject>) - Constructor for class org.apache.storm.sql.javac.CompilingClassLoader
 
CompilingClassLoader.CompilerException - Exception in org.apache.storm.sql.javac
Thrown when code cannot be compiled.
complete(ReturnResultsReducer.ReturnResultsState, TridentCollector) - Method in class org.apache.storm.trident.drpc.ReturnResultsReducer
 
complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator
 
complete(ComparisonAggregator.State, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator
 
complete(FirstN.FirstNAgg.State, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg
 
complete(PriorityQueue, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg
 
complete(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.GroupedMultiReducer
 
complete(ChainedResult, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
 
complete(Result, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl
 
complete(Object[], TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator
 
complete(Map<TridentTuple, Object>, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor
 
complete(Object, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.IdentityMultiReducer
 
complete(JoinerMultiReducer.JoinState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.JoinerMultiReducer
 
complete(Result, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl
 
complete(SingleEmitAggregator.SingleEmitState, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator
 
complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.MultiReducer
 
complete(CountAsAggregator.State, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator
 
completed() - Method in class org.apache.storm.testing.TestEventLogSpout
 
completeLatencyMs - Variable in class org.apache.storm.hooks.info.SpoutAckInfo
 
CompleteTopologyParam - Class in org.apache.storm.testing
The param class for the Testing.completeTopology.
CompleteTopologyParam() - Constructor for class org.apache.storm.testing.CompleteTopologyParam
 
Component - Class in org.apache.storm.scheduler.resource
 
Component(String) - Constructor for class org.apache.storm.scheduler.resource.Component
 
Component.ComponentType - Enum in org.apache.storm.scheduler.resource
 
ComponentAggregateStats - Class in org.apache.storm.generated
 
ComponentAggregateStats() - Constructor for class org.apache.storm.generated.ComponentAggregateStats
 
ComponentAggregateStats(ComponentAggregateStats) - Constructor for class org.apache.storm.generated.ComponentAggregateStats
Performs a deep copy on other.
ComponentAggregateStats._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentCommon - Class in org.apache.storm.generated
 
ComponentCommon() - Constructor for class org.apache.storm.generated.ComponentCommon
 
ComponentCommon(Map<GlobalStreamId, Grouping>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.generated.ComponentCommon
 
ComponentCommon(ComponentCommon) - Constructor for class org.apache.storm.generated.ComponentCommon
Performs a deep copy on other.
ComponentCommon._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Interface in org.apache.storm.topology
 
componentID - Variable in class org.apache.storm.hdfs.spout.FileLock.LogEntry
 
componentId - Variable in class org.apache.storm.planner.TaskBundle
 
componentName - Variable in class org.apache.storm.utils.ShellProcess
 
ComponentObject - Class in org.apache.storm.generated
 
ComponentObject() - Constructor for class org.apache.storm.generated.ComponentObject
 
ComponentObject(ComponentObject._Fields, Object) - Constructor for class org.apache.storm.generated.ComponentObject
 
ComponentObject(ComponentObject) - Constructor for class org.apache.storm.generated.ComponentObject
 
ComponentObject._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentPageInfo - Class in org.apache.storm.generated
 
ComponentPageInfo() - Constructor for class org.apache.storm.generated.ComponentPageInfo
 
ComponentPageInfo(String, ComponentType) - Constructor for class org.apache.storm.generated.ComponentPageInfo
 
ComponentPageInfo(ComponentPageInfo) - Constructor for class org.apache.storm.generated.ComponentPageInfo
Performs a deep copy on other.
ComponentPageInfo._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentType - Enum in org.apache.storm.generated
 
CompoundIdentifier() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a compound identifier.
CompoundSpout - Class in org.apache.storm.planner
 
CompoundSpout() - Constructor for class org.apache.storm.planner.CompoundSpout
 
CompoundTask - Class in org.apache.storm.planner
 
CompoundTask() - Constructor for class org.apache.storm.planner.CompoundTask
 
CONCAT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONDITION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONDITION_NUMBER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
conf - Variable in class org.apache.storm.blobstore.ClientBlobStore
 
conf - Variable in class org.apache.storm.scheduler.resource.SchedulingState
 
Config - Class in org.apache.storm
Topology configs are specified as a plain old map.
Config() - Constructor for class org.apache.storm.Config
 
config - Variable in class org.apache.storm.eventhubs.spout.SimplePartitionManager
 
config - Variable in class org.apache.storm.eventhubs.spout.StaticPartitionCoordinator
 
ConfigGetter(String) - Constructor for class org.apache.storm.topology.TopologyBuilder.ConfigGetter
 
configKey - Variable in class org.apache.storm.hbase.bolt.AbstractHBaseBolt
 
configKey - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options
 
configKey - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
configKey - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
configKey - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
ConfigMethodDef - Class in org.apache.storm.flux.model
 
ConfigMethodDef() - Constructor for class org.apache.storm.flux.model.ConfigMethodDef
 
Configs - Class in org.apache.storm.hdfs.spout
 
Configs() - Constructor for class org.apache.storm.hdfs.spout.Configs
 
configure(Map<String, ?>, boolean) - Method in class org.apache.storm.kafka.ByteBufferSerializer
 
configure(Map<String, ?>, boolean) - Method in class org.apache.storm.kafka.IntSerializer
 
configureClient(MqttOptions, String, KeyStoreLoader) - Static method in class org.apache.storm.mqtt.common.MqttUtils
 
ConfigValidation - Class in org.apache.storm.validation
Provides functionality for validating configuration fields.
ConfigValidation() - Constructor for class org.apache.storm.validation.ConfigValidation
 
ConfigValidation.BooleanValidator - Class in org.apache.storm.validation
 
ConfigValidation.DoubleValidator - Class in org.apache.storm.validation
 
ConfigValidation.ImpersonationAclUserEntryValidator - Class in org.apache.storm.validation
Validates an entry for ImpersonationAclUser
ConfigValidation.ImplementsClassValidator - Class in org.apache.storm.validation
 
ConfigValidation.IntegerValidator - Class in org.apache.storm.validation
Validates a Integer.
ConfigValidation.KryoRegValidator - Class in org.apache.storm.validation
Validates Kryo Registration
ConfigValidation.ListEntryCustomValidator - Class in org.apache.storm.validation
Validates each entry in a list against a list of custom Validators Each validator in the list of validators must inherit or be an instance of Validator class
ConfigValidation.ListEntryTypeValidator - Class in org.apache.storm.validation
Validates each entry in a list
ConfigValidation.MapEntryCustomValidator - Class in org.apache.storm.validation
validates each key and each value against the respective arrays of validators
ConfigValidation.MapEntryTypeValidator - Class in org.apache.storm.validation
validates each key and value in a map of a certain type
ConfigValidation.MapOfStringToMapOfStringToObjectValidator - Class in org.apache.storm.validation
 
ConfigValidation.MetricRegistryValidator - Class in org.apache.storm.validation
 
ConfigValidation.NoDuplicateInListValidator - Class in org.apache.storm.validation
validates a list of has no duplicates
ConfigValidation.NotNullValidator - Class in org.apache.storm.validation
Validates if an object is not null
ConfigValidation.NumberValidator - Class in org.apache.storm.validation
 
ConfigValidation.PacemakerAuthTypeValidator - Class in org.apache.storm.validation
 
ConfigValidation.PositiveNumberValidator - Class in org.apache.storm.validation
Validates a positive number
ConfigValidation.PowerOf2Validator - Class in org.apache.storm.validation
Validates if a number is a power of 2
ConfigValidation.SimpleTypeValidator - Class in org.apache.storm.validation
Validates basic types
ConfigValidation.StringOrStringListValidator - Class in org.apache.storm.validation
Validates a String or a list of Strings
ConfigValidation.StringValidator - Class in org.apache.storm.validation
 
ConfigValidation.UserResourcePoolEntryValidator - Class in org.apache.storm.validation
 
ConfigValidation.Validator - Class in org.apache.storm.validation
 
ConfigValidationAnnotations - Class in org.apache.storm.validation
Note: every annotation interface must have method validatorClass() For every annotation there must validator class to do the validation To add another annotation for config validation, add another annotation @interface class.
ConfigValidationAnnotations() - Constructor for class org.apache.storm.validation.ConfigValidationAnnotations
 
ConfigValidationAnnotations.CustomValidator - Annotation Type in org.apache.storm.validation
For custom validators
ConfigValidationAnnotations.isBoolean - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isImplementationOfClass - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isInteger - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isKryoReg - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isListEntryCustom - Annotation Type in org.apache.storm.validation
Validates each entry in a list with a list of validators Validators with fields: validatorClass and entryValidatorClass
ConfigValidationAnnotations.isListEntryType - Annotation Type in org.apache.storm.validation
validates each entry in a list is of a certain type
ConfigValidationAnnotations.isMapEntryCustom - Annotation Type in org.apache.storm.validation
Validates a each key and value in a Map with a list of validators Validator with fields: validatorClass, keyValidatorClasses, valueValidatorClasses
ConfigValidationAnnotations.isMapEntryType - Annotation Type in org.apache.storm.validation
Validates the type of each key and value in a map Validator with fields: validatorClass, keyValidatorClass, valueValidatorClass
ConfigValidationAnnotations.isNoDuplicateInList - Annotation Type in org.apache.storm.validation
Validates that there are no duplicates in a list
ConfigValidationAnnotations.isNumber - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isPositiveNumber - Annotation Type in org.apache.storm.validation
Checks if a number is positive and whether zero inclusive Validator with fields: validatorClass, includeZero
ConfigValidationAnnotations.isPowerOf2 - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isString - Annotation Type in org.apache.storm.validation
Validators with fields: validatorClass
ConfigValidationAnnotations.isStringList - Annotation Type in org.apache.storm.validation
 
ConfigValidationAnnotations.isStringOrStringList - Annotation Type in org.apache.storm.validation
Complex/custom type validators
ConfigValidationAnnotations.isType - Annotation Type in org.apache.storm.validation
Validators with fields: validatorClass and type
ConfigValidationAnnotations.NotNull - Annotation Type in org.apache.storm.validation
Validates on object is not null
ConfigValidationAnnotations.ValidatorParams - Class in org.apache.storm.validation
Field names for annotations
ConfigValidationUtils - Class in org.apache.storm.validation
 
ConfigValidationUtils() - Constructor for class org.apache.storm.validation.ConfigValidationUtils
 
ConfigValidationUtils.FieldValidator - Interface in org.apache.storm.validation
Declares methods for validating configuration values.
ConfigValidationUtils.NestableFieldValidator - Class in org.apache.storm.validation
Declares a method for validating configuration values that is nestable.
confirmAssigned(int) - Method in interface org.apache.storm.scheduler.ISupervisor
 
ConfluentAvroSerializer - Class in org.apache.storm.hdfs.avro
This class provides a mechanism to utilize the Confluent Schema Registry (https://github.com/confluentinc/schema-registry) for Storm to (de)serialize Avro generic records across a topology.
ConfluentAvroSerializer(Kryo, Map) - Constructor for class org.apache.storm.hdfs.avro.ConfluentAvroSerializer
A constructor with a signature that Storm can locate and use with kryo registration.
connect() - Method in class org.apache.storm.cassandra.client.impl.DefaultClient
Creates a new session on this cluster.
connect() - Method in interface org.apache.storm.cassandra.client.SimpleClient
Creates a new session on this cluster.
connect(String, String, int) - Method in interface org.apache.storm.messaging.IContext
This method establish a client side connection to a remote server
connect(String, String, int) - Method in class org.apache.storm.messaging.local.Context
 
connect(String, String, int) - Method in class org.apache.storm.messaging.netty.Context
establish a connection to a remote server
connect(Map, TopologyContext) - Method in interface org.apache.storm.multilang.ISerializer
This method transmits the Storm config to the non-JVM process and receives its pid.
connect(Map, TopologyContext) - Method in class org.apache.storm.multilang.JsonSerializer
 
connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.digest.DigestSaslTransportPlugin
 
connect(TTransport, String, String) - Method in interface org.apache.storm.security.auth.ITransportPlugin
Connect to the specified server via framed transport
connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin
 
connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.plain.PlainSaslTransportPlugin
 
connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.SimpleTransportPlugin
Deprecated.
Connect to the specified server via framed transport
CONNECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
connectAttemptsMax(long) - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder
 
ConnectFailure(HiveEndPoint, Throwable) - Constructor for exception org.apache.storm.hive.common.HiveWriter.ConnectFailure
 
CONNECTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONNECTION_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
connectionProvider - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
ConnectionProvider - Interface in org.apache.storm.jdbc.common
Provides a database connection.
ConnectionState - Enum in org.apache.storm.cluster
 
ConnectionWithStatus - Class in org.apache.storm.messaging
 
ConnectionWithStatus() - Constructor for class org.apache.storm.messaging.ConnectionWithStatus
 
ConnectionWithStatus.Status - Enum in org.apache.storm.messaging
 
connectMqtt(String) - Method in class org.apache.storm.mqtt.common.MqttPublisher
 
cons(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap
 
ConsList - Class in org.apache.storm.trident.tuple
 
ConsList(Object, List<Object>) - Constructor for class org.apache.storm.trident.tuple.ConsList
 
ConsolePreparableReporter - Class in org.apache.storm.daemon.metrics.reporters
 
ConsolePreparableReporter() - Constructor for class org.apache.storm.daemon.metrics.reporters.ConsolePreparableReporter
 
Constants - Class in org.apache.storm
 
Constants() - Constructor for class org.apache.storm.Constants
 
ConstBolt() - Constructor for class storm.starter.HdfsSpoutTopology.ConstBolt
 
constraint() - Method in class org.apache.storm.sql.parser.ColumnDefinition
 
CONSTRAINT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONSTRAINT_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONSTRAINT_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONSTRAINT_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CONSTRAINTS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
construct() - Method in class org.apache.storm.elasticsearch.common.StormElasticSearchClient
 
construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider
 
construct(URI, String, String, List<FieldInfo>) - Method in interface org.apache.storm.sql.runtime.DataSourcesProvider
Construct a new data source.
construct(URI, String, String, List<FieldInfo>) - Static method in class org.apache.storm.sql.runtime.DataSourcesRegistry
 
construct() - Static method in class org.apache.storm.sql.StormSql
 
construct() - Static method in class org.apache.storm.starter.ReachTopology
 
constructBlobCurrentSymlinkName(String) - Static method in class org.apache.storm.utils.Utils
 
constructBlobWithVersionFileName(String, long) - Static method in class org.apache.storm.utils.Utils
 
constructGetRequests(byte[], HBaseProjectionCriteria) - Method in class org.apache.storm.hbase.common.HBaseClient
 
constructMutationReq(byte[], ColumnList, Durability) - Method in class org.apache.storm.hbase.common.HBaseClient
 
CONSTRUCTOR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
constructTrident(URI, String, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider
 
constructTrident(URI, String, String, String, List<FieldInfo>) - Method in interface org.apache.storm.sql.runtime.DataSourcesProvider
 
constructTridentDataSource(URI, String, String, String, List<FieldInfo>) - Static method in class org.apache.storm.sql.runtime.DataSourcesRegistry
 
constructVersionFileName(String) - Static method in class org.apache.storm.utils.Utils
 
consumeBatch(EventHandler<Object>) - Method in class org.apache.storm.utils.DisruptorQueue
 
consumeBatchWhenAvailable(EventHandler<Object>) - Method in class org.apache.storm.utils.DisruptorQueue
 
consumeCPU(Double) - Method in class org.apache.storm.scheduler.resource.RAS_Node
Consumes a certain amount of cpu for this node
consumeMemory(Double) - Method in class org.apache.storm.scheduler.resource.RAS_Node
Consumes a certain amount of memory for this node
Consumer - Interface in org.apache.storm.trident.operation
Represents an operation that accepts a single input argument and returns no result.
consumeResourcesforTask(ExecutorDetails, TopologyDetails) - Method in class org.apache.storm.scheduler.resource.RAS_Node
Consumes a certain amount of resources for a executor in a topology.
ConsumerExecutor - Class in org.apache.storm.trident.operation.impl
 
ConsumerExecutor(Consumer) - Constructor for class org.apache.storm.trident.operation.impl.ConsumerExecutor
 
Container - Class in org.apache.storm.utils
 
Container() - Constructor for class org.apache.storm.utils.Container
 
CONTAINS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
contains(String) - Method in class org.apache.storm.trident.tuple.TridentTupleView
 
contains(String) - Method in class org.apache.storm.tuple.Fields
 
contains(String) - Method in interface org.apache.storm.tuple.ITuple
Returns true if this tuple contains the specified name of the field.
contains(String) - Method in class org.apache.storm.tuple.TupleImpl
 
contains(Object) - Method in class org.apache.storm.utils.ListDelegate
 
containsAll(Collection<?>) - Method in class org.apache.storm.utils.ListDelegate
 
containsKey(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap
 
containsKey(K) - Method in class org.apache.storm.utils.RotatingMap
 
containsKey(K) - Method in class org.apache.storm.utils.TimeCacheMap
Deprecated.
 
containsValue(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap
 
context - Variable in class org.apache.storm.cassandra.context.BaseBeanFactory
 
Context - Class in org.apache.storm.messaging.local
 
Context() - Constructor for class org.apache.storm.messaging.local.Context
 
Context - Class in org.apache.storm.messaging.netty
 
Context() - Constructor for class org.apache.storm.messaging.netty.Context
 
context - Variable in class org.apache.storm.mqtt.spout.MqttSpout
 
context() - Static method in class org.apache.storm.security.auth.ReqContext
 
ContextQuery - Interface in org.apache.storm.cassandra.query
This interface may be used to retrieve a cassandra bound query either from storm config or the tuple being proceed.
ContextQuery.BoundQueryContext - Class in org.apache.storm.cassandra.query
Default ContextQuery.BoundQueryContext implementation to retrieve a bound query identified by the provided key.
ContextQuery.BoundQueryNamedByFieldContext - Class in org.apache.storm.cassandra.query
Default ContextQuery.BoundQueryNamedByFieldContext implementation to retrieve a bound query named by the value of a specified tuple field.
ContextQuery.StaticContextQuery - Class in org.apache.storm.cassandra.query
Static implementation of ContextQuery interface.
ContextVariable() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
CONTINUE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
ControlMessage - Enum in org.apache.storm.messaging.netty
 
CONVERT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
convert(ConnectionState) - Static method in class org.apache.storm.utils.StormConnectionStateConverter
 
convertFileSetToFiles(FileSet) - Static method in class org.apache.storm.maven.plugin.versioninfo.VersionInfoMojo
 
COORD_STREAM(String) - Static method in class org.apache.storm.trident.topology.TridentBoltExecutor
 
COORD_STREAM_PREFIX - Static variable in class org.apache.storm.trident.topology.TridentBoltExecutor
 
CoordCondition() - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition
 
COORDINATED_STREAM_ID - Static variable in class org.apache.storm.Constants
 
CoordinatedBolt - Class in org.apache.storm.coordination
Coordination requires the request ids to be globally unique for awhile.
CoordinatedBolt(IRichBolt) - Constructor for class org.apache.storm.coordination.CoordinatedBolt
 
CoordinatedBolt(IRichBolt, String, CoordinatedBolt.SourceArgs, CoordinatedBolt.IdStreamSpec) - Constructor for class org.apache.storm.coordination.CoordinatedBolt
 
CoordinatedBolt(IRichBolt, Map<String, CoordinatedBolt.SourceArgs>, CoordinatedBolt.IdStreamSpec) - Constructor for class org.apache.storm.coordination.CoordinatedBolt
 
CoordinatedBolt.CoordinatedOutputCollector - Class in org.apache.storm.coordination
 
CoordinatedBolt.FinishedCallback - Interface in org.apache.storm.coordination
 
CoordinatedBolt.IdStreamSpec - Class in org.apache.storm.coordination
 
CoordinatedBolt.SourceArgs - Class in org.apache.storm.coordination
 
CoordinatedBolt.TimeoutCallback - Interface in org.apache.storm.coordination
 
CoordinatedBolt.TrackingInfo - Class in org.apache.storm.coordination
 
CoordinatedOutputCollector(IOutputCollector) - Constructor for class org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
 
Coordinator - Class in org.apache.storm.eventhubs.trident
 
Coordinator(EventHubSpoutConfig) - Constructor for class org.apache.storm.eventhubs.trident.Coordinator
 
coordinator - Variable in class org.apache.storm.kafka.trident.TridentKafkaConfig
 
Coordinator(Map, TopologyContext) - Constructor for class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator
 
Coordinator(Map, TopologyContext) - Constructor for class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator
 
coords - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec
 
CoordSpec() - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec
 
CoordType(boolean) - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType
 
copy(InputStream, OutputStream) - Static method in class org.apache.storm.hack.IOUtil
 
copy() - Method in interface org.apache.storm.starter.tools.Rankable
Note: We do not defensively copy the object wrapped by the Rankable.
copy() - Method in class org.apache.storm.starter.tools.RankableObjectWithFields
Note: We do not defensively copy the wrapped object and any accompanying fields.
copy() - Method in class org.apache.storm.starter.tools.Rankings
Creates a (defensive) copy of itself.
copyBytes(InputStream, OutputStream, int) - Static method in class org.apache.storm.utils.Utils
Copies from one stream to another.
CopyField - Class in org.apache.storm.solr.schema
 
CopyField() - Constructor for class org.apache.storm.solr.schema.CopyField
 
CORR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CORRESPONDING - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COUNT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
Count(int) - Constructor for class org.apache.storm.topology.base.BaseWindowedBolt.Count
 
Count - Class in org.apache.storm.trident.operation.builtin
 
Count() - Constructor for class org.apache.storm.trident.operation.builtin.Count
 
count() - Method in class org.apache.storm.tuple.TupleImpl
 
count() - Method in class org.apache.storm.utils.IndifferentAccessMap
 
COUNT_DATABASE - Static variable in class org.apache.storm.starter.TransactionalWords
 
CountAggregator() - Constructor for class org.apache.storm.starter.ReachTopology.CountAggregator
 
CountAsAggregator - Class in org.apache.storm.trident.testing
 
CountAsAggregator() - Constructor for class org.apache.storm.trident.testing.CountAsAggregator
 
CountBasedCommit - Class in org.apache.storm.solr.config
Class defining a count based commit strategy.
CountBasedCommit(int) - Constructor for class org.apache.storm.solr.config.CountBasedCommit
Initializes a count based commit strategy with the specified threshold
counterBatch(CQLStatementBuilder...) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder
Creates a new BatchStatement.Type.COUNTER batch statement for the specified CQL statement builders.
CountEvictionPolicy<T> - Class in org.apache.storm.windowing
An eviction policy that tracks event counts and can evict based on a threshold count.
CountEvictionPolicy(int) - Constructor for class org.apache.storm.windowing.CountEvictionPolicy
 
countFreeSlotsAlive(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node
 
countFreeSlotsAlive(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node
 
CountingBatchBolt - Class in org.apache.storm.testing
 
CountingBatchBolt() - Constructor for class org.apache.storm.testing.CountingBatchBolt
 
CountingCommitBolt - Class in org.apache.storm.testing
 
CountingCommitBolt() - Constructor for class org.apache.storm.testing.CountingCommitBolt
 
CountMetric - Class in org.apache.storm.metric.api
 
CountMetric() - Constructor for class org.apache.storm.metric.api.CountMetric
 
CountShellMetric - Class in org.apache.storm.metric.api.rpc
 
CountShellMetric() - Constructor for class org.apache.storm.metric.api.rpc.CountShellMetric
 
countSlotsUsed(String, Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node
 
countSlotsUsed(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node
 
countSlotsUsed(String, Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node
 
countSlotsUsed(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node
 
CountStatAndMetric - Class in org.apache.storm.metric.internal
Acts as a Count Metric, but also keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time.
CountStatAndMetric(int) - Constructor for class org.apache.storm.metric.internal.CountStatAndMetric
 
CountSyncPolicy - Class in org.apache.storm.hdfs.bolt.sync
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy
 
CountSyncPolicy - Class in org.apache.storm.hdfs.trident.sync
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.trident.sync.CountSyncPolicy
 
countTotalSlotsAlive(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node
 
countTotalSlotsAlive(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node
 
CountTriggerPolicy<T> - Class in org.apache.storm.windowing
A trigger that tracks event counts and calls back TriggerHandler.onTrigger() when the count threshold is hit.
CountTriggerPolicy(int, TriggerHandler, EvictionPolicy<T>) - Constructor for class org.apache.storm.windowing.CountTriggerPolicy
 
CountValue() - Constructor for class org.apache.storm.starter.TransactionalWords.CountValue
 
COVAR_POP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COVAR_SAMP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CPUMetric - Class in org.apache.storm.metrics.sigar
A metric using Sigar to get User and System CPU utilization for a worker.
CPUMetric() - Constructor for class org.apache.storm.metrics.sigar.CPUMetric
 
CQL3NamedSettersBinder() - Constructor for class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.CQL3NamedSettersBinder
 
CqlMapper - Interface in org.apache.storm.cassandra.query
Default interface to defines how a storm tuple maps to a list of columns representing a row in a database.
CqlMapper.DefaultCqlMapper - Class in org.apache.storm.cassandra.query
Default CqlMapper to map all tuple values to column.
CqlMapper.SelectableCqlMapper - Class in org.apache.storm.cassandra.query
 
CQLResultSetValuesMapper - Interface in org.apache.storm.cassandra.query
 
CQLStatementBuilder<T extends CQLStatementTupleMapper> - Interface in org.apache.storm.cassandra.query
 
CQLStatementTupleMapper - Interface in org.apache.storm.cassandra.query
Default interface to map a ITuple to a CQL Statement.
CQLStatementTupleMapper.DynamicCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query
 
CRC32OutputStream - Class in org.apache.storm.utils
 
CRC32OutputStream() - Constructor for class org.apache.storm.utils.CRC32OutputStream
 
create(Message, MessageId) - Static method in class org.apache.storm.eventhubs.spout.EventData
 
create(EventHubSpoutConfig, String) - Method in interface org.apache.storm.eventhubs.spout.IEventHubReceiverFactory
 
create(EventHubSpoutConfig, String, IStateStore, IEventHubReceiver) - Method in interface org.apache.storm.eventhubs.spout.IPartitionManagerFactory
 
create(String, String, long) - Static method in class org.apache.storm.eventhubs.spout.MessageId
 
create(IEventHubReceiver) - Method in interface org.apache.storm.eventhubs.trident.ITridentPartitionManagerFactory
 
create(Map) - Method in class org.apache.storm.hbase.trident.windowing.HBaseWindowsStoreFactory
 
create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.ArrayListSerializer
 
create(Kryo, Input, Class<Map>) - Method in class org.apache.storm.serialization.types.HashMapSerializer
 
create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.HashSetSerializer
 
create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.ListDelegateSerializer
 
CREATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
create(List[]) - Method in class org.apache.storm.trident.tuple.ComboList.Factory
 
create(List<Object>) - Method in class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory
 
create(TridentTupleView, List<Object>) - Method in class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory
 
create(TridentTuple) - Method in class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory
 
create(Tuple) - Method in class org.apache.storm.trident.tuple.TridentTupleView.RootFactory
 
create(Map) - Method in class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory
 
create(Map) - Method in interface org.apache.storm.trident.windowing.WindowsStoreFactory
Creates a window store
create_sequential(String, byte[], List<ACL>) - Method in interface org.apache.storm.cluster.ClusterState
Path will be appended with a monotonically increasing integer, a new node will be created there, and data will be put at that node.
createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore
Creates the blob.
createBlob(String, byte[], SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore
Wrapper called to create the blob which contains the byte data
createBlob(String, InputStream, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore
Wrapper called to create the blob which contains the byte data
createBlob(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.ClientBlobStore
Client facing API to create a blob.
createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.LocalFsBlobStore
 
createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStore
 
createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.ClientBlobStore
Client facing API to create a blob.
createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.NimbusBlobStore
 
createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.hdfs.blobstore.HdfsClientBlobStore
 
createEdge(Object, Object) - Method in class org.apache.storm.trident.util.ErrorEdgeFactory
 
createEventHubSpout() - Method in class org.apache.storm.eventhubs.samples.AtMostOnceEventCount
 
createEventHubSpout() - Method in class org.apache.storm.eventhubs.samples.EventCount
 
createFile(String) - Static method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology
 
createFilter(ITuple) - Method in interface org.apache.storm.mongodb.common.QueryFilterCreator
Create a query Filter by given Tuple
createFilter(ITuple) - Method in class org.apache.storm.mongodb.common.SimpleQueryFilterCreator
 
createFreshTuple(Fields, List<Object>) - Static method in class org.apache.storm.trident.tuple.TridentTupleView
 
createFreshTuple(Fields, Object...) - Static method in class org.apache.storm.trident.tuple.TridentTupleView
 
createLocalizer(Map, String) - Static method in class org.apache.storm.utils.Utils
 
createLocalTopology(ILocalDRPC) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.transactional.state.TestTransactionalState
 
createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.transactional.state.TransactionalState
 
createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.trident.topology.state.TestTransactionalState
 
createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.trident.topology.state.TransactionalState
 
createOutputFile() - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
createOutputFile() - Method in class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt
 
createOutputFile() - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
createOutputFile() - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
createRecordWriter(HiveEndPoint) - Method in class org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper
 
createRecordWriter(HiveEndPoint) - Method in interface org.apache.storm.hive.bolt.mapper.HiveMapper
Given a endPoint, returns a RecordWriter with columnNames.
createRecordWriter(HiveEndPoint) - Method in class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper
 
createRemoteTopology() - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
Deprecated.
 
createSaslServer(String, String, String, Map<String, ?>, CallbackHandler) - Method in class org.apache.storm.security.auth.plain.SaslPlainServer.SaslPlainServerFactory
 
createStateInZookeeper(Map, String, NimbusInfo) - Static method in class org.apache.storm.blobstore.BlobStoreUtils
 
createStateInZookeeper(String) - Method in class org.apache.storm.blobstore.ClientBlobStore
Creates state inside a zookeeper.
createStateInZookeeper(String) - Method in class org.apache.storm.blobstore.NimbusBlobStore
 
createStateInZookeeper(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
createStateInZookeeper(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
createStateInZookeeper() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.createStateInZookeeper
 
createStateInZookeeper(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
createStateInZookeeper(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
createStateInZookeeper() - Constructor for class org.apache.storm.generated.Nimbus.Processor.createStateInZookeeper
 
createStateInZookeeper(String) - Method in class org.apache.storm.hdfs.blobstore.HdfsClientBlobStore
 
createStateInZookeeper_args() - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
 
createStateInZookeeper_args(String) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
 
createStateInZookeeper_args(Nimbus.createStateInZookeeper_args) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
Performs a deep copy on other.
createStateInZookeeper_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.createStateInZookeeper_call
 
createStateInZookeeper_result() - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
 
createStateInZookeeper_result(Nimbus.createStateInZookeeper_result) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
Performs a deep copy on other.
createTopology() - Method in class org.apache.storm.topology.TopologyBuilder
 
createVersion() - Method in class org.apache.storm.utils.VersionedStore
 
createVersion(long) - Method in class org.apache.storm.utils.VersionedStore
 
createZKClient(Map) - Static method in class org.apache.storm.blobstore.BlobStoreUtils
 
creationIndex - Variable in class org.apache.storm.trident.planner.Node
 
Credentials - Class in org.apache.storm.generated
 
Credentials() - Constructor for class org.apache.storm.generated.Credentials
 
Credentials(Map<String, String>) - Constructor for class org.apache.storm.generated.Credentials
 
Credentials(Credentials) - Constructor for class org.apache.storm.generated.Credentials
Performs a deep copy on other.
credentials - Variable in class org.apache.storm.security.auth.AbstractSaslServerCallbackHandler
 
Credentials._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
CREDENTIALS_CHANGED_STREAM_ID - Static variable in class org.apache.storm.Constants
 
CROSS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CsvPreparableReporter - Class in org.apache.storm.daemon.metrics.reporters
 
CsvPreparableReporter() - Constructor for class org.apache.storm.daemon.metrics.reporters.CsvPreparableReporter
 
CUBE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CUME_DIST - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
curChar - Variable in class org.apache.storm.sql.parser.impl.StormParserImplTokenManager
 
CURRENT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_BLOB_SUFFIX_ID - Static variable in class org.apache.storm.utils.Utils
 
CURRENT_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_DATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_DEFAULT_TRANSFORM_GROUP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_PATH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_ROLE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_TIME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_TIMESTAMP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_TRANSFORM_GROUP_FOR_TYPE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURRENT_USER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
currentCount - Variable in class org.apache.storm.windowing.CountEvictionPolicy
 
currentRecord - Variable in class org.apache.storm.hdfs.spout.SequenceFileReader.Offset
 
currentTimeMillis() - Static method in class org.apache.storm.utils.Time
 
currentTimeSecs() - Static method in class org.apache.storm.utils.Time
 
currentToken - Variable in exception org.apache.storm.sql.parser.impl.ParseException
This is the last token that has been consumed successfully.
currGroup - Variable in class org.apache.storm.trident.operation.impl.GroupCollector
 
CURSOR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CURSOR_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
CursorExpression(SqlAbstractParserImpl.ExprContext) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a CURSOR(query) expression.
custom_object(JavaObject) - Static method in class org.apache.storm.generated.Grouping
 
custom_serialized(ByteBuffer) - Static method in class org.apache.storm.generated.Grouping
 
custom_serialized(byte[]) - Static method in class org.apache.storm.generated.Grouping
 
customGrouping(CustomStreamGrouping) - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer
 
customGrouping(String, CustomStreamGrouping) - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer
 
customGrouping(String, CustomStreamGrouping) - Method in interface org.apache.storm.topology.InputDeclarer
A custom stream grouping by implementing the CustomStreamGrouping interface.
customGrouping(String, String, CustomStreamGrouping) - Method in interface org.apache.storm.topology.InputDeclarer
A custom stream grouping by implementing the CustomStreamGrouping interface.
customGrouping(String, CustomStreamGrouping) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
 
customGrouping(String, String, CustomStreamGrouping) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
 
CustomMessageMapper - Class in org.apache.storm.mqtt.examples
Given a topic name: “users/{user}/{location}/{deviceId}” and a payload of “{temperature}/{humidity}” emits a tuple containing user(String), deviceId(String), location(String), temperature(float), humidity(float)
CustomMessageMapper() - Constructor for class org.apache.storm.mqtt.examples.CustomMessageMapper
 
CustomStreamGrouping - Interface in org.apache.storm.grouping
 
CYCLE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 

D

DaemonType - Enum in org.apache.storm.cluster
 
DATA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DATA - Static variable in class org.apache.storm.starter.TransactionalGlobalCount
 
DATA - Static variable in class org.apache.storm.starter.TransactionalWords
 
DATABASE - Static variable in class org.apache.storm.starter.TransactionalGlobalCount
 
databaseName - Variable in class org.apache.storm.hive.common.HiveOptions
 
dataFormat - Variable in class org.apache.storm.eventhubs.bolt.EventHubBoltConfig
 
DataPoint() - Constructor for class org.apache.storm.metric.api.IMetricsConsumer.DataPoint
 
DataPoint(String, Object) - Constructor for class org.apache.storm.metric.api.IMetricsConsumer.DataPoint
 
dataReceived(ChannelContext, Values) - Method in class org.apache.storm.sql.runtime.AbstractChannelHandler
 
dataReceived(ChannelContext, Values) - Method in interface org.apache.storm.sql.runtime.ChannelHandler
 
DataSource - Interface in org.apache.storm.sql.runtime
A DataSource ingests data in StormSQL.
DataSourcesProvider - Interface in org.apache.storm.sql.runtime
 
DataSourcesRegistry - Class in org.apache.storm.sql.runtime
 
dataType - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
 
dataType - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater
 
DataType() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
dataTypeDescription - Variable in class org.apache.storm.redis.trident.state.Options
 
DATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DATETIME_INTERVAL_CODE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DATETIME_INTERVAL_PRECISION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DateTimeLiteral() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a date/time literal.
DAY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
deactivate() - Method in class org.apache.storm.clojure.ClojureSpout
 
deactivate() - Method in class org.apache.storm.eventhubs.spout.EventHubSpout
 
deactivate(String, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
deactivate(String, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
deactivate() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.deactivate
 
deactivate(String) - Method in class org.apache.storm.generated.Nimbus.Client
 
deactivate(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
 
deactivate() - Constructor for class org.apache.storm.generated.Nimbus.Processor.deactivate
 
deactivate(String) - Method in interface org.apache.storm.ILocalCluster
 
deactivate() - Method in class org.apache.storm.kafka.KafkaSpout
 
deactivate() - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
deactivate() - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
deactivate() - Method in interface org.apache.storm.spout.ISpout
Called when a spout has been deactivated.
deactivate() - Method in class org.apache.storm.spout.ShellSpout
 
deactivate() - Method in class org.apache.storm.testing.FixedTupleSpout
 
deactivate() - Method in class org.apache.storm.topology.base.BaseRichSpout
 
deactivate() - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
 
deactivate() - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
deactivate_args() - Constructor for class org.apache.storm.generated.Nimbus.deactivate_args
 
deactivate_args(String) - Constructor for class org.apache.storm.generated.Nimbus.deactivate_args
 
deactivate_args(Nimbus.deactivate_args) - Constructor for class org.apache.storm.generated.Nimbus.deactivate_args
Performs a deep copy on other.
deactivate_call(String, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.deactivate_call
 
deactivate_result() - Constructor for class org.apache.storm.generated.Nimbus.deactivate_result
 
deactivate_result(NotAliveException, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.deactivate_result
 
deactivate_result(Nimbus.deactivate_result) - Constructor for class org.apache.storm.generated.Nimbus.deactivate_result
Performs a deep copy on other.
DEALLOCATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
debug(String, String, boolean, double, AsyncMethodCallback) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
 
debug(String, String, boolean, double, AsyncMethodCallback) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface
 
debug() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.debug
 
debug(String, String, boolean, double) - Method in class org.apache.storm.generated.Nimbus.Client
 
debug(String, String, boolean, double) - Method in interface org.apache.storm.generated.Nimbus.Iface
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.
debug() - Constructor for class org.apache.storm.generated.Nimbus.Processor.debug
 
debug(String, Object...) - Method in class org.apache.storm.mqtt.MqttLogger
 
Debug - Class in org.apache.storm.trident.operation.builtin
Filter for debugging purposes.
Debug() - Constructor for class org.apache.storm.trident.operation.builtin.Debug
 
Debug(String) - Constructor for class org.apache.storm.trident.operation.builtin.Debug
Creates a Debug filter with a string identifier.
debug_args() - Constructor for class org.apache.storm.generated.Nimbus.debug_args
 
debug_args(String, String, boolean, double) - Constructor for class org.apache.storm.generated.Nimbus.debug_args
 
debug_args(Nimbus.debug_args) - Constructor for class org.apache.storm.generated.Nimbus.debug_args
Performs a deep copy on other.
debug_call(String, String, boolean, double, AsyncMethodCallback, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.debug_call
 
debug_result() - Constructor for class org.apache.storm.generated.Nimbus.debug_result
 
debug_result(NotAliveException, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.debug_result
 
debug_result(Nimbus.debug_result) - Constructor for class org.apache.storm.generated.Nimbus.debug_result
Performs a deep copy on other.
DebugOptions - Class in org.apache.storm.generated
 
DebugOptions() - Constructor for class org.apache.storm.generated.DebugOptions
 
DebugOptions(DebugOptions) - Constructor for class org.apache.storm.generated.DebugOptions
Performs a deep copy on other.
DebugOptions._Fields - Enum in org.apache.storm.generated
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
debugStream - Variable in class org.apache.storm.sql.parser.impl.StormParserImplTokenManager
 
DEC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DECIMAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DECIMAL_NUMERIC_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DECLARE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
declare(Fields) - Method in interface org.apache.storm.topology.OutputFieldsDeclarer
Uses default stream id.
declare(boolean, Fields) - Method in interface org.apache.storm.topology.OutputFieldsDeclarer
 
declare(Fields) - Method in class org.apache.storm.topology.OutputFieldsGetter
 
declare(boolean, Fields) - Method in class org.apache.storm.topology.OutputFieldsGetter
 
declareCheckpointStream(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.BaseStatefulBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
Declare the output schema for all the streams of this topology.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.clojure.ClojureBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.clojure.ClojureSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.clojure.RichShellBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.clojure.RichShellSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.coordination.BatchBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.coordination.CoordinatedBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.drpc.DRPCSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.drpc.JoinResult
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.drpc.KeyedFairBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.drpc.PrepareRequest
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.drpc.ReturnResults
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.elasticsearch.bolt.EsLookupBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.elasticsearch.bolt.EsPercolateBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.eventhubs.bolt.EventHubBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.eventhubs.samples.bolt.GlobalCountBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.eventhubs.samples.bolt.PartialCountBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.eventhubs.spout.EventHubSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.examples.StatefulWordCounter
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.examples.TestPrintBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.examples.TestWindowBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.examples.WordCounter
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.bolts.LogInfoBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hbase.bolt.HBaseBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hbase.bolt.HBaseLookupBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in interface org.apache.storm.hbase.bolt.mapper.HBaseValueMapper
declares the output fields for the lookup bolt.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hdfs.spout.HdfsSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hive.bolt.HiveBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.jdbc.bolt.JdbcInsertBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.jdbc.bolt.JdbcLookupBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in interface org.apache.storm.jdbc.mapper.JdbcLookupMapper
declare what are the fields that this code will output.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.bolt.KafkaBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.KafkaSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStream
 
declareOutputFields(OutputFieldsDeclarer) - Method in interface org.apache.storm.kafka.spout.KafkaSpoutStreams
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsNamedTopics
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.kafka.spout.KafkaSpoutStreamsWildcardTopics
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.mongodb.bolt.MongoInsertBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.mongodb.bolt.MongoUpdateBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.mqtt.bolt.MqttBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.redis.bolt.RedisLookupBolt
Declare the output schema for all the streams of this topology.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.redis.bolt.RedisStoreBolt
Declare the output schema for all the streams of this topology.
declareOutputFields(OutputFieldsDeclarer) - Method in interface org.apache.storm.redis.common.mapper.RedisLookupMapper
declare what are the fields that this code will output.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.solr.bolt.SolrUpdateBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.spout.CheckpointSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.AbstractRankerBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.PrinterBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.RollingCountAggBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.RollingCountBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.SingleJoinBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.bolt.SlidingWindowSumBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ExclamationTopology.ExclamationBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.FastWordCountTopology.SplitSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.FastWordCountTopology.WordCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.InOrderDeliveryTest.Check
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ManualDRPC.ExclamationBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ReachTopology.CountAggregator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ReachTopology.GetFollowers
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ReachTopology.GetTweeters
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ReachTopology.PartialUniquer
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.spout.RandomIntegerSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.spout.RandomSentenceSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.spout.TwitterSampleSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ThroughputVsLatency.FastRandomSentenceSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ThroughputVsLatency.SplitSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.ThroughputVsLatency.WordCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.TransactionalGlobalCount.BatchCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.TransactionalGlobalCount.UpdateGlobalCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.TransactionalWords.BucketCountUpdater
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.TransactionalWords.Bucketize
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.TransactionalWords.KeyedCountUpdater
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.WordCountTopology.SplitSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.WordCountTopology.WordCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.WordCountTopologyNode.RandomSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.WordCountTopologyNode.SplitSentence
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.starter.WordCountTopologyNode.WordCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.BatchNumberList
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.BatchProcessWord
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.BatchRepeatA
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.BoltTracker
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.CountingBatchBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.CountingCommitBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.FeederSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.FixedTupleSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.IdentityBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.KeyedCountingBatchBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.KeyedSummingBatchBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.MemoryTransactionalSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.OpaqueMemoryTransactionalSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.PrepareBatchBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.PythonShellMetricsBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.PythonShellMetricsSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.SpoutTracker
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestAggregatesCounter
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestConfBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestEventLogSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestEventOrderCheckBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestGlobalCount
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestPlannerBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestPlannerSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestWordCounter
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TestWordSpout
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.testing.TupleCaptureBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.base.BaseStatefulBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.base.BaseWindowedBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.BasicBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.CheckpointTupleForwarder
 
declareOutputFields(OutputFieldsDeclarer) - Method in interface org.apache.storm.topology.IComponent
Declare the output schema for all the streams of this topology.
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.StatefulBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.topology.WindowedBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.transactional.TransactionalSpoutBatchExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.transactional.TransactionalSpoutCoordinator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.planner.SubtopologyBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.spout.TridentSpoutCoordinator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.spout.TridentSpoutExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
 
declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.trident.topology.TridentBoltExecutor
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.starter.HdfsSpoutTopology.ConstBolt
 
declareOutputFields(OutputFieldsDeclarer) - Method in class storm.starter.StatefulTopology.PrinterBolt
 
declareStream(String, Fields) - Method in interface org.apache.storm.topology.OutputFieldsDeclarer
 
declareStream(String, boolean, Fields) - Method in interface org.apache.storm.topology.OutputFieldsDeclarer
 
declareStream(String, Fields) - Method in class org.apache.storm.topology.OutputFieldsGetter
 
declareStream(String, boolean, Fields) - Method in class org.apache.storm.topology.OutputFieldsGetter
 
decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class org.apache.storm.messaging.netty.MessageDecoder
 
decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class org.apache.storm.pacemaker.codec.ThriftDecoder
 
decodeVIntSize(byte) - Static method in class org.apache.storm.utils.WritableUtils
Parse the first byte of a vint/vlong to determine the number of bytes
decorate(Kryo) - Method in interface org.apache.storm.serialization.IKryoDecorator
 
decorate(Kryo) - Method in class org.apache.storm.testing.TestKryoDecorator
 
deepCopy() - Method in class org.apache.storm.generated.AccessControl
 
deepCopy() - Method in exception org.apache.storm.generated.AlreadyAliveException
 
deepCopy() - Method in class org.apache.storm.generated.Assignment
 
deepCopy() - Method in exception org.apache.storm.generated.AuthorizationException
 
deepCopy() - Method in class org.apache.storm.generated.BeginDownloadResult
 
deepCopy() - Method in class org.apache.storm.generated.Bolt
 
deepCopy() - Method in class org.apache.storm.generated.BoltAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.BoltStats
 
deepCopy() - Method in class org.apache.storm.generated.ClusterSummary
 
deepCopy() - Method in class org.apache.storm.generated.ClusterWorkerHeartbeat
 
deepCopy() - Method in class org.apache.storm.generated.CommonAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.ComponentAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.ComponentCommon
 
deepCopy() - Method in class org.apache.storm.generated.ComponentObject
 
deepCopy() - Method in class org.apache.storm.generated.ComponentPageInfo
 
deepCopy() - Method in class org.apache.storm.generated.Credentials
 
deepCopy() - Method in class org.apache.storm.generated.DebugOptions
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPC.execute_args
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPC.execute_result
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_args
 
deepCopy() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_result
 
deepCopy() - Method in exception org.apache.storm.generated.DRPCExecutionException
 
deepCopy() - Method in class org.apache.storm.generated.DRPCRequest
 
deepCopy() - Method in class org.apache.storm.generated.ErrorInfo
 
deepCopy() - Method in class org.apache.storm.generated.ExecutorAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.ExecutorInfo
 
deepCopy() - Method in class org.apache.storm.generated.ExecutorSpecificStats
 
deepCopy() - Method in class org.apache.storm.generated.ExecutorStats
 
deepCopy() - Method in class org.apache.storm.generated.ExecutorSummary
 
deepCopy() - Method in class org.apache.storm.generated.GetInfoOptions
 
deepCopy() - Method in class org.apache.storm.generated.GlobalStreamId
 
deepCopy() - Method in class org.apache.storm.generated.Grouping
 
deepCopy() - Method in exception org.apache.storm.generated.HBAuthorizationException
 
deepCopy() - Method in exception org.apache.storm.generated.HBExecutionException
 
deepCopy() - Method in class org.apache.storm.generated.HBMessage
 
deepCopy() - Method in class org.apache.storm.generated.HBMessageData
 
deepCopy() - Method in class org.apache.storm.generated.HBNodes
 
deepCopy() - Method in class org.apache.storm.generated.HBPulse
 
deepCopy() - Method in class org.apache.storm.generated.HBRecords
 
deepCopy() - Method in exception org.apache.storm.generated.InvalidTopologyException
 
deepCopy() - Method in class org.apache.storm.generated.JavaObject
 
deepCopy() - Method in class org.apache.storm.generated.JavaObjectArg
 
deepCopy() - Method in exception org.apache.storm.generated.KeyAlreadyExistsException
 
deepCopy() - Method in exception org.apache.storm.generated.KeyNotFoundException
 
deepCopy() - Method in class org.apache.storm.generated.KillOptions
 
deepCopy() - Method in class org.apache.storm.generated.ListBlobsResult
 
deepCopy() - Method in class org.apache.storm.generated.LocalAssignment
 
deepCopy() - Method in class org.apache.storm.generated.LocalStateData
 
deepCopy() - Method in class org.apache.storm.generated.LogConfig
 
deepCopy() - Method in class org.apache.storm.generated.LogLevel
 
deepCopy() - Method in class org.apache.storm.generated.LSApprovedWorkers
 
deepCopy() - Method in class org.apache.storm.generated.LSSupervisorAssignments
 
deepCopy() - Method in class org.apache.storm.generated.LSSupervisorId
 
deepCopy() - Method in class org.apache.storm.generated.LSTopoHistory
 
deepCopy() - Method in class org.apache.storm.generated.LSTopoHistoryList
 
deepCopy() - Method in class org.apache.storm.generated.LSWorkerHeartbeat
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.activate_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.activate_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.deactivate_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.deactivate_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.debug_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.debug_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopology_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopology_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.killTopology_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.killTopology_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.listBlobs_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.listBlobs_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.rebalance_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.rebalance_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.submitTopology_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.submitTopology_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_result
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_args
 
deepCopy() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_result
 
deepCopy() - Method in class org.apache.storm.generated.NimbusSummary
 
deepCopy() - Method in class org.apache.storm.generated.NodeInfo
 
deepCopy() - Method in exception org.apache.storm.generated.NotAliveException
 
deepCopy() - Method in class org.apache.storm.generated.NullStruct
 
deepCopy() - Method in class org.apache.storm.generated.ProfileRequest
 
deepCopy() - Method in class org.apache.storm.generated.ReadableBlobMeta
 
deepCopy() - Method in class org.apache.storm.generated.RebalanceOptions
 
deepCopy() - Method in class org.apache.storm.generated.SettableBlobMeta
 
deepCopy() - Method in class org.apache.storm.generated.ShellComponent
 
deepCopy() - Method in class org.apache.storm.generated.SpecificAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.SpoutAggregateStats
 
deepCopy() - Method in class org.apache.storm.generated.SpoutSpec
 
deepCopy() - Method in class org.apache.storm.generated.SpoutStats
 
deepCopy() - Method in class org.apache.storm.generated.StateSpoutSpec
 
deepCopy() - Method in class org.apache.storm.generated.StormBase
 
deepCopy() - Method in class org.apache.storm.generated.StormTopology
 
deepCopy() - Method in class org.apache.storm.generated.StreamInfo
 
deepCopy() - Method in class org.apache.storm.generated.SubmitOptions
 
deepCopy() - Method in class org.apache.storm.generated.SupervisorInfo
 
deepCopy() - Method in class org.apache.storm.generated.SupervisorSummary
 
deepCopy() - Method in class org.apache.storm.generated.ThriftSerializedObject
 
deepCopy() - Method in class org.apache.storm.generated.TopologyActionOptions
 
deepCopy() - Method in class org.apache.storm.generated.TopologyHistoryInfo
 
deepCopy() - Method in class org.apache.storm.generated.TopologyInfo
 
deepCopy() - Method in class org.apache.storm.generated.TopologyPageInfo
 
deepCopy() - Method in class org.apache.storm.generated.TopologyStats
 
deepCopy() - Method in class org.apache.storm.generated.TopologySummary
 
deepCopy() - Method in class org.apache.storm.generated.WorkerResources
 
DEFAULT - Static variable in class org.apache.storm.blobstore.BlobStoreAclHandler
 
DEFAULT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DEFAULT_BLOB_VERSION_SUFFIX - Static variable in class org.apache.storm.utils.Utils
 
DEFAULT_CHARSET - Static variable in class org.apache.storm.multilang.JsonSerializer
 
DEFAULT_COMMIT_FREQ_COUNT - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_COMMIT_FREQ_SEC - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_CURRENT_BLOB_SUFFIX - Static variable in class org.apache.storm.utils.Utils
 
DEFAULT_EMIT_FREQUENCY - Static variable in class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt
 
DEFAULT_FIELD_DELIMITER - Static variable in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
DEFAULT_FIELD_DELIMITER - Static variable in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
DEFAULT_HDFS_CONFIG_KEY - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_IDENTIFIER_MAX_LENGTH - Static variable in class org.apache.storm.sql.parser.StormParser
 
DEFAULT_INMEMORY_TUPLE_CACHE_LIMIT - Static variable in class org.apache.storm.trident.windowing.WindowTridentProcessor
 
DEFAULT_KW - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DEFAULT_LOCK_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_LOCK_TIMEOUT - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_MAX_OUTSTANDING - Static variable in class org.apache.storm.hdfs.spout.Configs
 
DEFAULT_MAX_RETRIES - Static variable in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
DEFAULT_MAX_UNCOMMITTED_OFFSETS - Static variable in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
DEFAULT_METHOD_NAME - Static variable in class org.apache.storm.flux.model.TopologySourceDef
 
DEFAULT_OFFSET_COMMIT_PERIOD_MS - Static variable in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
DEFAULT_POLL_TIMEOUT_MS - Static variable in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
DEFAULT_POOL_CONFIG - Static variable in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder
 
DEFAULT_POOL_CONFIG - Static variable in class org.apache.storm.redis.trident.state.RedisClusterMapState.Factory
 
DEFAULT_POOL_CONFIG - Static variable in class org.apache.storm.redis.trident.state.RedisClusterState.Factory
 
DEFAULT_POOL_CONFIG - Static variable in class org.apache.storm.redis.trident.state.RedisMapState.Factory
 
DEFAULT_POOL_CONFIG - Static variable in class org.apache.storm.redis.trident.state.RedisState.Factory
 
DEFAULT_RACK - Static variable in interface org.apache.storm.networktopography.DNSToSwitchMapping
 
DEFAULT_RECORD_DELIMITER - Static variable in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
DEFAULT_RECORD_DELIMITER - Static variable in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
DEFAULT_SERIALIZERS - Static variable in class org.apache.storm.redis.trident.state.AbstractRedisMapState
 
DEFAULT_STREAM_ID - Static variable in class org.apache.storm.utils.Utils
 
DefaultBinder() - Constructor for class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.DefaultBinder
 
DefaultClient - Class in org.apache.storm.cassandra.client.impl
Simple class to wrap cassandra Cluster instance.
DefaultClient(Cluster, String) - Constructor for class org.apache.storm.cassandra.client.impl.DefaultClient
Create a new DefaultClient instance.
DefaultCoordinator - Class in org.apache.storm.kafka.trident
 
DefaultCoordinator() - Constructor for class org.apache.storm.kafka.trident.DefaultCoordinator
 
DefaultCqlMapper() - Constructor for class org.apache.storm.cassandra.query.CqlMapper.DefaultCqlMapper
Creates a new CqlMapper.DefaultCqlMapper instance.
DefaultEsTupleMapper - Class in org.apache.storm.elasticsearch.common
 
DefaultEsTupleMapper() - Constructor for class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper
 
DefaultEventDataFormat - Class in org.apache.storm.eventhubs.bolt
A default implementation of IEventDataFormat that converts the tuple into a delimited string.
DefaultEventDataFormat() - Constructor for class org.apache.storm.eventhubs.bolt.DefaultEventDataFormat
 
DefaultEvictionContext - Class in org.apache.storm.windowing
 
DefaultEvictionContext(Long) - Constructor for class org.apache.storm.windowing.DefaultEvictionContext
 
DefaultEvictionContext(Long, Long) - Constructor for class org.apache.storm.windowing.DefaultEvictionContext
 
DefaultEvictionContext(Long, Long, Long) - Constructor for class org.apache.storm.windowing.DefaultEvictionContext
 
DefaultEvictionStrategy - Class in org.apache.storm.scheduler.resource.strategies.eviction
 
DefaultEvictionStrategy() - Constructor for class org.apache.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy
 
defaultFields - Static variable in class org.apache.storm.hdfs.spout.SequenceFileReader
 
defaultFields - Static variable in class org.apache.storm.hdfs.spout.TextFileReader
 
DefaultFileNameFormat - Class in org.apache.storm.hdfs.bolt.format
Creates file names with the following format:
DefaultFileNameFormat() - Constructor for class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
DefaultFileNameFormat - Class in org.apache.storm.hdfs.trident.format
Creates file names with the following format:
DefaultFileNameFormat() - Constructor for class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
DefaultHttpCredentialsPlugin - Class in org.apache.storm.security.auth
 
DefaultHttpCredentialsPlugin() - Constructor for class org.apache.storm.security.auth.DefaultHttpCredentialsPlugin
 
DefaultKeyFactory() - Constructor for class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory
 
DefaultKeyStoreLoader - Class in org.apache.storm.mqtt.ssl
KeyStoreLoader implementation that uses local files.
DefaultKeyStoreLoader(String) - Constructor for class org.apache.storm.mqtt.ssl.DefaultKeyStoreLoader
Creates a DefaultKeystoreLoader that uses the same file for both the keystore and truststore.
DefaultKeyStoreLoader(String, String) - Constructor for class org.apache.storm.mqtt.ssl.DefaultKeyStoreLoader
Creates a DefaultKeystoreLoader that uses separate files for the keystore and truststore.
DefaultKryoFactory - Class in org.apache.storm.serialization
 
DefaultKryoFactory() - Constructor for class org.apache.storm.serialization.DefaultKryoFactory
 
DefaultKryoFactory.KryoSerializableDefault - Class in org.apache.storm.serialization
 
DefaultPool - Class in org.apache.storm.scheduler.multitenant
A pool of machines that anyone can use, but topologies are not isolated
DefaultPool() - Constructor for class org.apache.storm.scheduler.multitenant.DefaultPool
 
DefaultPrincipalToLocal - Class in org.apache.storm.security.auth
Storm can be configured to launch worker processed as a given user.
DefaultPrincipalToLocal() - Constructor for class org.apache.storm.security.auth.DefaultPrincipalToLocal
 
DefaultRackDNSToSwitchMapping - Class in org.apache.storm.networktopography
This class implements the DNSToSwitchMapping interface It returns the DEFAULT_RACK for every host.
DefaultRackDNSToSwitchMapping() - Constructor for class org.apache.storm.networktopography.DefaultRackDNSToSwitchMapping
 
DefaultResourceAwareStrategy - Class in org.apache.storm.scheduler.resource.strategies.scheduling
 
DefaultResourceAwareStrategy() - Constructor for class org.apache.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy