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
 
absoluteHealthCheckDir(Map) - Static method in class org.apache.storm.utils.ConfigUtils
 
absoluteStormLocalDir(Map) - Static method in class org.apache.storm.utils.ConfigUtils
 
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
 
AbstractHDFSWriter - Class in org.apache.storm.hdfs.common
 
AbstractJdbcBolt - Class in org.apache.storm.jdbc.bolt
 
AbstractJdbcBolt(ConnectionProvider) - Constructor for class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
Constructor.
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
 
AbstractTridentProcessor() - Constructor for class org.apache.storm.sql.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
 
AbstractUserTopology - Class in org.apache.storm.jdbc.topology
 
AbstractUserTopology() - Constructor for class org.apache.storm.jdbc.topology.AbstractUserTopology
 
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.elasticsearch.bolt.EsIndexTopology.UserDataSpout
 
ack(long) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout
 
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.hbase.topology.WordSpout
 
ack(Object) - Method in class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpout
 
ack(Object) - Method in class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpout
 
ack(Object) - Method in class org.apache.storm.hdfs.spout.HdfsSpout
 
ack(long) - Method in class org.apache.storm.hdfs.trident.FixedBatchSpout
 
ack(Object) - Method in class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout
 
ack(Object) - Method in class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout
 
ack(Object) - Method in class org.apache.storm.hive.bolt.HiveTopologyPartitioned.UserDataSpout
 
ack(long) - Method in class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout
 
ack(Object) - Method in class org.apache.storm.jdbc.spout.UserSpout
 
ack(Object) - Method in class org.apache.storm.jms.spout.JmsSpout
Ack a successfully handled message by the matching JmsMessageID.
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.kinesis.spout.KinesisSpout
 
ack(Object) - Method in class org.apache.storm.mongodb.topology.WordSpout
 
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(long) - Method in class org.apache.storm.opentsdb.MetricGenBatchSpout
 
ack(Object) - Method in class org.apache.storm.perf.spout.ConstSpout
 
ack(Object) - Method in class org.apache.storm.perf.spout.StringGenSpout
 
ack(Object) - Method in class org.apache.storm.redis.topology.WordSpout
 
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(long) - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.TridentSocketSpout
 
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.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.
acked(KinesisMessageId) - Method in class org.apache.storm.kinesis.spout.ExponentialBackoffRetrier
 
acked(KinesisMessageId) - Method in interface org.apache.storm.kinesis.spout.FailedMessageRetryHandler
message with messageId succeeded/acked in the 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() - Method in class org.apache.storm.hbase.topology.WordSpout
 
activate(String) - Method in interface org.apache.storm.ILocalCluster
 
activate() - Method in class org.apache.storm.jdbc.spout.UserSpout
 
activate() - Method in class org.apache.storm.kafka.spout.KafkaSpout
 
activate() - Method in class org.apache.storm.kinesis.spout.KinesisSpout
 
activate() - Method in class org.apache.storm.mongodb.topology.WordSpout
 
activate() - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
activate() - Method in class org.apache.storm.pmml.RawInputFromCSVSpout
 
activate() - Method in class org.apache.storm.redis.topology.WordSpout
 
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.
activateStorm(String, StormBase) - Method in interface org.apache.storm.cluster.IStormClusterState
 
activateStorm(String, StormBase) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
activeKeys() - Method in interface org.apache.storm.cluster.IStormClusterState
 
activeKeys() - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
activeStorms() - Method in interface org.apache.storm.cluster.IStormClusterState
 
activeStorms() - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
ADA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
add(Runnable) - Method in interface org.apache.storm.event.EventManager
 
add(Runnable) - Method in class org.apache.storm.event.EventManagerImp
 
add(String, LocalizedResource, boolean) - Method in class org.apache.storm.localizer.LocalizedResourceSet
 
add(TaskMessage) - Method in class org.apache.storm.messaging.netty.MessageBuffer
 
add(Byte, Byte) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ByteSum
 
add(Long, Values) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Count
 
add(Double, Double) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.DoubleAvg
 
add(Double, Double) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.DoubleSum
 
add(Float, Float) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.FloatSum
 
add(Integer, Integer) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.IntAvg
 
add(Integer, Integer) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.IntSum
 
add(Long, Long) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.LongSum
 
add(T, T) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Max
 
add(T, T) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Min
 
add(Short, Short) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ShortSum
 
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(StormTimer.QueueEntry) - Method in class org.apache.storm.StormTimer.StormTimerTask
 
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_listener(ConnectionStateListener) - Method in interface org.apache.storm.cluster.IStateStorage
Add a StateStorageListener to the connection.
add_listener(ConnectionStateListener) - Method in class org.apache.storm.cluster.ZKStateStorage
 
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_dependency_artifacts(String) - Method in class org.apache.storm.generated.StormTopology
 
add_to_dependency_jars(String) - Method in class org.apache.storm.generated.StormTopology
 
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_supervisor_summaries(SupervisorSummary) - Method in class org.apache.storm.generated.SupervisorPageInfo
 
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
 
add_to_worker_summaries(WorkerSummary) - Method in class org.apache.storm.generated.SupervisorPageInfo
 
