Index
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
andWindowsStore
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.
- 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
andTridentMinMaxOfDevicesTopology.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
andTridentMinMaxOfVehiclesTopology.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
andJmsSpout.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.JedisCommandsContainer
-
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.ProcessorNode
- 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.
HdfsSpout.setArchiveDir(String)