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

A

A - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

abort() - Method in class org.apache.storm.hive.common.HiveWriter

Aborts the current Txn and switches to next Txn.

abort() - Method in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule

ABS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ABSOLUTE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

absoluteHealthCheckDir(Map) - Static method in class org.apache.storm.utils.ConfigUtils

absoluteStormBlobStoreDir(Map<String, Object>) - Static method in class org.apache.storm.utils.ConfigUtils

absoluteStormLocalDir(Map) - Static method in class org.apache.storm.utils.ConfigUtils

AbstractAutoCreds - Class in org.apache.storm.common

The base class that for auto credential plugins that abstracts out some of the common functionality.

AbstractAutoCreds() - Constructor for class org.apache.storm.common.AbstractAutoCreds

AbstractAvroSerializer - Class in org.apache.storm.hdfs.avro

This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects across a Topology.

AbstractAvroSerializer() - Constructor for class org.apache.storm.hdfs.avro.AbstractAvroSerializer

AbstractChannelHandler - Class in org.apache.storm.sql.runtime

AbstractChannelHandler() - Constructor for class org.apache.storm.sql.runtime.AbstractChannelHandler

AbstractDNSToSwitchMapping - Class in org.apache.storm.networktopography

This is a base class for DNS to Switch mappings.

AbstractDNSToSwitchMapping() - Constructor for class org.apache.storm.networktopography.AbstractDNSToSwitchMapping

Create an unconfigured instance

AbstractEsBolt - Class in org.apache.storm.elasticsearch.bolt

AbstractEsBolt(EsConfig) - Constructor for class org.apache.storm.elasticsearch.bolt.AbstractEsBolt

AbstractExecutionResultHandler - Class in org.apache.storm.cassandra

Default interface to define strategies to apply when a query is either succeed or failed.

AbstractExecutionResultHandler() - Constructor for class org.apache.storm.cassandra.AbstractExecutionResultHandler

AbstractHBaseBolt - Class in org.apache.storm.hbase.bolt

AbstractHBaseBolt(String, HBaseMapper) - Constructor for class org.apache.storm.hbase.bolt.AbstractHBaseBolt

AbstractHdfsBolt - Class in org.apache.storm.hdfs.bolt

AbstractHdfsBolt() - Constructor for class org.apache.storm.hdfs.bolt.AbstractHdfsBolt

AbstractHDFSWriter - Class in org.apache.storm.hdfs.common

AbstractHDFSWriter(FileRotationPolicy, Path) - Constructor for class org.apache.storm.hdfs.common.AbstractHDFSWriter

AbstractJdbcBolt - Class in org.apache.storm.jdbc.bolt

AbstractJdbcBolt(ConnectionProvider) - Constructor for class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

Constructor.

AbstractMongoBolt - Class in org.apache.storm.mongodb.bolt

AbstractMongoBolt(String, String) - Constructor for class org.apache.storm.mongodb.bolt.AbstractMongoBolt

AbstractRankerBolt - Class in org.apache.storm.starter.bolt

This abstract bolt provides the basic behavior of bolts that rank objects according to their count.

AbstractRankerBolt() - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt

AbstractRankerBolt(int) - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt

AbstractRankerBolt(int, int) - Constructor for class org.apache.storm.starter.bolt.AbstractRankerBolt

AbstractRedisBolt - Class in org.apache.storm.redis.bolt

AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.