add_to_workers(WorkerSummary) - Method in class org.apache.storm.generated.TopologyPageInfo
 
addAll(Collection<? extends TopicPartition>) - Method in enum org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartitionRegistry
 
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
 
addClassLoader(CompilingClassLoader) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator
 
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
 
addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt
Add configuration for this bolt.
addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt
Add configuration for this bolt.
addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout
Add configuration for this spout.
addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout
Add configuration for this spout.
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
 
addListener(CuratorFramework, ConnectionStateListener) - Static method in class org.apache.storm.zookeeper.Zookeeper
 
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
 
addNimbusHost(String, NimbusSummary) - Method in interface org.apache.storm.cluster.IStormClusterState
 
addNimbusHost(String, NimbusSummary) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
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
 
addProfilerActions(Set<Slot.TopoProfileAction>) - Method in class org.apache.storm.daemon.supervisor.Slot
 
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
 
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
 
addShutdownHookWithForceKillIn1Sec(Runnable) - Static method in class org.apache.storm.utils.Utils
Adds the user supplied function as a shutdown hook for cleanup.
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(IAggregatableStream) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator
 
addTaskHook(ITaskHook) - Method in class org.apache.storm.task.TopologyContext
 
addToAckMsgs(KafkaSpoutMessageId) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
 
addToClasspath(String, Collection<String>) - Static method in class org.apache.storm.utils.Utils
 
addToClasspath(Collection<String>, Collection<String>) - Static method in class org.apache.storm.utils.Utils
 
addToClasspathImpl(String, Collection<String>) - Method in class org.apache.storm.utils.Utils
 
addToClasspathImpl(Collection<String>, Collection<String>) - Method in class org.apache.storm.utils.Utils
 
addToEmitMsgs(long) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
 
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.
addToLeaderLockQueue() - Method in class org.apache.storm.zookeeper.LeaderElectorImp
 
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
addTopologyHistory(LSTopoHistory) - Method in class org.apache.storm.utils.LocalState
 
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
 
addVersions(StormTopology) - Static method in class org.apache.storm.utils.Utils
Add version information to the given topology
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
 
AdvancedFSOps - Class in org.apache.storm.daemon.supervisor
 
AdvancedFSOps(Map<String, Object>) - Constructor for class org.apache.storm.daemon.supervisor.AdvancedFSOps
 
advanceTime(long) - Static method in class org.apache.storm.utils.Time
 
advanceTimeNanos(long) - Static method in class org.apache.storm.utils.Time
 
advanceTimeSecs(long) - Static method in class org.apache.storm.utils.Time
 
AetherUtils - Class in org.apache.storm.submit.dependency
 
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
 
All_CONFIGS() - Static method in class org.apache.storm.utils.ConfigUtils
 
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
 
