- 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
-
- absoluteStormBlobStoreDir(Map<String, Object>) - Static method in class org.apache.storm.utils.ConfigUtils
-
- absoluteStormLocalDir(Map) - Static method in class org.apache.storm.utils.ConfigUtils
-
- AbstractAutoCreds - Class in org.apache.storm.common
-
The base class that for auto credential plugins that abstracts out some of the common functionality.
- AbstractAutoCreds() - Constructor for class org.apache.storm.common.AbstractAutoCreds
-
- 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
-
- AbstractHDFSWriter(FileRotationPolicy, Path) - Constructor for class org.apache.storm.hdfs.common.AbstractHDFSWriter
-
- 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(boolean) - 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
-
Deprecated.
- 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.AnchoredWordCount.RandomSentenceSpout
-
- 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
-
- AclEnforcement - Class in org.apache.storm.zookeeper
-
This is code intended to enforce ZK ACLs.
- AclEnforcement() - Constructor for class org.apache.storm.zookeeper.AclEnforcement
-
- 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<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- activate(String, AsyncMethodCallback<Void>) - 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<Void>, 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, Map<String, Object>) - Method in interface org.apache.storm.cluster.IStormClusterState
-
- activateStorm(String, StormBase, Map<String, Object>) - 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(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
-
Adds a list of bolt definitions.
- addAllComponents(List<BeanDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
-
Adds a list of component definitions.
- addAllSpouts(List<SpoutDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
-
Adds a list of spout definitions.
- addAllStreams(List<StreamDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef
-
Adds a list of stream definitions.
- 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
-
- addBolt(IBatchBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
-
- 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
-
- addBolt(IBasicBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
-
- 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.
- addColumnFamily(byte[]) - 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
-
- 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
-
Utility class of Aether.
- 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
-
- AnchoredWordCount - Class in org.apache.storm.starter
-
- AnchoredWordCount() - Constructor for class org.apache.storm.starter.AnchoredWordCount
-
- AnchoredWordCount.RandomSentenceSpout - Class in org.apache.storm.starter
-
- AnchoredWordCount.SplitSentence - Class in org.apache.storm.starter
-
- AnchoredWordCount.WordCount - Class in org.apache.storm.starter
-
- 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
-
- arrivalRate() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics
-
- artifactToString(Artifact) - Static method in class org.apache.storm.submit.dependency.AetherUtils
-
Convert Artifact
object to String for printing.
- 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
-
- 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(boolean, 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.security
-
Automatically get HDFS delegation tokens and push it to user’s topology.
- AutoHDFS() - Constructor for class org.apache.storm.hdfs.security.AutoHDFS
-
- AutoHive - Class in org.apache.storm.hive.security
-
Automatically get hive delegation tokens and push it to user’s topology.
- AutoHive() - Constructor for class org.apache.storm.hive.security.AutoHive
-
- 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
-
- 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
-
- BACKPRESSURE_ZNODE_TIMEOUT_SECS - Static variable in class org.apache.storm.Config
-
How long until the backpressure znode is invalid.
- BACKPRESSURE_ZNODE_UPDATE_FREQ_SECS - Static variable in class org.apache.storm.Config
-
How often will the data (timestamp) of backpressure znode be updated.
- 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
-
- Base64ToBinaryStateMigrationUtil - Class in org.apache.storm.redis.tools
-
- Base64ToBinaryStateMigrationUtil(JedisPoolConfig) - Constructor for class org.apache.storm.redis.tools.Base64ToBinaryStateMigrationUtil
-
- Base64ToBinaryStateMigrationUtil(RedisCommandsInstanceContainer) - Constructor for class org.apache.storm.redis.tools.Base64ToBinaryStateMigrationUtil
-
- 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
-
- BaseBinaryStateIterator<K,V> - Class in org.apache.storm.state
-
Base implementation of iterator over
KeyValueState
which encoded types of key and value are both binary type.
- BaseBinaryStateIterator(Iterator<Map.Entry<byte[], byte[]>>, Iterator<Map.Entry<byte[], byte[]>>) - Constructor for class org.apache.storm.state.BaseBinaryStateIterator
-
Constructor.
- 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
-
- BaseCassandraBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.BaseCassandraBolt
-
- 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
-
- 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
-
- BaseStateIterator<K,V,KENCODED,VENCODED> - Class in org.apache.storm.state
-
- BaseStateIterator(Iterator<Map.Entry<KENCODED, VENCODED>>, Iterator<Map.Entry<KENCODED, VENCODED>>, Set<KENCODED>) - Constructor for class org.apache.storm.state.BaseStateIterator
-
Constructor.
- 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
-
- 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
-
- BatchCassandraWriterBolt(CQLStatementTupleMapper, int) - Constructor for class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt
-
- 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
-
- 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<BeginDownloadResult>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- beginBlobDownload(String, AsyncMethodCallback<BeginDownloadResult>) - 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<BeginDownloadResult>, 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
-
Deprecated.
- 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
-
Deprecated.
- 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<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- beginCreateBlob(String, SettableBlobMeta, AsyncMethodCallback<String>) - 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<String>, 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<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- beginFileDownload(String, AsyncMethodCallback<String>) - 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<String>, 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<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- beginFileUpload(AsyncMethodCallback<String>) - 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<String>, 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<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- beginUpdateBlob(String, AsyncMethodCallback<String>) - 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<String>, 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
-
Deprecated.
- 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
-
- BoundCQLStatementMapperBuilder(ContextQuery) - Constructor for class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder
-
- BoundCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query.impl
-
- BoundCQLStatementTupleMapper(ContextQuery, CqlMapper, RoutingKeyGenerator, PreparedStatementBinder) - Constructor for class org.apache.storm.cassandra.query.impl.BoundCQLStatementTupleMapper
-
- 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
-
- build() - Method in class org.apache.storm.cassandra.query.builder.SimpleCQLStatementMapperBuilder
-
- build() - Method in interface org.apache.storm.cassandra.query.CQLStatementBuilder
-
- build() - Method in class org.apache.storm.druid.bolt.DruidConfig.Builder
-
Deprecated.
- 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(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder
-
Builds container for single Redis environment.
- build(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder
-
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
-
Deprecated.
- builder(String, String...) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
-
Factory method that creates a Builder with String key/value deserializers.
- builder(String, Collection<String>) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
-
Factory method that creates a Builder with String key/value deserializers.
- builder(String, Pattern) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig
-
Factory method that creates a Builder with String key/value deserializers.
- Builder(String, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
-
- Builder(String, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
-
- Builder(String, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
-
- 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(String, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
-
Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.
- 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
-
- Builder(SchemaBuilder, SolrClient) - Constructor for class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder
-
- Builder(String, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder
-
- Builder(SolrClient, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder
-
- 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
-
- buildLogMessage(IEventLogger.EventInfo) - Method in class org.apache.storm.metric.FileBasedEventLogger
-
- 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.
- BulkIndexResponse - Class in org.apache.storm.elasticsearch.response
-
Mapped response for bulk index.
- BulkIndexResponse() - Constructor for class org.apache.storm.elasticsearch.response.BulkIndexResponse
-
- 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 - 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, 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<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- cancelBlobUpload(String, AsyncMethodCallback<Void>) - 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<Void>, 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_DATACENTER_NAME - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_HEARTBEAT_INTERVAL_SEC - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_IDLE_TIMEOUT_SEC - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_KEYSPACE - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_LOAD_BALANCING_POLICY - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE - 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_POOL_MAX_SIZE - 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_SOCKET_CONNECT_TIMEOUT_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf
-
- CASSANDRA_SOCKET_READ_TIMEOUT_MS - 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
-
- CassandraConf(Map<String, Object>) - Constructor for class org.apache.storm.cassandra.client.CassandraConf
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
Deprecated.
- 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.AbstractHdfsBolt
-
- 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.solr.bolt.SolrUpdateBolt
-
- 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
-
Deprecated.
- 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 interface org.apache.storm.hdfs.bolt.Writer
-
- close() - Method in class org.apache.storm.hdfs.common.AbstractHDFSWriter
-
- close() - Method in class org.apache.storm.hdfs.spout.HdfsSpout
-
- 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
-
Deprecated.
- 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.adapter.RedisCommandsAdapterJedis
-
- close() - Method in class org.apache.storm.redis.common.adapter.RedisCommandsAdapterJedisCluster
-
- 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.common.container.RedisClusterContainer
- close() - Method in class org.apache.storm.redis.common.container.RedisContainer
- 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
-
- 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
-
- ColumnMetaData(byte[], byte[]) - 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
-
Deprecated.
- commit(long) - Method in class org.apache.storm.hbase.state.HBaseKeyValueState
-
- commit() - Method in class org.apache.storm.hbase.state.HBaseKeyValueState
-
- 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 as committed.
- commit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState
-
Deprecated.
- 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
-
- CommitMetadata - Class in org.apache.storm.kafka.spout.internal
-
Object representing metadata committed to Kafka.
- CommitMetadata(String, int, String) - Constructor for class org.apache.storm.kafka.spout.internal.CommitMetadata
-
Kafka metadata.
- CommitMetadataManager - Class in org.apache.storm.kafka.spout.internal
-
Generates and reads commit metadata.
- CommitMetadataManager(TopologyContext, KafkaSpoutConfig.ProcessingGuarantee) - Constructor for class org.apache.storm.kafka.spout.internal.CommitMetadataManager
-
Create a manager with the given context.
- 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
-
- CONFIG_KEY_RESOURCES - Static variable in class org.apache.storm.common.AbstractAutoCreds
-
- 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.EventLoggerRegistryValidator - 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.MetricReportersValidator - 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.Password - Annotation Type in org.apache.storm.validation
-
- 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
-
- 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 implementation should return a new connection every call
- 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
-
- ConsoleStormReporter - Class in org.apache.storm.metrics2.reporters
-
- ConsoleStormReporter() - Constructor for class org.apache.storm.metrics2.reporters.ConsoleStormReporter
-
- 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(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
-
- ContextQuery.BoundQueryNamedByFieldContext - Class in org.apache.storm.cassandra.query
-
- ContextQuery.StaticContextQuery - Class in org.apache.storm.cassandra.query
-
- 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.
- 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
-
- counter(String, WorkerTopologyContext, String, Integer, String) - Static method in class org.apache.storm.metrics2.StormMetricRegistry
-
- counter(String, String, String, Integer, Integer, String) - Static method in class org.apache.storm.metrics2.StormMetricRegistry
-
- 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
-
- 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
-
Parses exclusion parameter and build Exclusion
object.
- 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
-
- createHiveConf(String, String) - Method in class org.apache.storm.hive.security.AutoHive
-
- createLocalizer(Map, String) - Static method in class org.apache.storm.utils.Utils
-
- createLocalTopology(ILocalDRPC) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
-
- 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
-
- 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<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient
-
- createStateInZookeeper(String, AsyncMethodCallback<Void>) - 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<Void>, 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, List<ACL>) - 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
-
- CSV_LOG_DIR - Static variable in class org.apache.storm.metrics2.reporters.CsvStormReporter
-
- 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
-
- CsvStormReporter - Class in org.apache.storm.metrics2.reporters
-
- CsvStormReporter() - Constructor for class org.apache.storm.metrics2.reporters.CsvStormReporter
-
- 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
-