AbstractRedisBolt(JedisPoolConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt

Constructor for single Redis environment (JedisPool)

AbstractRedisBolt(JedisClusterConfig) - Constructor for class org.apache.storm.redis.bolt.AbstractRedisBolt

Constructor for Redis Cluster environment (JedisCluster)

AbstractRedisMapState<T> - Class in org.apache.storm.redis.trident.state

AbstractRedisMapState is base class of any RedisMapState, which implements IBackingMap.

AbstractRedisMapState() - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisMapState

AbstractRedisStateQuerier<T extends State> - Class in org.apache.storm.redis.trident.state

AbstractRedisStateQuerier is base class of any RedisStateQuerier, which implements BaseQueryFunction.

AbstractRedisStateQuerier(RedisLookupMapper) - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier

Constructor

AbstractRedisStateUpdater<T extends State> - Class in org.apache.storm.redis.trident.state

AbstractRedisStateUpdater is base class of any RedisStateUpdater, which implements BaseStateUpdater.

AbstractRedisStateUpdater(RedisStoreMapper) - Constructor for class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

Constructor

AbstractSaslClientCallbackHandler - Class in org.apache.storm.security.auth

AbstractSaslClientCallbackHandler() - Constructor for class org.apache.storm.security.auth.AbstractSaslClientCallbackHandler

AbstractSaslServerCallbackHandler - Class in org.apache.storm.security.auth

AbstractSaslServerCallbackHandler(boolean) - Constructor for class org.apache.storm.security.auth.AbstractSaslServerCallbackHandler

AbstractTridentProcessor - Class in org.apache.storm.sql

AbstractTridentProcessor() - Constructor for class org.apache.storm.sql.AbstractTridentProcessor

AbstractTridentWindowManager<T> - Class in org.apache.storm.trident.windowing

Basic functionality to manage trident tuple events using WindowManager and WindowsStore for storing tuples and triggers related information.

AbstractTridentWindowManager(WindowConfig, String, WindowsStore, Aggregator, BatchOutputCollector) - Constructor for class org.apache.storm.trident.windowing.AbstractTridentWindowManager

AbstractUserTopology - Class in org.apache.storm.jdbc.topology

AbstractUserTopology() - Constructor for class org.apache.storm.jdbc.topology.AbstractUserTopology

AbstractValuesProcessor - Class in org.apache.storm.sql.runtime

Subclass of AbstractTupleProcessor provides a series of tuple.

AbstractValuesProcessor() - Constructor for class org.apache.storm.sql.runtime.AbstractValuesProcessor

accept(TridentTuple) - Method in interface org.apache.storm.trident.operation.Consumer

Performs the operation on the input trident tuple.

AccessControl - Class in org.apache.storm.generated

AccessControl() - Constructor for class org.apache.storm.generated.AccessControl

AccessControl(AccessControlType, int) - Constructor for class org.apache.storm.generated.AccessControl

AccessControl(AccessControl) - Constructor for class org.apache.storm.generated.AccessControl

Performs a deep copy on other.

AccessControl._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

accessControlToString(AccessControl) - Static method in class org.apache.storm.blobstore.BlobStoreAclHandler

AccessControlType - Enum in org.apache.storm.generated

AccessLoggingFilter - Class in org.apache.storm.logging.filters

AccessLoggingFilter() - Constructor for class org.apache.storm.logging.filters.AccessLoggingFilter

ack(Object) - Method in class org.apache.storm.clojure.ClojureSpout

ack(Tuple) - Method in class org.apache.storm.coordination.BatchOutputCollectorImpl

ack(Tuple) - Method in class org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

ack(Object) - Method in class org.apache.storm.drpc.DRPCSpout

ack(Object) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

ack(long) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

ack(Object) - Method in class org.apache.storm.eventhubs.spout.EventHubSpout

ack(String) - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager

ack(String) - Method in class org.apache.storm.eventhubs.spout.PartitionManager

ack(String) - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager

ack(Object) - Method in class org.apache.storm.hbase.topology.WordSpout

ack(Object) - Method in class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpout

ack(Object) - Method in class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpout

ack(Object) - Method in class org.apache.storm.hdfs.spout.HdfsSpout

ack(long) - Method in class org.apache.storm.hdfs.trident.FixedBatchSpout

ack(Object) - Method in class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout

ack(Object) - Method in class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout

ack(Object) - Method in class org.apache.storm.hive.bolt.HiveTopologyPartitioned.UserDataSpout

ack(long) - Method in class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout

ack(Object) - Method in class org.apache.storm.jdbc.spout.UserSpout

ack(Object) - Method in class org.apache.storm.jms.spout.JmsSpout

Ack a successfully handled message by the matching JmsMessageID.

ack(Object) - Method in class org.apache.storm.kafka.KafkaSpout

Deprecated.

ack(Long) - Method in class org.apache.storm.kafka.PartitionManager

ack(Object) - Method in class org.apache.storm.kafka.spout.KafkaSpout

ack(Object) - Method in class org.apache.storm.kinesis.spout.KinesisSpout

ack(Object) - Method in class org.apache.storm.mongodb.topology.WordSpout

ack(Object) - Method in class org.apache.storm.mqtt.spout.MqttSpout

Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed.

ack(long) - Method in class org.apache.storm.opentsdb.MetricGenBatchSpout

ack(Object) - Method in class org.apache.storm.perf.spout.ConstSpout

ack(Object) - Method in class org.apache.storm.perf.spout.StringGenSpout

ack(Object) - Method in class org.apache.storm.redis.topology.WordSpout

ack(Object) - Method in class org.apache.storm.spout.CheckpointSpout

ack(Object) - Method in interface org.apache.storm.spout.ISpout

Storm has determined that the tuple emitted by this spout with the msgId identifier has been fully processed.

ack(Object) - Method in class org.apache.storm.spout.ShellSpout

ack(long) - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.TridentSocketSpout

ack(Object) - Method in class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpout

ack(Object) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout

ack(Object) - Method in class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout

ack(Object) - Method in class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout

ack(Object) - Method in class org.apache.storm.starter.spout.RandomIntegerSpout

ack(long) - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout

ack(Object) - Method in class org.apache.storm.starter.spout.RandomSentenceSpout

ack(Object) - Method in class org.apache.storm.starter.ThroughputVsLatency.FastRandomSentenceSpout

ack(Tuple) - Method in interface org.apache.storm.task.IOutputCollector

ack(Tuple) - Method in class org.apache.storm.task.OutputCollector

ack(Object) - Method in interface org.apache.storm.testing.AckFailDelegate

ack(Object) - Method in class org.apache.storm.testing.AckFailMapTracker

ack(Object) - Method in class org.apache.storm.testing.AckTracker

ack(Object) - Method in class org.apache.storm.testing.FeederSpout

ack(Object) - Method in class org.apache.storm.testing.FixedTupleSpout

ack(Object) - Method in class org.apache.storm.testing.SpoutTracker

ack(Object) - Method in class org.apache.storm.testing.TestEventLogSpout

ack(Object) - Method in class org.apache.storm.testing.TestPlannerSpout

ack(Object) - Method in class org.apache.storm.testing.TestWordSpout

ack(Object) - Method in class org.apache.storm.topology.base.BaseRichSpout

ack(Object) - Method in class org.apache.storm.transactional.TransactionalSpoutCoordinator

ack(long) - Method in interface org.apache.storm.trident.spout.IBatchSpout

ack(Object) - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer

ack(long) - Method in class org.apache.storm.trident.testing.FixedBatchSpout

ack(Object) - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator

ack() - Method in class org.apache.storm.utils.BatchHelper

acked(Long) - Method in class org.apache.storm.kafka.ExponentialBackoffMsgRetryManager

acked(Long) - Method in interface org.apache.storm.kafka.FailedMsgRetryManager

Message corresponding to the offset, was acked to kafka spout.

acked(KinesisMessageId) - Method in class org.apache.storm.kinesis.spout.ExponentialBackoffRetrier

acked(KinesisMessageId) - Method in interface org.apache.storm.kinesis.spout.FailedMessageRetryHandler

message with messageId succeeded/acked in the spout

AckFailDelegate - Interface in org.apache.storm.testing

AckFailMapTracker - Class in org.apache.storm.testing

AckFailMapTracker() - Constructor for class org.apache.storm.testing.AckFailMapTracker

ackingTaskId - Variable in class org.apache.storm.hooks.info.BoltAckInfo

AckTracker - Class in org.apache.storm.testing

AckTracker() - Constructor for class org.apache.storm.testing.AckTracker

AclEnforcement - Class in org.apache.storm.zookeeper

This is code intended to enforce ZK ACLs.

AclEnforcement() - Constructor for class org.apache.storm.zookeeper.AclEnforcement

AclFunctionEntry(Collection<String>, String) - Constructor for class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry

acquireNewPort() - Static method in class org.apache.storm.utils.InprocMessaging

acquireOldestExpiredLock(FileSystem, Path, int, String) - Static method in class org.apache.storm.hdfs.spout.FileLock

Finds a oldest expired lock file (using modification timestamp), then takes ownership of the lock file Impt: Assumes access to lockFilesDir has been externally synchronized such that only one thread accessing the same thread

ACTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

activate() - Method in class org.apache.storm.clojure.ClojureSpout

activate(String, AsyncMethodCallback<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

activate(String, AsyncMethodCallback<Void>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

activate() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.activate

activate(String) - Method in class org.apache.storm.generated.Nimbus.Client

activate(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

activate() - Constructor for class org.apache.storm.generated.Nimbus.Processor.activate

activate() - Method in class org.apache.storm.hbase.topology.WordSpout

activate(String) - Method in interface org.apache.storm.ILocalCluster

activate() - Method in class org.apache.storm.jdbc.spout.UserSpout

activate() - Method in class org.apache.storm.kafka.spout.KafkaSpout

activate() - Method in class org.apache.storm.kinesis.spout.KinesisSpout

activate() - Method in class org.apache.storm.mongodb.topology.WordSpout

activate() - Method in class org.apache.storm.mqtt.spout.MqttSpout

activate() - Method in class org.apache.storm.pmml.RawInputFromCSVSpout

activate() - Method in class org.apache.storm.redis.topology.WordSpout

activate() - Method in interface org.apache.storm.spout.ISpout

Called when a spout has been activated out of a deactivated mode.

activate() - Method in class org.apache.storm.spout.ShellSpout

activate() - Method in class org.apache.storm.testing.FixedTupleSpout

activate() - Method in class org.apache.storm.topology.base.BaseRichSpout

activate() - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer

activate() - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator

activate_args() - Constructor for class org.apache.storm.generated.Nimbus.activate_args

activate_args(String) - Constructor for class org.apache.storm.generated.Nimbus.activate_args

activate_args(Nimbus.activate_args) - Constructor for class org.apache.storm.generated.Nimbus.activate_args

Performs a deep copy on other.

activate_call(String, AsyncMethodCallback<Void>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.activate_call

activate_result() - Constructor for class org.apache.storm.generated.Nimbus.activate_result

activate_result(NotAliveException, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.activate_result

activate_result(Nimbus.activate_result) - Constructor for class org.apache.storm.generated.Nimbus.activate_result

Performs a deep copy on other.

activateStorm(String, StormBase, Map<String, Object>) - Method in interface org.apache.storm.cluster.IStormClusterState

activateStorm(String, StormBase, Map<String, Object>) - Method in class org.apache.storm.cluster.StormClusterStateImpl

activeKeys() - Method in interface org.apache.storm.cluster.IStormClusterState

activeKeys() - Method in class org.apache.storm.cluster.StormClusterStateImpl

activeStorms() - Method in interface org.apache.storm.cluster.IStormClusterState

activeStorms() - Method in class org.apache.storm.cluster.StormClusterStateImpl

ADA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

add(Runnable) - Method in interface org.apache.storm.event.EventManager

add(Runnable) - Method in class org.apache.storm.event.EventManagerImp

add(String, LocalizedResource, boolean) - Method in class org.apache.storm.localizer.LocalizedResourceSet

add(TaskMessage) - Method in class org.apache.storm.messaging.netty.MessageBuffer

add(Byte, Byte) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ByteSum

add(Long, Values) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Count

add(Double, Double) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.DoubleAvg

add(Double, Double) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.DoubleSum

add(Float, Float) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.FloatSum

add(Integer, Integer) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.IntAvg

add(Integer, Integer) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.IntSum

add(Long, Long) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.LongSum

add(T, T) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Max

add(T, T) - Method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Min

add(Short, Short) - Static method in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ShortSum

ADD - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

add(int, Object, List<Object>) - Method in interface org.apache.storm.state.ISynchronizeOutputCollector

add(int, Object, List<Object>) - Method in class org.apache.storm.state.SynchronizeOutputCollector

add(StormTimer.QueueEntry) - Method in class org.apache.storm.StormTimer.StormTimerTask

add(int, Object) - Method in class org.apache.storm.trident.tuple.ConsList

add(Object, V) - Method in class org.apache.storm.utils.KeyedRoundRobinQueue

add(Object) - Method in class org.apache.storm.utils.ListDelegate

add(int, Object) - Method in class org.apache.storm.utils.ListDelegate

add(HashMap<Integer, ArrayList<TaskMessage>>) - Method in class org.apache.storm.utils.TransferDrainer

add(T) - Method in class org.apache.storm.windowing.WindowManager

Add an event into the window, with System.currentTimeMillis() as the tracking ts.

add(T, long) - Method in class org.apache.storm.windowing.WindowManager

Add an event into the window, with the given ts as the tracking ts.

add(Event<T>) - Method in class org.apache.storm.windowing.WindowManager

Tracks a window event

add_escapes(String) - Method in exception org.apache.storm.sql.parser.impl.ParseException

Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.

add_listener(ClusterStateListener) - Method in interface org.apache.storm.cluster.ClusterState

Add a ClusterStateListener to the connection.

add_listener(ConnectionStateListener) - Method in interface org.apache.storm.cluster.IStateStorage

Add a StateStorageListener to the connection.

add_listener(ConnectionStateListener) - Method in class org.apache.storm.cluster.ZKStateStorage

add_to_acl(AccessControl) - Method in class org.apache.storm.generated.SettableBlobMeta

add_to_args_list(JavaObjectArg) - Method in class org.apache.storm.generated.JavaObject

add_to_dependency_artifacts(String) - Method in class org.apache.storm.generated.StormTopology

add_to_dependency_jars(String) - Method in class org.apache.storm.generated.StormTopology

add_to_errors(ErrorInfo) - Method in class org.apache.storm.generated.ComponentPageInfo

add_to_exec_stats(ExecutorAggregateStats) - Method in class org.apache.storm.generated.ComponentPageInfo

add_to_executors(ExecutorInfo) - Method in class org.apache.storm.generated.LocalAssignment

add_to_executors(ExecutorInfo) - Method in class org.apache.storm.generated.LSWorkerHeartbeat

add_to_executors(ExecutorSummary) - Method in class org.apache.storm.generated.TopologyInfo

add_to_groups(String) - Method in class org.apache.storm.generated.LSTopoHistory

add_to_keys(String) - Method in class org.apache.storm.generated.ListBlobsResult

add_to_meta(long) - Method in class org.apache.storm.generated.SupervisorInfo

add_to_nimbuses(NimbusSummary) - Method in class org.apache.storm.generated.ClusterSummary

add_to_output_fields(String) - Method in class org.apache.storm.generated.StreamInfo

add_to_port(long) - Method in class org.apache.storm.generated.NodeInfo

add_to_pulseIds(String) - Method in class org.apache.storm.generated.HBNodes

add_to_pulses(HBPulse) - Method in class org.apache.storm.generated.HBRecords

add_to_success(ProfileRequest) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result

add_to_supervisor_summaries(SupervisorSummary) - Method in class org.apache.storm.generated.SupervisorPageInfo

add_to_supervisors(SupervisorSummary) - Method in class org.apache.storm.generated.ClusterSummary

add_to_topo_history(LSTopoHistory) - Method in class org.apache.storm.generated.LSTopoHistoryList

add_to_topo_ids(String) - Method in class org.apache.storm.generated.TopologyHistoryInfo

add_to_topologies(TopologySummary) - Method in class org.apache.storm.generated.ClusterSummary

add_to_used_ports(long) - Method in class org.apache.storm.generated.SupervisorInfo

add_to_users(String) - Method in class org.apache.storm.generated.LSTopoHistory

add_to_worker_hooks(ByteBuffer) - Method in class org.apache.storm.generated.StormTopology

add_to_worker_summaries(WorkerSummary) - Method in class org.apache.storm.generated.SupervisorPageInfo

add_to_workers(WorkerSummary) - Method in class org.apache.storm.generated.TopologyPageInfo

addAll(Collection<? extends TopicPartition>) - Method in enum org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartitionRegistry

addAll(Collection<?>) - Method in class org.apache.storm.utils.ListDelegate

addAll(int, Collection<?>) - Method in class org.apache.storm.utils.ListDelegate

addAllBolts(List<BoltDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef

Adds a list of bolt definitions.

addAllComponents(List<BeanDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef

Adds a list of component definitions.

addAllSpouts(List<SpoutDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef

Adds a list of spout definitions.

addAllStreams(List<StreamDef>, boolean) - Method in class org.apache.storm.flux.model.TopologyDef

Adds a list of stream definitions.

addAnchor(String) - Method in class org.apache.storm.multilang.ShellMsg

addAvroKryoSerializations(Config) - Static method in class org.apache.storm.hdfs.avro.AvroUtils

A helper method to extract avro serialization configurations from the topology configuration and register specific kryo serializers as necessary.

addBatch(Tuple) - Method in class org.apache.storm.utils.BatchHelper

addBolt(IBatchBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IBatchBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IRichBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

Deprecated.

addBolt(IRichBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

Deprecated.

addBolt(IBasicBolt, Number) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

addBolt(IBasicBolt) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

addBolt(String, Object) - Method in class org.apache.storm.flux.model.ExecutionContext

addClassLoader(CompilingClassLoader) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator

addColumn(HBaseProjectionCriteria.ColumnMetaData) - Method in class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria

Only this column from the the columnFamily will be included as result of HBase lookup.

addColumn(byte[], byte[], long, byte[]) - Method in class org.apache.storm.hbase.common.ColumnList

Add a standard HBase column.

addColumn(byte[], byte[], byte[]) - Method in class org.apache.storm.hbase.common.ColumnList

Add a standard HBase column

addColumn(IColumn) - Method in class org.apache.storm.hbase.common.ColumnList

Add a standard HBase column given an instance of a class that implements the IColumn interface.

addColumnFamily(String) - Method in class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria

all columns from this family will be included as result of HBase lookup.

addColumnFamily(byte[]) - Method in class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria

all columns from this family will be included as result of HBase lookup.

addComponent(String, Object) - Method in class org.apache.storm.flux.model.ExecutionContext

addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Add configuration for this bolt.

addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Add configuration for this bolt.

addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Add configuration for this spout.

addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Add configuration for this spout.

addConfiguration(String, Object) - Method in class org.apache.storm.topology.BaseConfigurationDeclarer

addConfiguration(String, Object) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer

addConfigurations(Map<String, Object>) - Method in interface org.apache.storm.topology.ComponentConfigurationDeclarer

addConfigurations(Map<String, Object>) - Method in class org.apache.storm.topology.TopologyBuilder.ConfigGetter

addCounter(byte[], byte[], long) - Method in class org.apache.storm.hbase.common.ColumnList

Add an HBase counter column.

addCounter(ICounter) - Method in class org.apache.storm.hbase.common.ColumnList

Add an HBase counter column given an instance of a class that implements the ICounter interface.

addEscapes(String) - Static method in error org.apache.storm.sql.parser.impl.TokenMgrError

Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string

addGroup(Group) - Method in class org.apache.storm.trident.graph.GraphGrouper

additionalKey - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier

additionalKey - Variable in class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

addListener(CuratorFramework, ConnectionStateListener) - Static method in class org.apache.storm.zookeeper.Zookeeper

addLocalizedResourceInDir(String, LocalizedResourceSet, boolean) - Method in class org.apache.storm.localizer.Localizer

addMockData(String, String, Values...) - Method in class org.apache.storm.testing.MockedSources

add mock data for the spout.

addMockData(String, Values...) - Method in class org.apache.storm.testing.MockedSources

addNimbusHost(String, NimbusSummary) - Method in interface org.apache.storm.cluster.IStormClusterState

addNimbusHost(String, NimbusSummary) - Method in class org.apache.storm.cluster.StormClusterStateImpl

addNode(Node) - Method in class org.apache.storm.trident.TridentTopology

addPartition(Partition) - Method in class org.apache.storm.eventhubs.trident.Partitions

addPartition(int, Broker) - Method in class org.apache.storm.kafka.trident.GlobalPartitionInformation

addProfilerActions(Set<Slot.TopoProfileAction>) - Method in class org.apache.storm.daemon.supervisor.Slot

addReceiver(TridentProcessor) - Method in class org.apache.storm.trident.planner.SubtopologyBolt.InitialReceiver

addReference(String) - Method in class org.apache.storm.localizer.LocalizedResource

addReferences(List<LocalResource>, String, String) - Method in class org.apache.storm.localizer.Localizer

addResources(LocalizedResourceSet) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet

addResourcesForExec(ExecutorDetails, Map<String, Double>) - Method in class org.apache.storm.scheduler.TopologyDetails

add resource requirements for a executor

addResourcesForSet(Iterator<LocalizedResource>, LocalizedResourceSet) - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet

AddressedTuple - Class in org.apache.storm.tuple

A Tuple that is addressed to a destination.

AddressedTuple(int, Tuple) - Constructor for class org.apache.storm.tuple.AddressedTuple

addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt

addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt

addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt

addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions

Deprecated.

addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions

addShutdownHookWithForceKillIn1Sec(Runnable) - Static method in class org.apache.storm.utils.Utils

Adds the user supplied function as a shutdown hook for cleanup.

addSourcedNode(List<Stream>, Node) - Method in class org.apache.storm.trident.TridentTopology

addSourcedNode(Stream, Node) - Method in class org.apache.storm.trident.TridentTopology

addSourcedStateNode(List<Stream>, Node) - Method in class org.apache.storm.trident.TridentTopology

addSourcedStateNode(Stream, Node) - Method in class org.apache.storm.trident.TridentTopology

addSpout(String, IRichSpout) - Method in class org.apache.storm.flux.model.ExecutionContext

addStream(IAggregatableStream) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator

addTaskHook(ITaskHook) - Method in class org.apache.storm.task.TopologyContext

addToAckMsgs(KafkaSpoutMessageId) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager

addToClasspath(String, Collection<String>) - Static method in class org.apache.storm.utils.Utils

addToClasspath(Collection<String>, Collection<String>) - Static method in class org.apache.storm.utils.Utils

addToClasspathImpl(String, Collection<String>) - Method in class org.apache.storm.utils.Utils

addToClasspathImpl(Collection<String>, Collection<String>) - Method in class org.apache.storm.utils.Utils

addToEmitMsgs(long) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager

addToLeaderLockQueue() - Method in interface org.apache.storm.nimbus.ILeaderElector

queue up for leadership lock.

addToLeaderLockQueue() - Method in class org.apache.storm.zookeeper.LeaderElectorImp

addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.DefaultPool

addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.FreePool

addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.IsolatedPool

addTopology(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.NodePool

Add a topology to the pool

addTopologyHistory(LSTopoHistory) - Method in class org.apache.storm.utils.LocalState

addTopologyToAttemptedQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User

addTopologyToInvalidQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User

addTopologyToPendingQueue(TopologyDetails, Cluster) - Method in class org.apache.storm.scheduler.resource.User

addTopologyToPendingQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User

addTopologyToRunningQueue(TopologyDetails, Cluster) - Method in class org.apache.storm.scheduler.resource.User

addTopologyToRunningQueue(TopologyDetails) - Method in class org.apache.storm.scheduler.resource.User

addTuple(Object) - Method in class org.apache.storm.multilang.ShellMsg

addTuplesBatch(Object, List<TridentTuple>) - Method in class org.apache.storm.trident.windowing.InMemoryTridentWindowManager

addTuplesBatch(Object, List<TridentTuple>) - Method in interface org.apache.storm.trident.windowing.ITridentWindowManager

Add received batch of tuples to cache/store and add them to WindowManager

addTuplesBatch(Object, List<TridentTuple>) - Method in class org.apache.storm.trident.windowing.StoreBasedTridentWindowManager

addVersions(StormTopology) - Static method in class org.apache.storm.utils.Utils

Add version information to the given topology

addWorkerHook(IWorkerHook) - Method in class org.apache.storm.topology.TopologyBuilder

Add a new worker lifecycle hook

adjustBeginLineColumn(int, int) - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream

Method to adjust line and column numbers for the start of a token.

ADMIN - Static variable in class org.apache.storm.blobstore.BlobStoreAclHandler

ADMIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AdvancedFSOps - Class in org.apache.storm.daemon.supervisor

AdvancedFSOps(Map<String, Object>) - Constructor for class org.apache.storm.daemon.supervisor.AdvancedFSOps

advanceTime(long) - Static method in class org.apache.storm.utils.Time

advanceTimeNanos(long) - Static method in class org.apache.storm.utils.Time

advanceTimeSecs(long) - Static method in class org.apache.storm.utils.Time

AetherUtils - Class in org.apache.storm.submit.dependency

Utility class of Aether.

AFTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

afterExecute(Runnable, Throwable) - Method in class org.apache.storm.utils.ExtendedThreadPoolExecutor

aggPartition(S) - Method in interface org.apache.storm.trident.fluent.GlobalAggregationScheme

aggPartition(GroupedStream) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

aggregate(Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(Fields, Aggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(Fields, CombinerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(Fields, ReducerAggregator, Fields) - Method in interface org.apache.storm.trident.fluent.ChainedFullAggregatorDeclarer

aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.fluent.GroupedStream

aggregate(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator

aggregate(ComparisonAggregator.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator

aggregate(FirstN.FirstNAgg.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg

aggregate(PriorityQueue, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg

aggregate(ChainedResult, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

aggregate(Result, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

aggregate(Object[], TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator

aggregate(Result, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl

aggregate(SingleEmitAggregator.SingleEmitState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator

aggregate(Aggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(Fields, Aggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(Fields, CombinerAggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(Fields, ReducerAggregator, Fields) - Method in class org.apache.storm.trident.Stream

aggregate(CountAsAggregator.State, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator

AggregateProcessor - Class in org.apache.storm.trident.planner.processor

AggregateProcessor(Fields, Aggregator) - Constructor for class org.apache.storm.trident.planner.processor.AggregateProcessor

Aggregator<T> - Interface in org.apache.storm.trident.operation

aggregator - Variable in class org.apache.storm.trident.windowing.AbstractTridentWindowManager

all() - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder

Includes all tuple fields.

all() - Static method in class org.apache.storm.coordination.CoordinatedBolt.SourceArgs

all(NullStruct) - Static method in class org.apache.storm.generated.Grouping

ALL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

all() - Static method in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType

All_CONFIGS() - Static method in class org.apache.storm.utils.ConfigUtils

allGrouping() - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer

allGrouping(String) - Method in interface org.apache.storm.drpc.LinearDRPCInputDeclarer

allGrouping(String) - Method in interface org.apache.storm.topology.InputDeclarer

The stream is replicated across all the bolt’s tasks.

allGrouping(String, String) - Method in interface org.apache.storm.topology.InputDeclarer

The stream is replicated across all the bolt’s tasks.

allGrouping(String) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter

allGrouping(String, String) - Method in class org.apache.storm.topology.TopologyBuilder.BoltGetter

ALLOCATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

allOutputFields - Variable in class org.apache.storm.trident.planner.Node

ALLOW - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

allSlotsAvailableForScheduling(Collection<SupervisorDetails>, Topologies, Set<String>) - Method in interface org.apache.storm.scheduler.INimbus

Returns all slots that are available for the next round of scheduling.

AlreadyAliveException - Exception in org.apache.storm.generated

AlreadyAliveException() - Constructor for exception org.apache.storm.generated.AlreadyAliveException

AlreadyAliveException(String) - Constructor for exception org.apache.storm.generated.AlreadyAliveException

AlreadyAliveException(AlreadyAliveException) - Constructor for exception org.apache.storm.generated.AlreadyAliveException

Performs a deep copy on other.

AlreadyAliveException._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ALTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AlternateRackDNSToSwitchMapping - Class in org.apache.storm.testing

This class implements the DNSToSwitchMapping interface It alternates bewteen RACK1 and RACK2 for the hosts.

AlternateRackDNSToSwitchMapping() - Constructor for class org.apache.storm.testing.AlternateRackDNSToSwitchMapping

ALWAYS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AnchoredWordCount - Class in org.apache.storm.starter

AnchoredWordCount() - Constructor for class org.apache.storm.starter.AnchoredWordCount

AnchoredWordCount.RandomSentenceSpout - Class in org.apache.storm.starter

AnchoredWordCount.SplitSentence - Class in org.apache.storm.starter

AnchoredWordCount.WordCount - Class in org.apache.storm.starter

AND - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ANOTHER_BOLT - Static variable in class org.apache.storm.jms.example.ExampleJmsTopology

ANY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AppendCollector - Class in org.apache.storm.trident.planner.processor

AppendCollector(TridentContext) - Constructor for class org.apache.storm.trident.planner.processor.AppendCollector

apply(PreparedStatement, List<Column>) - Method in interface org.apache.storm.cassandra.query.impl.PreparedStatementBinder

apply(PreparedStatement, List<Column>) - Method in class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.CQL3NamedSettersBinder

apply(PreparedStatement, List<Column>) - Method in class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.DefaultBinder

apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.ByTopicRecordTranslator

apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.DefaultRecordTranslator

apply(V) - Method in interface org.apache.storm.kafka.spout.Func

apply(ConsumerRecord<K, V>) - Method in interface org.apache.storm.kafka.spout.RecordTranslator

Translate the ConsumerRecord into a list of objects that can be emitted

apply(ConsumerRecord<K, V>) - Method in class org.apache.storm.kafka.spout.SimpleRecordTranslator

apply(IMetricsConsumer.DataPoint) - Method in class org.apache.storm.metric.filter.FilterByMetricName

APPLY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

apply(Stream) - Method in interface org.apache.storm.trident.operation.Assembly

Applies the Assembly to a given Stream

apply(Stream) - Method in class org.apache.storm.trident.operation.builtin.FirstN

applyAssembly(Assembly) - Method in class org.apache.storm.trident.Stream

Applies an Assembly to this Stream.

applyToSourceContent(String) - Method in interface org.apache.storm.hack.relocation.Relocator

applyToSourceContent(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator

applyUUIDToFileName(String) - Static method in class org.apache.storm.blobstore.BlobStoreUtils

APPROX_NUMERIC_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ARCHIVE_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs

ARCHIVESDIR - Static variable in class org.apache.storm.localizer.Localizer

ARE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.Container

areAllProcessesDead() - Method in interface org.apache.storm.daemon.supervisor.Killable

areAllProcessesDead() - Method in class org.apache.storm.daemon.supervisor.LocalContainer

areTaskIdsNeeded() - Method in class org.apache.storm.multilang.ShellMsg

Arg(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Arg0(List, SqlAbstractParserImpl.ExprContext) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

ARGS_STREAM - Static variable in class org.apache.storm.drpc.PrepareRequest

ARRAY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ArrayConstructor() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses an ARRAY constructor

ArrayListSerializer - Class in org.apache.storm.serialization.types

ArrayListSerializer() - Constructor for class org.apache.storm.serialization.types.ArrayListSerializer

arrivalRate() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics

artifactToString(Artifact) - Static method in class org.apache.storm.submit.dependency.AetherUtils

Convert Artifact object to String for printing.

as(String) - Method in class org.apache.storm.cassandra.query.selector.FieldSelector

Sets an alias for this field.

AS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ASC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ASENSITIVE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

asOpaqueEmitter() - Method in class org.apache.storm.kafka.trident.TridentKafkaEmitter

Assembly - Interface in org.apache.storm.trident.operation

The Assembly interface provides a means to encapsulate logic applied to a Stream.

assertFull() - Method in enum org.apache.storm.daemon.supervisor.Container.ContainerType

ASSERTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

assign(WorkerSlot, String, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.Cluster

Assign the slot to the executors for this topology.

assign(String, Collection<ExecutorDetails>, Cluster) - Method in class org.apache.storm.scheduler.multitenant.Node

Assign a free slot on the node to the following topology and executors.

assign(WorkerSlot, TopologyDetails, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.resource.RAS_Node

Assigns a worker to a node

assign(WorkerSlot, Collection<ExecutorDetails>) - Method in class org.apache.storm.scheduler.SchedulerAssignmentImpl

Assign the slot to executors.

AssignableMetric - Class in org.apache.storm.metric.api

AssignableMetric(Object) - Constructor for class org.apache.storm.metric.api.AssignableMetric

AssignableShellMetric - Class in org.apache.storm.metric.api.rpc

AssignableShellMetric(Object) - Constructor for class org.apache.storm.metric.api.rpc.AssignableShellMetric

assigned(Collection<Integer>) - Method in class org.apache.storm.daemon.supervisor.StandaloneSupervisor

assigned(Collection<Integer>) - Method in interface org.apache.storm.scheduler.ISupervisor

Assignment - Class in org.apache.storm.generated

Assignment() - Constructor for class org.apache.storm.generated.Assignment

Assignment(String) - Constructor for class org.apache.storm.generated.Assignment

Assignment(Assignment) - Constructor for class org.apache.storm.generated.Assignment

Performs a deep copy on other.

ASSIGNMENT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

Assignment._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

assignmentInfo(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

assignmentInfo(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

assignmentInfoWithVersion(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

assignmentInfoWithVersion(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

assignmentPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils

assignments(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

assignments(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

ASSIGNMENTS_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils

ASSIGNMENTS_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils

assignmentVersion(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

assignmentVersion(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

assignSlots(Topologies, Map<String, Collection<WorkerSlot>>) - Method in interface org.apache.storm.scheduler.INimbus

this is called after the assignment is changed in ZK

assignSlotTo(Node) - Method in class org.apache.storm.scheduler.multitenant.NodePool.RoundRobinSlotScheduler

Assign a slot to the given node.

assoc(Object, Object) - Method in class org.apache.storm.utils.IndifferentAccessMap

assocEx(Object, Object) - Method in class org.apache.storm.utils.IndifferentAccessMap

asTransactionalEmitter() - Method in class org.apache.storm.kafka.trident.TridentKafkaEmitter

ASYMMETRIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

async(CQLStatementBuilder...) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder

Builds multiple statements which will be executed asynchronously.

AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncClient

AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncClient

AsyncClient(TProtocolFactory, TAsyncClientManager, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient

AsyncExecutor<T> - Class in org.apache.storm.cassandra.executor

Service to asynchronously executes cassandra statements.

AsyncExecutor(Session, AsyncResultHandler<T>) - Constructor for class org.apache.storm.cassandra.executor.AsyncExecutor

Creates a new AsyncExecutor instance.

AsyncExecutorProvider - Class in org.apache.storm.cassandra.executor

This class must be used to obtain a single instance of AsyncExecutor per storm executor.

AsyncExecutorProvider() - Constructor for class org.apache.storm.cassandra.executor.AsyncExecutorProvider

AsyncLocalizer - Class in org.apache.storm.localizer

This is a wrapper around the Localizer class that provides the desired async interface to Slot.

AsyncLocalizer(Map<String, Object>, Localizer) - Constructor for class org.apache.storm.localizer.AsyncLocalizer

asyncLoop(Callable, boolean, Thread.UncaughtExceptionHandler, int, boolean, boolean, String) - Static method in class org.apache.storm.utils.Utils

Creates a thread that calls the given code repeatedly, sleeping for an interval of seconds equal to the return value of the previous call.

asyncLoop(Callable, String, Thread.UncaughtExceptionHandler) - Static method in class org.apache.storm.utils.Utils

Convenience method used when only the function and name suffix are given.

asyncLoop(Callable) - Static method in class org.apache.storm.utils.Utils

Convenience method used when only the function is given.

AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor

AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPC.AsyncProcessor

AsyncProcessor(I) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor

AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor

AsyncProcessor(I) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor

AsyncProcessor(I, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>>) - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor

AsyncResultHandler<T> - Interface in org.apache.storm.cassandra.executor

Default handler for batch asynchronous execution.

AT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AtMostOnceEventCount - Class in org.apache.storm.eventhubs.samples

AtMostOnceEventCount() - Constructor for class org.apache.storm.eventhubs.samples.AtMostOnceEventCount

ATOMIC - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AtomicOutputStream - Class in org.apache.storm.blobstore

An output stream where all of the data is committed on close, or can be canceled with cancel.

AtomicOutputStream() - Constructor for class org.apache.storm.blobstore.AtomicOutputStream

AtomicRowExpression() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses an atomic row expression.

ATTRIBUTE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ATTRIBUTES - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

authenticate(boolean, String, String) - Static method in class org.apache.storm.hive.common.HiveUtils

authenticated(Channel) - Method in interface org.apache.storm.messaging.netty.ISaslServer

AuthenticationFailed(String, Exception) - Constructor for exception org.apache.storm.hive.common.HiveUtils.AuthenticationFailed

AUTHORIZATION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AuthorizationException - Exception in org.apache.storm.generated

AuthorizationException() - Constructor for exception org.apache.storm.generated.AuthorizationException

AuthorizationException(String) - Constructor for exception org.apache.storm.generated.AuthorizationException

AuthorizationException(AuthorizationException) - Constructor for exception org.apache.storm.generated.AuthorizationException

Performs a deep copy on other.

AuthorizationException._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

authorizedGroups - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL

authorizedHosts - Variable in class org.apache.storm.security.auth.authorizer.ImpersonationAuthorizer.ImpersonationACL

AuthUtils - Class in org.apache.storm.security.auth

AuthUtils() - Constructor for class org.apache.storm.security.auth.AuthUtils

autoCreatePartitions - Variable in class org.apache.storm.hive.common.HiveOptions

AutoHBase - Class in org.apache.storm.hbase.security

Automatically get hbase delegation tokens and push it to user’s topology.

AutoHBase() - Constructor for class org.apache.storm.hbase.security.AutoHBase

AutoHDFS - Class in org.apache.storm.hdfs.security

Automatically get HDFS delegation tokens and push it to user’s topology.

AutoHDFS() - Constructor for class org.apache.storm.hdfs.security.AutoHDFS

AutoHive - Class in org.apache.storm.hive.security

Automatically get hive delegation tokens and push it to user’s topology.

AutoHive() - Constructor for class org.apache.storm.hive.security.AutoHive

AutoTGT - Class in org.apache.storm.security.auth.kerberos

Automatically take a user’s TGT, and push it, and renew it in Nimbus.

AutoTGT() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGT

AutoTGTKrb5LoginModule - Class in org.apache.storm.security.auth.kerberos

Custom LoginModule to enable Auto Login based on cached ticket

AutoTGTKrb5LoginModule() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule

AutoTGTKrb5LoginModuleTest - Class in org.apache.storm.security.auth.kerberos

Custom LoginModule extended for testing.

AutoTGTKrb5LoginModuleTest() - Constructor for class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModuleTest

available() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream

available() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusDownloadInputStream

avg(Collection<Double>) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils

Caculate the average of a collection of doubles

AVG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

AvroGenericRecordBolt - Class in org.apache.storm.hdfs.bolt

AvroGenericRecordBolt() - Constructor for class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt

AvroGenericRecordHDFSWriter - Class in org.apache.storm.hdfs.common

AvroGenericRecordHDFSWriter(FileRotationPolicy, Path, FSDataOutputStream, Schema) - Constructor for class org.apache.storm.hdfs.common.AvroGenericRecordHDFSWriter

AvroSchemaRegistry - Interface in org.apache.storm.hdfs.avro

AvroScheme - Class in org.apache.storm.sql.runtime.serde.avro

AvroScheme uses generic(without code generation) instead of specific(with code generation) readers.

AvroScheme(String, List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.avro.AvroScheme

AvroSerializer - Class in org.apache.storm.sql.runtime.serde.avro

AvroSerializer uses generic(without code generation) instead of specific(with code generation) writers.

AvroSerializer(String, List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.avro.AvroSerializer

AvroUtils - Class in org.apache.storm.hdfs.avro

AvroUtils() - Constructor for class org.apache.storm.hdfs.avro.AvroUtils

B

BACK_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BACKPRESSURE_DISRUPTOR_HIGH_WATERMARK - Static variable in class org.apache.storm.Config

This signifies the tuple congestion in a disruptor queue.

BACKPRESSURE_DISRUPTOR_LOW_WATERMARK - Static variable in class org.apache.storm.Config

This signifies a state that a disruptor queue has left the congestion.

BACKPRESSURE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils

BACKPRESSURE_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils

BACKPRESSURE_ZNODE_TIMEOUT_SECS - Static variable in class org.apache.storm.Config

How long until the backpressure znode is invalid.

BACKPRESSURE_ZNODE_UPDATE_FREQ_SECS - Static variable in class org.apache.storm.Config

How often will the data (timestamp) of backpressure znode be updated.

backpressurePath(String, String, Long) - Static method in class org.apache.storm.cluster.ClusterUtils

backpressureStormRoot(String) - Static method in class org.apache.storm.cluster.ClusterUtils

backpressureTopologies() - Method in interface org.apache.storm.cluster.IStormClusterState

backpressureTopologies() - Method in class org.apache.storm.cluster.StormClusterStateImpl

backup(int) - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream

BAD_DIR - Static variable in class org.apache.storm.hdfs.spout.Configs

Base64ToBinaryStateMigrationUtil - Class in org.apache.storm.redis.tools

Base64ToBinaryStateMigrationUtil(JedisPoolConfig) - Constructor for class org.apache.storm.redis.tools.Base64ToBinaryStateMigrationUtil

Base64ToBinaryStateMigrationUtil(RedisCommandsInstanceContainer) - Constructor for class org.apache.storm.redis.tools.Base64ToBinaryStateMigrationUtil

BASE_BLOBS_DIR_NAME - Static variable in class org.apache.storm.blobstore.BlobStore

BaseAggregator<T> - Class in org.apache.storm.trident.operation

BaseAggregator() - Constructor for class org.apache.storm.trident.operation.BaseAggregator

BaseBasicBolt - Class in org.apache.storm.topology.base

BaseBasicBolt() - Constructor for class org.apache.storm.topology.base.BaseBasicBolt

BaseBatchBolt<T> - Class in org.apache.storm.topology.base

BaseBatchBolt() - Constructor for class org.apache.storm.topology.base.BaseBatchBolt

BaseBeanFactory<T> - Class in org.apache.storm.cassandra.context

Base BeanProvider implementation.

BaseBeanFactory() - Constructor for class org.apache.storm.cassandra.context.BaseBeanFactory

BaseBinaryStateIterator<K,V> - Class in org.apache.storm.state

Base implementation of iterator over KeyValueState which encoded types of key and value are both binary type.

BaseBinaryStateIterator(Iterator<Map.Entry<byte[], byte[]>>, Iterator<Map.Entry<byte[], byte[]>>) - Constructor for class org.apache.storm.state.BaseBinaryStateIterator

Constructor.

BaseCassandraBolt<T> - Class in org.apache.storm.cassandra.bolt

A base cassandra bolt.

BaseCassandraBolt(CQLStatementTupleMapper, SimpleClientProvider) - Constructor for class org.apache.storm.cassandra.bolt.BaseCassandraBolt

Creates a new CassandraWriterBolt instance.

BaseCassandraBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.BaseCassandraBolt

Creates a new CassandraWriterBolt instance.

BaseComponent - Class in org.apache.storm.topology.base

BaseComponent() - Constructor for class org.apache.storm.topology.base.BaseComponent

BaseConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Class in org.apache.storm.topology

BaseConfigurationDeclarer() - Constructor for class org.apache.storm.topology.BaseConfigurationDeclarer

BaseCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query

Default interface to map a ITuple to a CQL Statement.

BaseCQLStatementTupleMapper() - Constructor for class org.apache.storm.cassandra.query.BaseCQLStatementTupleMapper

BaseExecutionResultHandler - Class in org.apache.storm.cassandra

Simple ExecutionResultHandler which fail the incoming tuple when an DriverException is thrown.

BaseExecutionResultHandler() - Constructor for class org.apache.storm.cassandra.BaseExecutionResultHandler

BaseFilter - Class in org.apache.storm.trident.operation

BaseFilter() - Constructor for class org.apache.storm.trident.operation.BaseFilter

BaseFunction - Class in org.apache.storm.trident.operation

BaseFunction() - Constructor for class org.apache.storm.trident.operation.BaseFunction

BaseMultiReducer<T> - Class in org.apache.storm.trident.operation

BaseMultiReducer() - Constructor for class org.apache.storm.trident.operation.BaseMultiReducer

BaseOpaquePartitionedTransactionalSpout<T> - Class in org.apache.storm.topology.base

BaseOpaquePartitionedTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BaseOpaquePartitionedTransactionalSpout

BaseOperation - Class in org.apache.storm.trident.operation

Convenience implementation of the Operation interface.

BaseOperation() - Constructor for class org.apache.storm.trident.operation.BaseOperation

BasePartitionedTransactionalSpout<T> - Class in org.apache.storm.topology.base

BasePartitionedTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BasePartitionedTransactionalSpout

BaseQueryFunction<S extends State,T> - Class in org.apache.storm.trident.state

BaseQueryFunction() - Constructor for class org.apache.storm.trident.state.BaseQueryFunction

BaseRichBolt - Class in org.apache.storm.topology.base

BaseRichBolt() - Constructor for class org.apache.storm.topology.base.BaseRichBolt

BaseRichSpout - Class in org.apache.storm.topology.base

BaseRichSpout() - Constructor for class org.apache.storm.topology.base.BaseRichSpout

BaseStatefulBolt<T extends State> - Class in org.apache.storm.topology.base

BaseStatefulBolt() - Constructor for class org.apache.storm.topology.base.BaseStatefulBolt

BaseStatefulBoltExecutor - Class in org.apache.storm.topology

Base class that abstracts the common logic for executing bolts in a stateful topology.

BaseStatefulBoltExecutor() - Constructor for class org.apache.storm.topology.BaseStatefulBoltExecutor

BaseStatefulBoltExecutor.AnchoringOutputCollector - Class in org.apache.storm.topology

BaseStatefulWindowedBolt<T extends State> - Class in org.apache.storm.topology.base

BaseStatefulWindowedBolt() - Constructor for class org.apache.storm.topology.base.BaseStatefulWindowedBolt

BaseStateIterator<K,V,KENCODED,VENCODED> - Class in org.apache.storm.state

Base implementation of iterator over KeyValueState.

BaseStateIterator(Iterator<Map.Entry<KENCODED, VENCODED>>, Iterator<Map.Entry<KENCODED, VENCODED>>, Set<KENCODED>) - Constructor for class org.apache.storm.state.BaseStateIterator

Constructor.

BaseStateUpdater<S extends State> - Class in org.apache.storm.trident.state

BaseStateUpdater() - Constructor for class org.apache.storm.trident.state.BaseStateUpdater

BaseTaskHook - Class in org.apache.storm.hooks

BaseTaskHook() - Constructor for class org.apache.storm.hooks.BaseTaskHook

BaseTickTupleAwareRichBolt - Class in org.apache.storm.topology.base

This class is based on BaseRichBolt, but is aware of tick tuple.

BaseTickTupleAwareRichBolt() - Constructor for class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt

BaseTransactionalBolt - Class in org.apache.storm.topology.base

BaseTransactionalBolt() - Constructor for class org.apache.storm.topology.base.BaseTransactionalBolt

BaseTransactionalSpout<T> - Class in org.apache.storm.topology.base

BaseTransactionalSpout() - Constructor for class org.apache.storm.topology.base.BaseTransactionalSpout

BaseWindowConfig - Class in org.apache.storm.trident.windowing.config

BaseWindowConfig(int, int) - Constructor for class org.apache.storm.trident.windowing.config.BaseWindowConfig

BaseWindowedBolt - Class in org.apache.storm.topology.base

BaseWindowedBolt() - Constructor for class org.apache.storm.topology.base.BaseWindowedBolt

BaseWindowedBolt.Count - Class in org.apache.storm.topology.base

Holds a count value for count based windows and sliding intervals.

BaseWindowedBolt.Duration - Class in org.apache.storm.topology.base

Holds a Time duration for time based windows and sliding intervals.

BaseWindowStrategy<T> - Class in org.apache.storm.trident.windowing.strategy

BaseWindowStrategy(WindowConfig) - Constructor for class org.apache.storm.trident.windowing.strategy.BaseWindowStrategy

BaseWorkerHook - Class in org.apache.storm.hooks

A BaseWorkerHook is a noop implementation of IWorkerHook.

BaseWorkerHook() - Constructor for class org.apache.storm.hooks.BaseWorkerHook

BasicBoltExecutor - Class in org.apache.storm.topology

BasicBoltExecutor(IBasicBolt) - Constructor for class org.apache.storm.topology.BasicBoltExecutor

BasicContainer - Class in org.apache.storm.daemon.supervisor

A container that runs processes on the local box.

BasicContainer(Container.ContainerType, Map<String, Object>, String, int, LocalAssignment, LocalState, String) - Constructor for class org.apache.storm.daemon.supervisor.BasicContainer

Create a new BasicContainer

BasicContainerLauncher - Class in org.apache.storm.daemon.supervisor

Launch containers with no security using standard java commands

BasicContainerLauncher(Map<String, Object>, String) - Constructor for class org.apache.storm.daemon.supervisor.BasicContainerLauncher

BasicDRPCTopology - Class in org.apache.storm.starter

This topology is a basic example of doing distributed RPC on top of Storm.

BasicDRPCTopology() - Constructor for class org.apache.storm.starter.BasicDRPCTopology

BasicDRPCTopology.ExclaimBolt - Class in org.apache.storm.starter

BasicMetricsCollector - Class in org.apache.storm.perf.utils

BasicMetricsCollector(Nimbus.Client, String, Map) - Constructor for class org.apache.storm.perf.utils.BasicMetricsCollector

BasicMetricsCollector(LocalCluster, String, Map) - Constructor for class org.apache.storm.perf.utils.BasicMetricsCollector

BasicMetricsCollector.MetricsCollectorConfig - Class in org.apache.storm.perf.utils

BasicMetricsCollector.MetricsItem - Enum in org.apache.storm.perf.utils

BasicOutputCollector - Class in org.apache.storm.topology

BasicOutputCollector(OutputCollector) - Constructor for class org.apache.storm.topology.BasicOutputCollector

BATCH_STREAM_ID - Static variable in class org.apache.storm.trident.topology.MasterBatchCoordinator

BatchAsyncResultHandler - Class in org.apache.storm.cassandra.executor.impl

BatchAsyncResultHandler(ExecutionResultHandler) - Constructor for class org.apache.storm.cassandra.executor.impl.BatchAsyncResultHandler

Creates a new BatchAsyncResultHandler instance.

BatchBoltExecutor - Class in org.apache.storm.coordination

BatchBoltExecutor(IBatchBolt) - Constructor for class org.apache.storm.coordination.BatchBoltExecutor

BatchCassandraWriterBolt - Class in org.apache.storm.cassandra.bolt

BatchCassandraWriterBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt

Creates a new CassandraWriterBolt instance.

BatchCassandraWriterBolt(CQLStatementTupleMapper, int) - Constructor for class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt

Creates a new CassandraWriterBolt instance.

BatchCount() - Constructor for class org.apache.storm.starter.TransactionalGlobalCount.BatchCount

BatchCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query.impl

BatchCQLStatementTupleMapper(BatchStatement.Type, List<CQLStatementTupleMapper>) - Constructor for class org.apache.storm.cassandra.query.impl.BatchCQLStatementTupleMapper

Creates a new BatchCQLStatementTupleMapper instance.

batchGet(List<Get>) - Method in class org.apache.storm.hbase.common.HBaseClient

batchGlobal() - Method in class org.apache.storm.trident.Stream

Repartitioning Operation

batchGroup - Variable in class org.apache.storm.trident.topology.BatchInfo

BatchHelper - Class in org.apache.storm.utils

BatchHelper(int, OutputCollector) - Constructor for class org.apache.storm.utils.BatchHelper

batchId - Variable in class org.apache.storm.trident.planner.ProcessorContext

batchId - Variable in class org.apache.storm.trident.topology.BatchInfo

BatchInfo - Class in org.apache.storm.trident.topology

BatchInfo(String, IBatchID, Object) - Constructor for class org.apache.storm.trident.topology.BatchInfo

batchMutate(List<Mutation>) - Method in class org.apache.storm.hbase.common.HBaseClient

BatchNumberList - Class in org.apache.storm.testing

BatchNumberList(String) - Constructor for class org.apache.storm.testing.BatchNumberList

BatchOutputCollector - Class in org.apache.storm.coordination

BatchOutputCollector() - Constructor for class org.apache.storm.coordination.BatchOutputCollector

BatchOutputCollectorImpl - Class in org.apache.storm.coordination

BatchOutputCollectorImpl(OutputCollector) - Constructor for class org.apache.storm.coordination.BatchOutputCollectorImpl

BatchProcessWord - Class in org.apache.storm.testing

BatchProcessWord() - Constructor for class org.apache.storm.testing.BatchProcessWord

BatchRepeatA - Class in org.apache.storm.testing

BatchRepeatA() - Constructor for class org.apache.storm.testing.BatchRepeatA

batchRetrieve(CassandraState, List<TridentTuple>) - Method in class org.apache.storm.cassandra.trident.state.CassandraQuery

batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.cassandra.trident.state.CassandraState

batchRetrieve(HBaseState, List<TridentTuple>) - Method in class org.apache.storm.hbase.trident.state.HBaseQuery

batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.hbase.trident.state.HBaseState

batchRetrieve(JdbcState, List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcQuery

batchRetrieve(List<TridentTuple>) - Method in class org.apache.storm.jdbc.trident.state.JdbcState

batchRetrieve(T, List<TridentTuple>) - Method in class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier

batchRetrieve(ReadOnlyMapState, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.MapGet

batchRetrieve(ReadOnlySnapshottable, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.SnapshotGet

batchRetrieve(State, List<TridentTuple>) - Method in class org.apache.storm.trident.operation.builtin.TupleCollectionGet

batchRetrieve(S, List<TridentTuple>) - Method in interface org.apache.storm.trident.state.QueryFunction

batchSize - Variable in class org.apache.storm.hive.common.HiveOptions

BatchSpoutEmitter() - Constructor for class org.apache.storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter

BatchSpoutExecutor - Class in org.apache.storm.trident.spout

BatchSpoutExecutor(IBatchSpout) - Constructor for class org.apache.storm.trident.spout.BatchSpoutExecutor

BatchSpoutExecutor.BatchSpoutEmitter - Class in org.apache.storm.trident.spout

BatchSpoutExecutor.EmptyCoordinator - Class in org.apache.storm.trident.spout

BatchSubtopologyBuilder - Class in org.apache.storm.coordination

BatchSubtopologyBuilder(String, IBasicBolt, Number) - Constructor for class org.apache.storm.coordination.BatchSubtopologyBuilder

BatchSubtopologyBuilder(String, IBasicBolt) - Constructor for class org.apache.storm.coordination.BatchSubtopologyBuilder

BeanDef - Class in org.apache.storm.flux.model

A representation of a Java object that is uniquely identifyable, and given a className, constructor arguments, and properties, can be instantiated.

BeanDef() - Constructor for class org.apache.storm.flux.model.BeanDef

BeanFactory<T> - Interface in org.apache.storm.cassandra.context

Simple interface used for providing services based on the storm configuration.

BeanListReference - Class in org.apache.storm.flux.model

A bean list reference is a list of bean reference.

BeanListReference() - Constructor for class org.apache.storm.flux.model.BeanListReference

BeanListReference(List<String>) - Constructor for class org.apache.storm.flux.model.BeanListReference

BeanReference - Class in org.apache.storm.flux.model

A bean reference is simply a string pointer to another id.

BeanReference() - Constructor for class org.apache.storm.flux.model.BeanReference

BeanReference(String) - Constructor for class org.apache.storm.flux.model.BeanReference

BEFORE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BEGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

beginBlobDownload(String, AsyncMethodCallback<BeginDownloadResult>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

beginBlobDownload(String, AsyncMethodCallback<BeginDownloadResult>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginBlobDownload

beginBlobDownload(String) - Method in class org.apache.storm.generated.Nimbus.Client

beginBlobDownload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

beginBlobDownload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginBlobDownload

beginBlobDownload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args

beginBlobDownload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args

beginBlobDownload_args(Nimbus.beginBlobDownload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_args

Performs a deep copy on other.

beginBlobDownload_call(String, AsyncMethodCallback<BeginDownloadResult>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginBlobDownload_call

beginBlobDownload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result

beginBlobDownload_result(BeginDownloadResult, AuthorizationException, KeyNotFoundException) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result

beginBlobDownload_result(Nimbus.beginBlobDownload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginBlobDownload_result

Performs a deep copy on other.

beginColumn - Variable in class org.apache.storm.sql.parser.impl.Token

beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.

beginCommit(Long) - Method in class org.apache.storm.cassandra.trident.state.CassandraState

beginCommit(Long) - Method in class org.apache.storm.druid.trident.DruidBeamState

Deprecated.

beginCommit(Long) - Method in class org.apache.storm.hbase.trident.state.HBaseState

beginCommit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState

beginCommit(Long) - Method in class org.apache.storm.hive.trident.HiveState

beginCommit(Long) - Method in class org.apache.storm.jdbc.trident.state.JdbcState

beginCommit(Long) - Method in class org.apache.storm.jms.trident.JmsState

beginCommit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState

Deprecated.

beginCommit(Long) - Method in class org.apache.storm.mongodb.trident.state.MongoState

beginCommit(Long) - Method in class org.apache.storm.opentsdb.trident.OpenTsdbState

beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisClusterState

beginCommit(Long) - Method in class org.apache.storm.redis.trident.state.RedisState

beginCommit(Long) - Method in class org.apache.storm.solr.trident.SolrState

beginCommit(Long) - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.SocketState

beginCommit(Long) - Method in class org.apache.storm.trident.state.map.NonTransactionalMap

beginCommit(Long) - Method in class org.apache.storm.trident.state.map.OpaqueMap

beginCommit(Long) - Method in class org.apache.storm.trident.state.map.SnapshottableMap

beginCommit(Long) - Method in class org.apache.storm.trident.state.map.TransactionalMap

beginCommit(Long) - Method in class org.apache.storm.trident.state.ReadOnlyState

beginCommit(Long) - Method in interface org.apache.storm.trident.state.State

beginCommit(Long) - Method in class org.apache.storm.trident.testing.LRUMemoryMapState

beginCommit(Long) - Method in class org.apache.storm.trident.testing.MemoryMapState

beginCommit(Long) - Method in class org.apache.storm.trident.windowing.WindowsState

beginCreateBlob(String, SettableBlobMeta, AsyncMethodCallback<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

beginCreateBlob(String, SettableBlobMeta, AsyncMethodCallback<String>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

beginCreateBlob() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginCreateBlob

beginCreateBlob(String, SettableBlobMeta) - Method in class org.apache.storm.generated.Nimbus.Client

beginCreateBlob(String, SettableBlobMeta) - Method in interface org.apache.storm.generated.Nimbus.Iface

beginCreateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginCreateBlob

beginCreateBlob_args() - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args

beginCreateBlob_args(String, SettableBlobMeta) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args

beginCreateBlob_args(Nimbus.beginCreateBlob_args) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_args

Performs a deep copy on other.

beginCreateBlob_call(String, SettableBlobMeta, AsyncMethodCallback<String>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginCreateBlob_call

beginCreateBlob_result() - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result

beginCreateBlob_result(String, AuthorizationException, KeyAlreadyExistsException) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result

beginCreateBlob_result(Nimbus.beginCreateBlob_result) - Constructor for class org.apache.storm.generated.Nimbus.beginCreateBlob_result

Performs a deep copy on other.

BeginDownloadResult - Class in org.apache.storm.generated

BeginDownloadResult() - Constructor for class org.apache.storm.generated.BeginDownloadResult

BeginDownloadResult(long, String) - Constructor for class org.apache.storm.generated.BeginDownloadResult

BeginDownloadResult(BeginDownloadResult) - Constructor for class org.apache.storm.generated.BeginDownloadResult

Performs a deep copy on other.

BeginDownloadResult._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

beginFileDownload(String, AsyncMethodCallback<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

beginFileDownload(String, AsyncMethodCallback<String>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

beginFileDownload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginFileDownload

beginFileDownload(String) - Method in class org.apache.storm.generated.Nimbus.Client

beginFileDownload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

beginFileDownload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginFileDownload

beginFileDownload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args

beginFileDownload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args

beginFileDownload_args(Nimbus.beginFileDownload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_args

Performs a deep copy on other.

beginFileDownload_call(String, AsyncMethodCallback<String>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginFileDownload_call

beginFileDownload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result

beginFileDownload_result(String, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result

beginFileDownload_result(Nimbus.beginFileDownload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginFileDownload_result

Performs a deep copy on other.

beginFileUpload(AsyncMethodCallback<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

beginFileUpload(AsyncMethodCallback<String>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginFileUpload

beginFileUpload() - Method in class org.apache.storm.generated.Nimbus.Client

beginFileUpload() - Method in interface org.apache.storm.generated.Nimbus.Iface

beginFileUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginFileUpload

beginFileUpload_args() - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_args

beginFileUpload_args(Nimbus.beginFileUpload_args) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_args

Performs a deep copy on other.

beginFileUpload_call(AsyncMethodCallback<String>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginFileUpload_call

beginFileUpload_result() - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result

beginFileUpload_result(String, AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result

beginFileUpload_result(Nimbus.beginFileUpload_result) - Constructor for class org.apache.storm.generated.Nimbus.beginFileUpload_result

Performs a deep copy on other.

beginLine - Variable in class org.apache.storm.sql.parser.impl.Token

beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.

BeginToken() - Method in class org.apache.storm.sql.parser.impl.SimpleCharStream

beginUpdateBlob(String, AsyncMethodCallback<String>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

beginUpdateBlob(String, AsyncMethodCallback<String>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.beginUpdateBlob

beginUpdateBlob(String) - Method in class org.apache.storm.generated.Nimbus.Client

beginUpdateBlob(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

beginUpdateBlob() - Constructor for class org.apache.storm.generated.Nimbus.Processor.beginUpdateBlob

beginUpdateBlob_args() - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

beginUpdateBlob_args(String) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

beginUpdateBlob_args(Nimbus.beginUpdateBlob_args) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

Performs a deep copy on other.

beginUpdateBlob_call(String, AsyncMethodCallback<String>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.beginUpdateBlob_call

beginUpdateBlob_result() - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

beginUpdateBlob_result(String, AuthorizationException, KeyNotFoundException) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

beginUpdateBlob_result(Nimbus.beginUpdateBlob_result) - Constructor for class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

Performs a deep copy on other.

BEL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BERNOULLI - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BETWEEN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BIGINT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BINARY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

binary_arg(ByteBuffer) - Static method in class org.apache.storm.generated.JavaObjectArg

binary_arg(byte[]) - Static method in class org.apache.storm.generated.JavaObjectArg

BINARY_STRING_LITERAL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BinaryEventDataScheme - Class in org.apache.storm.eventhubs.spout

An Event Data Scheme which deserializes message payload into the raw bytes.

BinaryEventDataScheme() - Constructor for class org.apache.storm.eventhubs.spout.BinaryEventDataScheme

BinaryMultisetOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a binary multiset operator.

BinaryQueryOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a binary query operator like UNION.

BinaryRowOperator() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a binary row operator like AND.

bind(FieldSelector...) - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

Includes only the specified tuple fields.

bind(CqlMapper) - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

Includes only the specified tuple fields.

bind(String, int) - Method in interface org.apache.storm.messaging.IContext

This method establishes a server side connection

bind(String, int) - Method in class org.apache.storm.messaging.local.Context

bind(String, int) - Method in class org.apache.storm.messaging.netty.Context

establish a server with a binding port

BIT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

bitXor(Long, Long) - Static method in class org.apache.storm.utils.Utils

bitXorVals(List<Long>) - Static method in class org.apache.storm.utils.Utils

blacklistHost(String) - Method in class org.apache.storm.scheduler.Cluster

BLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BlobKeySequenceInfo - Class in org.apache.storm.blobstore

BlobKeySequenceInfo() - Constructor for class org.apache.storm.blobstore.BlobKeySequenceInfo

BlobStore - Class in org.apache.storm.blobstore

Provides a way to store blobs that can be downloaded.

BlobStore() - Constructor for class org.apache.storm.blobstore.BlobStore

blobstore(Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

blobstore(Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

BlobStore.BlobStoreFileInputStream - Class in org.apache.storm.blobstore

Input stream implementation used for writing both the metadata containing the acl information and the blob data.

BlobStore.BlobStoreFileOutputStream - Class in org.apache.storm.blobstore

Output stream implementation used for reading the metadata and data information.

BlobStore.KeyTranslationIterator - Class in org.apache.storm.blobstore

Blob store implements its own version of iterator to list the blobs

BLOBSTORE_CLEANUP_ENABLE - Static variable in class org.apache.storm.Config

Enable the blobstore cleaner.

BLOBSTORE_DATA_FILE - Static variable in class org.apache.storm.blobstore.BlobStoreFile

BLOBSTORE_DIR - Static variable in class org.apache.storm.Config

What directory to use for the blobstore.

BLOBSTORE_DIR_PERMISSION - Static variable in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreImpl

BLOBSTORE_FILE_PERMISSION - Static variable in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile

BLOBSTORE_HDFS_KEYTAB - Static variable in class org.apache.storm.Config

keytab for nimbus/supervisor to use to access secure hdfs for the blobstore.

BLOBSTORE_HDFS_PRINCIPAL - Static variable in class org.apache.storm.Config

principal for nimbus/supervisor to use to access secure hdfs for the blobstore.

BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils

BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils

BLOBSTORE_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils

BLOBSTORE_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils

BLOBSTORE_SUPERUSER - Static variable in class org.apache.storm.Config

The blobstore super user has all read/write/admin permissions to all blobs - user running the blobstore.

BlobStoreAclHandler - Class in org.apache.storm.blobstore

Provides common handling of acls for Blobstores.

BlobStoreAclHandler(Map) - Constructor for class org.apache.storm.blobstore.BlobStoreAclHandler

BlobStoreAPIWordCountTopology - Class in org.apache.storm.starter

BlobStoreAPIWordCountTopology() - Constructor for class org.apache.storm.starter.BlobStoreAPIWordCountTopology

BlobStoreAPIWordCountTopology.FilterWords - Class in org.apache.storm.starter

BlobStoreAPIWordCountTopology.RandomSentenceSpout - Class in org.apache.storm.starter

BlobStoreAPIWordCountTopology.SplitSentence - Class in org.apache.storm.starter

BlobStoreFile - Class in org.apache.storm.blobstore

Provides an base implementation for creating a blobstore based on file backed storage.

BlobStoreFile() - Constructor for class org.apache.storm.blobstore.BlobStoreFile

BlobStoreFileInputStream(BlobStoreFile) - Constructor for class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream

BlobStoreFileOutputStream(BlobStoreFile) - Constructor for class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream

blobstoreInfo(String) - Method in interface org.apache.storm.cluster.IStormClusterState

blobstoreInfo(String) - Method in class org.apache.storm.cluster.StormClusterStateImpl

blobstoreMapToLocalresources(Map<String, Map<String, Object>>) - Static method in class org.apache.storm.daemon.supervisor.SupervisorUtils

Returns a list of LocalResources based on the blobstore-map passed in

blobstoreMaxKeySequenceNumberPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils

blobstorePath(String) - Static method in class org.apache.storm.cluster.ClusterUtils

BlobStoreUtils - Class in org.apache.storm.blobstore

BlobStoreUtils() - Constructor for class org.apache.storm.blobstore.BlobStoreUtils

BlobSynchronizer - Class in org.apache.storm.blobstore

Is called periodically and updates the nimbus with blobs based on the state stored inside the zookeeper for a non leader nimbus trying to be in sync with the operations performed on the leader nimbus.

BlobSynchronizer(BlobStore, Map) - Constructor for class org.apache.storm.blobstore.BlobSynchronizer

blockOnFull(boolean) - Method in class org.apache.storm.druid.bolt.DruidConfig.Builder

Deprecated.

BlowfishTupleSerializer - Class in org.apache.storm.security.serialization

Apply Blowfish encryption for tuple communication to bolts

BlowfishTupleSerializer(Kryo, Map) - Constructor for class org.apache.storm.security.serialization.BlowfishTupleSerializer

Bolt - Class in org.apache.storm.generated

Bolt() - Constructor for class org.apache.storm.generated.Bolt

Bolt(ComponentObject, ComponentCommon) - Constructor for class org.apache.storm.generated.Bolt

Bolt(Bolt) - Constructor for class org.apache.storm.generated.Bolt

Performs a deep copy on other.

bolt(BoltStats) - Static method in class org.apache.storm.generated.ExecutorSpecificStats

bolt(BoltAggregateStats) - Static method in class org.apache.storm.generated.SpecificAggregateStats

Bolt._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

BOLT1_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo

BOLT1_ID - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo

BOLT2_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo

BOLT2_ID - Static variable in class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo

BOLT_COUNT - Static variable in class org.apache.storm.perf.ConstSpoutNullBoltTopo

BOLT_ID - Static variable in class org.apache.storm.hdfs.spout.HdfsSpoutTopology

BOLT_ID - Static variable in class org.apache.storm.perf.ConstSpoutNullBoltTopo

BOLT_ID - Static variable in class org.apache.storm.perf.KafkaHdfsTopo

BOLT_ID - Static variable in class org.apache.storm.perf.KafkaSpoutNullBoltTopo

BOLT_ID - Static variable in class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo

BOLT_KEY - Static variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

BOLT_MESSAGE - Static variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

BOLT_NUM - Static variable in class org.apache.storm.perf.KafkaHdfsTopo

BOLT_NUM - Static variable in class org.apache.storm.perf.KafkaSpoutNullBoltTopo

BOLT_NUM - Static variable in class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo

boltAck(BoltAckInfo) - Method in class org.apache.storm.hooks.BaseTaskHook

boltAck(BoltAckInfo) - Method in interface org.apache.storm.hooks.ITaskHook

BoltAckInfo - Class in org.apache.storm.hooks.info

BoltAckInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltAckInfo

BoltAggregateStats - Class in org.apache.storm.generated

BoltAggregateStats() - Constructor for class org.apache.storm.generated.BoltAggregateStats

BoltAggregateStats(BoltAggregateStats) - Constructor for class org.apache.storm.generated.BoltAggregateStats

Performs a deep copy on other.

BoltAggregateStats._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

boltConfig - Variable in class org.apache.storm.eventhubs.bolt.EventHubBolt

BoltDeclarer - Interface in org.apache.storm.topology

BoltDeclarer includes grouping APIs for storm topology.

BoltDef - Class in org.apache.storm.flux.model

Bean representation of a Storm bolt.

BoltDef() - Constructor for class org.apache.storm.flux.model.BoltDef

boltExecute(BoltExecuteInfo) - Method in class org.apache.storm.hooks.BaseTaskHook

boltExecute(BoltExecuteInfo) - Method in interface org.apache.storm.hooks.ITaskHook

BoltExecuteInfo - Class in org.apache.storm.hooks.info

BoltExecuteInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltExecuteInfo

boltFail(BoltFailInfo) - Method in class org.apache.storm.hooks.BaseTaskHook

boltFail(BoltFailInfo) - Method in interface org.apache.storm.hooks.ITaskHook

BoltFailInfo - Class in org.apache.storm.hooks.info

BoltFailInfo(Tuple, int, Long) - Constructor for class org.apache.storm.hooks.info.BoltFailInfo

BoltGetter(String) - Constructor for class org.apache.storm.topology.TopologyBuilder.BoltGetter

boltKeyField - Variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

boltMessageField - Variable in class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

BoltMsg - Class in org.apache.storm.multilang

BoltMsg is an object that represents the data sent from a shell component to a bolt process that implements a multi-language protocol.

BoltMsg() - Constructor for class org.apache.storm.multilang.BoltMsg

BoltStats - Class in org.apache.storm.generated

BoltStats() - Constructor for class org.apache.storm.generated.BoltStats

BoltStats(Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Double>>, Map<String, Map<GlobalStreamId, Long>>, Map<String, Map<GlobalStreamId, Double>>) - Constructor for class org.apache.storm.generated.BoltStats

BoltStats(BoltStats) - Constructor for class org.apache.storm.generated.BoltStats

Performs a deep copy on other.

BoltStats._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

BoltTracker - Class in org.apache.storm.testing

BoltTracker(IRichBolt, String) - Constructor for class org.apache.storm.testing.BoltTracker

bool_arg(boolean) - Static method in class org.apache.storm.generated.JavaObjectArg

BOOLEAN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BooleanValidator() - Constructor for class org.apache.storm.validation.ConfigValidation.BooleanValidator

boolval(boolean) - Static method in class org.apache.storm.generated.HBMessageData

Booter - Class in org.apache.storm.submit.dependency

Manage mvn repository.

Booter() - Constructor for class org.apache.storm.submit.dependency.Booter

BOTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BoundCQLStatementMapperBuilder - Class in org.apache.storm.cassandra.query.builder

BoundCQLStatementMapperBuilder(String) - Constructor for class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

Creates a new BoundCQLStatementMapperBuilder instance.

BoundCQLStatementMapperBuilder(ContextQuery) - Constructor for class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

Creates a new BoundCQLStatementMapperBuilder instance.

BoundCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query.impl

BoundCQLStatementTupleMapper(ContextQuery, CqlMapper, RoutingKeyGenerator, PreparedStatementBinder) - Constructor for class org.apache.storm.cassandra.query.impl.BoundCQLStatementTupleMapper

Creates a new BoundCQLStatementTupleMapper instance.

boundQuery(String) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder

Builds a new bound statement based on the specified query.

boundQuery(ContextQuery) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder

Builds a new bound statement identified by the given field.

BoundQueryContext(String) - Constructor for class org.apache.storm.cassandra.query.ContextQuery.BoundQueryContext

BoundQueryNamedByFieldContext(String) - Constructor for class org.apache.storm.cassandra.query.ContextQuery.BoundQueryNamedByFieldContext

BRACKET_QUOTED_IDENTIFIER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BREADTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BridgeReceiver - Class in org.apache.storm.trident.planner

BridgeReceiver(BatchOutputCollector) - Constructor for class org.apache.storm.trident.planner.BridgeReceiver

broadcast() - Method in class org.apache.storm.trident.Stream

Repartitioning Operation

BROADCAST_DEST - Static variable in class org.apache.storm.tuple.AddressedTuple

Destination used when broadcasting a tuple.

Broker - Class in org.apache.storm.kafka

Broker(String, int) - Constructor for class org.apache.storm.kafka.Broker

Broker(String) - Constructor for class org.apache.storm.kafka.Broker

BrokerHosts - Interface in org.apache.storm.kafka

brokerPath() - Method in class org.apache.storm.kafka.DynamicBrokersReader

brokerZkPath - Variable in class org.apache.storm.kafka.ZkHosts

brokerZkStr - Variable in class org.apache.storm.kafka.ZkHosts

BTID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

BUCKET_DATABASE - Static variable in class org.apache.storm.starter.TransactionalWords

BUCKET_SIZE - Static variable in class org.apache.storm.starter.TransactionalWords

BucketCountUpdater() - Constructor for class org.apache.storm.starter.TransactionalWords.BucketCountUpdater

Bucketize() - Constructor for class org.apache.storm.starter.TransactionalWords.Bucketize

BucketTestHiveTopology - Class in org.apache.storm.hive.bolt

BucketTestHiveTopology() - Constructor for class org.apache.storm.hive.bolt.BucketTestHiveTopology

BucketTestHiveTopology.UserDataSpout - Class in org.apache.storm.hive.bolt

BucketValue() - Constructor for class org.apache.storm.starter.TransactionalWords.BucketValue

bufcolumn - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream

buffer() - Method in enum org.apache.storm.messaging.netty.ControlMessage

encode the current Control Message into a channel buffer

buffer() - Method in interface org.apache.storm.messaging.netty.INettySerializable

buffer() - Method in class org.apache.storm.messaging.netty.SaslMessageToken

encode the current SaslToken Message into a channel buffer SaslTokenMessageRequest is encoded as: identifier ….

buffer - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream

buffer_for_binary_arg() - Method in class org.apache.storm.generated.JavaObjectArg

buffer_for_bits() - Method in class org.apache.storm.generated.ThriftSerializedObject

buffer_for_chunk() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args

buffer_for_chunk() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args

buffer_for_custom_serialized() - Method in class org.apache.storm.generated.Grouping

buffer_for_details() - Method in class org.apache.storm.generated.HBPulse

buffer_for_message_blob() - Method in class org.apache.storm.generated.HBMessageData

buffer_for_serialized_java() - Method in class org.apache.storm.generated.ComponentObject

buffer_for_success() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result

buffer_for_success() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result

BUFFER_SIZE - Static variable in class org.apache.storm.hdfs.spout.SequenceFileReader

BUFFER_SIZE - Static variable in class org.apache.storm.hdfs.spout.TextFileReader

BufferFileInputStream - Class in org.apache.storm.utils

BufferFileInputStream(String, int) - Constructor for class org.apache.storm.utils.BufferFileInputStream

BufferFileInputStream(String) - Constructor for class org.apache.storm.utils.BufferFileInputStream

BufferInputStream - Class in org.apache.storm.utils

BufferInputStream(InputStream, int) - Constructor for class org.apache.storm.utils.BufferInputStream

BufferInputStream(InputStream) - Constructor for class org.apache.storm.utils.BufferInputStream

bufferSizeBytes - Variable in class org.apache.storm.kafka.KafkaConfig

bufline - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream

bufpos - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream

build() - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

Builds a new CQLStatementTupleMapper instance.

build() - Method in class org.apache.storm.cassandra.query.builder.SimpleCQLStatementMapperBuilder

Builds a new CQLStatementTupleMapper instance.

build() - Method in interface org.apache.storm.cassandra.query.CQLStatementBuilder

Builds a new CQLStatementTupleMapper instance.

build() - Method in class org.apache.storm.druid.bolt.DruidConfig.Builder

Deprecated.

build() - Method in class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

build() - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder

build() - Method in class org.apache.storm.opentsdb.client.OpenTsdbClient.Builder

build() - Method in class org.apache.storm.redis.common.config.JedisClusterConfig.Builder

Builds JedisClusterConfig.

build() - Method in class org.apache.storm.redis.common.config.JedisPoolConfig.Builder

Builds JedisPoolConfig.

build(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder

Builds container for single Redis environment.

build(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.JedisCommandsContainerBuilder

Builds container for Redis Cluster environment.

build(JedisPoolConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder

Builds container for single Redis environment.

build(JedisClusterConfig) - Static method in class org.apache.storm.redis.common.container.RedisCommandsContainerBuilder

Builds container for Redis Cluster environment.

build(List<Object>) - Method in interface org.apache.storm.redis.trident.state.KeyFactory

Converts state key to Redis key.

build(List<Object>) - Method in class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory

Converts state key to Redis key.

build() - Method in class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder

build() - Method in class org.apache.storm.solr.mapper.SolrJsonMapper.Builder

build() - Method in class org.apache.storm.sql.AbstractTridentProcessor

Construct the trident topology based on the SQL.

build() - Method in class org.apache.storm.sql.compiler.CompilerUtil.TableBuilderInfo

build(IBackingMap<T>) - Static method in class org.apache.storm.trident.state.map.NonTransactionalMap

build(IBackingMap<OpaqueValue>) - Static method in class org.apache.storm.trident.state.map.OpaqueMap

build(IBackingMap<TransactionalValue>) - Static method in class org.apache.storm.trident.state.map.TransactionalMap

build() - Method in class org.apache.storm.trident.TridentTopology

buildAndLaunchWordCountTopology(String[]) - Method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology

buildConfig(TopologyDef) - Static method in class org.apache.storm.flux.FluxBuilder

Given a topology definition, return a populated org.apache.storm.Config instance.

buildDevicesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology

Creates a topology with device-id and count (which are whole numbers) as tuple fields in a stream and it finally generates result stream based on min amd max with device-id and count values.

Builder() - Constructor for class org.apache.storm.druid.bolt.DruidConfig.Builder

Deprecated.

builder(String, String...) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig

Factory method that creates a Builder with String key/value deserializers.

builder(String, Collection<String>) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig

Factory method that creates a Builder with String key/value deserializers.

builder(String, Pattern) - Static method in class org.apache.storm.kafka.spout.KafkaSpoutConfig

Factory method that creates a Builder with String key/value deserializers.

Builder(String, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Builder(String, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Builder(String, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.lang.String...) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.util.Collection) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.util.regex.Pattern) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, String...) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.lang.String...) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Collection<String>) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.util.Collection) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Pattern) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, java.util.regex.Pattern) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Deprecated.

Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG

Builder(String, Subscription) - Constructor for class org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.

Builder() - Constructor for class org.apache.storm.mqtt.common.MqttOptions.Builder

Builder(String) - Constructor for class org.apache.storm.opentsdb.client.OpenTsdbClient.Builder

Builder() - Constructor for class org.apache.storm.redis.common.config.JedisClusterConfig.Builder

Builder() - Constructor for class org.apache.storm.redis.common.config.JedisPoolConfig.Builder

Builder(SchemaBuilder, String) - Constructor for class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder

SolrFieldsMapper builder class.

Builder(SchemaBuilder, SolrClient) - Constructor for class org.apache.storm.solr.mapper.SolrFieldsMapper.Builder

SolrFieldsMapper builder class.

Builder(String, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder

SolrJsonMapper builder class.

Builder(SolrClient, String) - Constructor for class org.apache.storm.solr.mapper.SolrJsonMapper.Builder

SolrJsonMapper builder class.

buildFieldIndex(ValuePointer[]) - Static method in class org.apache.storm.trident.tuple.ValuePointer

buildIndex(Fields, Map<String, ValuePointer>) - Static method in class org.apache.storm.trident.tuple.ValuePointer

buildLogMessage(IEventLogger.EventInfo) - Method in class org.apache.storm.metric.FileBasedEventLogger

buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.EventCount

buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.EventHubLoop

buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.OpaqueTridentEventCount

buildTopology(EventHubSpout) - Method in class org.apache.storm.eventhubs.samples.TransactionalTridentEventCount

buildTopology(ExecutionContext) - Static method in class org.apache.storm.flux.FluxBuilder

Given a topology definition, return a Storm topology that can be run either locally or remotely.

buildTopology(String) - Static method in class org.apache.storm.hbase.trident.WordCountTrident

buildTopology(String) - Static method in class org.apache.storm.hdfs.trident.TridentFileTopology

buildTopology(String) - Static method in class org.apache.storm.hdfs.trident.TridentSequenceTopology

buildTopology(String, String, String, Object, Object) - Static method in class org.apache.storm.hive.trident.TridentHiveTopology

buildTopology(String, String) - Static method in class org.apache.storm.mongodb.trident.WordCountTrident

buildTopology(String, Integer) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedis

buildTopology(String) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisCluster

buildTopology(String) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisClusterMap

buildTopology(String, Integer) - Static method in class org.apache.storm.redis.trident.WordCountTridentRedisMap

buildTopology(WindowsStoreFactory) - Static method in class org.apache.storm.starter.trident.TridentHBaseWindowingStoreTopology

buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentMapExample

buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentReach

buildTopology(WindowsStoreFactory, WindowConfig) - Static method in class org.apache.storm.starter.trident.TridentWindowingInmemoryStoreTopology

buildTopology(LocalDRPC) - Static method in class org.apache.storm.starter.trident.TridentWordCount

buildTopology() - Method in class org.apache.storm.transactional.TransactionalTopologyBuilder

Deprecated.

buildTopology(Map<String, Number>) - Method in class org.apache.storm.trident.topology.TridentTopologyBuilder

buildTopologyBuilder() - Method in class org.apache.storm.transactional.TransactionalTopologyBuilder

Deprecated.

buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology

Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfDevicesTopology.Vehicle and TridentMinMaxOfDevicesTopology.Driver respectively.

buildVehiclesTopology() - Static method in class org.apache.storm.starter.trident.TridentMinMaxOfVehiclesTopology

Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.

BuiltinAggregateFunctions - Class in org.apache.storm.sql.compiler.backends.standalone

Built-in implementations for some of the standard aggregation operations.

BuiltinAggregateFunctions() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions

BuiltinAggregateFunctions.ByteSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.Count - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.DoubleAvg - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.DoubleSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.FloatSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.IntAvg - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.IntSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.LongSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.Max<T extends Comparable<T>> - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.Min<T extends Comparable<T>> - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.ShortSum - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.TypeClass - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinAggregateFunctions.TypeClass.GenericType - Class in org.apache.storm.sql.compiler.backends.standalone

BuiltinFunctionCall() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a call to a builtin function with special syntax.

BulkIndexResponse - Class in org.apache.storm.elasticsearch.response

Mapped response for bulk index.

BulkIndexResponse() - Constructor for class org.apache.storm.elasticsearch.response.BulkIndexResponse

BY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

byNamedSetters() - Method in class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder

ByteArrayMessageMapper - Class in org.apache.storm.mqtt.mappers

ByteArrayMessageMapper() - Constructor for class org.apache.storm.mqtt.mappers.ByteArrayMessageMapper

ByteBufferSerializer - Class in org.apache.storm.kafka

ByteBufferSerializer() - Constructor for class org.apache.storm.kafka.ByteBufferSerializer

ByteSum() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.ByteSum

ByTopicRecordTranslator<K,V> - Class in org.apache.storm.kafka.spout

Based off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream

ByTopicRecordTranslator(Func<ConsumerRecord<K, V>, List<Object>>, Fields, String) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator

Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to stream.

ByTopicRecordTranslator(Func<ConsumerRecord<K, V>, List<Object>>, Fields) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator

Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to the default stream.

ByTopicRecordTranslator(RecordTranslator<K, V>) - Constructor for class org.apache.storm.kafka.spout.ByTopicRecordTranslator

C

C - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

C(Map) - Constructor for class org.apache.storm.starter.ThroughputVsLatency.C

cached - Variable in class org.apache.storm.trident.state.map.CachedBatchReadsMap.RetVal

CachedBatchReadsMap<T> - Class in org.apache.storm.trident.state.map

CachedBatchReadsMap(IBackingMap<T>) - Constructor for class org.apache.storm.trident.state.map.CachedBatchReadsMap

CachedBatchReadsMap.RetVal<T> - Class in org.apache.storm.trident.state.map

cachedGroups - Variable in class org.apache.storm.security.auth.ShellBasedGroupsMapping

CachedMap<T> - Class in org.apache.storm.trident.state.map

Useful to layer over a map that communicates with a database.

CachedMap(IBackingMap<T>, int) - Constructor for class org.apache.storm.trident.state.map.CachedMap

CachedSchemas - Class in org.apache.storm.sql.runtime.serde.avro

CachedSchemas() - Constructor for class org.apache.storm.sql.runtime.serde.avro.CachedSchemas

cacheSize - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options

calculateParititionIdsToOwn() - Method in class org.apache.storm.eventhubs.spout.StaticPartitionCoordinator

calculatePartitionsForTask(List<GlobalPartitionInformation>, int, int, int) - Static method in class org.apache.storm.kafka.KafkaUtils

call(int) - Method in interface org.apache.storm.daemon.supervisor.ExitCodeCallback

The process finished

call(T) - Method in interface org.apache.storm.daemon.supervisor.UniFunc

CALL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

callbackHandler - Variable in class org.apache.storm.messaging.netty.Login

CALLED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

callTimeout - Variable in class org.apache.storm.hive.common.HiveOptions

canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.DefaultPool

canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.FreePool

canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.IsolatedPool

canAdd(TopologyDetails) - Method in class org.apache.storm.scheduler.multitenant.NodePool

Check if this topology can be added to this pool

cancel() - Method in class org.apache.storm.blobstore.AtomicOutputStream

Cancel all of the writes associated with this stream and close it.

cancel() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream

cancel() - Method in class org.apache.storm.blobstore.BlobStoreFile

cancel() - Method in class org.apache.storm.blobstore.LocalFsBlobStoreFile

cancel() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusUploadAtomicOutputStream

cancel() - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile

cancelBlobUpload(String, AsyncMethodCallback<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

cancelBlobUpload(String, AsyncMethodCallback<Void>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

cancelBlobUpload() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.cancelBlobUpload

cancelBlobUpload(String) - Method in class org.apache.storm.generated.Nimbus.Client

cancelBlobUpload(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

cancelBlobUpload() - Constructor for class org.apache.storm.generated.Nimbus.Processor.cancelBlobUpload

cancelBlobUpload_args() - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

cancelBlobUpload_args(String) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

cancelBlobUpload_args(Nimbus.cancelBlobUpload_args) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

Performs a deep copy on other.

cancelBlobUpload_call(String, AsyncMethodCallback<Void>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.cancelBlobUpload_call

cancelBlobUpload_result() - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

cancelBlobUpload_result(AuthorizationException) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

cancelBlobUpload_result(Nimbus.cancelBlobUpload_result) - Constructor for class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

Performs a deep copy on other.

canConvertConvention(Convention) - Method in enum org.apache.storm.sql.planner.trident.rel.TridentLogicalConvention

canRelocateClass(String) - Method in interface org.apache.storm.hack.relocation.Relocator

canRelocateClass(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator

canRelocatePath(String) - Method in interface org.apache.storm.hack.relocation.Relocator

canRelocatePath(String) - Method in class org.apache.storm.hack.relocation.SimpleRelocator

canTransformResource(String) - Method in class org.apache.storm.hack.resource.ClojureTransformer

canTransformResource(String) - Method in interface org.apache.storm.hack.resource.ResourceTransformer

canTransformResource(String) - Method in class org.apache.storm.maven.shade.clojure.ClojureTransformer

canUserReadBlob(ReadableBlobMeta, String) - Static method in class org.apache.storm.utils.Utils

capacity() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics

CaptureCollector - Class in org.apache.storm.trident.operation.impl

CaptureCollector() - Constructor for class org.apache.storm.trident.operation.impl.CaptureCollector

captured - Variable in class org.apache.storm.trident.operation.impl.CaptureCollector

CARDINALITY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CASCADE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CASCADED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CASE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CaseExpression() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

CASSANDRA_BATCH_SIZE_ROWS - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_CONSISTENCY_LEVEL - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_DATACENTER_NAME - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_HEARTBEAT_INTERVAL_SEC - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_IDLE_TIMEOUT_SEC - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_KEYSPACE - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_LOAD_BALANCING_POLICY - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_MAX_REQUESTS_PER_CON_LOCAL - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_MAX_REQUESTS_PER_CON_REMOTE - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_NODES - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_PASSWORD - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_POOL_MAX_SIZE - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_PORT - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_RECONNECT_POLICY_BASE_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_RECONNECT_POLICY_MAX_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_RETRY_POLICY - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_SOCKET_CONNECT_TIMEOUT_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_SOCKET_READ_TIMEOUT_MS - Static variable in class org.apache.storm.cassandra.client.CassandraConf

CASSANDRA_USERNAME - Static variable in class org.apache.storm.cassandra.client.CassandraConf

cassandraConf - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt

CassandraConf - Class in org.apache.storm.cassandra.client

Configuration used by cassandra storm components.

CassandraConf() - Constructor for class org.apache.storm.cassandra.client.CassandraConf

Creates a new CassandraConf instance.

CassandraConf(Map<String, Object>) - Constructor for class org.apache.storm.cassandra.client.CassandraConf

Creates a new CassandraConf instance.

CassandraConfFactory() - Constructor for class org.apache.storm.cassandra.CassandraContext.CassandraConfFactory

CassandraContext - Class in org.apache.storm.cassandra

CassandraContext() - Constructor for class org.apache.storm.cassandra.CassandraContext

Creates a new CassandraContext instance.

CassandraContext.CassandraConfFactory - Class in org.apache.storm.cassandra

Simple class to make CassandraConf from a Storm topology configuration.

CassandraContext.ClientFactory - Class in org.apache.storm.cassandra

Simple class to make CassandraContext.ClientFactory from a Storm topology configuration.

CassandraQuery - Class in org.apache.storm.cassandra.trident.state

CassandraQuery() - Constructor for class org.apache.storm.cassandra.trident.state.CassandraQuery

CassandraState - Class in org.apache.storm.cassandra.trident.state

CassandraState(Map, CassandraState.Options) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraState

CassandraState.Options - Class in org.apache.storm.cassandra.trident.state

CassandraStateFactory - Class in org.apache.storm.cassandra.trident.state

CassandraStateFactory(CassandraState.Options) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateFactory

CassandraStateFactory(CQLStatementTupleMapper, CQLResultSetValuesMapper) - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateFactory

CassandraStateUpdater - Class in org.apache.storm.cassandra.trident.state

CassandraStateUpdater() - Constructor for class org.apache.storm.cassandra.trident.state.CassandraStateUpdater

CassandraWriterBolt - Class in org.apache.storm.cassandra.bolt

CassandraWriterBolt(CQLStatementTupleMapper) - Constructor for class org.apache.storm.cassandra.bolt.CassandraWriterBolt

Creates a new CassandraWriterBolt instance.

CAST - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CATALOG_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CEIL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CEILING - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CENTURY - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHAIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

chain(ChannelContext, ChannelHandler) - Static method in class org.apache.storm.sql.runtime.Channels

chainedAgg() - Method in class org.apache.storm.trident.fluent.GroupedStream

chainedAgg() - Method in class org.apache.storm.trident.Stream

ChainedAggregatorDeclarer - Class in org.apache.storm.trident.fluent

ChainedAggregatorDeclarer(IAggregatableStream, GlobalAggregationScheme) - Constructor for class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

ChainedAggregatorDeclarer.AggregationPartition - Interface in org.apache.storm.trident.fluent

ChainedAggregatorImpl - Class in org.apache.storm.trident.operation.impl

ChainedAggregatorImpl(Aggregator[], Fields[], ComboList.Factory) - Constructor for class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

ChainedFullAggregatorDeclarer - Interface in org.apache.storm.trident.fluent

ChainedPartitionAggregatorDeclarer - Interface in org.apache.storm.trident.fluent

ChainedResult - Class in org.apache.storm.trident.operation.impl

ChainedResult(TridentCollector, int) - Constructor for class org.apache.storm.trident.operation.impl.ChainedResult

chainEnd() - Method in class org.apache.storm.trident.fluent.ChainedAggregatorDeclarer

chainEnd() - Method in interface org.apache.storm.trident.fluent.IChainedAggregatorDeclarer

changeChildCWD(boolean) - Method in class org.apache.storm.spout.ShellSpout

Set if the current working directory of the child process should change to the resources dir from extracted from the jar, or if it should stay the same as the worker process to access things from the blob store.

changeChildCWD(boolean) - Method in class org.apache.storm.task.ShellBolt

Set if the current working directory of the child process should change to the resources dir from extracted from the jar, or if it should stay the same as the worker process to access things from the blob store.

changed(Watcher.Event.EventType, String) - Method in interface org.apache.storm.callback.ZKStateChangedCallback

channelConnected(Channel) - Method in class org.apache.storm.messaging.netty.Client

ISaslClient interface

channelConnected(Channel) - Method in interface org.apache.storm.messaging.netty.ISaslClient

channelConnected(Channel) - Method in interface org.apache.storm.messaging.netty.IServer

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.KerberosSaslClientHandler

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.SaslStormClientHandler

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.StormServerHandler

channelConnected(Channel) - Method in class org.apache.storm.pacemaker.PacemakerClient

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.pacemaker.PacemakerClientHandler

ChannelContext - Interface in org.apache.storm.sql.runtime

ChannelHandler - Interface in org.apache.storm.sql.runtime

DataListener provides an event-driven interface for the user to process series of events.

channelInactive(ChannelContext) - Method in class org.apache.storm.sql.runtime.AbstractChannelHandler

channelInactive(ChannelContext) - Method in interface org.apache.storm.sql.runtime.ChannelHandler

The producer of the data has indicated that the channel is no longer active.

channelInterestChanged(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.storm.messaging.netty.StormClientHandler

channelReady() - Method in class org.apache.storm.messaging.netty.Client

channelReady() - Method in interface org.apache.storm.messaging.netty.ISaslClient

channelReady() - Method in class org.apache.storm.pacemaker.PacemakerClient

Channels - Class in org.apache.storm.sql.runtime

Channels() - Constructor for class org.apache.storm.sql.runtime.Channels

CHAR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHAR_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTER_LENGTH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTER_SET_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTER_SET_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTER_SET_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTERISTICS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARACTERS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHARSET - Static variable in class org.apache.storm.hdfs.spout.TextFileReader

CHARSETNAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CHECK - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

Check() - Constructor for class org.apache.storm.starter.InOrderDeliveryTest.Check

CheckDirExists(String) - Static method in class org.apache.storm.utils.Utils

checkFileExists(File) - Static method in class org.apache.storm.utils.Utils

checkFileExists(String) - Static method in class org.apache.storm.utils.Utils

checkFileExists(String, String) - Static method in class org.apache.storm.utils.Utils

checkForBlobOrDownload(String) - Method in class org.apache.storm.blobstore.LocalFsBlobStore

checkForBlobUpdate(String) - Method in class org.apache.storm.blobstore.LocalFsBlobStore

checkForValidUsers(Subject, int) - Method in class org.apache.storm.blobstore.BlobStoreAclHandler

checkInitCPU(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils

checkInitMem(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils

checkIntialization(Map<String, Double>, String, Map) - Static method in class org.apache.storm.scheduler.resource.ResourceUtils

checkpoint() - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager

checkpoint() - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager

CHECKPOINT_COMPONENT_ID - Static variable in class org.apache.storm.spout.CheckpointSpout

CHECKPOINT_FIELD_ACTION - Static variable in class org.apache.storm.spout.CheckpointSpout

CHECKPOINT_FIELD_TXID - Static variable in class org.apache.storm.spout.CheckpointSpout

CHECKPOINT_STREAM_ID - Static variable in class org.apache.storm.spout.CheckpointSpout

CheckpointSpout - Class in org.apache.storm.spout

Emits checkpoint tuples which is used to save the state of the IStatefulComponent across the topology.

CheckpointSpout() - Constructor for class org.apache.storm.spout.CheckpointSpout

CheckPointState - Class in org.apache.storm.spout

Captures the current state of the transaction in CheckpointSpout.

CheckPointState(long, CheckPointState.State) - Constructor for class org.apache.storm.spout.CheckPointState

CheckPointState() - Constructor for class org.apache.storm.spout.CheckPointState

CheckPointState.Action - Enum in org.apache.storm.spout

CheckPointState.State - Enum in org.apache.storm.spout

CheckpointTupleForwarder - Class in org.apache.storm.topology

Wraps IRichBolt and forwards checkpoint tuples in a stateful topology.

CheckpointTupleForwarder(IRichBolt) - Constructor for class org.apache.storm.topology.CheckpointTupleForwarder

checkSslConfig(String, KeyStoreLoader) - Static method in class org.apache.storm.mqtt.common.SslUtils

checkType(ComponentObject._Fields, Object) - Method in class org.apache.storm.generated.ComponentObject

checkType(ExecutorSpecificStats._Fields, Object) - Method in class org.apache.storm.generated.ExecutorSpecificStats

checkType(Grouping._Fields, Object) - Method in class org.apache.storm.generated.Grouping

checkType(HBMessageData._Fields, Object) - Method in class org.apache.storm.generated.HBMessageData

checkType(JavaObjectArg._Fields, Object) - Method in class org.apache.storm.generated.JavaObjectArg

checkType(SpecificAggregateStats._Fields, Object) - Method in class org.apache.storm.generated.SpecificAggregateStats

checkType(TopologyActionOptions._Fields, Object) - Method in class org.apache.storm.generated.TopologyActionOptions

children - Variable in class org.apache.storm.scheduler.resource.Component

chooseTasks(int, List<Object>) - Method in class org.apache.storm.cassandra.Murmur3StreamGrouping

This function implements a custom stream grouping.

chooseTasks(int, List<Object>) - Method in interface org.apache.storm.grouping.CustomStreamGrouping

This function implements a custom stream grouping.

chooseTasks(int, List<Object>, LoadMapping) - Method in interface org.apache.storm.grouping.LoadAwareCustomStreamGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.LoadAwareShuffleGrouping

chooseTasks(int, List<Object>, LoadMapping) - Method in class org.apache.storm.grouping.LoadAwareShuffleGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.PartialKeyGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.grouping.ShuffleGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.testing.NGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.GlobalGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.IdentityGrouping

chooseTasks(int, List<Object>) - Method in class org.apache.storm.trident.partition.IndexHashGrouping

CLASS_ORIGIN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CLASS_PATH_SEPARATOR - Static variable in class org.apache.storm.utils.Utils

classLoaders - Variable in class org.apache.storm.sql.AbstractTridentProcessor

className() - Method in class org.apache.storm.sql.parser.SqlCreateFunction

clazz - Variable in class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.TypeClass

cleanConnection(boolean) - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder

cleanup() - Method in class org.apache.storm.cassandra.bolt.BaseCassandraBolt

Called when an IBolt is going to be shutdown.

cleanup() - Method in class org.apache.storm.cassandra.trident.state.CassandraState

cleanup() - Method in class org.apache.storm.clojure.ClojureBolt

cleanup() - Method in class org.apache.storm.coordination.BatchBoltExecutor

cleanup() - Method in class org.apache.storm.coordination.CoordinatedBolt

cleanUp() - Method in class org.apache.storm.daemon.supervisor.Container

cleanUp() - Method in interface org.apache.storm.daemon.supervisor.Killable

Clean up the container.

cleanup() - Method in class org.apache.storm.drpc.KeyedFairBolt

cleanup() - Method in class org.apache.storm.drpc.ReturnResults

cleanup() - Method in class org.apache.storm.druid.bolt.DruidBeamBolt

Deprecated.

cleanup() - Method in class org.apache.storm.hbase.bolt.AbstractHBaseBolt

cleanup() - Method in class org.apache.storm.hbase.topology.TotalWordCounter

cleanup() - Method in class org.apache.storm.hbase.topology.WordCounter

cleanup() - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt

cleanup() - Method in class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt

cleanup() - Method in class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt

cleanup() - Method in class org.apache.storm.hive.bolt.HiveBolt

cleanup() - Method in class org.apache.storm.hive.trident.HiveState

cleanup() - Method in class org.apache.storm.hooks.BaseTaskHook

cleanup() - Method in interface org.apache.storm.hooks.ITaskHook

cleanup() - Method in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

Cleanup.

cleanup() - Method in interface org.apache.storm.jdbc.common.ConnectionProvider

called once when the system is shutting down, should be idempotent.

cleanup() - Method in class org.apache.storm.jdbc.common.HikariCPConnectionProvider

cleanup() - Method in class org.apache.storm.jms.bolt.JmsBolt

Releases JMS resources.

cleanup() - Method in class org.apache.storm.jms.example.GenericBolt

cleanup() - Method in class org.apache.storm.kafka.bolt.KafkaBolt

Deprecated.

cleanup() - Method in class org.apache.storm.localizer.LocalizedResourceRetentionSet

cleanup() - Method in interface org.apache.storm.metric.api.IClusterMetricsConsumer

cleanup() - Method in interface org.apache.storm.metric.api.IMetricsConsumer

cleanup() - Method in class org.apache.storm.metric.ClusterMetricsConsumerExecutor

cleanup() - Method in class org.apache.storm.metric.EventLoggerBolt

cleanup() - Method in class org.apache.storm.metric.HttpForwardingMetricsConsumer

cleanup() - Method in class org.apache.storm.metric.LoggingClusterMetricsConsumer

cleanup() - Method in class org.apache.storm.metric.LoggingMetricsConsumer

cleanup() - Method in class org.apache.storm.metric.MetricsConsumerBolt

cleanup() - Method in class org.apache.storm.metric.SystemBolt

cleanup() - Method in class org.apache.storm.mongodb.bolt.AbstractMongoBolt

cleanup() - Method in class org.apache.storm.mongodb.topology.WordCounter

cleanup() - Method in interface org.apache.storm.nimbus.ITopologyActionNotifierPlugin

called during shutdown.

cleanup() - Method in class org.apache.storm.opentsdb.bolt.OpenTsdbBolt

cleanup() - Method in class org.apache.storm.opentsdb.client.OpenTsdbClient

cleanup() - Method in class org.apache.storm.redis.bolt.AbstractRedisBolt

cleanup() - Method in class org.apache.storm.redis.topology.WordCounter

cleanup() - Method in class org.apache.storm.solr.bolt.SolrUpdateBolt

cleanup() - Method in class org.apache.storm.sql.runtime.trident.functions.EvaluationCalc

cleanup() - Method in class org.apache.storm.sql.runtime.trident.functions.EvaluationFunction

cleanup() - Method in interface org.apache.storm.task.IBolt

Called when an IBolt is going to be shutdown.

cleanup() - Method in class org.apache.storm.task.ShellBolt

cleanup() - Method in class org.apache.storm.testing.FixedTupleSpout

cleanup() - Method in class org.apache.storm.testing.ForwardingMetricsConsumer

cleanup() - Method in class org.apache.storm.testing.MemoryTransactionalSpout

cleanup() - Method in class org.apache.storm.testing.NonRichBoltTracker

cleanup() - Method in class org.apache.storm.testing.OpaqueMemoryTransactionalSpout

cleanup() - Method in class org.apache.storm.testing.TestAggregatesCounter

cleanup() - Method in class org.apache.storm.testing.TestEventLogSpout

cleanup() - Method in class org.apache.storm.testing.TestEventOrderCheckBolt

cleanup() - Method in class org.apache.storm.testing.TestGlobalCount

cleanup() - Method in class org.apache.storm.testing.TestWordCounter

cleanup() - Method in class org.apache.storm.testing.TupleCaptureBolt

cleanup() - Method in class org.apache.storm.topology.base.BaseBasicBolt

cleanup() - Method in class org.apache.storm.topology.base.BaseRichBolt

cleanup() - Method in class org.apache.storm.topology.base.BaseStatefulBolt

cleanup() - Method in class org.apache.storm.topology.base.BaseWindowedBolt

cleanup() - Method in class org.apache.storm.topology.BasicBoltExecutor

cleanup() - Method in class org.apache.storm.topology.CheckpointTupleForwarder

cleanup() - Method in interface org.apache.storm.topology.IBasicBolt

cleanup() - Method in interface org.apache.storm.topology.IStatefulBolt

cleanup() - Method in interface org.apache.storm.topology.IWindowedBolt

cleanup() - Method in class org.apache.storm.topology.StatefulBoltExecutor

cleanup() - Method in class org.apache.storm.topology.WindowedBoltExecutor

cleanup() - Method in class org.apache.storm.transactional.TransactionalSpoutBatchExecutor

cleanup() - Method in class org.apache.storm.trident.drpc.ReturnResultsReducer

cleanup() - Method in class org.apache.storm.trident.operation.BaseMultiReducer

cleanup() - Method in class org.apache.storm.trident.operation.BaseOperation

No-op implemnation.

cleanup() - Method in class org.apache.storm.trident.operation.builtin.Negate

cleanup() - Method in interface org.apache.storm.trident.operation.GroupedMultiReducer

cleanup() - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl

cleanup() - Method in class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater

cleanup() - Method in class org.apache.storm.trident.operation.impl.FilterExecutor

cleanup() - Method in class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor

cleanup() - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator

cleanup() - Method in class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor

cleanup() - Method in class org.apache.storm.trident.operation.impl.IdentityMultiReducer

cleanup() - Method in class org.apache.storm.trident.operation.impl.JoinerMultiReducer

cleanup() - Method in class org.apache.storm.trident.operation.impl.MapFunctionExecutor

cleanup() - Method in class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer

cleanup() - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl

cleanup() - Method in class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater

cleanup() - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator

cleanup() - Method in class org.apache.storm.trident.operation.impl.TrueFilter

cleanup() - Method in interface org.apache.storm.trident.operation.MultiReducer

cleanup() - Method in interface org.apache.storm.trident.operation.Operation

When running in local mode, called when the local cluster is being shut down.

cleanup() - Method in class org.apache.storm.trident.planner.processor.AggregateProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.EachProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.MapProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.MultiReducerProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.PartitionPersistProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.ProjectedProcessor

cleanup() - Method in class org.apache.storm.trident.planner.processor.StateQueryProcessor

cleanup() - Method in class org.apache.storm.trident.planner.SubtopologyBolt

cleanup() - Method in interface org.apache.storm.trident.planner.TridentProcessor

cleanup() - Method in class org.apache.storm.trident.spout.TridentSpoutCoordinator

cleanup() - Method in class org.apache.storm.trident.spout.TridentSpoutExecutor

cleanup() - Method in class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater

cleanup() - Method in class org.apache.storm.trident.state.map.MapReducerAggStateUpdater

cleanup() - Method in interface org.apache.storm.trident.topology.ITridentBatchBolt

cleanup() - Method in class org.apache.storm.trident.topology.TridentBoltExecutor

cleanup() - Method in class org.apache.storm.trident.windowing.WindowsStateUpdater

cleanup() - Method in class org.apache.storm.trident.windowing.WindowTridentProcessor

cleanup(int) - Method in class org.apache.storm.utils.LocalState

cleanup() - Method in class org.apache.storm.utils.TimeCacheMap

Deprecated.

cleanup() - Method in class org.apache.storm.utils.VersionedStore

cleanup(int) - Method in class org.apache.storm.utils.VersionedStore

cleanupBefore(BigInteger) - Method in interface org.apache.storm.transactional.ITransactionalSpout.Emitter

Any state for transactions prior to the provided transaction id can be safely cleaned up, so this method should clean up that state.

cleanupBefore(BigInteger) - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

cleanupBefore(BigInteger) - Method in class org.apache.storm.transactional.state.RotatingTransactionalState

cleanupBefore(long) - Method in class org.apache.storm.trident.topology.state.RotatingTransactionalState

cleanUpForRestart() - Method in class org.apache.storm.daemon.supervisor.BasicContainer

cleanUpForRestart() - Method in class org.apache.storm.daemon.supervisor.Container

Clean up the container partly preparing for restart.

cleanupUnusedTopologies() - Method in class org.apache.storm.localizer.AsyncLocalizer

cleanupUnusedTopologies() - Method in interface org.apache.storm.localizer.ILocalizer

Clean up any topologies that are not in use right now.

clear() - Method in class org.apache.storm.generated.AccessControl

clear() - Method in exception org.apache.storm.generated.AlreadyAliveException

clear() - Method in class org.apache.storm.generated.Assignment

clear() - Method in exception org.apache.storm.generated.AuthorizationException

clear() - Method in class org.apache.storm.generated.BeginDownloadResult

clear() - Method in class org.apache.storm.generated.Bolt

clear() - Method in class org.apache.storm.generated.BoltAggregateStats

clear() - Method in class org.apache.storm.generated.BoltStats

clear() - Method in class org.apache.storm.generated.ClusterSummary

clear() - Method in class org.apache.storm.generated.ClusterWorkerHeartbeat

clear() - Method in class org.apache.storm.generated.CommonAggregateStats

clear() - Method in class org.apache.storm.generated.ComponentAggregateStats

clear() - Method in class org.apache.storm.generated.ComponentCommon

clear() - Method in class org.apache.storm.generated.ComponentPageInfo

clear() - Method in class org.apache.storm.generated.Credentials

clear() - Method in class org.apache.storm.generated.DebugOptions

clear() - Method in class org.apache.storm.generated.DistributedRPC.execute_args

clear() - Method in class org.apache.storm.generated.DistributedRPC.execute_result

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_args

clear() - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_result

clear() - Method in exception org.apache.storm.generated.DRPCExecutionException

clear() - Method in class org.apache.storm.generated.DRPCRequest

clear() - Method in class org.apache.storm.generated.ErrorInfo

clear() - Method in class org.apache.storm.generated.ExecutorAggregateStats

clear() - Method in class org.apache.storm.generated.ExecutorInfo

clear() - Method in class org.apache.storm.generated.ExecutorStats

clear() - Method in class org.apache.storm.generated.ExecutorSummary

clear() - Method in class org.apache.storm.generated.GetInfoOptions

clear() - Method in class org.apache.storm.generated.GlobalStreamId

clear() - Method in exception org.apache.storm.generated.HBAuthorizationException

clear() - Method in exception org.apache.storm.generated.HBExecutionException

clear() - Method in class org.apache.storm.generated.HBMessage

clear() - Method in class org.apache.storm.generated.HBNodes

clear() - Method in class org.apache.storm.generated.HBPulse

clear() - Method in class org.apache.storm.generated.HBRecords

clear() - Method in exception org.apache.storm.generated.InvalidTopologyException

clear() - Method in class org.apache.storm.generated.JavaObject

clear() - Method in exception org.apache.storm.generated.KeyAlreadyExistsException

clear() - Method in exception org.apache.storm.generated.KeyNotFoundException

clear() - Method in class org.apache.storm.generated.KillOptions

clear() - Method in class org.apache.storm.generated.ListBlobsResult

clear() - Method in class org.apache.storm.generated.LocalAssignment

clear() - Method in class org.apache.storm.generated.LocalStateData

clear() - Method in class org.apache.storm.generated.LogConfig

clear() - Method in class org.apache.storm.generated.LogLevel

clear() - Method in class org.apache.storm.generated.LSApprovedWorkers

clear() - Method in class org.apache.storm.generated.LSSupervisorAssignments

clear() - Method in class org.apache.storm.generated.LSSupervisorId

clear() - Method in class org.apache.storm.generated.LSTopoHistory

clear() - Method in class org.apache.storm.generated.LSTopoHistoryList

clear() - Method in class org.apache.storm.generated.LSWorkerHeartbeat

clear() - Method in class org.apache.storm.generated.Nimbus.activate_args

clear() - Method in class org.apache.storm.generated.Nimbus.activate_result

clear() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_args

clear() - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_result

clear() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_args

clear() - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_result

clear() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_args

clear() - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_result

clear() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_args

clear() - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_result

clear() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

clear() - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

clear() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

clear() - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

clear() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

clear() - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_result

clear() - Method in class org.apache.storm.generated.Nimbus.deactivate_args

clear() - Method in class org.apache.storm.generated.Nimbus.deactivate_result

clear() - Method in class org.apache.storm.generated.Nimbus.debug_args

clear() - Method in class org.apache.storm.generated.Nimbus.debug_result

clear() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_args

clear() - Method in class org.apache.storm.generated.Nimbus.deleteBlob_result

clear() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_args

clear() - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result

clear() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_args

clear() - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result

clear() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_args

clear() - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_result

clear() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_args

clear() - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_result

clear() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_args

clear() - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_result

clear() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_args

clear() - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_result

clear() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_args

clear() - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_result

clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_args

clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_result

clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args

clear() - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result

clear() - Method in class org.apache.storm.generated.Nimbus.getLeader_args

clear() - Method in class org.apache.storm.generated.Nimbus.getLeader_result

clear() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_args

clear() - Method in class org.apache.storm.generated.Nimbus.getLogConfig_result

clear() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_args

clear() - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_result

clear() - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args

clear() - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopology_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopology_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args

clear() - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result

clear() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_args

clear() - Method in class org.apache.storm.generated.Nimbus.getUserTopology_result

clear() - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args

clear() - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result

clear() - Method in class org.apache.storm.generated.Nimbus.killTopology_args

clear() - Method in class org.apache.storm.generated.Nimbus.killTopology_result

clear() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args

clear() - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result

clear() - Method in class org.apache.storm.generated.Nimbus.listBlobs_args

clear() - Method in class org.apache.storm.generated.Nimbus.listBlobs_result

clear() - Method in class org.apache.storm.generated.Nimbus.rebalance_args

clear() - Method in class org.apache.storm.generated.Nimbus.rebalance_result

clear() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_args

clear() - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_result

clear() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_args

clear() - Method in class org.apache.storm.generated.Nimbus.setLogConfig_result

clear() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_args

clear() - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_result

clear() - Method in class org.apache.storm.generated.Nimbus.submitTopology_args

clear() - Method in class org.apache.storm.generated.Nimbus.submitTopology_result

clear() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args

clear() - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result

clear() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_args

clear() - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_result

clear() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args

clear() - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_result

clear() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args

clear() - Method in class org.apache.storm.generated.Nimbus.uploadChunk_result

clear() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_args

clear() - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_result

clear() - Method in class org.apache.storm.generated.NimbusSummary

clear() - Method in class org.apache.storm.generated.NodeInfo

clear() - Method in exception org.apache.storm.generated.NotAliveException

clear() - Method in class org.apache.storm.generated.NullStruct

clear() - Method in class org.apache.storm.generated.ProfileRequest

clear() - Method in class org.apache.storm.generated.ReadableBlobMeta

clear() - Method in class org.apache.storm.generated.RebalanceOptions

clear() - Method in class org.apache.storm.generated.SettableBlobMeta

clear() - Method in class org.apache.storm.generated.ShellComponent

clear() - Method in class org.apache.storm.generated.SpoutAggregateStats

clear() - Method in class org.apache.storm.generated.SpoutSpec

clear() - Method in class org.apache.storm.generated.SpoutStats

clear() - Method in class org.apache.storm.generated.StateSpoutSpec

clear() - Method in class org.apache.storm.generated.StormBase

clear() - Method in class org.apache.storm.generated.StormTopology

clear() - Method in class org.apache.storm.generated.StreamInfo

clear() - Method in class org.apache.storm.generated.SubmitOptions

clear() - Method in class org.apache.storm.generated.SupervisorInfo

clear() - Method in class org.apache.storm.generated.SupervisorPageInfo

clear() - Method in class org.apache.storm.generated.SupervisorSummary

clear() - Method in class org.apache.storm.generated.ThriftSerializedObject

clear() - Method in class org.apache.storm.generated.TopologyHistoryInfo

clear() - Method in class org.apache.storm.generated.TopologyInfo

clear() - Method in class org.apache.storm.generated.TopologyPageInfo

clear() - Method in class org.apache.storm.generated.TopologyStats

clear() - Method in class org.apache.storm.generated.TopologySummary

clear() - Method in class org.apache.storm.generated.WorkerResources

clear() - Method in class org.apache.storm.generated.WorkerSummary

clear() - Method in class org.apache.storm.kafka.DynamicPartitionConnections

clear(String) - Static method in class org.apache.storm.testing.FixedTupleSpout

clear() - Method in class org.apache.storm.utils.IndifferentAccessMap

clear() - Method in class org.apache.storm.utils.ListDelegate

clear() - Method in class org.apache.storm.utils.TransferDrainer

clearCredentials(Subject, KerberosTicket) - Static method in class org.apache.storm.security.auth.kerberos.AutoTGT

clearOffsetsBefore(Long) - Method in class org.apache.storm.kafka.ExponentialBackoffMsgRetryManager

clearOffsetsBefore(Long) - Method in interface org.apache.storm.kafka.FailedMsgRetryManager

Clear any offsets before kafkaOffset.

clearState(String) - Static method in class org.apache.storm.utils.RegisteredGlobalState

client - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt

client - Static variable in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt

Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client

Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPC.Client

Client(TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client

Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.DistributedRPCInvocations.Client

Client(TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client

Client(TProtocol, TProtocol) - Constructor for class org.apache.storm.generated.Nimbus.Client

Client - Class in org.apache.storm.messaging.netty

A Netty client for sending task messages to a remote destination (Netty server).

client - Variable in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModuleTest

CLIENT_BLOBSTORE - Static variable in class org.apache.storm.Config

What blobstore implementation the storm client should use.

CLIENT_JAR_TRANSFORMER - Static variable in class org.apache.storm.Config

An implementation of @{link org.apache.storm.daemon.JarTransformer} that will can be used to transform a jar file before storm jar runs with it.

CLIENT_USERS_KEY - Static variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer

ClientBlobStore - Class in org.apache.storm.blobstore

The ClientBlobStore has two concrete implementations 1.

ClientBlobStore() - Constructor for class org.apache.storm.blobstore.ClientBlobStore

ClientCallbackHandler - Class in org.apache.storm.security.auth.digest

client side callback handler.

ClientCallbackHandler(Configuration) - Constructor for class org.apache.storm.security.auth.digest.ClientCallbackHandler

Constructor based on a JAAS configuration

ClientCallbackHandler - Class in org.apache.storm.security.auth.kerberos

SASL client side callback handler.

ClientCallbackHandler(Configuration) - Constructor for class org.apache.storm.security.auth.kerberos.ClientCallbackHandler

Constructor based on a JAAS configuration

ClientFactory() - Constructor for class org.apache.storm.cassandra.CassandraContext.ClientFactory

clientId - Variable in class org.apache.storm.kafka.KafkaConfig

ClientJarTransformerRunner - Class in org.apache.storm.daemon

Main executable to load and run a jar transformer

ClientJarTransformerRunner() - Constructor for class org.apache.storm.daemon.ClientJarTransformerRunner

clientProvider - Variable in class org.apache.storm.cassandra.bolt.BaseCassandraBolt

ClientResponse - Interface in org.apache.storm.opentsdb.client

This class represents the response from OpenTsdb for a request sent.

ClientResponse.Details - Class in org.apache.storm.opentsdb.client

ClientResponse.Details.Error - Class in org.apache.storm.opentsdb.client

ClientResponse.Summary - Class in org.apache.storm.opentsdb.client

clientUsers - Variable in class org.apache.storm.security.auth.authorizer.DRPCSimpleACLAuthorizer.AclFunctionEntry

CLOB - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CLOCKS_INSYNC - Static variable in class org.apache.storm.hdfs.spout.Configs

ClojureBolt - Class in org.apache.storm.clojure

ClojureBolt(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureBolt

clojureConfigName(String) - Static method in class org.apache.storm.utils.ConfigUtils

ClojureSpout - Class in org.apache.storm.clojure

ClojureSpout(List, List, List<Object>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.clojure.ClojureSpout

ClojureTimerTask - Class in org.apache.storm.utils

ClojureTimerTask(IFn) - Constructor for class org.apache.storm.utils.ClojureTimerTask

ClojureTransformer - Class in org.apache.storm.hack.resource

ClojureTransformer() - Constructor for class org.apache.storm.hack.resource.ClojureTransformer

ClojureTransformer - Class in org.apache.storm.maven.shade.clojure

ClojureTransformer() - Constructor for class org.apache.storm.maven.shade.clojure.ClojureTransformer

clone() - Method in class org.apache.storm.hdfs.spout.SequenceFileReader.Offset

clone() - Method in class org.apache.storm.hdfs.spout.TextFileReader.Offset

cloneKerberosTicket(KerberosTicket) - Static method in class org.apache.storm.security.auth.AuthUtils

close() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileInputStream

close() - Method in class org.apache.storm.blobstore.BlobStore.BlobStoreFileOutputStream

close() - Method in class org.apache.storm.blobstore.NimbusBlobStore

close() - Method in class org.apache.storm.blobstore.NimbusBlobStore.NimbusUploadAtomicOutputStream

close() - Method in class org.apache.storm.cassandra.client.impl.DefaultClient

Close the underlying Cluster instance.

close() - Method in interface org.apache.storm.cassandra.client.SimpleClient

Close the underlying Cluster instance.

close() - Method in class org.apache.storm.clojure.ClojureSpout

close() - Method in interface org.apache.storm.cluster.ClusterState

Close the connection to the data store.

close() - Method in interface org.apache.storm.cluster.IStateStorage

Close the connection to the data store.

close() - Method in class org.apache.storm.cluster.ZKStateStorage

close() - Method in class org.apache.storm.daemon.supervisor.ReadClusterState

close() - Method in class org.apache.storm.daemon.supervisor.Slot

close() - Method in class org.apache.storm.daemon.supervisor.Supervisor

close() - Method in class org.apache.storm.drpc.DRPCSpout

close() - Method in class org.apache.storm.druid.trident.DruidBeamState

Deprecated.

close() - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

close() - Method in class org.apache.storm.event.EventManagerImp

close() - Method in class org.apache.storm.eventhubs.spout.EventHubReceiverImpl

close() - Method in class org.apache.storm.eventhubs.spout.EventHubSpout

close() - Method in interface org.apache.storm.eventhubs.spout.IEventHubReceiver

close() - Method in interface org.apache.storm.eventhubs.spout.IPartitionManager

close() - Method in interface org.apache.storm.eventhubs.spout.IStateStore

close() - Method in class org.apache.storm.eventhubs.spout.SimplePartitionManager

close() - Method in class org.apache.storm.eventhubs.spout.ZookeeperStateStore

close() - Method in class org.apache.storm.eventhubs.trident.Coordinator

close() - Method in interface org.apache.storm.eventhubs.trident.ITridentPartitionManager

close() - Method in class org.apache.storm.eventhubs.trident.OpaqueTridentEventHubEmitter

close() - Method in class org.apache.storm.eventhubs.trident.TransactionalTridentEventHubEmitter

close() - Method in class org.apache.storm.eventhubs.trident.TridentPartitionManager

close() - Method in class org.apache.storm.hbase.common.HBaseClient

close() - Method in class org.apache.storm.hbase.topology.WordSpout

close() - Method in interface org.apache.storm.hdfs.bolt.Writer

close() - Method in class org.apache.storm.hdfs.common.AbstractHDFSWriter

close() - Method in class org.apache.storm.hdfs.spout.HdfsSpout

close() - Method in class org.apache.storm.hdfs.spout.SequenceFileReader

close() - Method in class org.apache.storm.hdfs.spout.TextFileReader

close() - Method in class org.apache.storm.hdfs.trident.FixedBatchSpout

close() - Method in class org.apache.storm.hive.common.HiveWriter

Close the Transaction Batch and connection

close() - Method in class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout

close() - Method in class org.apache.storm.jdbc.spout.UserSpout

close() - Method in class org.apache.storm.jms.spout.JmsSpout

Close the JmsSpout.session and JmsSpout.connection.

close() - Method in class org.apache.storm.kafka.ByteBufferSerializer

close() - Method in class org.apache.storm.kafka.DynamicBrokersReader

close() - Method in class org.apache.storm.kafka.IntSerializer

close() - Method in class org.apache.storm.kafka.KafkaSpout

Deprecated.

close() - Method in class org.apache.storm.kafka.PartitionManager

close() - Method in class org.apache.storm.kafka.spout.KafkaSpout

close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter

close() - Method in class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaqueCoordinator

close() - Method in class org.apache.storm.kafka.StaticPartitionConnections

close() - Method in class org.apache.storm.kafka.trident.DefaultCoordinator

close() - Method in interface org.apache.storm.kafka.trident.IBatchCoordinator

close() - Method in interface org.apache.storm.kafka.trident.IBrokerReader

close() - Method in class org.apache.storm.kafka.trident.StaticBrokerReader

close() - Method in class org.apache.storm.kafka.trident.ZkBrokerReader

close() - Method in class org.apache.storm.kafka.ZkState

close() - Method in class org.apache.storm.kinesis.spout.KinesisSpout

close() - Method in class org.apache.storm.LogWriter

close() - Method in interface org.apache.storm.messaging.IConnection

close this connection

close() - Method in class org.apache.storm.messaging.netty.Client

Gracefully close this client.

close() - Method in class org.apache.storm.metric.FileBasedEventLogger

close() - Method in interface org.apache.storm.metric.IEventLogger

close() - Method in class org.apache.storm.metric.internal.CountStatAndMetric

close() - Method in class org.apache.storm.metric.internal.LatencyStatAndMetric

close() - Method in class org.apache.storm.metric.internal.MultiCountStatAndMetric

close() - Method in class org.apache.storm.metric.internal.MultiLatencyStatAndMetric

close() - Method in class org.apache.storm.metric.internal.RateTracker

close() - Method in class org.apache.storm.mongodb.common.MongoDBClient

Closes all resources associated with this instance.

close() - Method in class org.apache.storm.mongodb.topology.WordSpout

close() - Method in class org.apache.storm.mqtt.spout.MqttSpout

close() - Method in interface org.apache.storm.nimbus.ILeaderElector

Method called to allow for cleanup.

close() - Method in class org.apache.storm.opentsdb.MetricGenBatchSpout

close() - Method in class org.apache.storm.pacemaker.PacemakerClient

close() - Method in class org.apache.storm.perf.utils.BasicMetricsCollector

close() - Method in class org.apache.storm.pmml.RawInputFromCSVSpout

close() - Method in class org.apache.storm.redis.common.adapter.RedisCommandsAdapterJedis

close() - Method in class org.apache.storm.redis.common.adapter.RedisCommandsAdapterJedisCluster

close() - Method in class org.apache.storm.redis.common.container.JedisClusterContainer

Release Container

close() - Method in interface org.apache.storm.redis.common.container.JedisCommandsInstanceContainer

Release Container

close() - Method in class org.apache.storm.redis.common.container.JedisContainer

Release Container

close() - Method in class org.apache.storm.redis.common.container.RedisClusterContainer

close() - Method in class org.apache.storm.redis.common.container.RedisContainer

close() - Method in class org.apache.storm.redis.topology.WordSpout

close() - Method in class org.apache.storm.security.auth.kerberos.NoOpTTrasport

close() - Method in class org.apache.storm.security.auth.ThriftClient

close() - Method in class org.apache.storm.solr.spout.SolrFieldsSpout

close() - Method in class org.apache.storm.solr.spout.SolrJsonSpout

close() - Method in interface org.apache.storm.spout.ISpout

Called when an ISpout is going to be shutdown.

close() - Method in class org.apache.storm.spout.ShellSpout

CLOSE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

close() - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.TridentSocketSpout

close() - Method in class org.apache.storm.starter.spout.RandomNumberGeneratorSpout

close() - Method in interface org.apache.storm.state.IStateSpout

close() - Method in class org.apache.storm.StormTimer

cancel timer

close() - Method in class org.apache.storm.testing.FeederSpout

close() - Method in class org.apache.storm.testing.FixedTupleSpout

close() - Method in class org.apache.storm.testing.SpoutTracker

close() - Method in class org.apache.storm.testing.staticmocking.MockedSupervisorUtils

close() - Method in class org.apache.storm.testing.TestEventLogSpout

close() - Method in class org.apache.storm.testing.TestPlannerSpout

close() - Method in class org.apache.storm.testing.TestWordSpout

close() - Method in class org.apache.storm.topology.base.BaseRichSpout

close() - Method in interface org.apache.storm.transactional.ITransactionalSpout.Coordinator

Release any resources from this coordinator.

close() - Method in interface org.apache.storm.transactional.ITransactionalSpout.Emitter

Release any resources held by this emitter.

close() - Method in interface org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Coordinator

close() - Method in interface org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout.Emitter

close() - Method in interface org.apache.storm.transactional.partitioned.IPartitionedTransactionalSpout.Coordinator

close() - Method in interface org.apache.storm.transactional.partitioned.IPartitionedTransactionalSpout.Emitter

close() - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

close() - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

close() - Method in class org.apache.storm.transactional.state.TransactionalState

close() - Method in class org.apache.storm.transactional.TransactionalSpoutCoordinator

close() - Method in class org.apache.storm.trident.spout.BatchSpoutExecutor.BatchSpoutEmitter

close() - Method in class org.apache.storm.trident.spout.BatchSpoutExecutor.EmptyCoordinator

close() - Method in interface org.apache.storm.trident.spout.IBatchSpout

close() - Method in interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout.Coordinator

close() - Method in interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter

close() - Method in interface org.apache.storm.trident.spout.IPartitionedTridentSpout.Coordinator

close() - Method in interface org.apache.storm.trident.spout.IPartitionedTridentSpout.Emitter

close() - Method in interface org.apache.storm.trident.spout.ITridentSpout.BatchCoordinator

Release any resources from this coordinator.

close() - Method in interface org.apache.storm.trident.spout.ITridentSpout.Emitter

Release any resources held by this emitter.

close() - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator

close() - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter

close() - Method in class org.apache.storm.trident.spout.RichSpoutBatchTriggerer

close() - Method in class org.apache.storm.trident.testing.FeederBatchSpout.FeederCoordinator

close() - Method in class org.apache.storm.trident.testing.FixedBatchSpout

close() - Method in class org.apache.storm.trident.topology.MasterBatchCoordinator

close() - Method in class org.apache.storm.trident.topology.state.TransactionalState

close() - Method in class org.apache.storm.utils.BufferFileInputStream

close() - Method in class org.apache.storm.utils.BufferInputStream

close() - Method in class org.apache.storm.utils.DisruptorQueue.QueueMetrics

close() - Method in class org.apache.storm.utils.Time.SimulatedTime

close() - Method in class org.apache.storm.zookeeper.LeaderElectorImp

closeChannel(Channel) - Method in interface org.apache.storm.messaging.netty.IServer

closed - Variable in class org.apache.storm.hive.common.HiveWriter

Cluster - Class in org.apache.storm.scheduler

Cluster(INimbus, Map<String, SupervisorDetails>, Map<String, SchedulerAssignmentImpl>, Map) - Constructor for class org.apache.storm.scheduler.Cluster

Cluster(Cluster) - Constructor for class org.apache.storm.scheduler.Cluster

Copy constructor

cluster - Variable in class org.apache.storm.scheduler.resource.SchedulingState

ClusterFactory - Class in org.apache.storm.cassandra.client

Default interface to build cassandra Cluster from the a Storm Topology configuration.

ClusterFactory() - Constructor for class org.apache.storm.cassandra.client.ClusterFactory

ClusterInfo(long) - Constructor for class org.apache.storm.metric.api.IClusterMetricsConsumer.ClusterInfo

ClusterMetricRegistryValidator() - Constructor for class org.apache.storm.validation.ConfigValidation.ClusterMetricRegistryValidator

ClusterMetricsConsumerExecutor - Class in org.apache.storm.metric

ClusterMetricsConsumerExecutor(String, Object) - Constructor for class org.apache.storm.metric.ClusterMetricsConsumerExecutor

clusterMode(Map) - Static method in class org.apache.storm.utils.ConfigUtils

clusterName - Static variable in class org.apache.storm.elasticsearch.common.EsConstants

ClusterState - Interface in org.apache.storm.cluster

ClusterState provides the API for the pluggable state store used by the Storm daemons.

ClusterStateContext - Class in org.apache.storm.cluster

This class is intended to provide runtime-context to ClusterStateFactory implementors, giving information such as what daemon is creating it.

ClusterStateContext() - Constructor for class org.apache.storm.cluster.ClusterStateContext

ClusterStateContext(DaemonType) - Constructor for class org.apache.storm.cluster.ClusterStateContext

ClusterStateFactory - Interface in org.apache.storm.cluster

ClusterStateListener - Interface in org.apache.storm.cluster

ClusterSummary - Class in org.apache.storm.generated

ClusterSummary() - Constructor for class org.apache.storm.generated.ClusterSummary

ClusterSummary(List<SupervisorSummary>, List<TopologySummary>, List<NimbusSummary>) - Constructor for class org.apache.storm.generated.ClusterSummary

ClusterSummary(ClusterSummary) - Constructor for class org.apache.storm.generated.ClusterSummary

Performs a deep copy on other.

ClusterSummary._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ClusterUtils - Class in org.apache.storm.cluster

ClusterUtils() - Constructor for class org.apache.storm.cluster.ClusterUtils

ClusterWorkerHeartbeat - Class in org.apache.storm.generated

ClusterWorkerHeartbeat() - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat

ClusterWorkerHeartbeat(String, Map<ExecutorInfo, ExecutorStats>, int, int) - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat

ClusterWorkerHeartbeat(ClusterWorkerHeartbeat) - Constructor for class org.apache.storm.generated.ClusterWorkerHeartbeat

Performs a deep copy on other.

ClusterWorkerHeartbeat._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

COALESCE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COBOL - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CollateClause() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a COLLATE clause

COLLATION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLATION_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLATION_ID - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLATION_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLATION_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

collect(Nimbus.Client) - Method in class org.apache.storm.perf.utils.BasicMetricsCollector

collect(LocalCluster) - Method in class org.apache.storm.perf.utils.BasicMetricsCollector

COLLECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLLECTION - Static variable in class org.apache.storm.solr.topology.SolrTopology

CollectionsTypeName() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

collectLocalMetricsAndKill(LocalCluster, String, Integer, Integer, Map) - Static method in class org.apache.storm.perf.utils.Helper

collectMetricsAndKill(String, Integer, Integer) - Static method in class org.apache.storm.perf.utils.Helper

collector - Variable in class org.apache.storm.elasticsearch.bolt.AbstractEsBolt

collector - Variable in class org.apache.storm.eventhubs.bolt.EventHubBolt

collector - Variable in class org.apache.storm.hbase.bolt.AbstractHBaseBolt

collector - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt

collector - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

collector - Variable in class org.apache.storm.kafka.spout.KafkaSpout

collector - Variable in class org.apache.storm.mongodb.bolt.AbstractMongoBolt

collector - Variable in class org.apache.storm.mqtt.spout.MqttSpout

collector - Variable in class org.apache.storm.redis.bolt.AbstractRedisBolt

collector - Variable in class org.apache.storm.topology.BaseStatefulBoltExecutor

collectTridentTupleOrKey(TridentBatchTuple, List<String>) - Method in class org.apache.storm.trident.windowing.StoreBasedTridentWindowManager

COLON - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

Column<T> - Class in org.apache.storm.cassandra.query

Column(String, T) - Constructor for class org.apache.storm.cassandra.query.Column

Column<T> - Class in org.apache.storm.jdbc.common

A database table can be defined as a list of rows and each row can be defined as a list of columns where each column instance has a name, a value and a type.

Column(String, T, int) - Constructor for class org.apache.storm.jdbc.common.Column

Column(String, int) - Constructor for class org.apache.storm.jdbc.common.Column

column - Variable in class org.apache.storm.sql.parser.impl.SimpleCharStream

COLUMN - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COLUMN_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ColumnConstraint - Class in org.apache.storm.sql.parser

ColumnConstraint.PrimaryKey - Class in org.apache.storm.sql.parser

ColumnDefinition - Class in org.apache.storm.sql.parser

ColumnDefinition(SqlIdentifier, SqlDataTypeSpec, ColumnConstraint, SqlParserPos) - Constructor for class org.apache.storm.sql.parser.ColumnDefinition

ColumnDefinitionList() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

columnFamily - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options

ColumnList - Class in org.apache.storm.hbase.common

Represents a list of HBase columns.

ColumnList() - Constructor for class org.apache.storm.hbase.common.ColumnList

ColumnList.AbstractColumn - Class in org.apache.storm.hbase.common

ColumnList.Column - Class in org.apache.storm.hbase.common

ColumnList.Counter - Class in org.apache.storm.hbase.common

ColumnMetaData(String, String) - Constructor for class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria.ColumnMetaData

ColumnMetaData(byte[], byte[]) - Constructor for class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria.ColumnMetaData

columns(Tuple) - Method in interface org.apache.storm.hbase.bolt.mapper.HBaseMapper

Given a tuple, return a list of HBase columns to insert.

columns(Tuple) - Method in class org.apache.storm.hbase.bolt.mapper.SimpleHBaseMapper

columns(TridentTuple) - Method in class org.apache.storm.hbase.trident.mapper.SimpleTridentHBaseMapper

columns(TridentTuple) - Method in interface org.apache.storm.hbase.trident.mapper.TridentHBaseMapper

Given a tuple, return a list of HBase columns to insert.

ColumnType(List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

combine(Long, Long) - Method in class org.apache.storm.kafka.trident.MaxMetric

combine(T, T) - Method in interface org.apache.storm.metric.api.ICombiner

combine(Integer, Integer) - Method in class org.apache.storm.starter.trident.TridentReach.One

combine(Long, Long) - Method in class org.apache.storm.trident.operation.builtin.Count

combine(Number, Number) - Method in class org.apache.storm.trident.operation.builtin.Sum

combine(T, T) - Method in interface org.apache.storm.trident.operation.CombinerAggregator

CombinedMetric - Class in org.apache.storm.metric.api

CombinedMetric(ICombiner) - Constructor for class org.apache.storm.metric.api.CombinedMetric

CombinedShellMetric - Class in org.apache.storm.metric.api.rpc

CombinedShellMetric(ICombiner) - Constructor for class org.apache.storm.metric.api.rpc.CombinedShellMetric

CombinerAggregator<T> - Interface in org.apache.storm.trident.operation

CombinerAggregatorCombineImpl - Class in org.apache.storm.trident.operation.impl

CombinerAggregatorCombineImpl(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

CombinerAggregatorInitImpl - Class in org.apache.storm.trident.operation.impl

CombinerAggregatorInitImpl(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl

CombinerAggStateUpdater - Class in org.apache.storm.trident.operation.impl

CombinerAggStateUpdater(CombinerAggregator) - Constructor for class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater

CombinerValueUpdater - Class in org.apache.storm.trident.state

CombinerValueUpdater(CombinerAggregator, Object) - Constructor for class org.apache.storm.trident.state.CombinerValueUpdater

ComboList - Class in org.apache.storm.trident.tuple

ComboList(List[], ComboList.Pointer[]) - Constructor for class org.apache.storm.trident.tuple.ComboList

ComboList.Factory - Class in org.apache.storm.trident.tuple

COMMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COMMAND_FUNCTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COMMAND_FUNCTION_CODE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CommandExec - Class in org.apache.storm.maven.plugin.util

CommandExec(Mojo) - Constructor for class org.apache.storm.maven.plugin.util.CommandExec

commit() - Method in class org.apache.storm.blobstore.BlobStoreFile

commit() - Method in class org.apache.storm.blobstore.LocalFsBlobStoreFile

commit(Long) - Method in class org.apache.storm.cassandra.trident.state.CassandraState

commit(Long) - Method in class org.apache.storm.druid.trident.DruidBeamState

Deprecated.

commit(long) - Method in class org.apache.storm.hbase.state.HBaseKeyValueState

commit() - Method in class org.apache.storm.hbase.state.HBaseKeyValueState

commit(Long) - Method in class org.apache.storm.hbase.trident.state.HBaseState

commit() - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile

commit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState

commit(Long) - Method in class org.apache.storm.hive.trident.HiveState

commit(Long) - Method in class org.apache.storm.jdbc.trident.state.JdbcState

commit(Long) - Method in class org.apache.storm.jms.trident.JmsState

commit() - Method in class org.apache.storm.kafka.PartitionManager

commit(OffsetAndMetadata) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager

Marks an offset as committed.

commit(Long) - Method in class org.apache.storm.kafka.trident.TridentKafkaState

Deprecated.

commit(Long) - Method in class org.apache.storm.mongodb.trident.state.MongoState

commit(Long) - Method in class org.apache.storm.opentsdb.trident.OpenTsdbState

commit(long) - Method in class org.apache.storm.redis.state.RedisKeyValueState

commit() - Method in class org.apache.storm.redis.state.RedisKeyValueState

commit(Long) - Method in class org.apache.storm.redis.trident.state.RedisClusterState

commit(Long) - Method in class org.apache.storm.redis.trident.state.RedisState

commit() - Method in class org.apache.storm.security.auth.kerberos.AutoTGTKrb5LoginModule

commit() - Method in class org.apache.storm.solr.config.CountBasedCommit

commit() - Method in interface org.apache.storm.solr.config.SolrCommitStrategy

commit(Long) - Method in class org.apache.storm.solr.trident.SolrState

COMMIT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

commit(Long) - Method in class org.apache.storm.sql.runtime.datasource.socket.trident.SocketState

commit() - Method in class org.apache.storm.state.InMemoryKeyValueState

commit(long) - Method in class org.apache.storm.state.InMemoryKeyValueState

commit(long) - Method in interface org.apache.storm.state.State

Commit a previously prepared transaction.

commit() - Method in interface org.apache.storm.state.State

Persist the current state.

commit(TransactionAttempt) - Method in interface org.apache.storm.transactional.ICommitterTransactionalSpout.Emitter

commit(TransactionAttempt) - Method in class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter

commit(TransactionAttempt) - Method in interface org.apache.storm.trident.spout.ICommitterTridentSpout.Emitter

commit(TransactionAttempt) - Method in class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter

commit(Long) - Method in class org.apache.storm.trident.state.map.NonTransactionalMap

commit(Long) - Method in class org.apache.storm.trident.state.map.OpaqueMap

commit(Long) - Method in class org.apache.storm.trident.state.map.SnapshottableMap

commit(Long) - Method in class org.apache.storm.trident.state.map.TransactionalMap

commit(Long) - Method in class org.apache.storm.trident.state.ReadOnlyState

commit(Long) - Method in interface org.apache.storm.trident.state.State

commit(Long) - Method in class org.apache.storm.trident.testing.LRUMemoryMapState

commit(Long) - Method in class org.apache.storm.trident.testing.MemoryMapState

commit(Long) - Method in class org.apache.storm.trident.windowing.WindowsState

COMMIT_FREQ_COUNT - Static variable in class org.apache.storm.hdfs.spout.Configs

COMMIT_FREQ_SEC - Static variable in class org.apache.storm.hdfs.spout.Configs

COMMIT_STREAM_ID - Static variable in class org.apache.storm.trident.topology.MasterBatchCoordinator

CommitFailure(HiveEndPoint, Long, Throwable) - Constructor for exception org.apache.storm.hive.common.HiveWriter.CommitFailure

CommitMetadata - Class in org.apache.storm.kafka.spout.internal

Object representing metadata committed to Kafka.

CommitMetadata(String, int, String) - Constructor for class org.apache.storm.kafka.spout.internal.CommitMetadata

Kafka metadata.

CommitMetadataManager - Class in org.apache.storm.kafka.spout.internal

Generates and reads commit metadata.

CommitMetadataManager(TopologyContext, KafkaSpoutConfig.ProcessingGuarantee) - Constructor for class org.apache.storm.kafka.spout.internal.CommitMetadataManager

Create a manager with the given context.

commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition

commitStream - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec

COMMITTED - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

committedOffset - Variable in class org.apache.storm.eventhubs.spout.SimplePartitionManager

committedPath() - Method in class org.apache.storm.kafka.PartitionManager

committer - Variable in class org.apache.storm.trident.planner.ProcessorNode

CommonAggregateStats - Class in org.apache.storm.generated

CommonAggregateStats() - Constructor for class org.apache.storm.generated.CommonAggregateStats

CommonAggregateStats(CommonAggregateStats) - Constructor for class org.apache.storm.generated.CommonAggregateStats

Performs a deep copy on other.

CommonAggregateStats._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

CommonNonReservedKeyWord() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a non-reserved keyword for use as an identifier.

compare(FileStatus, FileStatus) - Method in class org.apache.storm.hdfs.common.ModifTimeComparator

compare(TopicPartition, TopicPartition) - Method in class org.apache.storm.kafka.spout.TopicPartitionComparator

compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator

compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Max

compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.MaxWithComparator

compare(Comparable<Object>, Comparable<Object>) - Method in class org.apache.storm.trident.operation.builtin.Min

compare(T, T) - Method in class org.apache.storm.trident.operation.builtin.MinWithComparator

compareTo(EventData) - Method in class org.apache.storm.eventhubs.spout.EventData

compareTo(AccessControl) - Method in class org.apache.storm.generated.AccessControl

compareTo(AlreadyAliveException) - Method in exception org.apache.storm.generated.AlreadyAliveException

compareTo(Assignment) - Method in class org.apache.storm.generated.Assignment

compareTo(AuthorizationException) - Method in exception org.apache.storm.generated.AuthorizationException

compareTo(BeginDownloadResult) - Method in class org.apache.storm.generated.BeginDownloadResult

compareTo(Bolt) - Method in class org.apache.storm.generated.Bolt

compareTo(BoltAggregateStats) - Method in class org.apache.storm.generated.BoltAggregateStats

compareTo(BoltStats) - Method in class org.apache.storm.generated.BoltStats

compareTo(ClusterSummary) - Method in class org.apache.storm.generated.ClusterSummary

compareTo(ClusterWorkerHeartbeat) - Method in class org.apache.storm.generated.ClusterWorkerHeartbeat

compareTo(CommonAggregateStats) - Method in class org.apache.storm.generated.CommonAggregateStats

compareTo(ComponentAggregateStats) - Method in class org.apache.storm.generated.ComponentAggregateStats

compareTo(ComponentCommon) - Method in class org.apache.storm.generated.ComponentCommon

compareTo(ComponentObject) - Method in class org.apache.storm.generated.ComponentObject

compareTo(ComponentPageInfo) - Method in class org.apache.storm.generated.ComponentPageInfo

compareTo(Credentials) - Method in class org.apache.storm.generated.Credentials

compareTo(DebugOptions) - Method in class org.apache.storm.generated.DebugOptions

compareTo(DistributedRPC.execute_args) - Method in class org.apache.storm.generated.DistributedRPC.execute_args

compareTo(DistributedRPC.execute_result) - Method in class org.apache.storm.generated.DistributedRPC.execute_result

compareTo(DistributedRPCInvocations.failRequest_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args

compareTo(DistributedRPCInvocations.failRequest_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result

compareTo(DistributedRPCInvocations.fetchRequest_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args

compareTo(DistributedRPCInvocations.fetchRequest_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result

compareTo(DistributedRPCInvocations.result_args) - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_args

compareTo(DistributedRPCInvocations.result_result) - Method in class org.apache.storm.generated.DistributedRPCInvocations.result_result

compareTo(DRPCExecutionException) - Method in exception org.apache.storm.generated.DRPCExecutionException

compareTo(DRPCRequest) - Method in class org.apache.storm.generated.DRPCRequest

compareTo(ErrorInfo) - Method in class org.apache.storm.generated.ErrorInfo

compareTo(ExecutorAggregateStats) - Method in class org.apache.storm.generated.ExecutorAggregateStats

compareTo(ExecutorInfo) - Method in class org.apache.storm.generated.ExecutorInfo

compareTo(ExecutorSpecificStats) - Method in class org.apache.storm.generated.ExecutorSpecificStats

compareTo(ExecutorStats) - Method in class org.apache.storm.generated.ExecutorStats

compareTo(ExecutorSummary) - Method in class org.apache.storm.generated.ExecutorSummary

compareTo(GetInfoOptions) - Method in class org.apache.storm.generated.GetInfoOptions

compareTo(GlobalStreamId) - Method in class org.apache.storm.generated.GlobalStreamId

compareTo(Grouping) - Method in class org.apache.storm.generated.Grouping

compareTo(HBAuthorizationException) - Method in exception org.apache.storm.generated.HBAuthorizationException

compareTo(HBExecutionException) - Method in exception org.apache.storm.generated.HBExecutionException

compareTo(HBMessage) - Method in class org.apache.storm.generated.HBMessage

compareTo(HBMessageData) - Method in class org.apache.storm.generated.HBMessageData

compareTo(HBNodes) - Method in class org.apache.storm.generated.HBNodes

compareTo(HBPulse) - Method in class org.apache.storm.generated.HBPulse

compareTo(HBRecords) - Method in class org.apache.storm.generated.HBRecords

compareTo(InvalidTopologyException) - Method in exception org.apache.storm.generated.InvalidTopologyException

compareTo(JavaObject) - Method in class org.apache.storm.generated.JavaObject

compareTo(JavaObjectArg) - Method in class org.apache.storm.generated.JavaObjectArg

compareTo(KeyAlreadyExistsException) - Method in exception org.apache.storm.generated.KeyAlreadyExistsException

compareTo(KeyNotFoundException) - Method in exception org.apache.storm.generated.KeyNotFoundException

compareTo(KillOptions) - Method in class org.apache.storm.generated.KillOptions

compareTo(ListBlobsResult) - Method in class org.apache.storm.generated.ListBlobsResult

compareTo(LocalAssignment) - Method in class org.apache.storm.generated.LocalAssignment

compareTo(LocalStateData) - Method in class org.apache.storm.generated.LocalStateData

compareTo(LogConfig) - Method in class org.apache.storm.generated.LogConfig

compareTo(LogLevel) - Method in class org.apache.storm.generated.LogLevel

compareTo(LSApprovedWorkers) - Method in class org.apache.storm.generated.LSApprovedWorkers

compareTo(LSSupervisorAssignments) - Method in class org.apache.storm.generated.LSSupervisorAssignments

compareTo(LSSupervisorId) - Method in class org.apache.storm.generated.LSSupervisorId

compareTo(LSTopoHistory) - Method in class org.apache.storm.generated.LSTopoHistory

compareTo(LSTopoHistoryList) - Method in class org.apache.storm.generated.LSTopoHistoryList

compareTo(LSWorkerHeartbeat) - Method in class org.apache.storm.generated.LSWorkerHeartbeat

compareTo(Nimbus.activate_args) - Method in class org.apache.storm.generated.Nimbus.activate_args

compareTo(Nimbus.activate_result) - Method in class org.apache.storm.generated.Nimbus.activate_result

compareTo(Nimbus.beginBlobDownload_args) - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_args

compareTo(Nimbus.beginBlobDownload_result) - Method in class org.apache.storm.generated.Nimbus.beginBlobDownload_result

compareTo(Nimbus.beginCreateBlob_args) - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_args

compareTo(Nimbus.beginCreateBlob_result) - Method in class org.apache.storm.generated.Nimbus.beginCreateBlob_result

compareTo(Nimbus.beginFileDownload_args) - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_args

compareTo(Nimbus.beginFileDownload_result) - Method in class org.apache.storm.generated.Nimbus.beginFileDownload_result

compareTo(Nimbus.beginFileUpload_args) - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_args

compareTo(Nimbus.beginFileUpload_result) - Method in class org.apache.storm.generated.Nimbus.beginFileUpload_result

compareTo(Nimbus.beginUpdateBlob_args) - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

compareTo(Nimbus.beginUpdateBlob_result) - Method in class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

compareTo(Nimbus.cancelBlobUpload_args) - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

compareTo(Nimbus.cancelBlobUpload_result) - Method in class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

compareTo(Nimbus.createStateInZookeeper_args) - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

compareTo(Nimbus.createStateInZookeeper_result) - Method in class org.apache.storm.generated.Nimbus.createStateInZookeeper_result

compareTo(Nimbus.deactivate_args) - Method in class org.apache.storm.generated.Nimbus.deactivate_args

compareTo(Nimbus.deactivate_result) - Method in class org.apache.storm.generated.Nimbus.deactivate_result

compareTo(Nimbus.debug_args) - Method in class org.apache.storm.generated.Nimbus.debug_args

compareTo(Nimbus.debug_result) - Method in class org.apache.storm.generated.Nimbus.debug_result

compareTo(Nimbus.deleteBlob_args) - Method in class org.apache.storm.generated.Nimbus.deleteBlob_args

compareTo(Nimbus.deleteBlob_result) - Method in class org.apache.storm.generated.Nimbus.deleteBlob_result

compareTo(Nimbus.downloadBlobChunk_args) - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_args

compareTo(Nimbus.downloadBlobChunk_result) - Method in class org.apache.storm.generated.Nimbus.downloadBlobChunk_result

compareTo(Nimbus.downloadChunk_args) - Method in class org.apache.storm.generated.Nimbus.downloadChunk_args

compareTo(Nimbus.downloadChunk_result) - Method in class org.apache.storm.generated.Nimbus.downloadChunk_result

compareTo(Nimbus.finishBlobUpload_args) - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_args

compareTo(Nimbus.finishBlobUpload_result) - Method in class org.apache.storm.generated.Nimbus.finishBlobUpload_result

compareTo(Nimbus.finishFileUpload_args) - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_args

compareTo(Nimbus.finishFileUpload_result) - Method in class org.apache.storm.generated.Nimbus.finishFileUpload_result

compareTo(Nimbus.getBlobMeta_args) - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_args

compareTo(Nimbus.getBlobMeta_result) - Method in class org.apache.storm.generated.Nimbus.getBlobMeta_result

compareTo(Nimbus.getBlobReplication_args) - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_args

compareTo(Nimbus.getBlobReplication_result) - Method in class org.apache.storm.generated.Nimbus.getBlobReplication_result

compareTo(Nimbus.getClusterInfo_args) - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_args

compareTo(Nimbus.getClusterInfo_result) - Method in class org.apache.storm.generated.Nimbus.getClusterInfo_result

compareTo(Nimbus.getComponentPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_args

compareTo(Nimbus.getComponentPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getComponentPageInfo_result

compareTo(Nimbus.getComponentPendingProfileActions_args) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args

compareTo(Nimbus.getComponentPendingProfileActions_result) - Method in class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result

compareTo(Nimbus.getLeader_args) - Method in class org.apache.storm.generated.Nimbus.getLeader_args

compareTo(Nimbus.getLeader_result) - Method in class org.apache.storm.generated.Nimbus.getLeader_result

compareTo(Nimbus.getLogConfig_args) - Method in class org.apache.storm.generated.Nimbus.getLogConfig_args

compareTo(Nimbus.getLogConfig_result) - Method in class org.apache.storm.generated.Nimbus.getLogConfig_result

compareTo(Nimbus.getNimbusConf_args) - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_args

compareTo(Nimbus.getNimbusConf_result) - Method in class org.apache.storm.generated.Nimbus.getNimbusConf_result

compareTo(Nimbus.getSupervisorPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args

compareTo(Nimbus.getSupervisorPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_result

compareTo(Nimbus.getTopology_args) - Method in class org.apache.storm.generated.Nimbus.getTopology_args

compareTo(Nimbus.getTopology_result) - Method in class org.apache.storm.generated.Nimbus.getTopology_result

compareTo(Nimbus.getTopologyConf_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_args

compareTo(Nimbus.getTopologyConf_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyConf_result

compareTo(Nimbus.getTopologyHistory_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_args

compareTo(Nimbus.getTopologyHistory_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyHistory_result

compareTo(Nimbus.getTopologyInfo_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_args

compareTo(Nimbus.getTopologyInfo_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfo_result

compareTo(Nimbus.getTopologyInfoWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args

compareTo(Nimbus.getTopologyInfoWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result

compareTo(Nimbus.getTopologyPageInfo_args) - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args

compareTo(Nimbus.getTopologyPageInfo_result) - Method in class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result

compareTo(Nimbus.getUserTopology_args) - Method in class org.apache.storm.generated.Nimbus.getUserTopology_args

compareTo(Nimbus.getUserTopology_result) - Method in class org.apache.storm.generated.Nimbus.getUserTopology_result

compareTo(Nimbus.isTopologyNameAllowed_args) - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args

compareTo(Nimbus.isTopologyNameAllowed_result) - Method in class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result

compareTo(Nimbus.killTopology_args) - Method in class org.apache.storm.generated.Nimbus.killTopology_args

compareTo(Nimbus.killTopology_result) - Method in class org.apache.storm.generated.Nimbus.killTopology_result

compareTo(Nimbus.killTopologyWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args

compareTo(Nimbus.killTopologyWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result

compareTo(Nimbus.listBlobs_args) - Method in class org.apache.storm.generated.Nimbus.listBlobs_args

compareTo(Nimbus.listBlobs_result) - Method in class org.apache.storm.generated.Nimbus.listBlobs_result

compareTo(Nimbus.rebalance_args) - Method in class org.apache.storm.generated.Nimbus.rebalance_args

compareTo(Nimbus.rebalance_result) - Method in class org.apache.storm.generated.Nimbus.rebalance_result

compareTo(Nimbus.setBlobMeta_args) - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_args

compareTo(Nimbus.setBlobMeta_result) - Method in class org.apache.storm.generated.Nimbus.setBlobMeta_result

compareTo(Nimbus.setLogConfig_args) - Method in class org.apache.storm.generated.Nimbus.setLogConfig_args

compareTo(Nimbus.setLogConfig_result) - Method in class org.apache.storm.generated.Nimbus.setLogConfig_result

compareTo(Nimbus.setWorkerProfiler_args) - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_args

compareTo(Nimbus.setWorkerProfiler_result) - Method in class org.apache.storm.generated.Nimbus.setWorkerProfiler_result

compareTo(Nimbus.submitTopology_args) - Method in class org.apache.storm.generated.Nimbus.submitTopology_args

compareTo(Nimbus.submitTopology_result) - Method in class org.apache.storm.generated.Nimbus.submitTopology_result

compareTo(Nimbus.submitTopologyWithOpts_args) - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args

compareTo(Nimbus.submitTopologyWithOpts_result) - Method in class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result

compareTo(Nimbus.updateBlobReplication_args) - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_args

compareTo(Nimbus.updateBlobReplication_result) - Method in class org.apache.storm.generated.Nimbus.updateBlobReplication_result

compareTo(Nimbus.uploadBlobChunk_args) - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_args

compareTo(Nimbus.uploadBlobChunk_result) - Method in class org.apache.storm.generated.Nimbus.uploadBlobChunk_result

compareTo(Nimbus.uploadChunk_args) - Method in class org.apache.storm.generated.Nimbus.uploadChunk_args

compareTo(Nimbus.uploadChunk_result) - Method in class org.apache.storm.generated.Nimbus.uploadChunk_result

compareTo(Nimbus.uploadNewCredentials_args) - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_args

compareTo(Nimbus.uploadNewCredentials_result) - Method in class org.apache.storm.generated.Nimbus.uploadNewCredentials_result

compareTo(NimbusSummary) - Method in class org.apache.storm.generated.NimbusSummary

compareTo(NodeInfo) - Method in class org.apache.storm.generated.NodeInfo

compareTo(NotAliveException) - Method in exception org.apache.storm.generated.NotAliveException

compareTo(NullStruct) - Method in class org.apache.storm.generated.NullStruct

compareTo(ProfileRequest) - Method in class org.apache.storm.generated.ProfileRequest

compareTo(ReadableBlobMeta) - Method in class org.apache.storm.generated.ReadableBlobMeta

compareTo(RebalanceOptions) - Method in class org.apache.storm.generated.RebalanceOptions

compareTo(SettableBlobMeta) - Method in class org.apache.storm.generated.SettableBlobMeta

compareTo(ShellComponent) - Method in class org.apache.storm.generated.ShellComponent

compareTo(SpecificAggregateStats) - Method in class org.apache.storm.generated.SpecificAggregateStats

compareTo(SpoutAggregateStats) - Method in class org.apache.storm.generated.SpoutAggregateStats

compareTo(SpoutSpec) - Method in class org.apache.storm.generated.SpoutSpec

compareTo(SpoutStats) - Method in class org.apache.storm.generated.SpoutStats

compareTo(StateSpoutSpec) - Method in class org.apache.storm.generated.StateSpoutSpec

compareTo(StormBase) - Method in class org.apache.storm.generated.StormBase

compareTo(StormTopology) - Method in class org.apache.storm.generated.StormTopology

compareTo(StreamInfo) - Method in class org.apache.storm.generated.StreamInfo

compareTo(SubmitOptions) - Method in class org.apache.storm.generated.SubmitOptions

compareTo(SupervisorInfo) - Method in class org.apache.storm.generated.SupervisorInfo

compareTo(SupervisorPageInfo) - Method in class org.apache.storm.generated.SupervisorPageInfo

compareTo(SupervisorSummary) - Method in class org.apache.storm.generated.SupervisorSummary

compareTo(ThriftSerializedObject) - Method in class org.apache.storm.generated.ThriftSerializedObject

compareTo(TopologyActionOptions) - Method in class org.apache.storm.generated.TopologyActionOptions

compareTo(TopologyHistoryInfo) - Method in class org.apache.storm.generated.TopologyHistoryInfo

compareTo(TopologyInfo) - Method in class org.apache.storm.generated.TopologyInfo

compareTo(TopologyPageInfo) - Method in class org.apache.storm.generated.TopologyPageInfo

compareTo(TopologyStats) - Method in class org.apache.storm.generated.TopologyStats

compareTo(TopologySummary) - Method in class org.apache.storm.generated.TopologySummary

compareTo(WorkerResources) - Method in class org.apache.storm.generated.WorkerResources

compareTo(WorkerSummary) - Method in class org.apache.storm.generated.WorkerSummary

compareTo(FileOffset) - Method in class org.apache.storm.hdfs.spout.SequenceFileReader.Offset

compareTo(FileOffset) - Method in class org.apache.storm.hdfs.spout.TextFileReader.Offset

compareTo(JmsMessageID) - Method in class org.apache.storm.jms.spout.JmsMessageID

compareTo(Broker) - Method in class org.apache.storm.kafka.Broker

compareTo(Rankable) - Method in class org.apache.storm.starter.tools.RankableObjectWithFields

compareTo(Object) - Method in class org.apache.storm.trident.util.IndexedEdge

ComparisonAggregator<T> - Class in org.apache.storm.trident.operation.builtin

Abstract Aggregator for comparing two values in a stream.

ComparisonAggregator(String) - Constructor for class org.apache.storm.trident.operation.builtin.ComparisonAggregator

ComparisonAggregator.State - Class in org.apache.storm.trident.operation.builtin

compile(RelNode) - Method in class org.apache.storm.sql.compiler.backends.standalone.PlanCompiler

compile(List<RexNode>, RelDataType, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler

compile(RexProgram, String) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler

compile(Map<String, ISqlTridentDataSource>, String) - Method in class org.apache.storm.sql.planner.trident.QueryPlanner

CompilerException(String) - Constructor for exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerException

CompilerUtil - Class in org.apache.storm.sql.compiler

CompilerUtil() - Constructor for class org.apache.storm.sql.compiler.CompilerUtil

CompilerUtil.TableBuilderInfo - Class in org.apache.storm.sql.compiler

compileToBlock(List<RexNode>, RelDataType) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler

compileToBlock(RexProgram) - Method in class org.apache.storm.sql.compiler.RexNodeToJavaCodeCompiler

CompilingClassLoader - Class in org.apache.storm.sql.javac

This is a Java ClassLoader that will attempt to load a class from a string of source code.

CompilingClassLoader(ClassLoader, String, String, DiagnosticListener<JavaFileObject>) - Constructor for class org.apache.storm.sql.javac.CompilingClassLoader

CompilingClassLoader.CompilerException - Exception in org.apache.storm.sql.javac

Thrown when code cannot be compiled.

complete(ReturnResultsReducer.ReturnResultsState, TridentCollector) - Method in class org.apache.storm.trident.drpc.ReturnResultsReducer

complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.Aggregator

complete(ComparisonAggregator.State, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.ComparisonAggregator

complete(FirstN.FirstNAgg.State, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg

complete(PriorityQueue, TridentCollector) - Method in class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg

complete(T, TridentTuple, TridentCollector) - Method in interface org.apache.storm.trident.operation.GroupedMultiReducer

complete(ChainedResult, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

complete(Result, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

complete(Object[], TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedAggregator

complete(Map<TridentTuple, Object>, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor

complete(Object, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.IdentityMultiReducer

complete(JoinState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.JoinerMultiReducer

complete(JoinState, TridentTuple, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer

complete(Result, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl

complete(SingleEmitAggregator.SingleEmitState, TridentCollector) - Method in class org.apache.storm.trident.operation.impl.SingleEmitAggregator

complete(T, TridentCollector) - Method in interface org.apache.storm.trident.operation.MultiReducer

complete(CountAsAggregator.State, TridentCollector) - Method in class org.apache.storm.trident.testing.CountAsAggregator

completed() - Method in class org.apache.storm.testing.TestEventLogSpout

completeLatencyMs - Variable in class org.apache.storm.hooks.info.SpoutAckInfo

CompleteTopologyParam - Class in org.apache.storm.testing

The param class for the Testing.completeTopology.

CompleteTopologyParam() - Constructor for class org.apache.storm.testing.CompleteTopologyParam

Component - Class in org.apache.storm.scheduler.resource

Component(String) - Constructor for class org.apache.storm.scheduler.resource.Component

Component.ComponentType - Enum in org.apache.storm.scheduler.resource

ComponentAggregateStats - Class in org.apache.storm.generated

ComponentAggregateStats() - Constructor for class org.apache.storm.generated.ComponentAggregateStats

ComponentAggregateStats(ComponentAggregateStats) - Constructor for class org.apache.storm.generated.ComponentAggregateStats

Performs a deep copy on other.

ComponentAggregateStats._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ComponentCommon - Class in org.apache.storm.generated

ComponentCommon() - Constructor for class org.apache.storm.generated.ComponentCommon

ComponentCommon(Map<GlobalStreamId, Grouping>, Map<String, StreamInfo>) - Constructor for class org.apache.storm.generated.ComponentCommon

ComponentCommon(ComponentCommon) - Constructor for class org.apache.storm.generated.ComponentCommon

Performs a deep copy on other.

ComponentCommon._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer> - Interface in org.apache.storm.topology

componentID - Variable in class org.apache.storm.hdfs.spout.FileLock.LogEntry

componentId - Variable in class org.apache.storm.planner.TaskBundle

componentName - Variable in class org.apache.storm.utils.ShellProcess

ComponentObject - Class in org.apache.storm.generated

ComponentObject() - Constructor for class org.apache.storm.generated.ComponentObject

ComponentObject(ComponentObject._Fields, Object) - Constructor for class org.apache.storm.generated.ComponentObject

ComponentObject(ComponentObject) - Constructor for class org.apache.storm.generated.ComponentObject

ComponentObject._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ComponentPageInfo - Class in org.apache.storm.generated

ComponentPageInfo() - Constructor for class org.apache.storm.generated.ComponentPageInfo

ComponentPageInfo(String, ComponentType) - Constructor for class org.apache.storm.generated.ComponentPageInfo

ComponentPageInfo(ComponentPageInfo) - Constructor for class org.apache.storm.generated.ComponentPageInfo

Performs a deep copy on other.

ComponentPageInfo._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

ComponentType - Enum in org.apache.storm.generated

CompoundIdentifier() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a compound identifier.

CompoundIdentifierCommaList(List<SqlNode>) - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

Parses a comma-separated list of compound identifiers.

CompoundSpout - Class in org.apache.storm.planner

CompoundSpout() - Constructor for class org.apache.storm.planner.CompoundSpout

CompoundTask - Class in org.apache.storm.planner

CompoundTask() - Constructor for class org.apache.storm.planner.CompoundTask

CONCAT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

concatIfNotNull(String) - Static method in class org.apache.storm.utils.ConfigUtils

CONDITION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONDITION_NUMBER - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

conf - Variable in class org.apache.storm.blobstore.ClientBlobStore

conf - Variable in class org.apache.storm.scheduler.resource.SchedulingState

Config - Class in org.apache.storm

Topology configs are specified as a plain old map.

Config() - Constructor for class org.apache.storm.Config

config - Variable in class org.apache.storm.eventhubs.spout.SimplePartitionManager

config - Variable in class org.apache.storm.eventhubs.spout.StaticPartitionCoordinator

CONFIG_KEY_RESOURCES - Static variable in class org.apache.storm.common.AbstractAutoCreds

ConfigGetter(String) - Constructor for class org.apache.storm.topology.TopologyBuilder.ConfigGetter

configKey - Variable in class org.apache.storm.hbase.bolt.AbstractHBaseBolt

configKey - Variable in class org.apache.storm.hbase.trident.state.HBaseMapState.Options

configKey - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt

configKey - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options

configKey - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

ConfigMethodDef - Class in org.apache.storm.flux.model

ConfigMethodDef() - Constructor for class org.apache.storm.flux.model.ConfigMethodDef

Configs - Class in org.apache.storm.hdfs.spout

Configs() - Constructor for class org.apache.storm.hdfs.spout.Configs

configure(Map<String, ?>, boolean) - Method in class org.apache.storm.kafka.ByteBufferSerializer

configure(Map<String, ?>, boolean) - Method in class org.apache.storm.kafka.IntSerializer

configureClient(MqttOptions, String, KeyStoreLoader) - Static method in class org.apache.storm.mqtt.common.MqttUtils

ConfigUtils - Class in org.apache.storm.utils

ConfigUtils() - Constructor for class org.apache.storm.utils.ConfigUtils

ConfigValidation - Class in org.apache.storm.validation

Provides functionality for validating configuration fields.

ConfigValidation() - Constructor for class org.apache.storm.validation.ConfigValidation

ConfigValidation.BooleanValidator - Class in org.apache.storm.validation

ConfigValidation.ClusterMetricRegistryValidator - Class in org.apache.storm.validation

ConfigValidation.DoubleValidator - Class in org.apache.storm.validation

ConfigValidation.EventLoggerRegistryValidator - Class in org.apache.storm.validation

ConfigValidation.ImpersonationAclUserEntryValidator - Class in org.apache.storm.validation

Validates an entry for ImpersonationAclUser

ConfigValidation.ImplementsClassValidator - Class in org.apache.storm.validation

ConfigValidation.IntegerValidator - Class in org.apache.storm.validation

Validates a Integer.

ConfigValidation.KryoRegValidator - Class in org.apache.storm.validation

Validates Kryo Registration

ConfigValidation.ListEntryCustomValidator - Class in org.apache.storm.validation

Validates each entry in a list against a list of custom Validators Each validator in the list of validators must inherit or be an instance of Validator class

ConfigValidation.ListEntryTypeValidator - Class in org.apache.storm.validation

Validates each entry in a list

ConfigValidation.MapEntryCustomValidator - Class in org.apache.storm.validation

validates each key and each value against the respective arrays of validators

ConfigValidation.MapEntryTypeValidator - Class in org.apache.storm.validation

validates each key and value in a map of a certain type

ConfigValidation.MapOfStringToMapOfStringToObjectValidator - Class in org.apache.storm.validation

ConfigValidation.MetricRegistryValidator - Class in org.apache.storm.validation

ConfigValidation.MetricReportersValidator - Class in org.apache.storm.validation

ConfigValidation.NoDuplicateInListValidator - Class in org.apache.storm.validation

validates a list of has no duplicates

ConfigValidation.NotNullValidator - Class in org.apache.storm.validation

Validates if an object is not null

ConfigValidation.NumberValidator - Class in org.apache.storm.validation

ConfigValidation.PacemakerAuthTypeValidator - Class in org.apache.storm.validation

ConfigValidation.PositiveNumberValidator - Class in org.apache.storm.validation

Validates a positive number

ConfigValidation.PowerOf2Validator - Class in org.apache.storm.validation

Validates if a number is a power of 2

ConfigValidation.SimpleTypeValidator - Class in org.apache.storm.validation

Validates basic types

ConfigValidation.StringOrStringListValidator - Class in org.apache.storm.validation

Validates a String or a list of Strings

ConfigValidation.StringValidator - Class in org.apache.storm.validation

ConfigValidation.UserResourcePoolEntryValidator - Class in org.apache.storm.validation

ConfigValidation.Validator - Class in org.apache.storm.validation

ConfigValidationAnnotations - Class in org.apache.storm.validation

Note: every annotation interface must have method validatorClass() For every annotation there must validator class to do the validation To add another annotation for config validation, add another annotation @interface class.

ConfigValidationAnnotations() - Constructor for class org.apache.storm.validation.ConfigValidationAnnotations

ConfigValidationAnnotations.CustomValidator - Annotation Type in org.apache.storm.validation

For custom validators

ConfigValidationAnnotations.isBoolean - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isImplementationOfClass - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isInteger - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isKryoReg - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isListEntryCustom - Annotation Type in org.apache.storm.validation

Validates each entry in a list with a list of validators Validators with fields: validatorClass and entryValidatorClass

ConfigValidationAnnotations.isListEntryType - Annotation Type in org.apache.storm.validation

validates each entry in a list is of a certain type

ConfigValidationAnnotations.isMapEntryCustom - Annotation Type in org.apache.storm.validation

Validates a each key and value in a Map with a list of validators Validator with fields: validatorClass, keyValidatorClasses, valueValidatorClasses

ConfigValidationAnnotations.isMapEntryType - Annotation Type in org.apache.storm.validation

Validates the type of each key and value in a map Validator with fields: validatorClass, keyValidatorClass, valueValidatorClass

ConfigValidationAnnotations.isNoDuplicateInList - Annotation Type in org.apache.storm.validation

Validates that there are no duplicates in a list

ConfigValidationAnnotations.isNumber - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isPositiveNumber - Annotation Type in org.apache.storm.validation

Checks if a number is positive and whether zero inclusive Validator with fields: validatorClass, includeZero

ConfigValidationAnnotations.isPowerOf2 - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isString - Annotation Type in org.apache.storm.validation

Validators with fields: validatorClass

ConfigValidationAnnotations.isStringList - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.isStringOrStringList - Annotation Type in org.apache.storm.validation

Complex/custom type validators

ConfigValidationAnnotations.isType - Annotation Type in org.apache.storm.validation

Validators with fields: validatorClass and type

ConfigValidationAnnotations.NotNull - Annotation Type in org.apache.storm.validation

Validates on object is not null

ConfigValidationAnnotations.Password - Annotation Type in org.apache.storm.validation

ConfigValidationAnnotations.ValidatorParams - Class in org.apache.storm.validation

Field names for annotations

ConfigValidationUtils - Class in org.apache.storm.validation

ConfigValidationUtils() - Constructor for class org.apache.storm.validation.ConfigValidationUtils

ConfigValidationUtils.FieldValidator - Interface in org.apache.storm.validation

Declares methods for validating configuration values.

ConfigValidationUtils.NestableFieldValidator - Class in org.apache.storm.validation

Declares a method for validating configuration values that is nestable.

confirmAssigned(int) - Method in class org.apache.storm.daemon.supervisor.StandaloneSupervisor

confirmAssigned(int) - Method in interface org.apache.storm.scheduler.ISupervisor

ConfluentAvroSerializer - Class in org.apache.storm.hdfs.avro

This class provides a mechanism to utilize the Confluent Schema Registry (https://github.com/confluentinc/schema-registry) for Storm to (de)serialize Avro generic records across a topology.

ConfluentAvroSerializer(Kryo, Map) - Constructor for class org.apache.storm.hdfs.avro.ConfluentAvroSerializer

A constructor with a signature that Storm can locate and use with kryo registration.

connect() - Method in class org.apache.storm.cassandra.client.impl.DefaultClient

Creates a new session on this cluster.

connect() - Method in interface org.apache.storm.cassandra.client.SimpleClient

Creates a new session on this cluster.

connect(String, String, int) - Method in interface org.apache.storm.messaging.IContext

This method establish a client side connection to a remote server implementation should return a new connection every call

connect(String, String, int) - Method in class org.apache.storm.messaging.local.Context

connect(String, String, int) - Method in class org.apache.storm.messaging.netty.Context

establish a connection to a remote server

connect(Map, TopologyContext) - Method in interface org.apache.storm.multilang.ISerializer

This method transmits the Storm config to the non-JVM process and receives its pid.

connect(Map, TopologyContext) - Method in class org.apache.storm.multilang.JsonSerializer

connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.digest.DigestSaslTransportPlugin

connect(TTransport, String, String) - Method in interface org.apache.storm.security.auth.ITransportPlugin

Connect to the specified server via framed transport

connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.kerberos.KerberosSaslTransportPlugin

connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.plain.PlainSaslTransportPlugin

connect(TTransport, String, String) - Method in class org.apache.storm.security.auth.SimpleTransportPlugin

Deprecated.

Connect to the specified server via framed transport

CONNECT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

connectAttemptsMax(long) - Method in class org.apache.storm.mqtt.common.MqttOptions.Builder

ConnectFailure(HiveEndPoint, Throwable) - Constructor for exception org.apache.storm.hive.common.HiveWriter.ConnectFailure

CONNECTION - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONNECTION_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

connectionFactory() - Method in class org.apache.storm.jms.example.SpringJmsProvider

connectionFactory() - Method in interface org.apache.storm.jms.JmsProvider

Provides the JMS ConnectionFactory

connectionProvider - Variable in class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

ConnectionProvider - Interface in org.apache.storm.jdbc.common

Provides a database connection.

connectionProvider - Variable in class org.apache.storm.jdbc.topology.AbstractUserTopology

ConnectionState - Enum in org.apache.storm.cluster

ConnectionWithStatus - Class in org.apache.storm.messaging

ConnectionWithStatus() - Constructor for class org.apache.storm.messaging.ConnectionWithStatus

ConnectionWithStatus.Status - Enum in org.apache.storm.messaging

connectMqtt(String) - Method in class org.apache.storm.mqtt.common.MqttPublisher

cons(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap

ConsList - Class in org.apache.storm.trident.tuple

ConsList(Object, List<Object>) - Constructor for class org.apache.storm.trident.tuple.ConsList

ConsolePreparableReporter - Class in org.apache.storm.daemon.metrics.reporters

ConsolePreparableReporter() - Constructor for class org.apache.storm.daemon.metrics.reporters.ConsolePreparableReporter

ConsoleStormReporter - Class in org.apache.storm.metrics2.reporters

ConsoleStormReporter() - Constructor for class org.apache.storm.metrics2.reporters.ConsoleStormReporter

Constants - Class in org.apache.storm

Constants() - Constructor for class org.apache.storm.Constants

ConstBolt() - Constructor for class org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBolt

constraint() - Method in class org.apache.storm.sql.parser.ColumnDefinition

CONSTRAINT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONSTRAINT_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONSTRAINT_NAME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONSTRAINT_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CONSTRAINTS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

construct() - Method in class org.apache.storm.elasticsearch.common.StormElasticSearchClient

construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.hdfs.HdfsDataSourcesProvider

construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider

construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.mongodb.MongoDataSourcesProvider

construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.redis.RedisDataSourcesProvider

construct(URI, String, String, List<FieldInfo>) - Method in class org.apache.storm.sql.runtime.datasource.socket.SocketDataSourcesProvider

construct(URI, String, String, List<FieldInfo>) - Method in interface org.apache.storm.sql.runtime.DataSourcesProvider

Construct a new data source.

construct(URI, String, String, List<FieldInfo>) - Static method in class org.apache.storm.sql.runtime.DataSourcesRegistry

construct() - Static method in class org.apache.storm.sql.StormSql

construct() - Static method in class org.apache.storm.starter.ReachTopology

constructBlobCurrentSymlinkName(String) - Static method in class org.apache.storm.utils.Utils

constructBlobWithVersionFileName(String, long) - Static method in class org.apache.storm.utils.Utils

constructGetRequests(byte[], HBaseProjectionCriteria) - Method in class org.apache.storm.hbase.common.HBaseClient

constructMutationReq(byte[], ColumnList, Durability) - Method in class org.apache.storm.hbase.common.HBaseClient

CONSTRUCTOR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.hdfs.HdfsDataSourcesProvider

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.kafka.KafkaDataSourcesProvider

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.mongodb.MongoDataSourcesProvider

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.redis.RedisDataSourcesProvider

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in class org.apache.storm.sql.runtime.datasource.socket.SocketDataSourcesProvider

constructTrident(URI, String, String, Properties, List<FieldInfo>) - Method in interface org.apache.storm.sql.runtime.DataSourcesProvider

constructTridentDataSource(URI, String, String, Properties, List<FieldInfo>) - Static method in class org.apache.storm.sql.runtime.DataSourcesRegistry

constructVersionFileName(String) - Static method in class org.apache.storm.utils.Utils

ConstSpout - Class in org.apache.storm.perf.spout

ConstSpout(String) - Constructor for class org.apache.storm.perf.spout.ConstSpout

ConstSpoutIdBoltNullBoltTopo - Class in org.apache.storm.perf

ConstSpout -> IdBolt -> DevNullBolt This topology measures speed of messaging between spouts->bolt and bolt->bolt ConstSpout : Continuously emits a constant string IdBolt : clones and emits input tuples DevNullBolt : discards incoming tuples

ConstSpoutIdBoltNullBoltTopo() - Constructor for class org.apache.storm.perf.ConstSpoutIdBoltNullBoltTopo

ConstSpoutNullBoltTopo - Class in org.apache.storm.perf

This topo helps measure the messaging speed between a spout and a bolt.

ConstSpoutNullBoltTopo() - Constructor for class org.apache.storm.perf.ConstSpoutNullBoltTopo

ConstSpoutOnlyTopo - Class in org.apache.storm.perf

This topo helps measure how fast a spout can produce data (so no bolts are attached) Spout generates a stream of a fixed string.

ConstSpoutOnlyTopo() - Constructor for class org.apache.storm.perf.ConstSpoutOnlyTopo

consumeBatch(EventHandler<Object>) - Method in class org.apache.storm.utils.DisruptorQueue

consumeBatchWhenAvailable(EventHandler<Object>) - Method in class org.apache.storm.utils.DisruptorQueue

consumeCPU(Double) - Method in class org.apache.storm.scheduler.resource.RAS_Node

Consumes a certain amount of cpu for this node

consumeMemory(Double) - Method in class org.apache.storm.scheduler.resource.RAS_Node

Consumes a certain amount of memory for this node

Consumer - Interface in org.apache.storm.trident.operation

Represents an operation that accepts a single input argument and returns no result.

consumeResourcesforTask(ExecutorDetails, TopologyDetails) - Method in class org.apache.storm.scheduler.resource.RAS_Node

Consumes a certain amount of resources for a executor in a topology.

ConsumerExecutor - Class in org.apache.storm.trident.operation.impl

ConsumerExecutor(Consumer) - Constructor for class org.apache.storm.trident.operation.impl.ConsumerExecutor

Container - Class in org.apache.storm.daemon.supervisor

Represents a container that a worker will run in.

Container(Container.ContainerType, Map<String, Object>, String, int, LocalAssignment, String, Map<String, Object>, AdvancedFSOps) - Constructor for class org.apache.storm.daemon.supervisor.Container

Create a new Container.

Container - Class in org.apache.storm.utils

Container() - Constructor for class org.apache.storm.utils.Container

Container.ContainerType - Enum in org.apache.storm.daemon.supervisor

containerFilePath(String) - Static method in class org.apache.storm.utils.Utils

ContainerLauncher - Class in org.apache.storm.daemon.supervisor

Launches containers

ContainerLauncher() - Constructor for class org.apache.storm.daemon.supervisor.ContainerLauncher

ContainerRecoveryException - Exception in org.apache.storm.daemon.supervisor

Could not recover the container.

ContainerRecoveryException(String) - Constructor for exception org.apache.storm.daemon.supervisor.ContainerRecoveryException

contains(KafkaSpoutMessageId) - Method in class org.apache.storm.kafka.spout.internal.OffsetManager

CONTAINS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

contains(String) - Method in class org.apache.storm.trident.tuple.TridentTupleView

contains(String) - Method in class org.apache.storm.tuple.Fields

contains(String) - Method in interface org.apache.storm.tuple.ITuple

Returns true if this tuple contains the specified name of the field.

contains(String) - Method in class org.apache.storm.tuple.TupleImpl

contains(Object) - Method in class org.apache.storm.utils.ListDelegate

containsAll(Collection<?>) - Method in class org.apache.storm.utils.ListDelegate

containsKey(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap

containsKey(K) - Method in class org.apache.storm.utils.RotatingMap

containsKey(K) - Method in class org.apache.storm.utils.TimeCacheMap

Deprecated.

containsValue(Object) - Method in class org.apache.storm.utils.IndifferentAccessMap

context - Variable in class org.apache.storm.cassandra.context.BaseBeanFactory

Context - Class in org.apache.storm.messaging.local

Context() - Constructor for class org.apache.storm.messaging.local.Context

Context - Class in org.apache.storm.messaging.netty

Context() - Constructor for class org.apache.storm.messaging.netty.Context

context - Variable in class org.apache.storm.mqtt.spout.MqttSpout

context() - Static method in class org.apache.storm.security.auth.ReqContext

ContextQuery - Interface in org.apache.storm.cassandra.query

This interface may be used to retrieve a cassandra bound query either from storm config or the tuple being proceed.

ContextQuery.BoundQueryContext - Class in org.apache.storm.cassandra.query

Default ContextQuery.BoundQueryContext implementation to retrieve a bound query identified by the provided key.

ContextQuery.BoundQueryNamedByFieldContext - Class in org.apache.storm.cassandra.query

Default ContextQuery.BoundQueryNamedByFieldContext implementation to retrieve a bound query named by the value of a specified tuple field.

ContextQuery.StaticContextQuery - Class in org.apache.storm.cassandra.query

Static implementation of ContextQuery interface.

ContextVariable() - Method in class org.apache.storm.sql.parser.impl.StormParserImpl

CONTINUE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

ControlMessage - Enum in org.apache.storm.messaging.netty

CONVERT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentAggregateRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentCalcRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentFilterRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentJoinRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentModifyRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentProjectRule

convert(RelNode) - Method in class org.apache.storm.sql.planner.trident.rules.TridentScanRule

convert(ConnectionState) - Static method in class org.apache.storm.utils.StormConnectionStateConverter

convertAvroUtf8(Object) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils

convertAvroUtf8Array(GenericData.Array) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils

convertAvroUtf8Map(Map<Object, Object>) - Static method in class org.apache.storm.sql.runtime.utils.SerdeUtils

convertClojureMapToJavaMap(Map) - Static method in class org.apache.storm.utils.Utils

converts a clojure PersistentMap to java HashMap

convertExecutorBeats(List<ExecutorInfo>, ClusterWorkerHeartbeat) - Static method in class org.apache.storm.cluster.ClusterUtils

Ensures that we only return heartbeats for executors assigned to this worker

convertFileSetToFiles(FileSet) - Static method in class org.apache.storm.maven.plugin.versioninfo.VersionInfoMojo

COORD_STREAM(String) - Static method in class org.apache.storm.trident.topology.TridentBoltExecutor

COORD_STREAM_PREFIX - Static variable in class org.apache.storm.trident.topology.TridentBoltExecutor

CoordCondition() - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition

COORDINATED_STREAM_ID - Static variable in class org.apache.storm.Constants

CoordinatedBolt - Class in org.apache.storm.coordination

Coordination requires the request ids to be globally unique for awhile.

CoordinatedBolt(IRichBolt) - Constructor for class org.apache.storm.coordination.CoordinatedBolt

CoordinatedBolt(IRichBolt, String, CoordinatedBolt.SourceArgs, CoordinatedBolt.IdStreamSpec) - Constructor for class org.apache.storm.coordination.CoordinatedBolt

CoordinatedBolt(IRichBolt, Map<String, CoordinatedBolt.SourceArgs>, CoordinatedBolt.IdStreamSpec) - Constructor for class org.apache.storm.coordination.CoordinatedBolt

CoordinatedBolt.CoordinatedOutputCollector - Class in org.apache.storm.coordination

CoordinatedBolt.FinishedCallback - Interface in org.apache.storm.coordination

CoordinatedBolt.IdStreamSpec - Class in org.apache.storm.coordination

CoordinatedBolt.SourceArgs - Class in org.apache.storm.coordination

CoordinatedBolt.TimeoutCallback - Interface in org.apache.storm.coordination

CoordinatedBolt.TrackingInfo - Class in org.apache.storm.coordination

CoordinatedOutputCollector(IOutputCollector) - Constructor for class org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

Coordinator - Class in org.apache.storm.eventhubs.trident

Coordinator(EventHubSpoutConfig) - Constructor for class org.apache.storm.eventhubs.trident.Coordinator

coordinator - Variable in class org.apache.storm.kafka.trident.TridentKafkaConfig

Coordinator(Map, TopologyContext) - Constructor for class org.apache.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

Coordinator(Map, TopologyContext) - Constructor for class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Coordinator

coords - Variable in class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec

CoordSpec() - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec

CoordType(boolean) - Constructor for class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType

copy(InputStream, OutputStream) - Static method in class org.apache.storm.hack.IOUtil

copy() - Method in interface org.apache.storm.hdfs.bolt.rotation.FileRotationPolicy

Must be able to copy the rotation policy

copy() - Method in class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy

copy() - Method in class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy

copy() - Method in class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy

copy(RelTraitSet, RelNode, RexProgram) - Method in class org.apache.storm.sql.planner.trident.rel.TridentCalcRel

copy(RelTraitSet, RelNode, RexNode) - Method in class org.apache.storm.sql.planner.trident.rel.TridentFilterRel

copy(RelTraitSet, RelNode, List<RexNode>, RelDataType) - Method in class org.apache.storm.sql.planner.trident.rel.TridentProjectRel

copy(RelTraitSet, List<RelNode>) - Method in class org.apache.storm.sql.planner.trident.rel.TridentStreamInsertRel

copy() - Method in interface org.apache.storm.starter.tools.Rankable

Note: We do not defensively copy the object wrapped by the Rankable.

copy() - Method in class org.apache.storm.starter.tools.RankableObjectWithFields

Note: We do not defensively copy the wrapped object and any accompanying fields.

copy() - Method in class org.apache.storm.starter.tools.Rankings

Creates a (defensive) copy of itself.

copyDirectory(File, File) - Method in class org.apache.storm.daemon.supervisor.AdvancedFSOps

Copy a directory

CopyField - Class in org.apache.storm.solr.schema

CopyField() - Constructor for class org.apache.storm.solr.schema.CopyField

CORR - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CORRESPONDING - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

Count() - Constructor for class org.apache.storm.sql.compiler.backends.standalone.BuiltinAggregateFunctions.Count

COUNT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

Count(int) - Constructor for class org.apache.storm.topology.base.BaseWindowedBolt.Count

Count - Class in org.apache.storm.trident.operation.builtin

Count() - Constructor for class org.apache.storm.trident.operation.builtin.Count

count() - Method in class org.apache.storm.tuple.TupleImpl

count() - Method in class org.apache.storm.utils.IndifferentAccessMap

COUNT_DATABASE - Static variable in class org.apache.storm.starter.TransactionalWords

COUNT_ID - Static variable in class org.apache.storm.perf.FileReadWordCountTopo

COUNT_NUM - Static variable in class org.apache.storm.perf.FileReadWordCountTopo

CountAggregator() - Constructor for class org.apache.storm.starter.ReachTopology.CountAggregator

CountAsAggregator - Class in org.apache.storm.trident.testing

CountAsAggregator() - Constructor for class org.apache.storm.trident.testing.CountAsAggregator

CountBasedCommit - Class in org.apache.storm.solr.config

Class defining a count based commit strategy.

CountBasedCommit(int) - Constructor for class org.apache.storm.solr.config.CountBasedCommit

Initializes a count based commit strategy with the specified threshold

CountBolt - Class in org.apache.storm.perf.bolt

CountBolt() - Constructor for class org.apache.storm.perf.bolt.CountBolt

counter(String, WorkerTopologyContext, String, Integer, String) - Static method in class org.apache.storm.metrics2.StormMetricRegistry

counter(String, String, String, Integer, Integer, String) - Static method in class org.apache.storm.metrics2.StormMetricRegistry

counterBatch(CQLStatementBuilder...) - Static method in class org.apache.storm.cassandra.DynamicStatementBuilder

Creates a new BatchStatement.Type.COUNTER batch statement for the specified CQL statement builders.

CountEvictionPolicy<T> - Class in org.apache.storm.windowing

An eviction policy that tracks event counts and can evict based on a threshold count.

CountEvictionPolicy(int) - Constructor for class org.apache.storm.windowing.CountEvictionPolicy

countFreeSlotsAlive(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node

countFreeSlotsAlive(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node

CountingBatchBolt - Class in org.apache.storm.testing

CountingBatchBolt() - Constructor for class org.apache.storm.testing.CountingBatchBolt

CountingCommitBolt - Class in org.apache.storm.testing

CountingCommitBolt() - Constructor for class org.apache.storm.testing.CountingCommitBolt

CountMetric - Class in org.apache.storm.metric.api

CountMetric() - Constructor for class org.apache.storm.metric.api.CountMetric

CountShellMetric - Class in org.apache.storm.metric.api.rpc

CountShellMetric() - Constructor for class org.apache.storm.metric.api.rpc.CountShellMetric

countSlotsUsed(String, Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node

countSlotsUsed(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node

countSlotsUsed(String, Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node

countSlotsUsed(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node

CountStatAndMetric - Class in org.apache.storm.metric.internal

Acts as a Count Metric, but also keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time.

CountStatAndMetric(int) - Constructor for class org.apache.storm.metric.internal.CountStatAndMetric

CountSyncPolicy - Class in org.apache.storm.hdfs.bolt.sync

SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.

CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy

CountSyncPolicy - Class in org.apache.storm.hdfs.trident.sync

SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.

CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.trident.sync.CountSyncPolicy

countTotalSlotsAlive(Collection<Node>) - Static method in class org.apache.storm.scheduler.multitenant.Node

countTotalSlotsAlive(Collection<RAS_Node>) - Static method in class org.apache.storm.scheduler.resource.RAS_Node

CountTriggerPolicy<T> - Class in org.apache.storm.windowing

A trigger that tracks event counts and calls back TriggerHandler.onTrigger() when the count threshold is hit.

CountTriggerPolicy(int, TriggerHandler, EvictionPolicy<T>) - Constructor for class org.apache.storm.windowing.CountTriggerPolicy

CountValue() - Constructor for class org.apache.storm.starter.TransactionalWords.CountValue

COVAR_POP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

COVAR_SAMP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CPUMetric - Class in org.apache.storm.metrics.sigar

A metric using Sigar to get User and System CPU utilization for a worker.

CPUMetric() - Constructor for class org.apache.storm.metrics.sigar.CPUMetric

CQL3NamedSettersBinder() - Constructor for class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.CQL3NamedSettersBinder

CqlMapper - Interface in org.apache.storm.cassandra.query

Default interface to defines how a storm tuple maps to a list of columns representing a row in a database.

CqlMapper.DefaultCqlMapper - Class in org.apache.storm.cassandra.query

Default CqlMapper to map all tuple values to column.

CqlMapper.SelectableCqlMapper - Class in org.apache.storm.cassandra.query

CQLResultSetValuesMapper - Interface in org.apache.storm.cassandra.query

CQLStatementBuilder<T extends CQLStatementTupleMapper> - Interface in org.apache.storm.cassandra.query

CQLStatementTupleMapper - Interface in org.apache.storm.cassandra.query

Default interface to map a ITuple to a CQL Statement.

CQLStatementTupleMapper.DynamicCQLStatementTupleMapper - Class in org.apache.storm.cassandra.query

CRC32OutputStream - Class in org.apache.storm.utils

CRC32OutputStream() - Constructor for class org.apache.storm.utils.CRC32OutputStream

create(Message, MessageId) - Static method in class org.apache.storm.eventhubs.spout.EventData

create(EventHubSpoutConfig, String) - Method in interface org.apache.storm.eventhubs.spout.IEventHubReceiverFactory

create(EventHubSpoutConfig, String, IStateStore, IEventHubReceiver) - Method in interface org.apache.storm.eventhubs.spout.IPartitionManagerFactory

create(String, String, long) - Static method in class org.apache.storm.eventhubs.spout.MessageId

create(IEventHubReceiver) - Method in interface org.apache.storm.eventhubs.trident.ITridentPartitionManagerFactory

create(Map) - Method in class org.apache.storm.hbase.trident.windowing.HBaseWindowsStoreFactory

create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.ArrayListSerializer

create(Kryo, Input, Class<Map>) - Method in class org.apache.storm.serialization.types.HashMapSerializer

create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.HashSetSerializer

create(Kryo, Input, Class<Collection>) - Method in class org.apache.storm.serialization.types.ListDelegateSerializer

CREATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

create(List[]) - Method in class org.apache.storm.trident.tuple.ComboList.Factory

create(List<Object>) - Method in class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory

create(TridentTupleView, List<Object>) - Method in class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory

create(TridentTuple) - Method in class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory

create(Tuple) - Method in class org.apache.storm.trident.tuple.TridentTupleView.RootFactory

create(Map) - Method in class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory

create(Map) - Method in interface org.apache.storm.trident.windowing.WindowsStoreFactory

Creates a window store

create_sequential(String, byte[], List<ACL>) - Method in interface org.apache.storm.cluster.ClusterState

Path will be appended with a monotonically increasing integer, a new node will be created there, and data will be put at that node.

create_sequential(String, byte[], List<ACL>) - Method in interface org.apache.storm.cluster.IStateStorage

Path will be appended with a monotonically increasing integer, a new node will be created there, and data will be put at that node.

create_sequential(String, byte[], List<ACL>) - Method in class org.apache.storm.cluster.ZKStateStorage

createArtifactsLink() - Method in class org.apache.storm.daemon.supervisor.Container

Create symlink from the containers directory/artifacts to the artifacts directory

createArtifactsLink() - Method in class org.apache.storm.daemon.supervisor.LocalContainer

createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore

Creates the blob.

createBlob(String, byte[], SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore

Wrapper called to create the blob which contains the byte data

createBlob(String, InputStream, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.BlobStore

Wrapper called to create the blob which contains the byte data

createBlob(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.ClientBlobStore

Client facing API to create a blob.

createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.blobstore.LocalFsBlobStore

createBlob(String, SettableBlobMeta, Subject) - Method in class org.apache.storm.hdfs.blobstore.HdfsBlobStore

createBlobstoreLinks() - Method in class org.apache.storm.daemon.supervisor.Container

Create symlinks for each of the blobs from the container’s directory to corresponding links in the storm dist directory.

createBlobstoreLinks() - Method in class org.apache.storm.daemon.supervisor.LocalContainer

createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.ClientBlobStore

Client facing API to create a blob.

createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.blobstore.NimbusBlobStore

createBlobToExtend(String, SettableBlobMeta) - Method in class org.apache.storm.hdfs.blobstore.HdfsClientBlobStore

createConsumer(KafkaSpoutConfig<K, V>) - Method in interface org.apache.storm.kafka.spout.internal.KafkaConsumerFactory

createConsumer(KafkaSpoutConfig<K, V>) - Method in class org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault

createEdge(Object, Object) - Method in class org.apache.storm.trident.util.ErrorEdgeFactory

createEventHubSpout() - Method in class org.apache.storm.eventhubs.samples.AtMostOnceEventCount

createEventHubSpout() - Method in class org.apache.storm.eventhubs.samples.EventCount

createExclusion(String) - Static method in class org.apache.storm.submit.dependency.AetherUtils

Parses exclusion parameter and build Exclusion object.

createFile(String) - Static method in class org.apache.storm.starter.BlobStoreAPIWordCountTopology

createFilter(ITuple) - Method in interface org.apache.storm.mongodb.common.QueryFilterCreator

Create a query Filter by given Tuple

createFilter(ITuple) - Method in class org.apache.storm.mongodb.common.SimpleQueryFilterCreator

createFreshTuple(Fields, List<Object>) - Static method in class org.apache.storm.trident.tuple.TridentTupleView

createFreshTuple(Fields, Object...) - Static method in class org.apache.storm.trident.tuple.TridentTupleView

createHiveConf(String, String) - Method in class org.apache.storm.hive.security.AutoHive

createLocalizer(Map, String) - Static method in class org.apache.storm.utils.Utils

createLocalTopology(ILocalDRPC) - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

createNewWorkerId() - Method in class org.apache.storm.daemon.supervisor.BasicContainer

Create a new worker ID for this process and store in in this object and in the local state.

createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.transactional.state.TestTransactionalState

createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.transactional.state.TransactionalState

createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.trident.topology.state.TestTransactionalState

createNode(CuratorFramework, String, byte[], List<ACL>, CreateMode) - Static method in class org.apache.storm.trident.topology.state.TransactionalState

createNode(CuratorFramework, String, byte[], CreateMode, List<ACL>) - Static method in class org.apache.storm.zookeeper.Zookeeper

createNode(CuratorFramework, String, byte[], List<ACL>) - Static method in class org.apache.storm.zookeeper.Zookeeper

createRecordWriter(HiveEndPoint) - Method in class org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper

createRecordWriter(HiveEndPoint) - Method in interface org.apache.storm.hive.bolt.mapper.HiveMapper

Given a endPoint, returns a RecordWriter with columnNames.

createRecordWriter(HiveEndPoint) - Method in class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper

createRemoteTopology() - Method in class org.apache.storm.drpc.LinearDRPCTopologyBuilder

createSaslServer(String, String, String, Map<String, ?>, CallbackHandler) - Method in class org.apache.storm.security.auth.plain.SaslPlainServer.SaslPlainServerFactory

createScalarInstance(List<RexNode>, RelDataType, String) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator

createScalarInstance(RexProgram, String) - Method in class org.apache.storm.sql.planner.trident.TridentPlanCreator

createStateInZookeeper(Map, String, NimbusInfo) - Static method in class org.apache.storm.blobstore.BlobStoreUtils

createStateInZookeeper(String) - Method in class org.apache.storm.blobstore.ClientBlobStore

Creates state inside a zookeeper.

createStateInZookeeper(String) - Method in class org.apache.storm.blobstore.NimbusBlobStore

createStateInZookeeper(String, AsyncMethodCallback<Void>) - Method in class org.apache.storm.generated.Nimbus.AsyncClient

createStateInZookeeper(String, AsyncMethodCallback<Void>) - Method in interface org.apache.storm.generated.Nimbus.AsyncIface

createStateInZookeeper() - Constructor for class org.apache.storm.generated.Nimbus.AsyncProcessor.createStateInZookeeper

createStateInZookeeper(String) - Method in class org.apache.storm.generated.Nimbus.Client

createStateInZookeeper(String) - Method in interface org.apache.storm.generated.Nimbus.Iface

createStateInZookeeper() - Constructor for class org.apache.storm.generated.Nimbus.Processor.createStateInZookeeper

createStateInZookeeper(String) - Method in class org.apache.storm.hdfs.blobstore.HdfsClientBlobStore

createStateInZookeeper_args() - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

createStateInZookeeper_args(String) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

createStateInZookeeper_args(Nimbus.createStateInZookeeper_args) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

Performs a deep copy on other.

createStateInZookeeper_call(String, AsyncMethodCallback<Void>, TAsyncClient, TProtocolFactory, TNonblockingTransport) - Constructor for class org.apache.storm.generated.Nimbus.AsyncClient.createStateInZookeeper_call

createStateInZookeeper_result() - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_result

createStateInZookeeper_result(Nimbus.createStateInZookeeper_result) - Constructor for class org.apache.storm.generated.Nimbus.createStateInZookeeper_result

Performs a deep copy on other.

createSymlink(File, File) - Method in class org.apache.storm.daemon.supervisor.AdvancedFSOps

Create a symbolic link pointing at target

createTopology() - Method in class org.apache.storm.topology.TopologyBuilder

createVersion() - Method in class org.apache.storm.utils.VersionedStore

createVersion(long) - Method in class org.apache.storm.utils.VersionedStore

createZKClient(Map, List<ACL>) - Static method in class org.apache.storm.blobstore.BlobStoreUtils

creationIndex - Variable in class org.apache.storm.trident.planner.Node

credentials(String, Runnable) - Method in interface org.apache.storm.cluster.IStormClusterState

credentials(String, Runnable) - Method in class org.apache.storm.cluster.StormClusterStateImpl

Credentials - Class in org.apache.storm.generated

Credentials() - Constructor for class org.apache.storm.generated.Credentials

Credentials(Map<String, String>) - Constructor for class org.apache.storm.generated.Credentials

Credentials(Credentials) - Constructor for class org.apache.storm.generated.Credentials

Performs a deep copy on other.

credentials - Variable in class org.apache.storm.security.auth.AbstractSaslServerCallbackHandler

Credentials._Fields - Enum in org.apache.storm.generated

The set of fields this struct contains, along with convenience methods for finding and manipulating them.

CREDENTIALS_CHANGED_STREAM_ID - Static variable in class org.apache.storm.Constants

CREDENTIALS_ROOT - Static variable in class org.apache.storm.cluster.ClusterUtils

CREDENTIALS_SUBTREE - Static variable in class org.apache.storm.cluster.ClusterUtils

credentialsPath(String) - Static method in class org.apache.storm.cluster.ClusterUtils

CredentialsProviderChain - Class in org.apache.storm.kinesis.spout

Class representing chain of mechanisms that will be used in order to connect to kinesis

CredentialsProviderChain() - Constructor for class org.apache.storm.kinesis.spout.CredentialsProviderChain

CROSS - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CSV_LOG_DIR - Static variable in class org.apache.storm.metrics2.reporters.CsvStormReporter

CsvPreparableReporter - Class in org.apache.storm.daemon.metrics.reporters

CsvPreparableReporter() - Constructor for class org.apache.storm.daemon.metrics.reporters.CsvPreparableReporter

CsvScheme - Class in org.apache.storm.sql.runtime.serde.csv

CsvScheme uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.

CsvScheme(List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.csv.CsvScheme

CsvSerializer - Class in org.apache.storm.sql.runtime.serde.csv

CsvSerializer uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.

CsvSerializer(List<String>) - Constructor for class org.apache.storm.sql.runtime.serde.csv.CsvSerializer

CsvStormReporter - Class in org.apache.storm.metrics2.reporters

CsvStormReporter() - Constructor for class org.apache.storm.metrics2.reporters.CsvStormReporter

CUBE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CUME_DIST - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

curChar - Variable in class org.apache.storm.sql.parser.impl.StormParserImplTokenManager

CURRENT - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_BLOB_SUFFIX_ID - Static variable in class org.apache.storm.utils.Utils

CURRENT_CATALOG - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_DATE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_DEFAULT_TRANSFORM_GROUP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_PATH - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_ROLE - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_SCHEMA - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_TIME - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants

CURRENT_TIMESTAMP - Static variable in interface org.apache.storm.sql.parser.impl.StormParserImplConstants