ANOTHER_BOLT - Static variable in class org.apache.storm.jms.example.ExampleJmsTopology
 
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(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.ByTopicRecordTranslator
 
apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.DefaultRecordTranslator
 
apply(V) - Method in interface org.apache.storm.kafka.spout.Func
 
apply(ConsumerRecord<K, V>) - Method in interface org.apache.storm.kafka.spout.RecordTranslator
Translate the ConsumerRecord into a list of objects that can be emitted
apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.SimpleRecordTranslator
 
apply(IMetricsConsumer.DataPoint) - Method in class org.apache.storm.metric.filter.FilterByMetricName
 
APPLY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
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
 
applyUUIDToFileName(String) - Static method in class org.apache.storm.blobstore.BlobStoreUtils
 
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
 
areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.Container
 
areAllProcessesDead() - Method in interface org.apache.storm.daemon.supervisor.Killable
 
areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.LocalContainer
 
areTaskIdsNeeded() - Method in class org.apache.storm.multilang.ShellMsg
 
Arg(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
Arg0(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
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
 
artifactToString(Artifact) - Static method in class org.apache.storm.submit.dependency.AetherUtils
 
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.
assertFull() - Method in enum org.apache.storm.daemon.supervisor.Container.ContainerType
 
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 class org.apache.storm.daemon.supervisor.StandaloneSupervisor
 
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.
assignmentInfo(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
assignmentInfo(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
assignmentInfoWithVersion(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
assignmentInfoWithVersion(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
assignmentPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils
 
assignments(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
assignments(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
ASSIGNMENTS_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
ASSIGNMENTS_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
 
assignmentVersion(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
assignmentVersion(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
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
 
AsyncLocalizer - Class in org.apache.storm.localizer
This is a wrapper around the Localizer class that provides the desired async interface to Slot.
AsyncLocalizer(Map<String, Object>, Localizer) - Constructor for class org.apache.storm.localizer.AsyncLocalizer
 
asyncLoop(Callable, boolean, Thread.UncaughtExceptionHandler, int, boolean, boolean, String) - Static method in class org.apache.storm.utils.Utils
Creates a thread that calls the given code repeatedly, sleeping for an interval of seconds equal to the return value of the previous call.
asyncLoop(Callable, String, Thread.UncaughtExceptionHandler) - Static method in class org.apache.storm.utils.Utils
Convenience method used when only the function and name suffix are given.
asyncLoop(Callable) - Static method in class org.apache.storm.utils.Utils
Convenience method used when only the function is given.
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
 
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(Collection<Double>) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils
Caculate the average of a collection of doubles
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
 
AvroGenericRecordHDFSWriter - Class in org.apache.storm.hdfs.common
 
AvroGenericRecordHDFSWriter(FileRotationPolicy, Path, FSDataOutputStream, Schema) - Constructor for class org.apache.storm.hdfs.common.AvroGenericRecordHDFSWriter
 
AvroSchemaRegistry - Interface in org.apache.storm.hdfs.avro
 
AvroScheme - Class in org.apache.storm.sql.runtime.serde.avro
AvroScheme uses generic(without code generation) instead of specific(with code generation) readers.
AvroScheme(String, List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.avro.AvroScheme
 
AvroSerializer - Class in org.apache.storm.sql.runtime.serde.avro
AvroSerializer uses generic(without code generation) instead of specific(with code generation) writers.
AvroSerializer(String, List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.avro.AvroSerializer
 
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.
BACKPRESSURE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
BACKPRESSURE_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
 
backpressurePath(String, String, Long) - Static method in class org.apache.storm.cluster.ClusterUtils
 
backpressureStormRoot(String) - Static method in class org.apache.storm.cluster.ClusterUtils
 
backpressureTopologies() - Method in interface org.apache.storm.cluster.IStormClusterState
 
backpressureTopologies() - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
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
 
BaseTickTupleAwareRichBolt - Class in org.apache.storm.topology.base
This class is based on BaseRichBolt, but is aware of tick tuple.
BaseTickTupleAwareRichBolt() - Constructor for class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt
 
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
 
BasicContainer - Class in org.apache.storm.daemon.supervisor
A container that runs processes on the local box.
BasicContainer(Container.ContainerType, Map<String, Object>, String, int, LocalAssignment, LocalState, String) - Constructor for class org.apache.storm.daemon.supervisor.BasicContainer
Create a new BasicContainer
BasicContainerLauncher - Class in org.apache.storm.daemon.supervisor
Launch containers with no security using standard java commands
BasicContainerLauncher(Map<String, Object>, String) - Constructor for class org.apache.storm.daemon.supervisor.BasicContainerLauncher
 
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
 
BasicMetricsCollector - Class in org.apache.storm.perf.utils
 
BasicMetricsCollector(Nimbus.Client, String, Map) - Constructor for class org.apache.storm.perf.utils.BasicMetricsCollector
 
BasicMetricsCollector(LocalCluster, String, Map) - Constructor for class org.apache.storm.perf.utils.BasicMetricsCollector
 
BasicMetricsCollector.MetricsCollectorConfig - Class in org.apache.storm.perf.utils
 
BasicMetricsCollector.MetricsItem - Enum in org.apache.storm.perf.utils
 
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.
BeanListReference - Class in org.apache.storm.flux.model
A bean list reference is a list of bean reference.
BeanListReference() - Constructor for class org.apache.storm.flux.model.BeanListReference
 
BeanListReference(List<String>) - Constructor for class org.apache.storm.flux.model.BeanListReference
 
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.druid.trident.DruidBeamState
 
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.jms.trident.JmsState
 
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.opentsdb.trident.OpenTsdbState
 
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.sql.runtime.datasource.socket.trident.SocketState
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
 
BinaryEventDataScheme - Class in org.apache.storm.eventhubs.spout
An Event Data Scheme which deserializes message payload into the raw bytes.
BinaryEventDataScheme() - Constructor for class org.apache.storm.eventhubs.spout.BinaryEventDataScheme
 
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
 
bitXor(Long, Long) - Static method in class org.apache.storm.utils.Utils
 
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(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
blobstore(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
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_MAX_KEY_SEQUENCE_NUMBER_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
 
BLOBSTORE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
BLOBSTORE_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
 
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
 
blobstoreInfo(String) - Method in interface org.apache.storm.cluster.IStormClusterState
 
blobstoreInfo(String) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
blobstoreMapToLocalresources(Map<String, Map<String, Object>>) - Static method in class org.apache.storm.daemon.supervisor.SupervisorUtils
Returns a list of LocalResources based on the blobstore-map passed in
blobstoreMaxKeySequenceNumberPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils
 
blobstorePath(String) - Static method in class org.apache.storm.cluster.ClusterUtils
 
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
 
blockOnFull(boolean) - Method in class org.apache.storm.druid.bolt.DruidConfig.Builder
 
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.
BOLT1_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo
 
BOLT1_ID - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo
 
BOLT2_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo
 
BOLT2_ID - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo
 
BOLT_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutNullBoltTopo
 
BOLT_ID - Static variable in class org.apache.storm.hdfs.spout.HdfsSpoutTopology
 
BOLT_ID - Static variable in class org.apache.storm.perf.ConstSpoutNullBoltTopo
 
BOLT_ID - Static variable in class org.apache.storm.perf.KafkaHdfsTopo
 
BOLT_ID - Static variable in class org.apache.storm.perf.KafkaSpoutNullBoltTopo
 
BOLT_ID - Static variable in class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo
 
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
 
BOLT_NUM - Static variable in class org.apache.storm.perf.KafkaHdfsTopo
 
BOLT_NUM - Static variable in class org.apache.storm.perf.KafkaSpoutNullBoltTopo
 
BOLT_NUM - Static variable in class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo
 
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
 
Booter - Class in org.apache.storm.submit.dependency
Manage mvn repository.
Booter() - Constructor for class org.apache.storm.submit.dependency.Booter
 
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
 
BucketTestHiveTopology - Class in org.apache.storm.hive.bolt
 
BucketTestHiveTopology() - Constructor for class org.apache.storm.hive.bolt.BucketTestHiveTopology
 
BucketTestHiveTopology.UserDataSpout - Class in org.apache.storm.hive.bolt
 
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.druid.bolt.DruidConfig.Builder
 
build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
build() - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder
 
build() - Method in class org.apache.storm.opentsdb.client.OpenTsdbClient.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.AbstractTridentProcessor
Construct the trident topology based on the SQL.
build() - Method in class org.apache.storm.sql.compiler.CompilerUtil.TableBuilderInfo
 
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.
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() - Constructor for class org.apache.storm.druid.bolt.DruidConfig.Builder
 
builder(String, String...) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
builder(String, Collection<String>) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
builder(String, Pattern) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
 
Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
 
Builder() - Constructor for class org.apache.storm.mqtt.common.MqttOptions.Builder
 
Builder(String) - Constructor for class org.apache.storm.opentsdb.client.OpenTsdbClient.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
 
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(String) - Static method in class org.apache.storm.hbase.trident.WordCountTrident
 
buildTopology(String) - Static method in class org.apache.storm.hdfs.trident.TridentFileTopology
 
buildTopology(String) - Static method in class org.apache.storm.hdfs.trident.TridentSequenceTopology
 
buildTopology(String, String, String, Object, Object) - Static method in class org.apache.storm.hive.trident.TridentHiveTopology
 
buildTopology(String, String) - Static method in class org.apache.storm.mongodb.trident.WordCountTrident
 
buildTopology(String, Integer) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedis
 
buildTopology(String) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisCluster
 
buildTopology(String) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisClusterMap
 
buildTopology(String, Integer) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisMap
 
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(Map<String, Number>) - Method in class org.apache.storm.trident.topology.TridentTopologyBuilder
 
buildTopologyBuilder() - Method in class org.apache.storm.transactional.TransactionalTopologyBuilder
Deprecated.
 
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.
BuiltinAggregateFunctions - Class in org.apache.storm.sql.compiler.backends.standalone
Built-in implementations for some of the standard aggregation operations.
BuiltinAggregateFunctions() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions
 
BuiltinAggregateFunctions.ByteSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.Count - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.DoubleAvg - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.DoubleSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.FloatSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.IntAvg - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.IntSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.LongSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.Max<T extends Comparable<T>> - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.Min<T extends Comparable<T>> - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.ShortSum - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.TypeClass - Class in org.apache.storm.sql.compiler.backends.standalone
 
BuiltinAggregateFunctions.TypeClass.GenericType - Class in org.apache.storm.sql.compiler.backends.standalone
 
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
 
ByteSum() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ByteSum
 
ByTopicRecordTranslator<K,V> - Class in org.apache.storm.kafka.spout
Based off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream
ByTopicRecordTranslator(Func<ConsumerRecord<K, V>, List<Object>>, Fields, String) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator
Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to stream.
ByTopicRecordTranslator(Func<ConsumerRecord<K, V>, List<Object>>, Fields) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator
Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to the default stream.
ByTopicRecordTranslator(RecordTranslator<K, V>) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator
 

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
 
CachedSchemas - Class in org.apache.storm.sql.runtime.serde.avro
 
CachedSchemas() - Constructor for class org.apache.storm.sql.runtime.serde.avro.CachedSchemas
 
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(int) - Method in interface org.apache.storm.daemon.supervisor.ExitCodeCallback
The process finished
call(T) - Method in interface org.apache.storm.daemon.supervisor.UniFunc
 
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.
canConvertConvention(Convention) - Method in enum org.apache.storm.sql.planner.trident.rel.TridentLogicalConvention
 
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 - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt
 
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.
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
 
CENTURY - 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
 
changeChildCWD(boolean) - Method in class org.apache.storm.spout.ShellSpout
Set if the current working directory of the child process should change to the resources dir from extracted from the jar, or if it should stay the same as the worker process to access things from the blob store.
changeChildCWD(boolean) - Method in class org.apache.storm.task.ShellBolt
Set if the current working directory of the child process should change to the resources dir from extracted from the jar, or if it should stay the same as the worker process to access things from the blob store.
changed(Watcher.Event.EventType, String) - Method in interface org.apache.storm.callback.ZKStateChangedCallback
 
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
 
CheckDirExists(String) - Static method in class org.apache.storm.utils.Utils
 
checkFileExists(File) - Static method in class org.apache.storm.utils.Utils
 
checkFileExists(String) - Static method in class org.apache.storm.utils.Utils
 
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
 
CLASS_PATH_SEPARATOR - Static variable in class org.apache.storm.utils.Utils
 
classLoaders - Variable in class org.apache.storm.sql.AbstractTridentProcessor
 
className() - Method in class org.apache.storm.sql.parser.SqlCreateFunction
 
clazz - Variable in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.TypeClass
 
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.daemon.supervisor.Container
 
cleanUp() - Method in interface org.apache.storm.daemon.supervisor.Killable
Clean up the container.
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.druid.bolt.DruidBeamBolt
 
cleanup() - Method in class org.apache.storm.hbase.bolt.AbstractHBaseBolt
 
cleanup() - Method in class org.apache.storm.hbase.topology.TotalWordCounter
 
cleanup() - Method in class org.apache.storm.hbase.topology.WordCounter
 
cleanup() - Method in class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt
 
cleanup() - Method in class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt
 
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.
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.jms.bolt.JmsBolt
Releases JMS resources.
cleanup() - Method in class org.apache.storm.jms.example.GenericBolt
 
cleanup() - Method in class org.apache.storm.kafka.bolt.KafkaBolt
Deprecated.
 
cleanup() - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet
 
cleanup() - Method in interface org.apache.storm.metric.api.IClusterMetricsConsumer
 
cleanup() - Method in interface org.apache.storm.metric.api.IMetricsConsumer
 
cleanup() - Method in class org.apache.storm.metric.ClusterMetricsConsumerExecutor
 
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.LoggingClusterMetricsConsumer
 
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 class org.apache.storm.mongodb.topology.WordCounter
 
cleanup() - Method in interface org.apache.storm.nimbus.ITopologyActionNotifierPlugin
called during shutdown.
cleanup() - Method in class org.apache.storm.opentsdb.bolt.OpenTsdbBolt
 
cleanup() - Method in class org.apache.storm.opentsdb.client.OpenTsdbClient
 
cleanup() - Method in class org.apache.storm.redis.bolt.AbstractRedisBolt
 
cleanup() - Method in class org.apache.storm.redis.topology.WordCounter
 
cleanup() - Method in class org.apache.storm.sql.runtime.trident.functions.EvaluationCalc
 
cleanup() - Method in class org.apache.storm.sql.runtime.trident.functions.EvaluationFunction
 
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.FlatMapFunctionExecutor
 
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.MapFunctionExecutor
 
cleanup() - Method in class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer
 
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
 
cleanUpForRestart() - Method in class org.apache.storm.daemon.supervisor.BasicContainer
 
cleanUpForRestart() - Method in class org.apache.storm.daemon.supervisor.Container
Clean up the container partly preparing for restart.
cleanupUnusedTopologies() - Method in class org.apache.storm.localizer.AsyncLocalizer
 
cleanupUnusedTopologies() - Method in interface org.apache.storm.localizer.ILocalizer
Clean up any topologies that are not in use right now.
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.getLeader_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getLeader_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.getSupervisorPageInfo_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_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.isTopologyNameAllowed_args
 
clear() - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_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.SupervisorPageInfo
 
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.generated.WorkerSummary
 
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
 
ClientResponse - Interface in org.apache.storm.opentsdb.client
This class represents the response from OpenTsdb for a request sent.
ClientResponse.Details - Class in org.apache.storm.opentsdb.client
 
ClientResponse.Details.Error - Class in org.apache.storm.opentsdb.client
 
ClientResponse.Summary - Class in org.apache.storm.opentsdb.client
 
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
 
clojureConfigName(String) - Static method in class org.apache.storm.utils.ConfigUtils
 
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
 
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 interface org.apache.storm.cluster.IStateStorage
Close the connection to the data store.
close() - Method in class org.apache.storm.cluster.ZKStateStorage
 
close() - Method in class org.apache.storm.daemon.supervisor.ReadClusterState
 
close() - Method in class org.apache.storm.daemon.supervisor.Slot
 
close() - Method in class org.apache.storm.daemon.supervisor.Supervisor
 
close() - Method in class org.apache.storm.drpc.DRPCSpout
 
close() - Method in class org.apache.storm.druid.trident.DruidBeamState
 
close() - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout
 
close() - Method in class org.apache.storm.event.EventManagerImp
 
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.hbase.topology.WordSpout
 
close() - Method in class org.apache.storm.hdfs.common.AbstractHDFSWriter
 
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.hdfs.trident.FixedBatchSpout
 
close() - Method in class org.apache.storm.hive.common.HiveWriter
Close the Transaction Batch and connection
close() - Method in class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout
 
close() - Method in class org.apache.storm.jdbc.spout.UserSpout
 
close() - Method in class org.apache.storm.jms.spout.JmsSpout
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.spout.trident.KafkaTridentSpoutEmitter
 
close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaqueCoordinator
 
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.kinesis.spout.KinesisSpout
 
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.mongodb.topology.WordSpout
 
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.opentsdb.MetricGenBatchSpout
 
close() - Method in class org.apache.storm.pacemaker.PacemakerClient
 
close() - Method in class org.apache.storm.perf.utils.BasicMetricsCollector
 
close() - Method in class org.apache.storm.pmml.RawInputFromCSVSpout
 
close() - Method in class org.apache.storm.redis.common.container.JedisClusterContainer
Release Container
close() - Method in interface org.apache.storm.redis.common.container.JedisCommandsInstanceContainer
Release Container
close() - Method in class org.apache.storm.redis.common.container.JedisContainer
Release Container
close() - Method in class org.apache.storm.redis.topology.WordSpout
 
close() - Method in class org.apache.storm.security.auth.kerberos.NoOpTTrasport
 
close() - Method in class org.apache.storm.security.auth.ThriftClient
 
close() - Method in class org.apache.storm.solr.spout.SolrFieldsSpout
 
close() - Method in class org.apache.storm.solr.spout.SolrJsonSpout
 
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.sql.runtime.datasource.socket.trident.TridentSocketSpout
 
close() - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout
 
close() - Method in interface org.apache.storm.state.IStateSpout
 
close() - Method in class org.apache.storm.StormTimer
cancel timer
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.staticmocking.MockedSupervisorUtils
 
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
 
close() - Method in class org.apache.storm.utils.Time.SimulatedTime
 
close() - Method in class org.apache.storm.zookeeper.LeaderElectorImp
 
closeChannel(Channel) - Method in interface org.apache.storm.messaging.netty.IServer
 
closed - Variable in class org.apache.storm.hive.common.HiveWriter
 
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
 
ClusterInfo(long) - Constructor for class org.apache.storm.metric.api.IClusterMetricsConsumer.ClusterInfo
 
ClusterMetricRegistryValidator() - Constructor for class org.apache.storm.validation.ConfigValidation.ClusterMetricRegistryValidator
 
ClusterMetricsConsumerExecutor - Class in org.apache.storm.metric
 
ClusterMetricsConsumerExecutor(String, Object) - Constructor for class org.apache.storm.metric.ClusterMetricsConsumerExecutor
 
clusterMode(Map) - Static method in class org.apache.storm.utils.ConfigUtils
 
clusterName - Static variable in class org.apache.storm.elasticsearch.common.EsConstants
 
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.
ClusterUtils - Class in org.apache.storm.cluster
 
ClusterUtils() - Constructor for class org.apache.storm.cluster.ClusterUtils
 
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
 
CODE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
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(Nimbus.Client) - Method in class org.apache.storm.perf.utils.BasicMetricsCollector
 
collect(LocalCluster) - Method in class org.apache.storm.perf.utils.BasicMetricsCollector
 
COLLECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
COLLECTION - Static variable in class org.apache.storm.solr.topology.SolrTopology
 
CollectionsTypeName() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
 
collectLocalMetricsAndKill(LocalCluster, String, Integer, Integer, Map) - Static method in class org.apache.storm.perf.utils.Helper
 
collectMetricsAndKill(String, Integer, Integer) - Static method in class org.apache.storm.perf.utils.Helper
 
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.druid.trident.DruidBeamState
 
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(Long) - Method in class org.apache.storm.jms.trident.JmsState
 
commit() - Method in class org.apache.storm.kafka.PartitionManager
 
commit(OffsetAndMetadata) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
Marks an offset has committed.
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.opentsdb.trident.OpenTsdbState
 
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(Long) - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.SocketState
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
 
committedPath() - Method in class org.apache.storm.kafka.PartitionManager
 
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(TopicPartition, TopicPartition) - Method in class org.apache.storm.kafka.spout.TopicPartitionComparator
 
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.getLeader_args) - Method in class org.apache.storm.generated.Nimbus.getLeader_args
 
compareTo(Nimbus.getLeader_result) - Method in class org.apache.storm.generated.Nimbus.getLeader_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.getSupervisorPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args
 
compareTo(Nimbus.getSupervisorPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_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.isTopologyNameAllowed_args) - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args
 
compareTo(Nimbus.isTopologyNameAllowed_result) - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_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(SupervisorPageInfo) - Method in class org.apache.storm.generated.SupervisorPageInfo
 
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(WorkerSummary) - Method in class org.apache.storm.generated.WorkerSummary
 
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(JmsMessageID) - Method in class org.apache.storm.jms.spout.JmsMessageID
 
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(List<RexNode>, RelDataType, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
 
compile(RexProgram, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
 
compile(Map<String, ISqlTridentDataSource>, String) - Method in class org.apache.storm.sql.planner.trident.QueryPlanner
 
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
 
compileToBlock(List<RexNode>, RelDataType) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
 
compileToBlock(RexProgram) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
 
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(JoinState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.JoinerMultiReducer
 
complete(JoinState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer
 
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.
CompoundIdentifierCommaList(List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
Parses a comma-separated list of compound identifiers.
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
 
concatIfNotNull(String) - Static method in class org.apache.storm.utils.ConfigUtils
 
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
 
ConfigUtils - Class in org.apache.storm.utils
 
ConfigUtils() - Constructor for class org.apache.storm.utils.ConfigUtils
 
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.ClusterMetricRegistryValidator - 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 class org.apache.storm.daemon.supervisor.StandaloneSupervisor
 
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
 
connectionFactory() - Method in class org.apache.storm.jms.example.SpringJmsProvider
 
connectionFactory() - Method in interface org.apache.storm.jms.JmsProvider
Provides the JMS ConnectionFactory
connectionProvider - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
 
ConnectionProvider - Interface in org.apache.storm.jdbc.common
Provides a database connection.
connectionProvider - Variable in class org.apache.storm.jdbc.topology.AbstractUserTopology
 
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 org.apache.storm.hdfs.spout.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.hdfs.HdfsDataSourcesProvider
 
construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider
 
construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.mongodb.MongoDataSourcesProvider
 
construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.redis.RedisDataSourcesProvider
 
construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.runtime.datasource.socket.SocketDataSourcesProvider
 
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, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.hdfs.HdfsDataSourcesProvider
 
constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider
 
constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.mongodb.MongoDataSourcesProvider
 
constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.redis.RedisDataSourcesProvider
 
constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.runtime.datasource.socket.SocketDataSourcesProvider
 
constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in interface org.apache.storm.sql.runtime.DataSourcesProvider
 
constructTridentDataSource(URI, String, String, Properties, List<FieldInfo>) - Static method in class org.apache.storm.sql.runtime.DataSourcesRegistry
 
constructVersionFileName(String) - Static method in class org.apache.storm.utils.Utils
 
ConstSpout - Class in org.apache.storm.perf.spout
 
ConstSpout(String) - Constructor for class org.apache.storm.perf.spout.ConstSpout
 
ConstSpoutIdBoltNullBoltTopo - Class in org.apache.storm.perf
ConstSpout -> IdBolt -> DevNullBolt This topology measures speed of messaging between spouts->bolt and bolt->bolt ConstSpout : Continuously emits a constant string IdBolt : clones and emits input tuples DevNullBolt : discards incoming tuples
ConstSpoutIdBoltNullBoltTopo() - Constructor for class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo
 
ConstSpoutNullBoltTopo - Class in org.apache.storm.perf
This topo helps measure the messaging speed between a spout and a bolt.
ConstSpoutNullBoltTopo() - Constructor for class org.apache.storm.perf.ConstSpoutNullBoltTopo
 
ConstSpoutOnlyTopo - Class in org.apache.storm.perf
This topo helps measure how fast a spout can produce data (so no bolts are attached) Spout generates a stream of a fixed string.
ConstSpoutOnlyTopo() - Constructor for class org.apache.storm.perf.ConstSpoutOnlyTopo
 
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.daemon.supervisor
Represents a container that a worker will run in.
Container(Container.ContainerType, Map<String, Object>, String, int, LocalAssignment, String, Map<String, Object>, AdvancedFSOps) - Constructor for class org.apache.storm.daemon.supervisor.Container
Create a new Container.
Container - Class in org.apache.storm.utils
 
Container() - Constructor for class org.apache.storm.utils.Container
 
Container.ContainerType - Enum in org.apache.storm.daemon.supervisor
 
containerFilePath(String) - Static method in class org.apache.storm.utils.Utils
 
ContainerLauncher - Class in org.apache.storm.daemon.supervisor
Launches containers
ContainerLauncher() - Constructor for class org.apache.storm.daemon.supervisor.ContainerLauncher
 
ContainerRecoveryException - Exception in org.apache.storm.daemon.supervisor
Could not recover the container.
ContainerRecoveryException(String) - Constructor for exception org.apache.storm.daemon.supervisor.ContainerRecoveryException
 
contains(ConsumerRecord) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
 
contains(KafkaSpoutMessageId) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
 
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(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentAggregateRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentCalcRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentFilterRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentJoinRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentModifyRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentProjectRule
 
convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentScanRule
 
convert(ConnectionState) - Static method in class org.apache.storm.utils.StormConnectionStateConverter
 
convertAvroUtf8(Object) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils
 
convertAvroUtf8Array(GenericData.Array) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils
 
convertAvroUtf8Map(Map<Object, Object>) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils
 
convertClojureMapToJavaMap(Map) - Static method in class org.apache.storm.utils.Utils
converts a clojure PersistentMap to java HashMap
convertExecutorBeats(List<ExecutorInfo>, ClusterWorkerHeartbeat) - Static method in class org.apache.storm.cluster.ClusterUtils
Ensures that we only return heartbeats for executors assigned to this worker
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.hdfs.bolt.rotation.FileRotationPolicy
Must be able to copy the rotation policy
copy() - Method in class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy
 
copy() - Method in class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
 
copy() - Method in class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
 
copy(RelTraitSet, RelNode, RexProgram) - Method in class org.apache.storm.sql.planner.trident.rel.TridentCalcRel
 
copy(RelTraitSet, RelNode, RexNode) - Method in class org.apache.storm.sql.planner.trident.rel.TridentFilterRel
 
copy(RelTraitSet, RelNode, List<RexNode>, RelDataType) - Method in class org.apache.storm.sql.planner.trident.rel.TridentProjectRel
 
copy(RelTraitSet, List<RelNode>) - Method in class org.apache.storm.sql.planner.trident.rel.TridentStreamInsertRel
 
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.
copyDirectory(File, File) - Method in class org.apache.storm.daemon.supervisor.AdvancedFSOps
Copy a directory
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() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Count
 
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
 
COUNT_ID - Static variable in class org.apache.storm.perf.FileReadWordCountTopo
 
COUNT_NUM - Static variable in class org.apache.storm.perf.FileReadWordCountTopo
 
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
CountBolt - Class in org.apache.storm.perf.bolt
 
CountBolt() - Constructor for class org.apache.storm.perf.bolt.CountBolt
 
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.
create_sequential(String, byte[], List<ACL>) - Method in interface org.apache.storm.cluster.IStateStorage
Path will be appended with a monotonically increasing integer, a new node will be created there, and data will be put at that node.
create_sequential(String, byte[], List<ACL>) - Method in class org.apache.storm.cluster.ZKStateStorage
 
createArtifactsLink() - Method in class org.apache.storm.daemon.supervisor.Container
Create symlink from the containers directory/artifacts to the artifacts directory
createArtifactsLink() - Method in class org.apache.storm.daemon.supervisor.LocalContainer
 
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
 
createBlobstoreLinks() - Method in class org.apache.storm.daemon.supervisor.Container
Create symlinks for each of the blobs from the container’s directory to corresponding links in the storm dist directory.
createBlobstoreLinks() - Method in class org.apache.storm.daemon.supervisor.LocalContainer
 
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
 
createConsumer(KafkaSpoutConfig<K, V>) - Method in interface org.apache.storm.kafka.spout.internal.KafkaConsumerFactory
 
createConsumer(KafkaSpoutConfig<K, V>) - Method in class org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault
 
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
 
createExclusion(String) - Static method in class org.apache.storm.submit.dependency.AetherUtils
 
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.
 
createNewWorkerId() - Method in class org.apache.storm.daemon.supervisor.BasicContainer
Create a new worker ID for this process and store in in this object and in the local state.
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
 
createNode(CuratorFramework, String, byte[], CreateMode, List<ACL>) - Static method in class org.apache.storm.zookeeper.Zookeeper
 
createNode(CuratorFramework, String, byte[], List<ACL>) - Static method in class org.apache.storm.zookeeper.Zookeeper
 
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
 
createScalarInstance(List<RexNode>, RelDataType, String) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator
 
createScalarInstance(RexProgram, String) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator
 
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.
createSymlink(File, File) - Method in class org.apache.storm.daemon.supervisor.AdvancedFSOps
Create a symbolic link pointing at target
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(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
 
credentials(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
 
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
 
CREDENTIALS_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
 
CREDENTIALS_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
 
credentialsPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils
 
CredentialsProviderChain - Class in org.apache.storm.kinesis.spout
Class representing chain of mechanisms that will be used in order to connect to kinesis
CredentialsProviderChain() - Constructor for class org.apache.storm.kinesis.spout.CredentialsProviderChain
 
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
 
CsvScheme - Class in org.apache.storm.sql.runtime.serde.csv
CsvScheme uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.
CsvScheme(List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.csv.CsvScheme
 
CsvSerializer - Class in org.apache.storm.sql.runtime.serde.csv
CsvSerializer uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.
CsvSerializer(List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.csv.CsvSerializer
 
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
 
currentClasspath() - Static method in class org.apache.storm.utils.Utils
Returns the value of java.class.path System property.
currentClasspathImpl() - Method in class org.apache.storm.utils.Utils
 
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

DaemonCommon - Interface in org.apache.storm.daemon
 
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 interface org.apache.storm.sql.parser.impl.StormParserImplConstants
 
DATABASE - Static variable in class org.apache.storm.starter.TransactionalGlobalCount
 
databaseName - Variable in class org.apache.storm.hive.common.HiveOptions
 
dataContext - Variable in class org.apache.storm.sql.AbstractTridentProcessor
 
dataFormat - Variable in class org.apache.storm.eventhubs.bolt.EventHubBoltConfig
 
DataPoint - Class in org.apache.storm.metric.api
 
DataPoint() - Constructor for class org.apache.storm.metric.api.DataPoint
 
DataPoint(String, Object) - Constructor for class org.apache.storm.metric.api.DataPoint
 
DataPoint() - Constructor for class org.apache.storm.metric.api.IMetricsConsumer.DataPoint
 
DataPoint(String, Object) - Constructor for class org.apache.storm.metric.api.IMetricsConsumer.DataPoint
 
DataPointExpander - Class in org.apache.storm.metric.util
 
DataPointExpander(boolean, String) - Constructor for class org.apache.storm.metric.util.DataPointExpander
 
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
 
days(int) - Static method in class org.apache.storm.topology.base.BaseWindowedBolt.Duration
Returns a BaseWindowedBolt.Duration corresponding to the the given value in days.
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() - Method in class org.apache.storm.hbase.topology.WordSpout
 
deactivate(String) - Method in interface org.apache.storm.ILocalCluster
 
deactivate() - Method in class org.apache.storm.jdbc.spout.UserSpout
 
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.kinesis.spout.KinesisSpout
 
deactivate() - Method in class org.apache.storm.mongodb.topology.WordSpout
 
deactivate() - Method in class org.apache.storm.mqtt.spout.MqttSpout
 
deactivate() - Method in class org.apache.storm.pmml.RawInputFromCSVSpout
 
deactivate() - Method in class org.apache.storm.redis.topology.WordSpout
 
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