Index (Storm 2.6.0 API)

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

A - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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: RegularExpression Id.
ABSOLUTE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
absoluteHealthCheckDir(Map<String, Object>) - Static method in class org.apache.storm.utils.ServerConfigUtils
absoluteStormBlobStoreDir(Map<String, Object>) - Static method in class org.apache.storm.utils.ConfigUtils
absoluteStormLocalDir(Map<String, Object>) - Static method in class org.apache.storm.utils.ConfigUtils
AbstractAvroSerializer - Class in org.apache.storm.hdfs.avro: This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects across a Topology.
AbstractAvroSerializer() - Constructor for class org.apache.storm.hdfs.avro.AbstractAvroSerializer
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
AbstractHadoopAutoCreds - Class in org.apache.storm.common: The base class that for auto credential plugins that abstracts out some of the common functionality.
AbstractHadoopAutoCreds() - Constructor for class org.apache.storm.common.AbstractHadoopAutoCreds
AbstractHadoopNimbusPluginAutoCreds - Class in org.apache.storm.common: The base class that for auto credential plugins that abstracts out some of the common functionality.
AbstractHadoopNimbusPluginAutoCreds() - Constructor for class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds
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.
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(JedisClusterConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt: Constructor for Redis Cluster environment (JedisCluster).
AbstractRedisBolt(JedisPoolConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt: Constructor for single Redis environment (JedisPool).
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.
AbstractStreamsProcessor - Class in org.apache.storm.sql
AbstractStreamsProcessor() - Constructor for class org.apache.storm.sql.AbstractStreamsProcessor
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: For topology-related code reusage.
AbstractUserTopology() - Constructor for class org.apache.storm.jdbc.topology.AbstractUserTopology
accept(Object) - Method in class org.apache.storm.daemon.worker.WorkerTransfer
accept(Object) - Method in class org.apache.storm.executor.Executor
accept(Object) - Method in interface org.apache.storm.utils.JCQueue.Consumer
accept(TridentTuple) - Method in interface org.apache.storm.trident.operation.Consumer: Performs the operation on the input trident tuple.
accept(T) - Method in interface org.apache.storm.streams.operations.Consumer: Performs an operation on the given argument.
accept(T) - Method in class org.apache.storm.streams.operations.PrintConsumer
acceptedValues() - Element in annotation type org.apache.storm.validation.ConfigValidationAnnotations.IsString
ACCESS - Enum constant in enum org.apache.storm.generated.AccessControl._Fields
AccessControl - Class in org.apache.storm.generated
AccessControl() - 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(AccessControlType, int) - Constructor for class org.apache.storm.generated.AccessControl
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() - Method in class org.apache.storm.utils.BatchHelper
ack(long) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout: Acknowledges the message with id msgId.
ack(long) - Method in class org.apache.storm.hdfs.trident.FixedBatchSpout
ack(long) - Method in class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout
ack(long) - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout
ack(long) - Method in interface org.apache.storm.trident.spout.IBatchSpout
ack(long) - Method in class org.apache.storm.trident.testing.FixedBatchSpout
ack(Object) - Method in class org.apache.storm.clojure.ClojureSpout
ack(Object) - Method in class org.apache.storm.drpc.DRPCSpout
ack(Object) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout: Acknowledges the message with id msgId.
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(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(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.spout.KafkaSpout
ack(Object) - Method in class org.apache.storm.loadgen.LoadSpout
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(Object) - Method in class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout
ack(Object) - Method in class org.apache.storm.st.topology.window.IncrementingSpout
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(Object) - Method in class org.apache.storm.starter.spout.RandomSentenceSpout
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.trident.spout.RichSpoutBatchTriggerer
ack(Object) - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator
ack(Tuple) - Method in class org.apache.storm.coordination.BatchOutputCollectorImpl
ack(Tuple) - Method in class org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector
ack(Tuple) - Method in class org.apache.storm.executor.bolt.BoltOutputCollectorImpl
ack(Tuple) - Method in interface org.apache.storm.task.IOutputCollector
ack(Tuple) - Method in class org.apache.storm.task.OutputCollector
ACKED - Enum constant in enum org.apache.storm.generated.BoltStats._Fields
ACKED - Enum constant in enum org.apache.storm.generated.CommonAggregateStats._Fields
ACKED - Enum constant in enum org.apache.storm.generated.SpoutStats._Fields
Acker - Class in org.apache.storm.daemon
Acker() - Constructor for class org.apache.storm.daemon.Acker
ACKER_ACK_STREAM_ID - Static variable in class org.apache.storm.daemon.Acker
ACKER_COMPONENT_ID - Static variable in class org.apache.storm.daemon.Acker
ACKER_FAIL_STREAM_ID - Static variable in class org.apache.storm.daemon.Acker
ACKER_INIT_STREAM_ID - Static variable in class org.apache.storm.daemon.Acker
ACKER_RESET_TIMEOUT_STREAM_ID - Static variable in class org.apache.storm.daemon.Acker
ackerInputs(StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
AckFailDelegate - Interface in org.apache.storm.testing
AckFailMapTracker - Class in org.apache.storm.testing
AckFailMapTracker() - Constructor for class org.apache.storm.testing.AckFailMapTracker
ackingEnabled - Variable in class org.apache.storm.executor.Executor
ackingTaskId - Variable in class org.apache.storm.hooks.info.BoltAckInfo
ackSpoutMsg(SpoutExecutor, Task, Long, TupleInfo) - Method in class org.apache.storm.executor.spout.SpoutExecutor
AckTracker - Class in org.apache.storm.testing
AckTracker() - Constructor for class org.apache.storm.testing.AckTracker
ACL - Enum constant in enum org.apache.storm.generated.SettableBlobMeta._Fields
AclEnforcement - Class in org.apache.storm.zookeeper: This is code intended to enforce ZK ACLs.
AclEnforcement() - Constructor for class org.apache.storm.zookeeper.AclEnforcement
aclFileName - Variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer
AclFunctionEntry(Collection<String>, String) - Constructor for class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry
aclHandler - Variable in class org.apache.storm.blobstore.LocalFsBlobStore
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.
ACTION - Enum constant in enum org.apache.storm.generated.LogLevel._Fields
ACTION - Enum constant in enum org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args._Fields
ACTION - Enum constant in enum org.apache.storm.generated.ProfileRequest._Fields
ACTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
activate() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.activate
activate() - Constructor for class org.apache.storm.generated.Nimbus.Processor.activate
activate() - Method in class org.apache.storm.clojure.ClojureSpout
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.redis.topology.WordSpout
activate() - Method in interface org.apache.storm.spout.ISpout: Called when a spout has been activated out of a deactivated mode. nextTuple will be called on this spout soon.
activate() - Method in class org.apache.storm.spout.ShellSpout
activate() - Method in class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout
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(String) - Method in class org.apache.storm.daemon.nimbus.Nimbus
activate(String) - Method in class org.apache.storm.generated.Nimbus.Client
activate(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
activate(String) - Method in interface org.apache.storm.ILocalCluster: Activate a topology.
activate(String) - Method in class org.apache.storm.LocalCluster
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 - Class in org.apache.storm.command
Activate() - Constructor for class org.apache.storm.command.Activate
ACTIVATE - Enum constant in enum org.apache.storm.daemon.nimbus.TopologyActions
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(Nimbus.activate_result) - Constructor for class org.apache.storm.generated.Nimbus.activate_result: Performs a deep copy on other.
activate_result(NotAliveException, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.activate_result
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
activateWorkerWhenAllConnectionsReady() - Method in class org.apache.storm.daemon.worker.WorkerState: we will wait all connections to be ready and then activate the spout/bolt when the worker bootup.
ACTIVE - Enum constant in enum org.apache.storm.generated.TopologyInitialStatus
ACTIVE - Enum constant in enum org.apache.storm.generated.TopologyStatus
activeAnonSize - Variable in class org.apache.storm.container.cgroup.core.MemoryCore.Stat
activeFileSize - Variable in class org.apache.storm.container.cgroup.core.MemoryCore.Stat
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: RegularExpression Id.
add(int, Object) - Method in class org.apache.storm.trident.tuple.ConsList
add(int, Object) - Method in class org.apache.storm.utils.ListDelegate
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(Object) - Method in class org.apache.storm.utils.ListDelegate
add(Object, V) - Method in class org.apache.storm.utils.KeyedRoundRobinQueue
add(Runnable) - Method in interface org.apache.storm.event.EventManager
add(Runnable) - Method in class org.apache.storm.event.EventManagerImp
add(TopologyResources) - Method in class org.apache.storm.daemon.nimbus.TopologyResources: Add the values in other to this and return a combined resources object.
add(WorkerResources) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest: Add the resources from a worker to those in this.
add(WorkerResources) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Add the resources from a worker to this.
add(WorkerResources) - Method in class org.apache.storm.scheduler.SupervisorResources
add(InputStream) - Method in class org.apache.storm.loadgen.LoadBolt
add(LoadMetricsServer.Measurements) - Method in class org.apache.storm.loadgen.LoadMetricsServer.Measurements: Add other to this.
add(TaskMessage) - Method in class org.apache.storm.messaging.netty.MessageBuffer
add(TaskMessage) - Method in class org.apache.storm.utils.TransferDrainer
add(NormalizedResourceRequest) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest: Add the resources in other to this.
add(NormalizedResources) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources
add(NormalizedResourcesWithMemory) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceOffer
add(ObjectResourcesItem) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.ObjectResourcesItem
add(StormTimer.QueueEntry) - Method in class org.apache.storm.StormTimer.StormTimerTask
add(Event<T>) - Method in class org.apache.storm.windowing.persistence.WindowState
add(Event<T>) - Method in class org.apache.storm.windowing.WindowManager: Tracks a window event.
add(T) - Method in class org.apache.storm.windowing.WindowManager: Add an event into the window, with System.currentTimeMillis() as the tracking ts.
add(T, long) - Method in class org.apache.storm.windowing.WindowManager: Add an event into the window, with the given ts as the tracking ts.
ADD - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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.PaceMakerStateStorage
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(ExecutorInfo) - Method in class org.apache.storm.generated.SupervisorWorkerHeartbeat
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_metrics(WorkerMetricPoint) - Method in class org.apache.storm.generated.WorkerMetricList
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(OwnerResourceSummary) - Method in class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result
add_to_success(ProfileRequest) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
add_to_success(TopologySummary) - Method in class org.apache.storm.generated.Nimbus.getTopologySummaries_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_heartbeats(SupervisorWorkerHeartbeat) - Method in class org.apache.storm.generated.SupervisorWorkerHeartbeats
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
addAcker(Map<String, Object>, StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
addAggLevel(AggLevel) - Method in class org.apache.storm.metricstore.FilterOptions: Add an aggregation level to search for.
addAll(int, Collection<?>) - Method in class org.apache.storm.utils.ListDelegate
addAll(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.
addAllReadOnlyMountLocations(List<String>) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add all readonly locations.
addAllReadOnlyMountLocations(List<String>, boolean) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add all readonly locations.
addAllReadWriteMountLocations(List<String>) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add all the rw bind mount locations.
addAllReadWriteMountLocations(List<String>, boolean) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add all the rw bind mount locations.
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.
addAllWorkerHooks(List<WorkerHookDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef: Adds a list of worker hook definitions.
addAnchor(String) - Method in class org.apache.storm.multilang.ShellMsg
addAssignmentsForNode(String, String, Integer, SupervisorAssignments, StormMetricsRegistry) - Method in class org.apache.storm.nimbus.AssignmentDistributionService: Add an assignments for a node/supervisor for distribution.
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(String, Object) - Method in class org.apache.storm.flux.model.ExecutionContext
addBolt(IBatchBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
addBolt(IBatchBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
addBolt(IBasicBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
addBolt(IBasicBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder
addBolt(IRichBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder: Deprecated.
addBolt(IRichBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder: Deprecated.
addChild(Component) - Method in class org.apache.storm.scheduler.Component: Add a child link.
addClassLoader(CompilingClassLoader) - Method in class org.apache.storm.sql.planner.streams.StreamsPlanCreator
addCommandArguments(String...) - Method in class org.apache.storm.container.docker.DockerCommand: Add command commandWithArguments.
addCommandLineOptions(Options) - Static method in class org.apache.storm.loadgen.LoadMetricsServer: Add Command line options for configuring the output of this.
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, 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.bolts.FluxShellBolt: Add configuration for this bolt.
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: Add in a single config.
addConfigurations(Map<String, Object>) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer: add in several configs to the component.
addConfigurations(Map<String, Object>) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter
addCounter(String, Counter) - Method in class org.apache.storm.metrics2.TaskMetricRepo
addCpuSetBindings(List<String>, String) - Method in class org.apache.storm.container.docker.DockerRunCommand
addDevice(String, String) - Method in class org.apache.storm.container.docker.DockerRunCommand: Set --device option.
addEmptyTopoForTests(String) - Method in class org.apache.storm.daemon.nimbus.HeartbeatCache: Add an empty topology to the cache for testing purposes.
addEscapes(String) - Static method in error org.apache.storm.sql.parser.impl.TokenMgrError: Replaces unprintable characters by their escaped (or unicode escaped) equivalents in the given string
addEventLogger(Map<String, Object>, StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
addExecCommand(List<String>) - Method in class org.apache.storm.container.docker.DockerExecCommand: Add the command to run from inside container.
addGauge(String, Gauge) - Method in class org.apache.storm.metrics2.TaskMetricRepo
addGroup(Group) - Method in class org.apache.storm.trident.graph.GraphGrouper
addHistogram(String, Histogram) - Method in class org.apache.storm.metrics2.TaskMetricRepo
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.ClientZookeeper
addLocalSupervisor(Supervisor) - Method in class org.apache.storm.nimbus.AssignmentDistributionService
addMem(Double) - Method in class org.apache.storm.scheduler.SupervisorResources
addMeter(String, Meter) - Method in class org.apache.storm.metrics2.TaskMetricRepo
addMetricComponents(Map<String, Object>, StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
addMetricStreams(StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
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
addObjectResourcesItem(ObjectResourcesItem) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.ObjectResourcesSummary
addOffHeap(double) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
addOnHeap(double) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
addPredicate(Predicate<? super T>, String) - Method in class org.apache.storm.streams.processors.BranchProcessor
addPrivateWorkerKey(WorkerTokenServiceType, String, long, PrivateWorkerKey) - Method in interface org.apache.storm.cluster.IStormClusterState: Store a new version of a private key.
addPrivateWorkerKey(WorkerTokenServiceType, String, long, PrivateWorkerKey) - Method in class org.apache.storm.cluster.StormClusterStateImpl
addProcs(int) - Method in class org.apache.storm.container.cgroup.CgroupCommon
addProcs(int) - Method in interface org.apache.storm.container.cgroup.CgroupCommonOperation: add a process to cgroup.
addProfilerActions(Set<Slot.TopoProfileAction>) - Method in class org.apache.storm.daemon.supervisor.Slot
addReadOnlyMountLocation(String, String) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add readonly bind mout location.
addReadOnlyMountLocation(String, String, boolean) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add readonly bind mount location.
addReadWriteMountLocation(String, String) - Method in class org.apache.storm.container.docker.DockerRunCommand
addReadWriteMountLocation(String, String, boolean) - Method in class org.apache.storm.container.docker.DockerRunCommand: Add bind mount locations.
addReceiver(TridentProcessor) - Method in class org.apache.storm.trident.planner.SubtopologyBolt.InitialReceiver
addReference(PortAndAssignment, BlobChangingCallback) - Method in class org.apache.storm.localizer.LocallyCachedBlob: Mark that a given port and assignment are using this.
addRequestContextFilter(ServletContextHandler, String, Map<String, Object>) - Static method in class org.apache.storm.daemon.drpc.DRPCServer: Add a request context filter to the Servlet Context Handler.
addRequestContextFilter(ServletContextHandler, String, Map<String, Object>) - Static method in class org.apache.storm.daemon.ui.UIServer: addRequestContextFilter.
addResource(String, Number) - Method in class org.apache.storm.topology.BaseConfigurationDeclarer
addResource(String, Number) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer: Add generic resource for this component.
addResource(String, Number) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter
addResourceMap(Map<String, Double>, Map<String, Double>) - Static method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
addResources(ConcurrentMap<String, ? extends LocallyCachedBlob>) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet: Add blobs to be checked if they can be deleted.
addResources(Map<String, Double>) - Method in class org.apache.storm.topology.BaseConfigurationDeclarer: Add generic resources for this component.
addResources(Map<String, Double>) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer: Add generic resources for this component.
addResources(Map<String, Double>) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter
addResourcesForExec(ExecutorDetails, NormalizedResourceRequest) - Method in class org.apache.storm.scheduler.TopologyDetails: add resource requirements for a executor.
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
addSharedMemory(SharedMemory) - Method in interface org.apache.storm.topology.ResourceDeclarer: Add in request for shared memory that this component will use.
addSharedMemory(SharedMemory) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter
addSharedMemory(SharedMemory) - Method in class org.apache.storm.trident.operation.DefaultResourceDeclarer
addSharedMemory(SharedMemory) - Method in class org.apache.storm.trident.Stream
addSharedMemory(SharedMemory) - Method in class org.apache.storm.trident.TridentState
addShutdownHooks(MyThread...) - Static method in class org.apache.storm.perf.queuetest.JCQueuePerfTest
addShutdownHooks(MyThd...) - Static method in class org.apache.storm.perf.toolstest.JCToolsPerfTest
addShutdownHookWithDelayedForceKill(Runnable, int) - Static method in class org.apache.storm.utils.Utils: Adds the user supplied function as a shutdown hook for cleanup.
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(Stream<Values>) - Method in class org.apache.storm.sql.planner.streams.StreamsPlanCreator
addSupervisor() - Method in class org.apache.storm.LocalCluster: Add another supervisor to the topology.
addSupervisor(Number) - Method in class org.apache.storm.LocalCluster: Add another supervisor to the topology.
addSupervisor(Number, String) - Method in class org.apache.storm.LocalCluster: Add another supervisor to the topology.
addSupervisor(Number, Map<String, Object>, String) - Method in class org.apache.storm.LocalCluster: Add another supervisor to the topology.
addSupervisor(Supervisor) - Method in class org.apache.storm.daemon.nimbus.Nimbus: Used for local cluster.
addSystemComponents(Map<String, Object>, StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
addSystemStreams(StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
addTask(int) - Method in class org.apache.storm.container.cgroup.CgroupCommon
addTask(int) - Method in interface org.apache.storm.container.cgroup.CgroupCommonOperation: add task to cgroup.
addTaskHook(ITaskHook) - Method in class org.apache.storm.task.TopologyContext
addTimer(String, Timer) - Method in class org.apache.storm.metrics2.TaskMetricRepo
addToAckMsgs(KafkaSpoutMessageId) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager
addToCache(String, String) - Static method in class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt
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.testing.MockLeaderElector
addToLeaderLockQueue() - Method in class org.apache.storm.zookeeper.LeaderElectorImp
addTopoConf(String, Subject, Map<String, Object>) - Method in class org.apache.storm.daemon.nimbus.TopoCache: Add a new topology config.
addTopology(String, Subject, StormTopology) - Method in class org.apache.storm.daemon.nimbus.TopoCache: Add a new topology.
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
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
addValue(double) - Method in class org.apache.storm.metrics2.RollingAverageGauge
addValue(double) - Method in class org.apache.storm.metricstore.Metric: Adds an additional value to the metric.
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.
adjustImageConfigForTopo(Map<String, Object>, Map<String, Object>, String) - Static method in class org.apache.storm.container.oci.OciUtils: Adjust the image config for the topology.
ADMIN - Static variable in class org.apache.storm.blobstore.BlobStoreAclHandler
ADMIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
AdminCommands - Class in org.apache.storm.command
AdminCommands() - Constructor for class org.apache.storm.command.AdminCommands
AdminCommands.AdminCommand - Interface in org.apache.storm.command
admins - Variable in class org.apache.storm.security.auth.authorizer.SimpleACLAuthorizer
admins - Variable in class org.apache.storm.security.auth.authorizer.SupervisorSimpleACLAuthorizer
adminsGroups - Variable in class org.apache.storm.security.auth.authorizer.SimpleACLAuthorizer
adminsGroups - Variable in class org.apache.storm.security.auth.authorizer.SupervisorSimpleACLAuthorizer
advanceClusterTime(int) - Method in interface org.apache.storm.ILocalCluster: Advance the cluster time when the cluster is using SimulatedTime.
advanceClusterTime(int) - Method in class org.apache.storm.LocalCluster
advanceClusterTime(int, int) - Method in interface org.apache.storm.ILocalCluster: Advance the cluster time when the cluster is using SimulatedTime.
advanceClusterTime(int, int) - Method in class org.apache.storm.LocalCluster
advanceClusterTime(ILocalCluster, Integer) - Static method in class org.apache.storm.Testing: Simulated time wait for a cluster.
advanceClusterTime(ILocalCluster, Integer, Integer) - Static method in class org.apache.storm.Testing: Simulated time wait for a cluster.
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: RegularExpression Id.
afterExecute(Runnable, Throwable) - Method in class org.apache.storm.utils.ExtendedThreadPoolExecutor
AGG_LEVEL_1_MIN - Enum constant in enum org.apache.storm.metricstore.AggLevel
AGG_LEVEL_10_MIN - Enum constant in enum org.apache.storm.metricstore.AggLevel
AGG_LEVEL_60_MIN - Enum constant in enum org.apache.storm.metricstore.AggLevel
AGG_LEVEL_NONE - Enum constant in enum org.apache.storm.metricstore.AggLevel
aggBoltExecWinStats(Map<String, Object>, Map<String, Object>, boolean) - Static method in class org.apache.storm.stats.StatsUtil: aggregate windowed stats from a bolt executor stats with a Map of accumulated stats.
aggBoltLatAndCount(Map<List<String>, Double>, Map<List<String>, Double>, Map<List<String>, Long>) - Static method in class org.apache.storm.stats.StatsUtil: Aggregates number executed, process latency, and execute latency across all streams.
aggBoltStreamsLatAndCount(Map<K, Double>, Map<K, Double>, Map<K, Long>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate number executed and process & execute latencies.
aggCompExecsStats(Map, Map, Map<List<Integer>, Map<String, Object>>, String, boolean, String, StormTopology, String) - Static method in class org.apache.storm.stats.StatsUtil: aggregate component executor stats.
aggCompExecStats(String, boolean, Map<String, Object>, Map<String, Object>, String) - Static method in class org.apache.storm.stats.StatsUtil: Combines the aggregate stats of one executor with the given map, selecting the appropriate window and including system components as specified.
AggLevel - Enum in org.apache.storm.metricstore: Specifies the available timeframes for Metric aggregation.
aggPartition(GroupedStream) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggPartition(S) - Method in interface org.apache.storm.trident.fluent.GlobalAggregationScheme
aggPreMergeCompPageBolt(Map<String, Object>, String, boolean) - Static method in class org.apache.storm.stats.StatsUtil: pre-merge component page bolt stats from an executor heartbeat 1. computes component capacity 2. converts map keys of stats 3.
aggPreMergeCompPageSpout(Map<String, Object>, String, boolean) - Static method in class org.apache.storm.stats.StatsUtil: pre-merge component page spout stats from an executor heartbeat 1. computes component capacity 2. converts map keys of stats 3.
aggPreMergeTopoPageBolt(Map<String, Object>, String, boolean) - Static method in class org.apache.storm.stats.StatsUtil: pre-merge component stats of specified bolt id.
aggPreMergeTopoPageSpout(Map<String, Object>, String, boolean) - Static method in class org.apache.storm.stats.StatsUtil: pre-merge component stats of specified spout id and returns { comp id -> comp-stats }.
aggregate(Object[], TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator
aggregate(PriorityQueue, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg
aggregate(CombinerAggregator<? super T, A, ? extends R>) - Method in class org.apache.storm.streams.Stream: Aggregates the values in this stream using the aggregator.
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.Stream
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(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
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(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(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
aggregate(CountAsAggregator.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(Fields, Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.Stream
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(Fields, CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
aggregate(Fields, ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream
aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream
aggregate(R, BiFunction<? super R, ? super T, ? extends R>, BiFunction<? super R, ? super R, ? extends R>) - Method in class org.apache.storm.streams.Stream: Aggregates the values in this stream using the given initial value, accumulator and combiner.
aggregate(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator
aggregateAverages(List<Map<String, Map<K, Double>>>, List<Map<String, Map<K, Long>>>) - Static method in class org.apache.storm.stats.StatsUtil: compute an weighted average from a list of average maps and a corresponding count maps extracted from a list of ExecutorSummary.
aggregateAvgStreams(Map<String, Map<K, Double>>, Map<String, Map<K, Long>>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate weighted average of all streams.
aggregateBoltStats(List<ExecutorSummary>, boolean) - Static method in class org.apache.storm.stats.StatsUtil: aggregate bolt stats.
aggregateBoltStreams(Map<String, Map>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate all bolt streams.
aggregateByKey(CombinerAggregator<? super V, A, ? extends R>) - Method in class org.apache.storm.streams.PairStream: Aggregates the values for each key of this stream using the given CombinerAggregator.
aggregateByKey(R, BiFunction<? super R, ? super V, ? extends R>, BiFunction<? super R, ? super R, ? extends R>) - Method in class org.apache.storm.streams.PairStream: Aggregates the values for each key of this stream using the given initial value, accumulator and combiner.
AggregateByKeyProcessor<K,V,A,R> - Class in org.apache.storm.streams.processors
AggregateByKeyProcessor(CombinerAggregator<V, A, R>) - Constructor for class org.apache.storm.streams.processors.AggregateByKeyProcessor
AggregateByKeyProcessor(CombinerAggregator<V, A, R>, boolean) - Constructor for class org.apache.storm.streams.processors.AggregateByKeyProcessor
aggregateCommonStats(List<ExecutorSummary>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate common stats from a spout/bolt, called in aggregateSpoutStats/aggregateBoltStats.
aggregateCompStats(String, boolean, List<Map<String, Object>>, String) - Static method in class org.apache.storm.stats.StatsUtil: Aggregate the stats for a component over a given window of time.
aggregateCounts(List<Map<String, Map<T, Long>>>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate a list of count maps into one map.
aggregateCountStreams(Map<String, Map<K, V>>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate count streams by window.
AggregateExample - Class in org.apache.storm.starter.streams: An example that illustrates the global aggregate.
AggregateExample() - Constructor for class org.apache.storm.starter.streams.AggregateExample
AggregateProcessor<T,A,R> - Class in org.apache.storm.streams.processors
AggregateProcessor - Class in org.apache.storm.trident.planner.processor
AggregateProcessor(CombinerAggregator<T, A, R>) - Constructor for class org.apache.storm.streams.processors.AggregateProcessor
AggregateProcessor(CombinerAggregator<T, A, R>, boolean) - Constructor for class org.apache.storm.streams.processors.AggregateProcessor
AggregateProcessor(Fields, Aggregator) - Constructor for class org.apache.storm.trident.planner.processor.AggregateProcessor
aggregateSpoutStats(List<ExecutorSummary>, boolean) - Static method in class org.apache.storm.stats.StatsUtil: aggregate spout stats.
aggregateSpoutStreams(Map<String, Map>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate all spout streams.
aggregator - Variable in class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor
aggregator - Variable in class org.apache.storm.trident.windowing.AbstractTridentWindowManager
Aggregator<T> - Interface in org.apache.storm.trident.operation
aggSpoutExecWinStats(Map<String, Object>, Map<String, Object>, boolean) - Static method in class org.apache.storm.stats.StatsUtil: aggregate windowed stats from a spout executor stats with a Map of accumulated stats.
aggSpoutLatAndCount(Map<String, Double>, Map<String, Long>) - Static method in class org.apache.storm.stats.StatsUtil: aggregate number acked and complete latencies across all streams.
aggSpoutStreamsLatAndCount(Map<K, Double>, Map<K, Long>) - Static method in class org.apache.storm.stats.StatsUtil: Aggregates number acked and complete latencies.
aggTopoExecsStats(String, Map, Map, Map<List<Integer>, Map<String, Object>>, StormTopology, String, boolean, IStormClusterState) - Static method in class org.apache.storm.stats.StatsUtil: aggregate topo executors stats.
aggTopoExecStats(String, boolean, Map<String, Object>, Map<String, Object>, String) - Static method in class org.apache.storm.stats.StatsUtil: A helper function that does the common work to aggregate stats of one executor with the given map for the topology page.
aggWorkerStats(String, String, Map<Integer, String>, Map<List<Integer>, Map<String, Object>>, Map<List<Long>, List<Object>>, Map<String, String>, Map<WorkerSlot, WorkerResources>, boolean, boolean, String, String) - Static method in class org.apache.storm.stats.StatsUtil: aggregate statistics per worker for a topology.
all() - Static method in class org.apache.storm.coordination.CoordinatedBolt.SourceArgs
all() - Static method in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType
all(NullStruct) - Static method in class org.apache.storm.generated.Grouping
ALL - Enum constant in enum org.apache.storm.flux.model.GroupingDef.Type
ALL - Enum constant in enum org.apache.storm.generated.Grouping._Fields
ALL - Enum constant in enum org.apache.storm.generated.NumErrorsChoice
ALL - Enum constant in enum org.apache.storm.loadgen.GroupingType
ALL - Enum constant in enum org.apache.storm.perf.utils.BasicMetricsCollector.MetricsItem
ALL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
allComponents(StormTopology) - Static method in class org.apache.storm.daemon.StormCommon
AllGrouper() - Constructor for class org.apache.storm.daemon.GrouperFactory.AllGrouper
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) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
allGrouping(String, String) - Method in interface org.apache.storm.topology.InputDeclarer: The stream is replicated across all the bolt's tasks.
allGrouping(String, String) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter
ALLOCATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
allocateBuffer(ChannelHandlerContext, INettySerializable, boolean) - Method in class org.apache.storm.messaging.netty.NettySerializableMessageEncoder
allOutputFields - Variable in class org.apache.storm.trident.planner.Node
ALLOW - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
allowRetry(int, long, RetrySleeper) - Method in class org.apache.storm.utils.StormBoundedExponentialBackoffRetry
allSlotsAvailableForScheduling(Collection<SupervisorDetails>, Topologies, Set<String>) - Method in class org.apache.storm.daemon.nimbus.Nimbus.StandaloneINimbus
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.
allSupervisorInfo() - Method in interface org.apache.storm.cluster.IStormClusterState: Get all of the supervisors with the ID as the key.
allSupervisorInfo(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState: Get all supervisor info.
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: RegularExpression Id.
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: RegularExpression Id.
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: RegularExpression Id.
anonymize() - Method in class org.apache.storm.loadgen.TopologyLoadConf: Create a new version of this topology with identifiable information removed.
ANOTHER_BOLT - Static variable in class org.apache.storm.jms.example.ExampleJmsTopology
ANY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
anyNonCpuOverZero() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Are any of the non cpu resources positive.
AppendCollector - Class in org.apache.storm.trident.planner.processor
AppendCollector(TridentContext) - Constructor for class org.apache.storm.trident.planner.processor.AppendCollector
apply(A, T) - Method in interface org.apache.storm.streams.operations.CombinerAggregator: Updates the accumulator by applying the current accumulator with the value.
apply(Long, Number) - Method in class org.apache.storm.streams.operations.aggregators.LongSum
apply(Long, T) - Method in class org.apache.storm.streams.operations.aggregators.Count
apply(ConsumerRecord<ByteBuffer, ByteBuffer>) - Method in class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter
apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.flux.examples.OnlyValueRecordTranslator
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(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(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
apply(Tuple) - Method in class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper
apply(Tuple) - Method in class org.apache.storm.streams.operations.mappers.PairValueMapper
apply(Tuple) - Method in class org.apache.storm.streams.operations.mappers.ValueMapper
apply(Tuple) - Method in class org.apache.storm.streams.operations.mappers.ValuesMapper
apply(Values) - Method in class org.apache.storm.sql.runtime.streams.functions.EvaluationCalc
apply(Values) - Method in class org.apache.storm.sql.runtime.streams.functions.EvaluationFunction
apply(Values) - Method in class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction
apply(S, T) - Method in interface org.apache.storm.streams.operations.StateUpdater: Returns a new state by applying the value on the current state.
apply(T) - Method in interface org.apache.storm.localizer.IOFunction
apply(T) - Method in interface org.apache.storm.streams.operations.Function: Applies this function to the given argument.
apply(T) - Method in class org.apache.storm.streams.operations.IdentityFunction
apply(T, T) - Method in interface org.apache.storm.streams.operations.Reducer: Applies this function to the given arguments.
apply(T, U) - Method in interface org.apache.storm.streams.operations.BiFunction: Applies this function to the given arguments.
apply(V) - Method in interface org.apache.storm.kafka.spout.Func
apply(V1, V2) - Method in class org.apache.storm.streams.operations.PairValueJoiner: Joins two values and produces a Pair of the values as the result.
apply(V1, V2) - Method in interface org.apache.storm.streams.operations.ValueJoiner: Joins two values and produces a result.
APPLY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
applyAssembly(Assembly) - Method in class org.apache.storm.trident.Stream: Applies an `Assembly` to this `Stream`.
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.BoltAckInfo
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.BoltExecuteInfo
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.BoltFailInfo
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.EmitInfo
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.SpoutAckInfo
applyOn(TopologyContext) - Method in class org.apache.storm.hooks.info.SpoutFailInfo
applyTo(ISeq) - Method in class org.apache.storm.clojure.ClojureTuple
applyUUIDToFileName(String) - Static method in class org.apache.storm.dependency.DependencyBlobStoreUtils
APPROVED_WORKERS - Enum constant in enum org.apache.storm.generated.LSApprovedWorkers._Fields
APPROX_NUMERIC_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
ARCHIVE_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs: Deprecated.
please use HdfsSpout.setArchiveDir(String)
ARE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
areAllConnectionsReady() - Method in class org.apache.storm.daemon.worker.WorkerState
areAllExecsScheduled() - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.SchedulingSearcherState
areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.Container
areAllProcessesDead() - Method in interface org.apache.storm.daemon.supervisor.Killable: Check whether all processes are dead.
areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.LocalContainer
areAllProcessesDead(String, String) - Method in class org.apache.storm.container.DefaultResourceIsolationManager
areAllProcessesDead(String, String) - Method in class org.apache.storm.container.docker.DockerManager: Currently it only checks if the container is alive.
areAllProcessesDead(String, String) - Method in class org.apache.storm.container.oci.RuncLibContainerManager: The container terminates if any process inside the container dies.
areAllProcessesDead(String, String) - Method in interface org.apache.storm.container.ResourceIsolationInterface: Check if all the processes are dead.
areAllProcessesDead(Map<String, Object>, String, String, Set<Long>) - Static method in class org.apache.storm.utils.ServerUtils: Find if all processes for the user on workId are dead.
areAnyOverZero() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceOffer
areAnyOverZero() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
areAnyOverZero() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Are any of the resources positive.
areAnyOverZero() - Method in interface org.apache.storm.scheduler.resource.normalization.NormalizedResourcesWithMemory: Return true if any of the resources are > 0.
areKeysSkewed - Variable in class org.apache.storm.loadgen.OutputStream
areLocalAssignmentsEquivalent(LocalAssignment, LocalAssignment) - Static method in class org.apache.storm.utils.EquivalenceUtils: Decide the equivalence of two local assignments, ignoring the order of executors This is different from #equal method.
areSearchLimitsExceeded() - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.SchedulingSearcherState
areTaskIdsNeeded() - Method in class org.apache.storm.multilang.ShellMsg
areWorkerTokensEnabledServer(ThriftConnectionType, Map<String, Object>) - Static method in class org.apache.storm.security.auth.ClientAuthUtils: Check if worker tokens should be enabled on the server side or not (for a given server).
areWorkerTokensEnabledServer(ThriftServer, Map<String, Object>) - Static method in class org.apache.storm.security.auth.ClientAuthUtils: Check if worker tokens should be enabled on the server side or not.
areWorkerTokensSupported() - Method in class org.apache.storm.security.auth.digest.DigestSaslTransportPlugin
areWorkerTokensSupported() - Method in interface org.apache.storm.security.auth.ITransportPlugin: Check if worker tokens are supported by this transport.
areWorkerTokensSupported() - Method in class org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin
arg(String) - Static method in class org.apache.storm.command.CLI: Add a named argument.
arg(String) - Method in class org.apache.storm.command.CLI.CLIBuilder: Add a named argument.
arg(String, CLI.Assoc) - Static method in class org.apache.storm.command.CLI: Add a named argument.
arg(String, CLI.Assoc) - Method in class org.apache.storm.command.CLI.CLIBuilder: Add a named argument.
arg(String, CLI.Parse) - Static method in class org.apache.storm.command.CLI: Add a named argument.
arg(String, CLI.Parse) - Method in class org.apache.storm.command.CLI.CLIBuilder: Add a named argument.
arg(String, CLI.Parse, CLI.Assoc) - Static method in class org.apache.storm.command.CLI: Add a named argument.
arg(String, CLI.Parse, CLI.Assoc) - Method in class org.apache.storm.command.CLI.CLIBuilder: Add a named argument.
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_LIST - Enum constant in enum org.apache.storm.generated.JavaObject._Fields
ARGS_STREAM - Static variable in class org.apache.storm.drpc.PrepareRequest
ARRAY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
ARRAY_MAX_CARDINALITY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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
ArtifactoryConfigLoader - Class in org.apache.storm.scheduler.utils: A dynamic loader that can load scheduler configurations for user resource guarantees from Artifactory (an artifact repository manager).
ArtifactoryConfigLoader(Map<String, Object>) - Constructor for class org.apache.storm.scheduler.utils.ArtifactoryConfigLoader
ArtifactoryConfigLoaderFactory - Class in org.apache.storm.scheduler.utils: Factory class for ArtifactoryConfigLoader.
ArtifactoryConfigLoaderFactory() - Constructor for class org.apache.storm.scheduler.utils.ArtifactoryConfigLoaderFactory
artifactToString(Artifact) - Static method in class org.apache.storm.submit.dependency.AetherUtils: Convert Artifact object to String for printing.
AS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
AS_INT - Static variable in class org.apache.storm.command.CLI: Parse function to return an Integer.
AS_STRING - Static variable in class org.apache.storm.command.CLI: Noop parse function, returns the String.
ASC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
ASENSITIVE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
asMap() - Method in class org.apache.storm.windowing.persistence.SimpleWindowPartitionCache
asMap() - Method in interface org.apache.storm.windowing.persistence.WindowPartitionCache: Return a ConcurrentMap view of the current entries in the cache.
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: RegularExpression Id.
assertValidTopologyForModification(String) - Method in class org.apache.storm.scheduler.Cluster: Check if the given topology is allowed for modification right now.
assertValidTopologyForModification(String) - Method in class org.apache.storm.scheduler.SingleTopologyCluster
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(SchedulerAssignment, boolean) - Method in class org.apache.storm.scheduler.Cluster: Assign everything for the given topology.
assign(WorkerSlot, String, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.Cluster: Assign the slot to the executors for this topology.
assign(WorkerSlot, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.SchedulerAssignmentImpl: Deprecated.
assign(WorkerSlot, Collection<ExecutorDetails>, WorkerResources) - Method in class org.apache.storm.scheduler.SchedulerAssignmentImpl: Assign the slot to executors.
assign(WorkerSlot, TopologyDetails, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.resource.RasNode: Assigns a worker to a node.
assign(BoltDeclarer, InputStream) - Method in enum org.apache.storm.loadgen.GroupingType
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
assignBoundAckersForNewWorkerSlot(ExecutorDetails, RasNode, WorkerSlot) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy: Determine how many bound ackers to put into the given workerSlot.
assignCurrentExecutor(Map<ExecutorDetails, String>, RasNode, WorkerSlot) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.SchedulingSearcherState: Attempt to assign current executor (execIndex points to) to worker and node.
assigned(Collection<Integer>) - Method in class org.apache.storm.daemon.supervisor.StandaloneSupervisor
assigned(Collection<Integer>) - Method in interface org.apache.storm.scheduler.ISupervisor
ASSIGNED_CPU - Enum constant in enum org.apache.storm.generated.TopologyInfo._Fields
ASSIGNED_CPU - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_CPU - Enum constant in enum org.apache.storm.generated.TopologySummary._Fields
ASSIGNED_CPU - Enum constant in enum org.apache.storm.generated.WorkerSummary._Fields
ASSIGNED_GENERIC_RESOURCES - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_GENERIC_RESOURCES - Enum constant in enum org.apache.storm.generated.TopologySummary._Fields
ASSIGNED_MEMOFFHEAP - Enum constant in enum org.apache.storm.generated.TopologyInfo._Fields
ASSIGNED_MEMOFFHEAP - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_MEMOFFHEAP - Enum constant in enum org.apache.storm.generated.TopologySummary._Fields
ASSIGNED_MEMOFFHEAP - Enum constant in enum org.apache.storm.generated.WorkerSummary._Fields
ASSIGNED_MEMONHEAP - Enum constant in enum org.apache.storm.generated.TopologyInfo._Fields
ASSIGNED_MEMONHEAP - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_MEMONHEAP - Enum constant in enum org.apache.storm.generated.TopologySummary._Fields
ASSIGNED_MEMONHEAP - Enum constant in enum org.apache.storm.generated.WorkerSummary._Fields
ASSIGNED_OFF_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.OwnerResourceSummary._Fields
ASSIGNED_ON_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.OwnerResourceSummary._Fields
ASSIGNED_REGULAR_OFF_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_REGULAR_ON_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_SHARED_OFF_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
ASSIGNED_SHARED_ON_HEAP_MEMORY - Enum constant in enum org.apache.storm.generated.TopologyPageInfo._Fields
assignedCpu - Variable in class org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy.SimulatedUser
assignedMemory - Variable in class org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy.SimulatedUser
assignment - Variable in class org.apache.storm.daemon.supervisor.Container
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: RegularExpression Id.
ASSIGNMENT_ID - Enum constant in enum org.apache.storm.generated.SupervisorInfo._Fields
Assignment._Fields - Enum in org.apache.storm.generated: The set of fields this struct contains, along with convenience methods for finding and manipulating them.
AssignmentDistributionService - Class in org.apache.storm.nimbus: A service for distributing master assignments to supervisors, this service makes the assignments notification asynchronous.
AssignmentDistributionService() - Constructor for class org.apache.storm.nimbus.AssignmentDistributionService
assignmentInfo(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState: Get the assignment based on storm id from local backend.
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() - Method in interface org.apache.storm.assignments.ILocalAssignmentsBackend: List all the storm runtime ids of local assignments.
assignments() - Method in class org.apache.storm.assignments.InMemoryAssignmentBackend
assignments(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
assignments(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
ASSIGNMENTS - Enum constant in enum org.apache.storm.generated.LSSupervisorAssignments._Fields
ASSIGNMENTS - Enum constant in enum org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args._Fields
ASSIGNMENTS_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
ASSIGNMENTS_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
assignmentsInfo() - Method in interface org.apache.storm.assignments.ILocalAssignmentsBackend: Get all the local assignments of local state.
assignmentsInfo() - Method in class org.apache.storm.assignments.InMemoryAssignmentBackend
assignmentsInfo() - Method in interface org.apache.storm.cluster.IStormClusterState: Get all the topologies assignments mapping stormId -> Assignment from local backend.
assignmentsInfo() - Method in class org.apache.storm.cluster.StormClusterStateImpl
assignmentVersion(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
assignmentVersion(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
assignPartitions(Consumer<K, V>, Set<TopicPartition>, ConsumerRebalanceListener) - Method in class org.apache.storm.kafka.spout.subscription.TopicAssigner: Assign partitions to the KafkaConsumer.
assignSingleBoundAcker(RasNode, WorkerSlot) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.SchedulingSearcherState: Remove the head of unassigned ackers and attempt to assign it to a workerSlot as a bound acker.
assignSingleExecutor(WorkerSlot, ExecutorDetails, TopologyDetails) - Method in class org.apache.storm.scheduler.resource.RasNode: Assign a single executor to a slot, even if other things are in the slot.
assignSlots(Topologies, Map<String, Collection<WorkerSlot>>) - Method in class org.apache.storm.daemon.nimbus.Nimbus.StandaloneINimbus
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.clojure.ClojureTuple
assoc(Object, Object) - Method in class org.apache.storm.clojure.IndifferentAccessMap
assoc(Object, Object) - Method in interface org.apache.storm.command.CLI.Assoc: Associate a value into something else.
assocEx(Object, Object) - Method in class org.apache.storm.clojure.ClojureTuple
assocEx(Object, Object) - Method in class org.apache.storm.clojure.IndifferentAccessMap
ASYMMETRIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
async - Enum constant in enum org.apache.storm.container.cgroup.core.BlkioCore.RecordType
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
AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Supervisor.AsyncClient
AsyncLocalizer - Class in org.apache.storm.localizer: Downloads and caches blobs locally.
AsyncLocalizer(Map<String, Object>, StormMetricsRegistry) - Constructor for class org.apache.storm.localizer.AsyncLocalizer
asyncLoop(Callable) - Static method in class org.apache.storm.utils.Utils: Convenience method used when only the function is given.
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.
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor
AsyncProcessor(I) - Constructor for class org.apache.storm.generated.Supervisor.AsyncProcessor
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor
AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.Supervisor.AsyncProcessor
AT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
AT_LEAST_ONCE - Enum constant in enum org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee: An offset is ready to commit only after the corresponding tuple has been processed and acked (at least once).
AT_MOST_ONCE - Enum constant in enum org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee: Every offset will be synchronously committed to Kafka right after being polled but before being emitted to the downstream components of the topology.
ATOMIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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: RegularExpression Id.
ATTRIBUTES - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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
AuthNimbusOp - Annotation Type in org.apache.storm.daemon.ui.resources
AUTHORIZATION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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.
AuthorizationExceptionMapper - Class in org.apache.storm.daemon.common
AuthorizationExceptionMapper - Class in org.apache.storm.daemon.ui.exceptionmappers
AuthorizationExceptionMapper() - Constructor for class org.apache.storm.daemon.common.AuthorizationExceptionMapper
AuthorizationExceptionMapper() - Constructor for class org.apache.storm.daemon.ui.exceptionmappers.AuthorizationExceptionMapper
authorizedGroups - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL
authorizedHosts - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL
AuthorizedUserFilter - Class in org.apache.storm.daemon.ui.filters
AuthorizedUserFilter() - Constructor for class org.apache.storm.daemon.ui.filters.AuthorizedUserFilter
autoCreatePartitions - Variable in class org.apache.storm.hive.common.HiveOptions
AutoHBase - Class in org.apache.storm.hbase.security: Auto credentials plugin for HBase implementation.
AutoHBase() - Constructor for class org.apache.storm.hbase.security.AutoHBase
AutoHBaseCommand - Class in org.apache.storm.hbase.security: Command tool of Hive credential renewer.
AutoHBaseNimbus - Class in org.apache.storm.hbase.security: Auto credentials nimbus plugin for HBase implementation.
AutoHBaseNimbus() - Constructor for class org.apache.storm.hbase.security.AutoHBaseNimbus
AutoHDFS - Class in org.apache.storm.hdfs.security: Auto credentials plugin for HDFS implementation.
AutoHDFS() - Constructor for class org.apache.storm.hdfs.security.AutoHDFS
AutoHDFSCommand - Class in org.apache.storm.hdfs.security: Command tool of HDFS credential renewer.
AutoHDFSNimbus - Class in org.apache.storm.hdfs.security: Auto credentials nimbus plugin for HDFS implementation.
AutoHDFSNimbus() - Constructor for class org.apache.storm.hdfs.security.AutoHDFSNimbus
AutoHive - Class in org.apache.storm.hive.security: Auto credentials plugin for Hive implementation.
AutoHive() - Constructor for class org.apache.storm.hive.security.AutoHive
AutoHiveCommand - Class in org.apache.storm.hive.security: Command tool of Hive credential renewer.
AutoHiveNimbus - Class in org.apache.storm.hive.security: Auto credentials nimbus plugin for Hive implementation.
AutoHiveNimbus() - Constructor for class org.apache.storm.hive.security.AutoHiveNimbus
AutoSSL - Class in org.apache.storm.security.auth: This plugin is intended to be used for user topologies to send SSL keystore/truststore files to the remote workers.
AutoSSL() - Constructor for class org.apache.storm.security.auth.AutoSSL
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
availableResources - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.ObjectResourcesItem
AVG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
avgResourcePercent - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.ObjectResourcesItem: Amongst all ObjectResourcesItem.availableResources, this is the average ratio of resource to the total available in group.
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: AvroScheme Constructor.
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: AvroSerializer Constructor.
AvroUtils - Class in org.apache.storm.hdfs.avro
AvroUtils() - Constructor for class org.apache.storm.hdfs.avro.AvroUtils
awaitLeadership(long, TimeUnit) - Method in class org.apache.storm.daemon.nimbus.Nimbus
awaitLeadership(long, TimeUnit) - Method in interface org.apache.storm.nimbus.ILeaderElector: Wait for the caller to gain leadership.
awaitLeadership(long, TimeUnit) - Method in class org.apache.storm.testing.MockLeaderElector
awaitLeadership(long, TimeUnit) - Method in class org.apache.storm.zookeeper.LeaderElectorImp
AZE - Enum constant in enum org.apache.storm.generated.DistributedRPC.execute_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.DistributedRPCInvocations.failRequest_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.DistributedRPCInvocations.result_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.activate_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.beginBlobDownload_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.beginCreateBlob_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.beginFileUpload_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.beginUpdateBlob_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.cancelBlobUpload_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.deactivate_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.debug_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.deleteBlob_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.downloadBlobChunk_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.downloadChunk_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.finishBlobUpload_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.finishFileUpload_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getBlobMeta_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getBlobReplication_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getClusterInfo_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getComponentPageInfo_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getLeader_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getNimbusConf_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getSupervisorAssignments_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getSupervisorPageInfo_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopology_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyConf_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyHistory_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyInfo_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyInfoByName_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologyPageInfo_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologySummaries_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologySummary_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getTopologySummaryByName_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.getUserTopology_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.isRemoteBlobExists_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.killTopology_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.killTopologyWithOpts_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.rebalance_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.setBlobMeta_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.submitTopology_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.updateBlobReplication_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.uploadBlobChunk_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.uploadChunk_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Nimbus.uploadNewCredentials_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result._Fields
AZE - Enum constant in enum org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result._Fields

B

BACK_PRESSURE_WAIT - Enum constant in enum org.apache.storm.policy.IWaitStrategy.WaitSituation
BACK_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BACKPRESSURE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils
BACKPRESSURE_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils
backpressurePath(String, String) - Static method in class org.apache.storm.cluster.ClusterUtils: Get the backpressure znode full path.
backpressurePath(String, String, Long) - Static method in class org.apache.storm.cluster.ClusterUtils
BackPressureStatus - Class in org.apache.storm.messaging.netty
BackPressureStatus() - Constructor for class org.apache.storm.messaging.netty.BackPressureStatus
BackPressureStatus(String, Collection<Integer>, Collection<Integer>) - Constructor for class org.apache.storm.messaging.netty.BackPressureStatus: Constructor.
BackPressureStatusEncoder - Class in org.apache.storm.messaging.netty
BackPressureStatusEncoder(KryoValuesSerializer) - Constructor for class org.apache.storm.messaging.netty.BackPressureStatusEncoder
backpressureStormRoot(String) - Static method in class org.apache.storm.cluster.ClusterUtils
BackPressureTopo - Class in org.apache.storm.perf
BackPressureTopo() - Constructor for class org.apache.storm.perf.BackPressureTopo
backpressureTopologies() - Method in interface org.apache.storm.cluster.IStormClusterState: Deprecated, for removal: This API element is subject to removal in a future version.
backpressureTopologies() - Method in class org.apache.storm.cluster.StormClusterStateImpl
BackPressureTracker - Class in org.apache.storm.daemon.worker: Tracks the BackPressure status.
BackPressureTracker(String, Map<Integer, JCQueue>, StormMetricRegistry, Map<Integer, String>) - Constructor for class org.apache.storm.daemon.worker.BackPressureTracker
BackPressureTracker.BackpressureState - Class in org.apache.storm.daemon.worker
backtrack(Map<ExecutorDetails, String>, RasNode[], WorkerSlot[]) - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.SchedulingSearcherState: Backtrack to prior executor that was directly assigned.
backup(int) - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream: Backup a number of characters.
BAD_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs: Deprecated.
please use HdfsSpout.setBadFilesDir(String)
badSupervisorsToleranceSlidingWindow - Variable in class org.apache.storm.scheduler.blacklist.BlacklistScheduler
BalancedTargetSelector() - Constructor for class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelector
BASE_BLOBS_DIR_NAME - Static variable in class org.apache.storm.blobstore.BlobStore
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
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
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.
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
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
BaseOperation - Class in org.apache.storm.trident.operation: Convenience implementation of the Operation interface.
BaseOperation() - Constructor for class org.apache.storm.trident.operation.BaseOperation
BaseQueryFunction<S extends State,T> - Class in org.apache.storm.trident.state
BaseQueryFunction() - Constructor for class org.apache.storm.trident.state.BaseQueryFunction
BaseResourceAwareStrategy - Class in org.apache.storm.scheduler.resource.strategies.scheduling
BaseResourceAwareStrategy() - Constructor for class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
BaseResourceAwareStrategy(boolean, BaseResourceAwareStrategy.NodeSortType) - Constructor for class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy: Initialize for the default implementation of schedule().
BaseResourceAwareStrategy.NodeSortType - Enum in org.apache.storm.scheduler.resource.strategies.scheduling: Different node sorting types available.
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,KENCODEDT,VENCODEDT> - Class in org.apache.storm.state: Base implementation of iterator over KeyValueState.
BaseStateIterator(Iterator<Map.Entry<KENCODEDT, VENCODEDT>>, Iterator<Map.Entry<KENCODEDT, VENCODEDT>>, Set<KENCODEDT>) - 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
baseType() - Element in annotation type org.apache.storm.validation.ConfigValidationAnnotations.IsDerivedFrom
BaseWindow<L,I> - Class in org.apache.storm.streams.windowing
BaseWindow() - Constructor for class org.apache.storm.streams.windowing.BaseWindow
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, int, LocalAssignment, ResourceIsolationInterface, LocalState, String, StormMetricsRegistry, ContainerMemoryTracker) - 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, int, ResourceIsolationInterface, StormMetricsRegistry, ContainerMemoryTracker) - Constructor for class org.apache.storm.daemon.supervisor.BasicContainerLauncher
BasicDrpcClient - Class in org.apache.storm.command: A simple client for connecting to DRPC.
BasicDrpcClient() - Constructor for class org.apache.storm.command.BasicDrpcClient
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
BasicLoadAwareCustomStreamGrouping(CustomStreamGrouping) - Constructor for class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping
BasicMetricsCollector - Class in org.apache.storm.perf.utils
BasicMetricsCollector(String, Map<String, Object>) - 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 - Enum constant in enum org.apache.storm.trident.planner.SpoutNode.SpoutType
BATCH_STREAM_ID - Static variable in class org.apache.storm.trident.topology.MasterBatchCoordinator
BatchBoltExecutor - Class in org.apache.storm.coordination
BatchBoltExecutor(IBatchBolt) - Constructor for class org.apache.storm.coordination.BatchBoltExecutor
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
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
BatchProcessor - Interface in org.apache.storm.streams.processors: Top level marker interface for processors that computes results for a batch of tuples like Aggregate, Join etc.
batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcState
batchRetrieve(JdbcState, List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcQuery
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
batchRetrieve(T, List<TridentTuple>) - Method in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
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) - Constructor for class org.apache.storm.coordination.BatchSubtopologyBuilder
BatchSubtopologyBuilder(String, IBasicBolt, Number) - 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
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: RegularExpression Id.
BEGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BEGIN_FRAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BEGIN_PARTITION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginBlobDownload
beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginBlobDownload
beginBlobDownload(String) - Method in class org.apache.storm.daemon.nimbus.Nimbus
beginBlobDownload(String) - Method in class org.apache.storm.generated.Nimbus.Client
beginBlobDownload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
beginBlobDownload(String) - Method in class org.apache.storm.LocalCluster
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_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: The column number of the first character of this Token.
beginCommit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState
beginCommit(Long) - Method in class org.apache.storm.hive.trident.HiveState
beginCommit(Long) - Method in class org.apache.storm.jdbc.trident.state.JdbcState
beginCommit(Long) - Method in class org.apache.storm.jms.trident.JmsState
beginCommit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState
beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisClusterState
beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisState
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() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginCreateBlob
beginCreateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginCreateBlob
beginCreateBlob(String, SettableBlobMeta) - Method in class org.apache.storm.daemon.nimbus.Nimbus
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(String, SettableBlobMeta) - Method in class org.apache.storm.LocalCluster
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_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.
beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginFileUpload
beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginFileUpload
beginFileUpload() - Method in class org.apache.storm.daemon.nimbus.Nimbus
beginFileUpload() - Method in class org.apache.storm.generated.Nimbus.Client
beginFileUpload() - Method in interface org.apache.storm.generated.Nimbus.Iface
beginFileUpload() - Method in class org.apache.storm.LocalCluster
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_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: The line number of the first character of this Token.
BeginToken() - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream: Start.
beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginUpdateBlob
beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginUpdateBlob
beginUpdateBlob(String) - Method in class org.apache.storm.daemon.nimbus.Nimbus
beginUpdateBlob(String) - Method in class org.apache.storm.generated.Nimbus.Client
beginUpdateBlob(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
beginUpdateBlob(String) - Method in class org.apache.storm.LocalCluster
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_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: RegularExpression Id.
BERNOULLI - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BETWEEN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BiFunction<T,U,R> - Interface in org.apache.storm.streams.operations: a function that accepts two arguments and produces a result.
BIGINT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BINARY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
binary_arg(byte[]) - Static method in class org.apache.storm.generated.JavaObjectArg
binary_arg(ByteBuffer) - Static method in class org.apache.storm.generated.JavaObjectArg
BINARY_ARG - Enum constant in enum org.apache.storm.generated.JavaObjectArg._Fields
BINARY_STRING_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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(String, int, IConnectionCallback, Supplier<Object>) - Method in interface org.apache.storm.messaging.IContext: This method establishes a server side connection.
bind(String, int, IConnectionCallback, Supplier<Object>) - Method in class org.apache.storm.messaging.local.Context
bind(String, int, IConnectionCallback, Supplier<Object>) - 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: RegularExpression Id.
BITS - Enum constant in enum org.apache.storm.generated.ThriftSerializedObject._Fields
bitXor(Long, Long) - Static method in class org.apache.storm.utils.Utils
bitXorVals(List<Long>) - Static method in class org.apache.storm.utils.Utils
BLACKLIST_SCHEDULER_ASSUME_SUPERVISOR_BAD_BASED_ON_BAD_SLOT - Static variable in class org.apache.storm.DaemonConfig: Whether BlacklistScheduler will assume the supervisor is bad based on bad slots or not.
BLACKLIST_SCHEDULER_ENABLE_SEND_ASSIGNMENT_FAILURES - Static variable in class org.apache.storm.DaemonConfig: Enables blacklisting support for supervisors with failed send assignment calls.
BLACKLIST_SCHEDULER_REPORTER - Static variable in class org.apache.storm.DaemonConfig: The class that the blacklist scheduler will report the blacklist.
BLACKLIST_SCHEDULER_RESUME_TIME - Static variable in class org.apache.storm.DaemonConfig: The number of seconds that the blacklisted slots or supervisor will be resumed.
BLACKLIST_SCHEDULER_STRATEGY - Static variable in class org.apache.storm.DaemonConfig: The class that specifies the eviction strategy to use in blacklist scheduler.
BLACKLIST_SCHEDULER_TOLERANCE_COUNT - Static variable in class org.apache.storm.DaemonConfig: The number of hit count that will trigger blacklist in tolerance time.
BLACKLIST_SCHEDULER_TOLERANCE_TIME - Static variable in class org.apache.storm.DaemonConfig: The number of seconds that the blacklist scheduler will concern of bad slots or supervisors.
BLACKLISTED - Enum constant in enum org.apache.storm.generated.SupervisorSummary._Fields
blacklistedSupervisorIds - Variable in class org.apache.storm.scheduler.blacklist.BlacklistScheduler
blacklistHost(String) - Method in class org.apache.storm.scheduler.Cluster
BlacklistScheduler - Class in org.apache.storm.scheduler.blacklist
BlacklistScheduler(IScheduler) - Constructor for class org.apache.storm.scheduler.blacklist.BlacklistScheduler
blacklistStrategy - Variable in class org.apache.storm.scheduler.blacklist.BlacklistScheduler
blkio - Enum constant in enum org.apache.storm.container.cgroup.SubSystemType
BLKIO_IO_MERGED - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_IO_QUEUED - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_IO_SERVICE_BYTES - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_IO_SERVICE_TIME - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_IO_SERVICED - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_IO_WAIT_TIME - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_RESET_STATS - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_SECTORS - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_IO_SERVICE_BYTES - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_IO_SERVICED - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_READ_BPS_DEVICE - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_READ_IOPS_DEVICE - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_WRITE_BPS_DEVICE - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_THROTTLE_WRITE_IOPS_DEVICE - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_TIME - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_WEIGHT - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BLKIO_WEIGHT_DEVICE - Static variable in class org.apache.storm.container.cgroup.core.BlkioCore
BlkioCore - Class in org.apache.storm.container.cgroup.core
BlkioCore(String) - Constructor for class org.apache.storm.container.cgroup.core.BlkioCore
BlkioCore.RecordType - Enum in org.apache.storm.container.cgroup.core
BLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BLOB_KEY - Enum constant in enum org.apache.storm.generated.Nimbus.isRemoteBlobExists_args._Fields
BLOB_KEY_PATTERN - Static variable in class org.apache.storm.utils.Utils
blobChanging(LocalAssignment, int, LocallyCachedBlob, GoodToGo) - Method in class org.apache.storm.daemon.supervisor.Slot
blobChanging(LocalAssignment, int, LocallyCachedBlob, GoodToGo) - Method in interface org.apache.storm.localizer.BlobChangingCallback: Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the worker process.
BlobChangingCallback - Interface in org.apache.storm.localizer: Callback for when a localized blob is going to change.
blobExists(String, Subject) - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStore: Checks if a blob exists.
BlobKeySequenceInfo - Class in org.apache.storm.blobstore
BlobKeySequenceInfo() - Constructor for class org.apache.storm.blobstore.BlobKeySequenceInfo
blobNeedsWorkerRestart(Map<String, Object>) - Static method in class org.apache.storm.daemon.supervisor.SupervisorUtils: Given the blob information returns the value of the workerRestart field, handling it being a boolean value, or if it's not specified then returns false.
blobstore(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState
blobstore(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl
Blobstore - Class in org.apache.storm.command
Blobstore() - Constructor for class org.apache.storm.command.Blobstore
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_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: Deprecated.
BLOBSTORE_HDFS_PRINCIPAL - Static variable in class org.apache.storm.Config: Deprecated, for removal: This API element is subject to removal in a future version.
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.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.
BlobStoreAclHandler - Class in org.apache.storm.blobstore: Provides common handling of acls for Blobstores.
BlobStoreAclHandler(Map<String, Object>) - 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
BlockingOutstandingRequest - Class in org.apache.storm.daemon.drpc
BlockingOutstandingRequest(String, DRPCRequest) - Constructor for class org.apache.storm.daemon.drpc.BlockingOutstandingRequest
BlowfishTupleSerializer - Class in org.apache.storm.security.serialization: Apply Blowfish encryption for tuple communication to bolts.
BlowfishTupleSerializer(Kryo, Map<String, Object>) - Constructor for class org.apache.storm.security.serialization.BlowfishTupleSerializer
bolt(BoltAggregateStats) - Static method in class org.apache.storm.generated.SpecificAggregateStats
bolt(BoltStats) - Static method in class org.apache.storm.generated.ExecutorSpecificStats
Bolt - Class in org.apache.storm.generated
Bolt() - 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(ComponentObject, ComponentCommon) - Constructor for class org.apache.storm.generated.Bolt
BOLT - Enum constant in enum org.apache.storm.generated.ComponentType
BOLT - Enum constant in enum org.apache.storm.generated.ExecutorSpecificStats._Fields
BOLT - Enum constant in enum org.apache.storm.generated.SpecificAggregateStats._Fields
BOLT - Static variable in class org.apache.storm.stats.ClientStatsUtil
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.KafkaClientHdfsTopo
BOLT_ID - Static variable in class org.apache.storm.perf.KafkaClientSpoutNullBoltTopo
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.KafkaClientHdfsTopo
BOLT_NUM - Static variable in class org.apache.storm.perf.KafkaClientSpoutNullBoltTopo
BOLT_NUM - Static variable in class org.apache.storm.perf.SimplifiedWordCountTopo
BOLT_NUM - Static variable in class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo
BOLT_OBJECT - Enum constant in enum org.apache.storm.generated.Bolt._Fields
BOLT_WAIT - Enum constant in enum org.apache.storm.policy.IWaitStrategy.WaitSituation
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
boltAck(BoltAckInfo) - Method in class org.apache.storm.hooks.BaseTaskHook
boltAck(BoltAckInfo) - Method in interface org.apache.storm.hooks.ITaskHook
boltAckedTuple(String, String, long) - Method in class org.apache.storm.metrics2.TaskMetrics
boltAckedTuple(String, String, long) - Method in class org.apache.storm.stats.BoltExecutorStats
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.
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
BoltDetails(Object, Map<String, Object>, Integer, Map<GlobalStreamId, Grouping>) - Constructor for class org.apache.storm.Thrift.BoltDetails
boltExecute(Supplier<Iterator<Tuple>>, Supplier<Iterator<Tuple>>, Supplier<Iterator<Tuple>>, Long) - Method in class org.apache.storm.topology.WindowedBoltExecutor
boltExecute(List<Tuple>, List<Tuple>, List<Tuple>, Long) - Method in class org.apache.storm.topology.WindowedBoltExecutor
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
boltExecuteTuple(String, String, long) - Method in class org.apache.storm.metrics2.TaskMetrics
boltExecuteTuple(String, String, long, long, Task) - Method in class org.apache.storm.stats.BoltExecutorStats
BoltExecutor - Class in org.apache.storm.executor.bolt
BoltExecutor(WorkerState, List<Long>, Map<String, String>) - Constructor for class org.apache.storm.executor.bolt.BoltExecutor
BoltExecutorStats - Class in org.apache.storm.stats
BoltExecutorStats(int, int) - Constructor for class org.apache.storm.stats.BoltExecutorStats
boltFail(BoltFailInfo) - Method in class org.apache.storm.hooks.BaseTaskHook
boltFail(BoltFailInfo) - Method in interface org.apache.storm.hooks.ITaskHook
boltFailedTuple(String, String) - Method in class org.apache.storm.metrics2.TaskMetrics
boltFailedTuple(String, String) - Method in class org.apache.storm.stats.BoltExecutorStats
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
BoltOutputCollectorImpl - Class in org.apache.storm.executor.bolt
BoltOutputCollectorImpl(BoltExecutor, Task, Random, boolean, boolean, boolean) - Constructor for class org.apache.storm.executor.bolt.BoltOutputCollectorImpl
bolts - Variable in class org.apache.storm.loadgen.TopologyLoadConf
BOLTS - Enum constant in enum org.apache.storm.generated.StormTopology._Fields
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.
boltStreamsStats(List<ExecutorSummary>, boolean) - Static method in class org.apache.storm.stats.StatsUtil: aggregates bolt stream stats, returns a Map of {metric -> win -> aggregated value}.
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
BOOL_ARG - Enum constant in enum org.apache.storm.generated.JavaObjectArg._Fields
BOOLEAN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
BooleanValidator() - Constructor for class org.apache.storm.validation.ConfigValidation.BooleanValidator
boolOpt(String, String) - Static method in class org.apache.storm.command.CLI: Add a boolean option that enables something.
boolOpt(String, String) - Method in class org.apache.storm.command.CLI.CLIBuilder: Add a boolean option that enables something.
boolval(boolean) - Static method in class org.apache.storm.generated.HBMessageData
BOOLVAL - Enum constant in enum org.apache.storm.generated.HBMessageData._Fields
Booter - Class in org.apache.storm.submit.dependency: Manage mvn repository.
Booter() - Constructor for class org.apache.storm.submit.dependency.Booter
BOOTSTRAP_SERVERS - Static variable in class org.apache.storm.perf.KafkaClientSpoutNullBoltTopo
BOTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
bpTasks - Variable in class org.apache.storm.messaging.netty.BackPressureStatus
BRACKET_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
branch(Predicate<? super Pair<K, V>>...) - Method in class org.apache.storm.streams.PairStream: Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
branch(Predicate<? super T>...) - Method in class org.apache.storm.streams.Stream: Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
BranchExample - Class in org.apache.storm.starter.streams: An example that demonstrates the usage of Stream.branch(Predicate[]) to split a stream into multiple branches based on predicates.
BranchExample() - Constructor for class org.apache.storm.starter.streams.BranchExample
BranchProcessor<T> - Class in org.apache.storm.streams.processors
BranchProcessor() - Constructor for class org.apache.storm.streams.processors.BranchProcessor
BREADTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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.
BTID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: Lexical state.
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
bufcolumn - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
buffer - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
buffer(ByteBufAllocator, KryoValuesSerializer) - Method in class org.apache.storm.messaging.netty.BackPressureStatus: Encoded as -600 ... short(2) len ... int(4) payload ... byte[] *
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_info() - Method in class org.apache.storm.generated.WorkerToken
buffer_for_key() - Method in class org.apache.storm.generated.PrivateWorkerKey
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_signature() - Method in class org.apache.storm.generated.WorkerToken
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) - Constructor for class org.apache.storm.utils.BufferFileInputStream
BufferFileInputStream(String, int) - Constructor for class org.apache.storm.utils.BufferFileInputStream
BufferInputStream - Class in org.apache.storm.utils
BufferInputStream(InputStream) - Constructor for class org.apache.storm.utils.BufferInputStream
BufferInputStream(InputStream, int) - Constructor for class org.apache.storm.utils.BufferInputStream
bufline - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
bufpos - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream: Position in buffer.
build() - Method in class org.apache.storm.daemon.common.JsonResponseBuilder: Build a Response based on given parameters.
build() - Method in class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder
build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
build() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder
build() - Method in class org.apache.storm.loadgen.InputStream.Builder
build() - Method in class org.apache.storm.loadgen.LoadCompConf.Builder
build() - Method in class org.apache.storm.loadgen.OutputStream.Builder
build() - Method in class org.apache.storm.LocalCluster.Builder: Builds a new LocalCluster.
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() - Method in class org.apache.storm.sql.AbstractStreamsProcessor: Construct the Storm topology based on the SQL.
build() - Method in class org.apache.storm.sql.compiler.CompilerUtil.TableBuilderInfo
build() - Method in class org.apache.storm.streams.StreamBuilder: Builds a new StormTopology for the computation expressed via the stream api.
build() - Method in class org.apache.storm.trident.TridentTopology
build(String, Map<String, Object>) - Static method in class org.apache.storm.daemon.utils.UrlBuilder: Build the URL. the key and value of query parameters will be encoded.
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(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder: Builds container for Redis Cluster environment.
build(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder: Builds container for Redis Cluster environment.
build(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder: Builds container for single Redis environment.
build(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder: Builds container for single Redis environment.
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(IBackingMap<T>) - Static method in class org.apache.storm.trident.state.map.NonTransactionalMap
build(WindowPartitionCache.CacheLoader<K, V>) - Method in class org.apache.storm.windowing.persistence.SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder
build(WindowPartitionCache.CacheLoader<K, V>) - Method in interface org.apache.storm.windowing.persistence.WindowPartitionCache.Builder: Build the cache.
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.
buildDownloadFile(String, File, Meter) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing download a file.
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, String...) - Static method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig: 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, Pattern) - Static method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig: Factory method that creates a Builder with String key/value deserializers.
builder(String, Set<String>) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig: Factory method that creates a Builder with String key/value deserializers.
builder(String, Set<String>) - Static method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig: Factory method that creates a Builder with String key/value deserializers.
Builder() - Constructor for class org.apache.storm.loadgen.InputStream.Builder
Builder() - Constructor for class org.apache.storm.loadgen.LoadCompConf.Builder
Builder() - Constructor for class org.apache.storm.loadgen.OutputStream.Builder
Builder() - Constructor for class org.apache.storm.LocalCluster.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(String, String...) - Constructor for class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder
Builder(String, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
Builder(String, String...) - Constructor for class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder
Builder(String, Pattern) - Constructor for class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder
Builder(String, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
Builder(String, Pattern) - Constructor for class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder
Builder(String, Set<String>) - Constructor for class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder
Builder(String, Set<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
Builder(String, Set<String>) - Constructor for class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder
Builder(String, TopicFilter, ManualPartitioner) - Constructor for class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder: Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.
Builder(String, TopicFilter, ManualPartitioner) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder: Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.
Builder(String, TopicFilter, ManualPartitioner) - Constructor for class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder
buildExceptionJsonResponse(Exception, String) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing exception, with JSON response.
buildFieldIndex(ValuePointer[]) - Static method in class org.apache.storm.trident.tuple.ValuePointer
buildFrameWorkConfig() - Method in class org.apache.storm.sql.StormSqlContext
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
buildResponsePageNotFound() - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing page not found.
buildResponseUnauthorizedUser(String) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing unauthorized user, with HTML response.
buildSuccessHtmlResponse(String) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing success response with HTML entity.
buildSuccessJsonResponse(Object, String, String) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing success response with JSON entity.
buildTopology() - Static method in class org.apache.storm.starter.trident.TridentMapExample
buildTopology() - Static method in class org.apache.storm.starter.trident.TridentReach
buildTopology() - Static method in class org.apache.storm.starter.trident.TridentWordCount
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) - 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.WordCountTridentRedis
buildTopology(String, Integer) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisMap
buildTopology(String, String, String, Object, Object) - Static method in class org.apache.storm.hive.trident.TridentHiveTopology
buildTopology(HashMap<String, Thrift.SpoutDetails>, HashMap<String, Thrift.BoltDetails>, HashMap<String, StateSpoutSpec>) - Static method in class org.apache.storm.Thrift
buildTopology(Map<String, Number>) - Method in class org.apache.storm.trident.topology.TridentTopologyBuilder
buildTopology(Map<String, Thrift.SpoutDetails>, Map<String, Thrift.BoltDetails>) - Static method in class org.apache.storm.Thrift
buildTopology(ExecutionContext) - Static method in class org.apache.storm.flux.FluxBuilder: Given a topology definition, return a Storm topology that can be run either locally or remotely.
buildTopology(WindowsStoreFactory, WindowConfig) - Static method in class org.apache.storm.starter.trident.TridentWindowingInmemoryStoreTopology
buildUnauthorizedUserJsonResponse(String, String) - Static method in class org.apache.storm.daemon.logviewer.utils.LogviewerResponseBuilder: Build a Response object representing unauthorized user, with JSON response.
buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology: Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfDevicesTopology.Vehicle and TridentMinMaxOfDevicesTopology.Driver respectively.
buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfVehiclesTopology: Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.
BuiltinFunctionCall() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl: Parses a call to a builtin function with special syntax.
BuiltinMetricsUtil - Class in org.apache.storm.daemon.metrics
BuiltinMetricsUtil() - Constructor for class org.apache.storm.daemon.metrics.BuiltinMetricsUtil
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: RegularExpression Id.
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) - 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(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(RecordTranslator<K, V>) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator: Create a record translator with the given default translator.

C

C - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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.FixedGroupsMapping
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. you generally layer opaque map over this over your database store.
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
cachedSupervisors - Variable in class org.apache.storm.scheduler.blacklist.BlacklistScheduler
cacheSize - Variable in class org.apache.storm.container.cgroup.core.MemoryCore.Stat
cacheTargetSize - Variable in class org.apache.storm.localizer.AsyncLocalizer
calculateAveragePercentageUsedBy(NormalizedResourceOffer) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceOffer: Calculate the average percentage used.
calculateAveragePercentageUsedBy(NormalizedResources, double, double) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Calculate the average resource usage percentage with this being the total resources and used being the amounts used.
calculateMinPercentageUsedBy(NormalizedResourceOffer) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceOffer: Calculate the min percentage used of the resource.
calculateMinPercentageUsedBy(NormalizedResources, double, double) - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Calculate the minimum resource usage percentage with this being the total resources and used being the amounts used.
call() - Method in class org.apache.storm.clojure.ClojureTuple
call() - Method in class org.apache.storm.executor.bolt.BoltExecutor
call() - Method in class org.apache.storm.executor.spout.SpoutExecutor
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: RegularExpression Id.
callbackHandler - Variable in class org.apache.storm.messaging.netty.Login
callbackParameterName - Static variable in class org.apache.storm.daemon.ui.resources.StormApiResource
CALLED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.cancelBlobUpload
cancelBlobUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.cancelBlobUpload
cancelBlobUpload(String) - Method in class org.apache.storm.daemon.nimbus.Nimbus
cancelBlobUpload(String) - Method in class org.apache.storm.generated.Nimbus.Client
cancelBlobUpload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface
cancelBlobUpload(String) - Method in class org.apache.storm.LocalCluster
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_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.streams.rel.StreamsLogicalConvention
canTransformResource(String) - Method in class org.apache.storm.maven.shade.clojure.ClojureTransformer
canUserReadBlob(ReadableBlobMeta, String, Map<String, Object>) - Static method in class org.apache.storm.utils.ServerUtils
CAPACITY - Enum constant in enum org.apache.storm.generated.BoltAggregateStats._Fields
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
CapturedTopology(T, TupleCaptureBolt) - Constructor for class org.apache.storm.Testing.CapturedTopology
CaptureLoad - Class in org.apache.storm.loadgen: Capture running topologies for load gen later on.
CaptureLoad() - Constructor for class org.apache.storm.loadgen.CaptureLoad
capturer - Variable in class org.apache.storm.Testing.CapturedTopology: a Bolt that will hold all of the captured data.
captureTopology(StormTopology) - Static method in class org.apache.storm.Testing: Rewrites a topology so that all the tuples flowing through it are captured.
CARDINALITY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CARET - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CASCADE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CASCADED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CASE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CaseExpression() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
CAST - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CATALOG_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
cb(Metric) - Method in interface org.apache.storm.metricstore.MetricStore.ScanCallback
ceil(DateTime, int) - Static method in class org.apache.storm.st.utils.TimeUtil
CEIL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CEILING - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CENTURY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CGROUP_CLONE_CHILDREN - Static variable in class org.apache.storm.container.cgroup.CgroupCommon
CGROUP_EVENT_CONTROL - Static variable in class org.apache.storm.container.cgroup.CgroupCommon
CGROUP_PROCS - Static variable in class org.apache.storm.container.cgroup.CgroupCommon
CGROUP_STATUS_FILE - Static variable in class org.apache.storm.container.cgroup.CgroupUtils
CgroupCenter - Class in org.apache.storm.container.cgroup
CgroupCommon - Class in org.apache.storm.container.cgroup
CgroupCommon(String, Hierarchy, CgroupCommon) - Constructor for class org.apache.storm.container.cgroup.CgroupCommon
CgroupCommon(Hierarchy, String) - Constructor for class org.apache.storm.container.cgroup.CgroupCommon
CgroupCommonOperation - Interface in org.apache.storm.container.cgroup
CgroupCore - Interface in org.apache.storm.container.cgroup.core
CgroupCoreFactory - Class in org.apache.storm.container.cgroup
CgroupCoreFactory() - Constructor for class org.apache.storm.container.cgroup.CgroupCoreFactory
CGroupCpu - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupCpu - Class in org.apache.storm.metrics2.cgroup: Report CPU used in the cgroup.
CGroupCpu(Map<String, Object>) - Constructor for class org.apache.storm.metric.cgroup.CGroupCpu: Deprecated.
CGroupCpu(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupCpu
CGroupCpuGuarantee - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupCpuGuarantee - Class in org.apache.storm.metrics2.cgroup: Report the guaranteed number of cpu percentage this worker has requested.
CGroupCpuGuarantee(Map<String, Object>) - Constructor for class org.apache.storm.metric.cgroup.CGroupCpuGuarantee: Deprecated.
CGroupCpuGuarantee(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupCpuGuarantee
CGroupCpuGuaranteeByCfsQuota - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupCpuGuaranteeByCfsQuota - Class in org.apache.storm.metrics2.cgroup: Report the percentage of the cpu guaranteed for the worker.
CGroupCpuGuaranteeByCfsQuota(Map<String, Object>) - Constructor for class org.apache.storm.metric.cgroup.CGroupCpuGuaranteeByCfsQuota: Deprecated.
CGroupCpuGuaranteeByCfsQuota(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupCpuGuaranteeByCfsQuota
CGroupCpuStat - Class in org.apache.storm.metrics2.cgroup
CGroupCpuStat(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupCpuStat
CgroupManager - Class in org.apache.storm.container.cgroup: Class that implements ResourceIsolationInterface that manages cgroups.
CgroupManager() - Constructor for class org.apache.storm.container.cgroup.CgroupManager
CGroupMemoryLimit - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupMemoryLimit - Class in org.apache.storm.metrics2.cgroup: Reports the current memory limit of the cgroup for this worker.
CGroupMemoryLimit(Map<String, Object>) - Constructor for class org.apache.storm.metric.cgroup.CGroupMemoryLimit: Deprecated.
CGroupMemoryLimit(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupMemoryLimit
CGroupMemoryUsage - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupMemoryUsage - Class in org.apache.storm.metrics2.cgroup: Reports the current memory usage of the cgroup for this worker.
CGroupMemoryUsage(Map<String, Object>) - Constructor for class org.apache.storm.metric.cgroup.CGroupMemoryUsage: Deprecated.
CGroupMemoryUsage(Map<String, Object>) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupMemoryUsage
CGroupMetricsBase<T> - Class in org.apache.storm.metric.cgroup: Deprecated.
CGroupMetricsBase - Class in org.apache.storm.metrics2.cgroup: Base class for checking if CGroups are enabled, etc.
CGroupMetricsBase(Map<String, Object>, SubSystemType) - Constructor for class org.apache.storm.metric.cgroup.CGroupMetricsBase: Deprecated.
CGroupMetricsBase(Map<String, Object>, SubSystemType) - Constructor for class org.apache.storm.metrics2.cgroup.CGroupMetricsBase
CgroupOperation - Interface in org.apache.storm.container.cgroup: An interface to implement the basic functions to manage cgroups such as mount and mounting a hiearchy and creating cgroups.
cgroupParent - Variable in class org.apache.storm.container.oci.OciContainerManager
cgroupRootPath - Variable in class org.apache.storm.container.oci.OciContainerManager
CgroupUtils - Class in org.apache.storm.container.cgroup
CgroupUtils() - Constructor for class org.apache.storm.container.cgroup.CgroupUtils
CHAIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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
ChainedProcessorContext<T> - Class in org.apache.storm.streams.processors: A composite context that holds a chain of ProcessorContext.
ChainedProcessorContext(ProcessorNode, List<? extends ProcessorContext>) - Constructor for class org.apache.storm.streams.processors.ChainedProcessorContext
ChainedProcessorContext(ProcessorNode, ProcessorContext...) - Constructor for class org.apache.storm.streams.processors.ChainedProcessorContext
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
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
channelActive(Channel) - Method in interface org.apache.storm.messaging.netty.IServer
channelActive(ChannelHandlerContext) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler
channelActive(ChannelHandlerContext) - Method in class org.apache.storm.messaging.netty.SaslStormClientHandler
channelActive(ChannelHandlerContext) - Method in class org.apache.storm.messaging.netty.StormServerHandler
channelActive(ChannelHandlerContext) - Method in class org.apache.storm.pacemaker.PacemakerClientHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.KerberosSaslServerHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.SaslStormClientHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.SaslStormServerAuthorizeHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.SaslStormServerHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.StormClientHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.messaging.netty.StormServerHandler
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.storm.pacemaker.PacemakerClientHandler
channelReady(Channel) - Method in class org.apache.storm.messaging.netty.Client
channelReady(Channel) - Method in interface org.apache.storm.messaging.netty.ISaslClient
channelReady(Channel) - Method in class org.apache.storm.pacemaker.PacemakerClient
channelRegistered(ChannelHandlerContext) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler
channelUnregistered(ChannelHandlerContext) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler
CHAR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHAR_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTER_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTER_SET_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTER_SET_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTER_SET_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTERISTICS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARACTERS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CHARSET - Static variable in class org.apache.storm.hdfs.spout.TextFileReader
CHARSETNAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
Check() - Constructor for class org.apache.storm.starter.InOrderDeliveryTest.Check
CHECK - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
checkAuthorization(String) - Method in class org.apache.storm.daemon.supervisor.Supervisor
checkAuthorization(String, Map<String, Object>, String) - Method in class org.apache.storm.daemon.nimbus.Nimbus
checkAuthorization(String, Map<String, Object>, String) - Method in class org.apache.storm.daemon.supervisor.Supervisor
checkAuthorization(String, Map<String, Object>, String, ReqContext) - Method in class org.apache.storm.daemon.nimbus.Nimbus
checkAuthorization(String, Map<String, Object>, String, ReqContext) - Method in class org.apache.storm.daemon.supervisor.Supervisor
checkCredentialsChanged() - Method in class org.apache.storm.daemon.worker.Worker
checkDirExists(String) - Static method in class org.apache.storm.utils.Utils
checkFileExists(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
checkInitialization(Map<String, Double>, String, Map<String, Object>) - Static method in class org.apache.storm.loadgen.CaptureLoad: Checks if the topology's resource requirements are initialized.
checkLogConfigChanged() - Method in class org.apache.storm.daemon.worker.Worker
CHECKPOINT_COMPONENT_ID - Static variable in class org.apache.storm.spout.CheckpointSpout
CHECKPOINT_FIELD_ACTION - Static variable in class org.apache.storm.spout.CheckpointSpout
CHECKPOINT_FIELD_TXID - Static variable in class org.apache.storm.spout.CheckpointSpout
CHECKPOINT_STREAM_ID - Static variable in class org.apache.storm.spout.CheckpointSpout
CheckpointSpout - Class in org.apache.storm.spout: Emits checkpoint tuples which is used to save the state of the IStatefulComponent across the topology.
CheckpointSpout() - Constructor for class org.apache.storm.spout.CheckpointSpout
CheckPointState - Class in org.apache.storm.spout: Captures the current state of the transaction in CheckpointSpout.
CheckPointState() - Constructor for class org.apache.storm.spout.CheckPointState
CheckPointState(long, CheckPointState.State) - 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
checkSchedulingFeasibility() - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy: Check scheduling feasibility for a quick failure as the second step in BaseResourceAwareStrategy.schedule(Cluster, TopologyDetails).
checkSchedulingFeasibility() - Method in class org.apache.storm.scheduler.resource.strategies.scheduling.ConstraintSolverStrategy
checkSerialize(KryoTupleSerializer, AddressedTuple) - Method in class org.apache.storm.daemon.worker.WorkerState
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
chooseTask(int[]) - Method in class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelector: Chooses one of the incoming tasks and selects the one that has been selected the fewest times so far.
chooseTask(int[]) - Method in interface org.apache.storm.grouping.PartialKeyGrouping.TargetSelector
chooseTaskIndex(List<T>, int) - Static method in class org.apache.storm.utils.TupleUtils
chooseTasks(int, List<Object>) - Method in class org.apache.storm.daemon.GrouperFactory.AllGrouper
chooseTasks(int, List<Object>) - Method in class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping
chooseTasks(int, List<Object>) - Method in class org.apache.storm.daemon.GrouperFactory.FieldsGrouper
chooseTasks(int, List<Object>) - Method in class org.apache.storm.daemon.GrouperFactory.GlobalGrouper
chooseTasks(int, List<Object>) - Method in class org.apache.storm.daemon.GrouperFactory.NoneGrouper
chooseTasks(int, List<Object>) - Method in interface org.apache.storm.grouping.CustomStreamGrouping: This function implements a custom stream grouping.
chooseTasks(int, List<Object>) - 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
CHUNK - Enum constant in enum org.apache.storm.generated.Nimbus.uploadBlobChunk_args._Fields
CHUNK - Enum constant in enum org.apache.storm.generated.Nimbus.uploadChunk_args._Fields
CLASS_ORIGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CLASSIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
classLoaders - Variable in class org.apache.storm.sql.AbstractStreamsProcessor
className() - Method in class org.apache.storm.sql.parser.SqlCreateFunction
clean() - Method in interface org.apache.storm.testing.CompletableSpout: Cleanup any global state kept.
cleanInbox(String, int) - Static method in class org.apache.storm.daemon.nimbus.Nimbus: Deletes jar files in dirLoc older than seconds.
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.Acker
cleanup() - Method in class org.apache.storm.drpc.KeyedFairBolt
cleanup() - Method in class org.apache.storm.drpc.ReturnResults
cleanup() - Method in class org.apache.storm.flux.examples.WordCounter
cleanup() - Method in class org.apache.storm.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
cleanup() - Method in class org.apache.storm.loadgen.HttpForwardingMetricsConsumer
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.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 interface org.apache.storm.nimbus.ITopologyActionNotifierPlugin: Called during shutdown.
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.scheduler.blacklist.BlacklistScheduler
cleanup() - Method in interface org.apache.storm.scheduler.IScheduler: called once when the system is shutting down, should be idempotent.
cleanup() - Method in class org.apache.storm.scheduler.resource.ResourceAwareScheduler
cleanup() - Method in class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt
cleanup() - Method in class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentence
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.NonRichBoltTracker
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: Analogue to bolt function.
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.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() - 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.LocalState
cleanup(int) - Method in class org.apache.storm.utils.VersionedStore
cleanup(String, String, int) - Method in class org.apache.storm.container.cgroup.CgroupManager
cleanup(String, String, int) - Method in class org.apache.storm.container.DefaultResourceIsolationManager
cleanup(String, String, int) - Method in class org.apache.storm.container.docker.DockerManager
cleanup(String, String, int) - Method in class org.apache.storm.container.oci.OciContainerManager
cleanup(String, String, int) - Method in class org.apache.storm.container.oci.RuncLibContainerManager
cleanup(String, String, int) - Method in interface org.apache.storm.container.ResourceIsolationInterface: This function will be called when the worker needs to shutdown.
cleanup(ClientBlobStore) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet: Actually cleanup the blobs to try and get below the target cache size.
cleanUp() - Method in class org.apache.storm.daemon.supervisor.Container
cleanUp() - Method in interface org.apache.storm.daemon.supervisor.Killable: Clean up the container.
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.
cleanupOrphanedData() - Method in class org.apache.storm.localizer.LocalizedResource
cleanupOrphanedData() - Method in class org.apache.storm.localizer.LocallyCachedBlob: Clean up any temporary files.
cleanupOrphanedData() - Method in class org.apache.storm.localizer.LocallyCachedTopologyBlob
cleanupStats() - Method in class org.apache.storm.stats.BoltExecutorStats
cleanupStats() - Method in class org.apache.storm.stats.CommonStats
cleanupStats() - Method in class org.apache.storm.stats.SpoutExecutorStats
clear() - Method in class org.apache.storm.clojure.ClojureTuple
clear() - Method in class org.apache.storm.clojure.IndifferentAccessMap
clear() - Method in class org.apache.storm.daemon.nimbus.TopoCache: Clear all entries from the Cache.
clear() - Method in class org.apache.storm.executor.TupleInfo
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.failRequestV2_args
clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_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.IllegalStateException
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.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.getOwnerResourceSummaries_args
clear() - Method in class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result
clear() - Method in class org.apache.storm.generated.Nimbus.getSupervisorAssignments_args
clear() - Method in class org.apache.storm.generated.Nimbus.getSupervisorAssignments_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.getTopologyInfoByName_args
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByName_result
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_args
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_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.getTopologySummaries_args
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologySummaries_result
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologySummary_args
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologySummary_result
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologySummaryByName_args
clear() - Method in class org.apache.storm.generated.Nimbus.getTopologySummaryByName_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.isRemoteBlobExists_args
clear() - Method in class org.apache.storm.generated.Nimbus.isRemoteBlobExists_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.processWorkerMetrics_args
clear() - Method in class org.apache.storm.generated.Nimbus.processWorkerMetrics_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.sendSupervisorWorkerHeartbeat_args
clear() - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result
clear() - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_args
clear() - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_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.OwnerResourceSummary
clear() - Method in class org.apache.storm.generated.PrivateWorkerKey
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.SharedMemory
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.Supervisor.getLocalAssignmentForStorm_args
clear() - Method in class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result
clear() - Method in class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args
clear() - Method in class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result
clear() - Method in class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_args
clear() - Method in class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result
clear() - Method in class org.apache.storm.generated.SupervisorAssignments
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.SupervisorWorkerHeartbeat
clear() - Method in class org.apache.storm.generated.SupervisorWorkerHeartbeats
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.WorkerMetricList
clear() - Method in class org.apache.storm.generated.WorkerMetricPoint
clear() - Method in class org.apache.storm.generated.WorkerMetrics
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.generated.WorkerToken
clear() - Method in class org.apache.storm.generated.WorkerTokenInfo
clear() - Method in class org.apache.storm.loadgen.ScopedTopologySet
clear() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceOffer
clear() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResourceRequest
clear() - Method in class org.apache.storm.scheduler.resource.normalization.NormalizedResources: Set all resources to 0.
clear() - Method in interface org.apache.storm.scheduler.resource.normalization.NormalizedResourcesWithMemory: Set all resources to 0.
clear() - Method in class org.apache.storm.utils.ListDelegate
clear() - Method in class org.apache.storm.utils.TransferDrainer
clear(String) - Static method in class org.apache.storm.testing.FixedTupleSpout
clearCredentials(Subject, KerberosTicket) - Static method in class org.apache.storm.security.auth.kerberos.AutoTGT
clearForceEmpty() - Method in class org.apache.storm.container.cgroup.core.MemoryCore
clearIteratorPins() - Method in class org.apache.storm.windowing.persistence.WindowState
clearState(String) - Static method in class org.apache.storm.utils.RegisteredGlobalState
clearStateForStorm(String) - Method in interface org.apache.storm.assignments.ILocalAssignmentsBackend: Clear all the state for a storm.
clearStateForStorm(String) - Method in class org.apache.storm.assignments.InMemoryAssignmentBackend
clearTrackId() - Static method in class org.apache.storm.executor.LocalExecutor
CLI - Class in org.apache.storm.command
CLI() - Constructor for class org.apache.storm.command.CLI
CLI.Assoc - Interface in org.apache.storm.command
CLI.CLIBuilder - Class in org.apache.storm.command
CLI.Parse - Interface in org.apache.storm.command
CLIBuilder() - Constructor for class org.apache.storm.command.CLI.CLIBuilder
client - Static variable in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
client - Variable in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModuleTest
Client - Class in org.apache.storm.messaging.netty: A Netty client for sending task messages to a remote destination (Netty server).
Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client
Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client
Client(TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client
Client(TProtocol) - Constructor for class org.apache.storm.generated.Supervisor.Client
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client
Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.Supervisor.Client
CLIENT_BLOBSTORE - Static variable in class org.apache.storm.Config: What blobstore implementation the storm client should use.
CLIENT_USERS_KEY - Static variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer
ClientAuthUtils - Class in org.apache.storm.security.auth
ClientAuthUtils() - Constructor for class org.apache.storm.security.auth.ClientAuthUtils
ClientBlobStore - Class in org.apache.storm.blobstore: The ClientBlobStore has two concrete implementations 1.
ClientBlobStore() - Constructor for class org.apache.storm.blobstore.ClientBlobStore
ClientBlobStore.WithBlobstore - Interface in org.apache.storm.blobstore
ClientCallbackHandler - Class in org.apache.storm.security.auth.kerberos: SASL client side callback handler.
ClientCallbackHandler(Map<String, Object>) - Constructor for class org.apache.storm.security.auth.kerberos.ClientCallbackHandler: Constructor based on a JAAS configuration.
ClientMetricsUtils - Class in org.apache.storm.daemon.metrics
ClientMetricsUtils() - Constructor for class org.apache.storm.daemon.metrics.ClientMetricsUtils
ClientStatsUtil - Class in org.apache.storm.stats: Stats calculations needed by storm client code.
ClientStatsUtil() - Constructor for class org.apache.storm.stats.ClientStatsUtil
ClientSupervisorUtils - Class in org.apache.storm.daemon.supervisor
ClientSupervisorUtils() - Constructor for class org.apache.storm.daemon.supervisor.ClientSupervisorUtils
clientUsers - Variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry
ClientZookeeper - Class in org.apache.storm.zookeeper
ClientZookeeper() - Constructor for class org.apache.storm.zookeeper.ClientZookeeper
CLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CLOCKS_INSYNC - Static variable in class org.apache.storm.hdfs.spout.Configs: Deprecated.
please use HdfsSpout.setClocksInSync(boolean)
ClojureBolt - Class in org.apache.storm.clojure
ClojureBolt(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureBolt
ClojureSerializationRegister - Class in org.apache.storm.clojure
ClojureSerializationRegister() - Constructor for class org.apache.storm.clojure.ClojureSerializationRegister
ClojureSpout - Class in org.apache.storm.clojure
ClojureSpout(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureSpout
ClojureTransformer - Class in org.apache.storm.maven.shade.clojure
ClojureTransformer() - Constructor for class org.apache.storm.maven.shade.clojure.ClojureTransformer
ClojureTuple - Class in org.apache.storm.clojure
ClojureTuple(Tuple) - Constructor for class org.apache.storm.clojure.ClojureTuple
ClojureUtil - Class in org.apache.storm.clojure
ClojureUtil() - Constructor for class org.apache.storm.clojure.ClojureUtil
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.ClientAuthUtils
close() - Method in interface org.apache.storm.assignments.ILocalAssignmentsBackend: Function to release resource.
close() - Method in class org.apache.storm.assignments.InMemoryAssignmentBackend
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.BlobStore
close() - Method in class org.apache.storm.blobstore.ClientBlobStore
close() - Method in class org.apache.storm.blobstore.LocalModeClientBlobStore
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.clojure.ClojureSpout
close() - Method in interface org.apache.storm.cluster.IStateStorage: Close the connection to the data store.
close() - Method in class org.apache.storm.cluster.PaceMakerStateStorage
close() - Method in class org.apache.storm.cluster.ZKStateStorage
close() - Method in class org.apache.storm.daemon.drpc.DRPC
close() - Method in class org.apache.storm.daemon.drpc.DRPCServer
close() - Method in class org.apache.storm.daemon.logviewer.LogviewerServer
close() - Method in class org.apache.storm.daemon.logviewer.utils.LogCleaner
close() - Method in class org.apache.storm.daemon.nimbus.TimedWritableByteChannel
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.elasticsearch.trident.TridentEsTopology.FixedBatchSpout: Closes the spout.
close() - Method in class org.apache.storm.event.EventManagerImp
close() - Method in class org.apache.storm.hdfs.blobstore.HdfsClientBlobStore
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 the JmsSpout.session and JmsSpout.connection.
close() - Method in class org.apache.storm.kafka.spout.KafkaSpout
close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter
close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator
close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter
close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitter
close() - Method in class org.apache.storm.loadgen.ScopedTopologySet
close() - Method in class org.apache.storm.LocalCluster
close() - Method in class org.apache.storm.LocalCluster.LocalTopology
close() - Method in class org.apache.storm.LocalDRPC
close() - Method in class org.apache.storm.localizer.AsyncLocalizer
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.CountStat
close() - Method in class org.apache.storm.metric.internal.LatencyStat
close() - Method in class org.apache.storm.metric.internal.MultiCountStat
close() - Method in class org.apache.storm.metric.internal.MultiLatencyStat
close() - Method in class org.apache.storm.metric.internal.RateTracker
close() - Method in class org.apache.storm.metric.timed.TimedResource
close() - Method in interface org.apache.storm.metric.timed.TimerDecorated
close() - Method in interface org.apache.storm.metricstore.MetricStore: Close the metric store.
close() - Method in class org.apache.storm.metricstore.NoOpMetricStore
close() - Method in class org.apache.storm.metricstore.rocksdb.MetricsCleaner
close() - Method in class org.apache.storm.metricstore.rocksdb.RocksDbMetricsWriter
close() - Method in class org.apache.storm.metricstore.rocksdb.RocksDbStore: Shutdown the store.
close() - Method in class org.apache.storm.nimbus.AssignmentDistributionService
close() - Method in interface org.apache.storm.nimbus.ILeaderElector: Method called to allow for cleanup.
close() - Method in class org.apache.storm.pacemaker.PacemakerClient
close() - Method in class org.apache.storm.pacemaker.PacemakerClientPool
close() - Method in class org.apache.storm.perf.utils.BasicMetricsCollector
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.digest.DigestSaslTransportPlugin
close() - Method in class org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin
close() - Method in class org.apache.storm.security.auth.kerberos.NoOpTTrasport
close() - Method in class org.apache.storm.security.auth.sasl.SaslTransportPlugin
close() - Method in class org.apache.storm.security.auth.ThriftClient
close() - Method in class org.apache.storm.security.auth.workertoken.WorkerTokenAuthorizer
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() - Method in class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout
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.InProcessZookeeper
close() - Method in class org.apache.storm.testing.MockLeaderElector
close() - Method in class org.apache.storm.testing.SpoutTracker
close() - Method in class org.apache.storm.testing.staticmocking.MockedClientZookeeper
close() - Method in class org.apache.storm.testing.staticmocking.MockedCluster
close() - Method in class org.apache.storm.testing.staticmocking.MockedSupervisorUtils
close() - Method in class org.apache.storm.testing.staticmocking.MockedZookeeper
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.testing.TmpPath
close() - Method in class org.apache.storm.topology.base.BaseRichSpout
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.DRPCClient.LocalOverride
close() - Method in class org.apache.storm.utils.JCQueue
close() - Method in class org.apache.storm.utils.JCQueueMetrics
close() - Method in class org.apache.storm.utils.NimbusClient.LocalOverride
close() - Method in class org.apache.storm.utils.StormCommonInstaller
close() - Method in interface org.apache.storm.utils.SupervisorIfaceFactory
close() - Method in class org.apache.storm.utils.Time.SimulatedTime
close() - Method in class org.apache.storm.zookeeper.LeaderElectorImp
CLOSE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CLOSE_MESSAGE - Enum constant in enum org.apache.storm.messaging.netty.ControlMessage
closed - Variable in class org.apache.storm.hive.common.HiveWriter
Closed - Enum constant in enum org.apache.storm.messaging.ConnectionWithStatus.Status: The connection channel is closed or being closed.
closeResources() - Method in class org.apache.storm.daemon.worker.WorkerState
CLS - Static variable in class org.apache.storm.st.topology.window.data.TimeData
cluster - Variable in class org.apache.storm.scheduler.multitenant.NodePool
cluster - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
cluster - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.sorter.NodeSorter
cluster - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.sorter.NodeSorterHostProximity
Cluster - Class in org.apache.storm.scheduler: The current state of the storm cluster.
Cluster(Cluster) - Constructor for class org.apache.storm.scheduler.Cluster: Copy constructor.
Cluster(Cluster, Topologies) - Constructor for class org.apache.storm.scheduler.Cluster: Testing Constructor that takes an existing cluster and replaces the topologies in it.
Cluster(INimbus, ResourceMetrics, Map<String, SupervisorDetails>, Map<String, ? extends SchedulerAssignment>, Topologies, Map<String, Object>) - Constructor for class org.apache.storm.scheduler.Cluster
CLUSTER_NAME - Static variable in class org.apache.storm.elasticsearch.common.EsConstants: The cluster name.
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
ClusterStateContext - Class in org.apache.storm.cluster: This class is intended to provide runtime-context to StateStorageFactory implementors, giving information such as what daemon is creating it.
ClusterStateContext() - Constructor for class org.apache.storm.cluster.ClusterStateContext
ClusterStateContext(DaemonType, Map<String, Object>) - Constructor for class org.apache.storm.cluster.ClusterStateContext
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: RegularExpression Id.
COBOL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
coGroupByKey(PairStream<K, V1>) - Method in class org.apache.storm.streams.PairStream: Groups the values of this stream with the values having the same key from the other stream.
CoGroupByKeyProcessor<K,V1,V2> - Class in org.apache.storm.streams.processors: co-group by key implementation.
CoGroupByKeyProcessor(String, String) - Constructor for class org.apache.storm.streams.processors.CoGroupByKeyProcessor
COLLATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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: RegularExpression Id.
COLLATION_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COLLATION_ID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COLLATION_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COLLATION_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
collect(Nimbus.Iface) - Method in class org.apache.storm.perf.utils.BasicMetricsCollector
COLLECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CollectionsTypeName() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
collectMetricsAndKill(String, Integer, int) - 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.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.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: RegularExpression Id.
column - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream
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, int) - Constructor for class org.apache.storm.jdbc.common.Column
Column(String, T, int) - Constructor for class org.apache.storm.jdbc.common.Column
COLUMN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COLUMN_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
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
ColumnType(List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl
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.metric.api.ICombiner
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,A,R> - Interface in org.apache.storm.streams.operations: Interface for aggregating values.
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: RegularExpression Id.
COMMAND_FUNCTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COMMAND_FUNCTION_CODE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CommandExec - Class in org.apache.storm.maven.plugin.util
CommandExec(Mojo) - Constructor for class org.apache.storm.maven.plugin.util.CommandExec
commandFilePath(String, String) - Method in class org.apache.storm.container.oci.OciContainerManager
COMMANDS - Static variable in class org.apache.storm.command.AdminCommands
commit() - Method in class org.apache.storm.blobstore.BlobStoreFile
commit() - Method in class org.apache.storm.blobstore.LocalFsBlobStoreFile
commit() - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile
commit() - Method in class org.apache.storm.redis.state.RedisKeyValueState
commit() - Method in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule
commit() - Method in class org.apache.storm.state.InMemoryKeyValueState
commit() - Method in interface org.apache.storm.state.State: Persist the current state.
commit(long) - Method in class org.apache.storm.redis.state.RedisKeyValueState
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(long) - Method in class org.apache.storm.windowing.persistence.WindowState: Commits the WindowState.
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(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState
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(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(OffsetAndMetadata) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager: Marks an offset as committed.
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 - Enum constant in enum org.apache.storm.spout.CheckPointState.Action: commit the previously prepared transaction.
COMMIT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
COMMIT_FREQ_COUNT - Static variable in class org.apache.storm.hdfs.spout.Configs: Deprecated.
please use HdfsSpout.setCommitFrequencyCount(int)
COMMIT_FREQ_SEC - Static variable in class org.apache.storm.hdfs.spout.Configs: Deprecated.
please use HdfsSpout.setCommitFrequencySec(int)
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.
commitNewVersion(long) - Method in class org.apache.storm.localizer.LocalizedResource
commitNewVersion(long) - Method in class org.apache.storm.localizer.LocallyCachedBlob: Commit the new version and make it available for the end user.
commitNewVersion(long) - Method in class org.apache.storm.localizer.LocallyCachedTopologyBlob
commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition
commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec
COMMITTED - Enum constant in enum org.apache.storm.spout.CheckPointState.State: The checkpoint spout has committed the transaction.
COMMITTED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
committer - Variable in class org.apache.storm.trident.planner.ProcessorNode
COMMITTING - Enum constant in enum org.apache.storm.spout.CheckPointState.State: The checkpoint spout has started committing the transaction and the commit is in progress.
COMMON - Enum constant in enum org.apache.storm.generated.Bolt._Fields
COMMON - Enum constant in enum org.apache.storm.generated.SpoutSpec._Fields
COMMON - Enum constant in enum org.apache.storm.generated.StateSpoutSpec._Fields
COMMON - Enum constant in enum org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy.NodeSortType: New and only node sorting type going forward.
COMMON_CPU_RESOURCE_NAME - Static variable in class org.apache.storm.Constants
COMMON_OFFHEAP_MEMORY_RESOURCE_NAME - Static variable in class org.apache.storm.Constants
COMMON_ONHEAP_MEMORY_RESOURCE_NAME - Static variable in class org.apache.storm.Constants
COMMON_STATS - Enum constant in enum org.apache.storm.generated.ComponentAggregateStats._Fields
COMMON_TOTAL_MEMORY_RESOURCE_NAME - Static variable in class org.apache.storm.Constants
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.
CommonKafkaSpoutConfig<K,V> - Class in org.apache.storm.kafka.spout.internal
CommonKafkaSpoutConfig(CommonKafkaSpoutConfig.Builder<K, V, ?>) - Constructor for class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig: Creates a new CommonKafkaSpoutConfig using a Builder.
CommonKafkaSpoutConfig.Builder<K,V,T extends CommonKafkaSpoutConfig.Builder<K,V,T>> - Class in org.apache.storm.kafka.spout.internal
CommonNonReservedKeyWord() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl: Parses a non-reserved keyword for use as an identifier.
CommonStats - Class in org.apache.storm.stats
CommonStats(int, int) - Constructor for class org.apache.storm.stats.CommonStats
comp() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl: Parses a comparison operator inside a SOME / ALL predicate.
COMPACT - Enum constant in enum org.apache.storm.trident.JoinOutFieldsMode
compactWindow() - Method in class org.apache.storm.windowing.StatefulWindowManager
compactWindow() - Method in class org.apache.storm.windowing.WindowManager: expires events that fall out of the window every EXPIRE_EVENTS_THRESHOLD so that the window does not grow too big.
compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Max
compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Min
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(T, T) - Method in class org.apache.storm.trident.operation.builtin.MaxWithComparator
compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.MinWithComparator
compareTo(Object) - Method in class org.apache.storm.trident.util.IndexedEdge
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.failRequestV2_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_args
compareTo(DistributedRPCInvocations.failRequestV2_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_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(IllegalStateException) - Method in exception org.apache.storm.generated.IllegalStateException
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.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.getOwnerResourceSummaries_args) - Method in class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_args
compareTo(Nimbus.getOwnerResourceSummaries_result) - Method in class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result
compareTo(Nimbus.getSupervisorAssignments_args) - Method in class org.apache.storm.generated.Nimbus.getSupervisorAssignments_args
compareTo(Nimbus.getSupervisorAssignments_result) - Method in class org.apache.storm.generated.Nimbus.getSupervisorAssignments_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.getTopologyInfoByName_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByName_args
compareTo(Nimbus.getTopologyInfoByName_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByName_result
compareTo(Nimbus.getTopologyInfoByNameWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_args
compareTo(Nimbus.getTopologyInfoByNameWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_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.getTopologySummaries_args) - Method in class org.apache.storm.generated.Nimbus.getTopologySummaries_args
compareTo(Nimbus.getTopologySummaries_result) - Method in class org.apache.storm.generated.Nimbus.getTopologySummaries_result
compareTo(Nimbus.getTopologySummary_args) - Method in class org.apache.storm.generated.Nimbus.getTopologySummary_args
compareTo(Nimbus.getTopologySummary_result) - Method in class org.apache.storm.generated.Nimbus.getTopologySummary_result
compareTo(Nimbus.getTopologySummaryByName_args) - Method in class org.apache.storm.generated.Nimbus.getTopologySummaryByName_args
compareTo(Nimbus.getTopologySummaryByName_result) - Method in class org.apache.storm.generated.Nimbus.getTopologySummaryByName_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.isRemoteBlobExists_args) - Method in class org.apache.storm.generated.Nimbus.isRemoteBlobExists_args
compareTo(Nimbus.isRemoteBlobExists_result) - Method in class org.apache.storm.generated.Nimbus.isRemoteBlobExists_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.processWorkerMetrics_args) - Method in class org.apache.storm.generated.Nimbus.processWorkerMetrics_args
compareTo(Nimbus.processWorkerMetrics_result) - Method in class org.apache.storm.generated.Nimbus.processWorkerMetrics_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.sendSupervisorWorkerHeartbeat_args) - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_args
compareTo(Nimbus.sendSupervisorWorkerHeartbeat_result) - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result
compareTo(Nimbus.sendSupervisorWorkerHeartbeats_args) - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_args
compareTo(Nimbus.sendSupervisorWorkerHeartbeats_result) - Method in class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_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(OwnerResourceSummary) - Method in class org.apache.storm.generated.OwnerResourceSummary
compareTo(PrivateWorkerKey) - Method in class org.apache.storm.generated.PrivateWorkerKey
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(SharedMemory) - Method in class org.apache.storm.generated.SharedMemory
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(Supervisor.getLocalAssignmentForStorm_args) - Method in class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_args
compareTo(Supervisor.getLocalAssignmentForStorm_result) - Method in class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result
compareTo(Supervisor.sendSupervisorAssignments_args) - Method in class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args
compareTo(Supervisor.sendSupervisorAssignments_result) - Method in class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result
compareTo(Supervisor.sendSupervisorWorkerHeartbeat_args) - Method in class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_args
compareTo(Supervisor.sendSupervisorWorkerHeartbeat_result) - Method in class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result
compareTo(SupervisorAssignments) - Method in class org.apache.storm.generated.SupervisorAssignments
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(SupervisorWorkerHeartbeat) - Method in class org.apache.storm.generated.SupervisorWorkerHeartbeat
compareTo(SupervisorWorkerHeartbeats) - Method in class org.apache.storm.generated.SupervisorWorkerHeartbeats
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(WorkerMetricList) - Method in class org.apache.storm.generated.WorkerMetricList
compareTo(WorkerMetricPoint) - Method in class org.apache.storm.generated.WorkerMetricPoint
compareTo(WorkerMetrics) - Method in class org.apache.storm.generated.WorkerMetrics
compareTo(WorkerResources) - Method in class org.apache.storm.generated.WorkerResources
compareTo(WorkerSummary) - Method in class org.apache.storm.generated.WorkerSummary
compareTo(WorkerToken) - Method in class org.apache.storm.generated.WorkerToken
compareTo(WorkerTokenInfo) - Method in class org.apache.storm.generated.WorkerTokenInfo
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(Metric) - Method in class org.apache.storm.metricstore.Metric
compareTo(RocksDbKey) - Method in class org.apache.storm.metricstore.rocksdb.RocksDbKey: compares to keys on a byte by byte basis.
compareTo(RasNode) - Method in class org.apache.storm.scheduler.resource.RasNode
compareTo(TimeData) - Method in class org.apache.storm.st.topology.window.data.TimeData
compareTo(Rankable) - Method in class org.apache.storm.starter.tools.RankableObjectWithFields
compareTo(SimpleVersion) - Method in class org.apache.storm.utils.SimpleVersion
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(List<RexNode>, RelDataType, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
compile(Map<String, ISqlStreamsDataSource>, String) - Method in class org.apache.storm.sql.planner.streams.QueryPlanner
compile(RexProgram, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler
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
compileSql(String) - Method in class org.apache.storm.sql.StormSqlContext
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: Constructor.
CompilingClassLoader.CompilerException - Exception in org.apache.storm.sql.javac: Thrown when code cannot be compiled.
CompletableSpout - Interface in org.apache.storm.testing
complete() - Method in interface org.apache.storm.localizer.PortAndAssignment
complete() - Method in class org.apache.storm.localizer.TimePortAndAssignment
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(PriorityQueue, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg
complete(ReturnResultsReducer.ReturnResultsState, TridentCollector) - Method in class org.apache.storm.trident.drpc.ReturnResultsReducer
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(ChainedResult, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
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.CombinerAggregatorCombineImpl
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(CountAsAggregator.State, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator
complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator
complete(T, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.IdentityMultiReducer
complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.MultiReducer
complete(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.GroupedMultiReducer
COMPLETE_LATENCY_MS - Enum constant in enum org.apache.storm.generated.SpoutAggregateStats._Fields
COMPLETE_MS_AVG - Enum constant in enum org.apache.storm.generated.SpoutStats._Fields
completed() - Method in class org.apache.storm.testing.TestEventLogSpout
completeLatencyMs - Variable in class org.apache.storm.hooks.info.SpoutAckInfo
completelyRemove() - Method in class org.apache.storm.localizer.LocalizedResource
completelyRemove() - Method in class org.apache.storm.localizer.LocallyCachedBlob: Completely remove anything that is cached locally for this blob and all tracking files also stored for it.
completelyRemove() - Method in class org.apache.storm.localizer.LocallyCachedTopologyBlob
completeTopology(ILocalCluster, StormTopology) - Static method in class org.apache.storm.Testing: Run a topology to completion capturing all of the messages that are emitted.
completeTopology(ILocalCluster, StormTopology, CompleteTopologyParam) - Static method in class org.apache.storm.Testing: Run a topology to completion capturing all of the messages that are emitted.
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
Component(ComponentType, String, List<ExecutorDetails>, Map<GlobalStreamId, Grouping>) - Constructor for class org.apache.storm.scheduler.Component: Create a new component.
COMPONENT - Enum constant in enum org.apache.storm.generated.Nimbus.debug_args._Fields
COMPONENT_DEBUG - Enum constant in enum org.apache.storm.generated.StormBase._Fields
COMPONENT_DEBUG - Enum constant in enum org.apache.storm.generated.TopologyInfo._Fields
COMPONENT_EXECUTORS - Enum constant in enum org.apache.storm.generated.StormBase._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.ComponentPageInfo._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.ExecutorSummary._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.GlobalStreamId._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.Nimbus.getComponentPageInfo_args._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args._Fields
COMPONENT_ID - Enum constant in enum org.apache.storm.generated.WorkerMetricPoint._Fields
COMPONENT_STRING - Enum constant in enum org.apache.storm.metricstore.rocksdb.KeyType
COMPONENT_TO_DEBUG_ATOM - Static variable in class org.apache.storm.Constants
COMPONENT_TO_NUM_TASKS - Enum constant in enum org.apache.storm.generated.WorkerSummary._Fields
COMPONENT_TO_SHARED_MEMORY - Enum constant in enum org.apache.storm.generated.StormTopology._Fields
COMPONENT_TO_SORTED_TASKS - Static variable in class org.apache.storm.Constants
COMPONENT_TO_STREAM_TO_FIELDS - Static variable in class org.apache.storm.Constants
COMPONENT_TYPE - Enum constant in enum org.apache.storm.generated.ComponentPageInfo._Fields
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.
componentConf(Object) - Static method in class org.apache.storm.daemon.StormCommon
ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Interface in org.apache.storm.topology
componentId - Variable in class org.apache.storm.executor.Executor
componentId - Variable in class org.apache.storm.hdfs.spout.FileLock.LogEntry
componentId - Variable in class org.apache.storm.planner.TaskBundle
componentId - Variable in class org.apache.storm.streams.WindowNode
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) - Constructor for class org.apache.storm.generated.ComponentObject
ComponentObject(ComponentObject._Fields, Object) - 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(StormTopology, String) - Static method in class org.apache.storm.stats.StatsUtil: Get the coponenet type for a give id.
ComponentType - Enum in org.apache.storm.generated
CompoundIdentifier() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl: Parses a compound identifier.
CompoundIdentifierType(List<SqlNode>, List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl: Parses a compound identifier with optional type.
CompoundIdentifierTypeCommaList(List<SqlNode>, 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
compToExecs - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
computeBoltCapacity(List<ExecutorSummary>) - Static method in class org.apache.storm.stats.StatsUtil: computes max bolt capacity.
computeExecutorCapacity(ExecutorSummary) - Static method in class org.apache.storm.stats.StatsUtil: Compute the capacity of a executor. approximation of the % of time spent doing real work.
CONCAT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
concatIfNotNull(String) - Static method in class org.apache.storm.utils.ConfigUtils
CONDITION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
CONDITION_NUMBER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants: RegularExpression Id.
conf - Variable in class org.apache.storm.container.DefaultResourceIsolationManager
conf - Variable in class org.apache.storm.container.oci.OciContainerManager
conf - Variable in class org.apache.storm.daemon.supervisor.Container
conf - Static variable in class org.apache.storm.daemon.ui.filters.AuthorizedUserFilter
conf - Variable in class org.apache.storm.executor.Executor
conf - Variable in class org.apache.storm.security.auth.sasl.SaslTransportPlugin
conf - Variable in class org.apache.storm.topology.ConfigurableTopology
CONF - Static variable in class org.apache.storm.Constants
config - Static variable in class org.apache.storm.daemon.ui.resources.StormApiResource
config - Variable in class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
config() - Method in class org.apache.storm.scheduler.blacklist.BlacklistScheduler
config() - Method in class org.apache.storm.scheduler.DefaultScheduler
config() - Method in class org.apache.storm.scheduler.EvenScheduler
config() - Method in interface org.apache.storm.scheduler.IScheduler: This function returns the scheduler's configuration.
config() - Method in class org.apache.storm.scheduler.IsolationScheduler
config() - Method in class org.apache.storm.scheduler.multitenant.MultitenantScheduler
config() - Method in class org.apache.storm.scheduler.resource.ResourceAwareScheduler
Config - Class in org.apache.storm: Topology configs are specified as a plain old map.
Config() - Constructor for class org.apache.storm.Config
CONFIG - Enum constant in enum org.apache.storm.generated.Nimbus.setLogConfig_args._Fields
CONFIG_KEY_RESOURCES - Static variable in class org.apache.storm.common.AbstractHadoopNimbusPluginAutoCreds
configFilter(Server, Servlet, List<FilterConfiguration>) - Static method in class org.apache.storm.daemon.ui.UIHelpers
configFilter(Server, Servlet, List<FilterConfiguration>, Map<String, String>) - Static method in class org.apache.storm.daemon.ui.UIHelpers: Config filter.
configFilters(ServletContextHandler, List<FilterConfiguration>) - Static method in class org.apache.storm.daemon.ui.UIHelpers: Config filters.
ConfigGetter(String) - Constructor for class org.apache.storm.topology.TopologyBuilder.ConfigGetter
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
configLoader - Variable in class org.apache.storm.scheduler.multitenant.MultitenantScheduler
ConfigLoaderFactoryService - Class in org.apache.storm.scheduler.utils: The user interface to create a concrete IConfigLoader instance for use.
ConfigLoaderFactoryService() - Constructor for class org.apache.storm.scheduler.utils.ConfigLoaderFactoryService
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
Configs.ReaderTypeValidator - Class in org.apache.storm.hdfs.spout
configSsl(Server, Integer, String, String, String, String, String, String, String, Boolean, Boolean, boolean) - Static method in class org.apache.storm.daemon.ui.UIHelpers
configSsl(Server, Integer, String, String, String, String, String, String, String, Boolean, Boolean, Integer, boolean) - Static method in class org.apache.storm.daemon.ui.UIHelpers: configSsl.
ConfigurableTopology - Class in org.apache.storm.topology: Extensions of this class takes a reference to one or more configuration files.
ConfigurableTopology() - Constructor for class org.apache.storm.topology.ConfigurableTopology
configure(Map<String, Object>, StormMetricsRegistry) - Static method in class org.apache.storm.metricstore.