# All Classes and Interfaces

Class
Description
AbstractAvroSerializer
This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects across a Topology.
AbstractDNSToSwitchMapping
This is a base class for DNS to Switch mappings.
AbstractHadoopAutoCreds
The base class that for auto credential plugins that abstracts out some of the common functionality.
AbstractHadoopNimbusPluginAutoCreds
The base class that for auto credential plugins that abstracts out some of the common functionality.
AbstractHdfsBolt
AbstractHDFSWriter
AbstractJdbcBolt
AbstractRankerBolt
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
AbstractRedisBolt
AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.
AbstractRedisMapState<T>
AbstractRedisMapState is base class of any RedisMapState, which implements IBackingMap.
AbstractRedisStateQuerier<T extends State>
AbstractRedisStateQuerier is base class of any RedisStateQuerier, which implements BaseQueryFunction.
AbstractRedisStateUpdater<T extends State>
AbstractRedisStateUpdater is base class of any RedisStateUpdater, which implements BaseStateUpdater.
AbstractStreamsProcessor
AbstractTridentWindowManager<T>
Basic functionality to manage trident tuple events using `WindowManager` and `WindowsStore` for storing tuples and triggers related information.
AbstractUserTopology
For topology-related code reusage.
AccessControl
AccessControl._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
AccessControlType
AccessLoggingFilter
Acker
AckFailDelegate
AckFailMapTracker
AckTracker
AclEnforcement
This is code intended to enforce ZK ACLs.
Activate
AddressedTuple
A Tuple that is addressed to a destination.
AdminCommands
AdminCommands.AdminCommand
AdvancedFSOps
AetherUtils
Utility class of Aether.
AggLevel
Specifies the available timeframes for Metric aggregation.
AggregateByKeyProcessor<K,V,A,R>
AggregateExample
An example that illustrates the global aggregate.
AggregateProcessor<T,A,R>
AggregateProcessor
Aggregator<T>
AlreadyAliveException
AlreadyAliveException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
AlternateRackDNSToSwitchMapping
This class implements the `DNSToSwitchMapping` interface It alternates bewteen RACK1 and RACK2 for the hosts.
AnchoredWordCount
AnchoredWordCount.RandomSentenceSpout
AnchoredWordCount.SplitSentence
AnchoredWordCount.WordCount
AppendCollector
ArrayListSerializer
ArtifactoryConfigLoader
A dynamic loader that can load scheduler configurations for user resource guarantees from Artifactory (an artifact repository manager).
ArtifactoryConfigLoaderFactory
Factory class for ArtifactoryConfigLoader.
Assembly
The `Assembly` interface provides a means to encapsulate logic applied to a `Stream`.
AssignableMetric
AssignableShellMetric
Assignment
Assignment._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
AssignmentDistributionService
A service for distributing master assignments to supervisors, this service makes the assignments notification asynchronous.
AsyncLocalizer
Downloads and caches blobs locally.
AtomicOutputStream
An output stream where all of the data is committed on close, or can be canceled with cancel.
AuthNimbusOp
AuthorizationException
AuthorizationException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
AuthorizationExceptionMapper
AuthorizationExceptionMapper
AuthorizedUserFilter
AutoHBase
Auto credentials plugin for HBase implementation.
AutoHBaseCommand
Command tool of Hive credential renewer.
AutoHBaseNimbus
Auto credentials nimbus plugin for HBase implementation.
AutoHDFS
Auto credentials plugin for HDFS implementation.
AutoHDFSCommand
Command tool of HDFS credential renewer.
AutoHDFSNimbus
Auto credentials nimbus plugin for HDFS implementation.
AutoSSL
This plugin is intended to be used for user topologies to send SSL keystore/truststore files to the remote workers.
AutoTGT
Automatically take a user's TGT, and push it, and renew it in Nimbus.
AutoTGTKrb5LoginModule
Custom LoginModule to enable Auto Login based on cached ticket.
AutoTGTKrb5LoginModuleTest
Custom LoginModule extended for testing.
AvroGenericRecordBolt
AvroGenericRecordHDFSWriter
AvroSchemaRegistry
AvroScheme
AvroScheme uses generic(without code generation) instead of specific(with code generation) readers.
AvroSerializer
AvroSerializer uses generic(without code generation) instead of specific(with code generation) writers.
AvroUtils
BackPressureStatus
BackPressureStatusEncoder
BackPressureTopo
BackPressureTracker
Tracks the BackPressure status.
BackPressureTracker.BackpressureState
Base64ToBinaryStateMigrationUtil
BaseAggregator<T>
BaseBasicBolt
BaseBatchBolt<T>
BaseBinaryStateIterator<K,V>
Base implementation of iterator over `KeyValueState` which encoded types of key and value are both binary type.
BaseComponent
BaseConfigurationDeclarer<T extends ComponentConfigurationDeclarer>
BaseFilter
BaseFunction
BaseMultiReducer<T>
BaseOperation
Convenience implementation of the `Operation` interface.
BaseQueryFunction<S extends State,T>
BaseResourceAwareStrategy
BaseResourceAwareStrategy.NodeSortType
Different node sorting types available.
BaseRichBolt
BaseRichSpout
BaseStatefulBolt<T extends State>
BaseStatefulBoltExecutor
Base class that abstracts the common logic for executing bolts in a stateful topology.
BaseStatefulBoltExecutor.AnchoringOutputCollector
BaseStatefulWindowedBolt<T extends State>
BaseStateIterator<K,V,KENCODEDT,VENCODEDT>
Base implementation of iterator over `KeyValueState`.
BaseStateUpdater<S extends State>
BaseTaskHook
BaseTickTupleAwareRichBolt
This class is based on BaseRichBolt, but is aware of tick tuple.
BaseWindow<L,I>
BaseWindowConfig
BaseWindowedBolt
BaseWindowedBolt.Count
Holds a count value for count based windows and sliding intervals.
BaseWindowedBolt.Duration
Holds a Time duration for time based windows and sliding intervals.
BaseWindowStrategy<T>
BaseWorkerHook
A BaseWorkerHook is a noop implementation of IWorkerHook.
BasicBoltExecutor
BasicContainer
A container that runs processes on the local box.
BasicContainerLauncher
Launch containers with no security using standard java commands.
BasicDrpcClient
A simple client for connecting to DRPC.
BasicDRPCTopology
This topology is a basic example of doing distributed RPC on top of Storm.
BasicDRPCTopology.ExclaimBolt
BasicMetricsCollector
BasicMetricsCollector.MetricsCollectorConfig
BasicMetricsCollector.MetricsItem
BasicOutputCollector
BatchBoltExecutor
BatchHelper
BatchInfo
BatchOutputCollector
BatchOutputCollectorImpl
BatchProcessor
Top level marker interface for processors that computes results for a batch of tuples like Aggregate, Join etc.
BatchSpoutExecutor
BatchSpoutExecutor.EmptyCoordinator
BatchSubtopologyBuilder
BeanDef
A representation of a Java object that is uniquely identifyable, and given a className, constructor arguments, and properties, can be instantiated.
BeanListReference
A bean list reference is a list of bean reference.
BeanReference
A bean reference is simply a string pointer to another id.
BeginDownloadResult
BeginDownloadResult._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BiFunction<T,U,R>
a function that accepts two arguments and produces a result.
BlacklistScheduler
BlkioCore
BlkioCore.RecordType
BlobChangingCallback
Callback for when a localized blob is going to change.
BlobKeySequenceInfo
Blobstore
BlobStore
Provides a way to store blobs that can be downloaded.
BlobStore.KeyTranslationIterator
Blob store implements its own version of iterator to list the blobs.
BlobStoreAclHandler
Provides common handling of acls for Blobstores.
BlobStoreAPIWordCountTopology
BlobStoreAPIWordCountTopology.FilterWords
BlobStoreAPIWordCountTopology.RandomSentenceSpout
BlobStoreAPIWordCountTopology.SplitSentence
BlobStoreFile
Provides an base implementation for creating a blobstore based on file backed storage.
BlobStoreUtils
BlockingOutstandingRequest
BlowfishTupleSerializer
Apply Blowfish encryption for tuple communication to bolts.
Bolt
Bolt._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BoltAckInfo
BoltAggregateStats
BoltAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BoltDeclarer
BoltDeclarer includes grouping APIs for storm topology.
BoltDef
Bean representation of a Storm bolt.
BoltExecuteInfo
BoltExecutor
BoltExecutorStats
BoltFailInfo
BoltMsg
BoltMsg is an object that represents the data sent from a shell component to a bolt process that implements a multi-language protocol.
BoltOutputCollectorImpl
BoltStats
BoltStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
BoltTracker
Booter
Manage mvn repository.
BranchExample
An example that demonstrates the usage of `Stream.branch(Predicate[])` to split a stream into multiple branches based on predicates.
BranchProcessor<T>
BridgeReceiver
BufferFileInputStream
BufferInputStream
BuiltinMetricsUtil
ByTopicRecordTranslator<K,V>
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.
CachedBatchReadsMap<T>
CachedBatchReadsMap.RetVal<T>
CachedMap<T>
Useful to layer over a map that communicates with a database.
CachedSchemas
CaptureCollector
CaptureLoad
Capture running topologies for load gen later on.
CgroupCenter
CgroupCommon
CgroupCommonOperation
CgroupCore
CgroupCoreFactory
CGroupCpu
Deprecated.
CGroupCpu
Report CPU used in the cgroup.
CGroupCpuGuarantee
Deprecated.
CGroupCpuGuarantee
Report the guaranteed number of cpu percentage this worker has requested.
CGroupCpuGuaranteeByCfsQuota
Deprecated.
CGroupCpuGuaranteeByCfsQuota
Report the percentage of the cpu guaranteed for the worker.
CGroupCpuStat
CgroupManager
Class that implements ResourceIsolationInterface that manages cgroups.
CGroupMemoryLimit
Deprecated.
CGroupMemoryLimit
Reports the current memory limit of the cgroup for this worker.
CGroupMemoryUsage
Deprecated.
CGroupMemoryUsage
Reports the current memory usage of the cgroup for this worker.
CGroupMetricsBase<T>
Deprecated.
CGroupMetricsBase
Base class for checking if CGroups are enabled, etc.
CgroupOperation
An interface to implement the basic functions to manage cgroups such as mount and mounting a hiearchy and creating cgroups.
CgroupUtils
ChainedAggregatorDeclarer
ChainedAggregatorDeclarer.AggregationPartition
ChainedAggregatorImpl
ChainedFullAggregatorDeclarer
ChainedPartitionAggregatorDeclarer
ChainedProcessorContext<T>
A composite context that holds a chain of `ProcessorContext`.
ChainedResult
CheckpointSpout
Emits checkpoint tuples which is used to save the state of the `IStatefulComponent` across the topology.
CheckPointState
Captures the current state of the transaction in `CheckpointSpout`.
CheckPointState.Action
CheckPointState.State
CheckpointTupleForwarder
Wraps `IRichBolt` and forwards checkpoint tuples in a stateful topology.
CLI
CLI.Assoc
CLI.CLIBuilder
CLI.Parse
Client
A Netty client for sending task messages to a remote destination (Netty server).
ClientAuthUtils
ClientBlobStore
The ClientBlobStore has two concrete implementations 1.
ClientBlobStore.WithBlobstore
ClientCallbackHandler
SASL client side callback handler.
ClientFactory<K,V>
This is here to enable testing.
ClientFactoryDefault<K,V>
ClientMetricsUtils
ClientStatsUtil
Stats calculations needed by storm client code.
ClientSupervisorUtils
ClientZookeeper
ClojureBolt
ClojureSerializationRegister
ClojureSpout
ClojureTransformer
ClojureTuple
ClojureUtil
Cluster
The current state of the storm cluster.
ClusterMetricsConsumerExecutor
ClusterStateContext
This class is intended to provide runtime-context to StateStorageFactory implementors, giving information such as what daemon is creating it.
ClusterStateListener
ClusterSummary
ClusterSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ClusterUtils
ClusterWorkerHeartbeat
ClusterWorkerHeartbeat._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
CoGroupByKeyProcessor<K,V1,V2>
co-group by key implementation.
Column<T>
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.
ColumnConstraint
ColumnConstraint.PrimaryKey
ColumnDefinition
CombinedMetric
CombinedShellMetric
CombinerAggregator<T,A,R>
Interface for aggregating values.
CombinerAggregator<T>
CombinerAggregatorCombineImpl
CombinerAggregatorInitImpl
CombinerAggStateUpdater
CombinerValueUpdater
ComboList
ComboList.Factory
CommandExec
CommitMetadata
Object representing metadata committed to Kafka.
CommitMetadataManager
Generates and reads commit metadata.
CommonAggregateStats
CommonAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
CommonKafkaSpoutConfig<K,V>
CommonKafkaSpoutConfig.Builder<K,V,T extends CommonKafkaSpoutConfig.Builder<K,V,T>>
CommonStats
ComparisonAggregator<T>
Abstract `Aggregator` for comparing two values in a stream.
ComparisonAggregator.State
CompilerUtil
CompilerUtil.TableBuilderInfo
CompilingClassLoader
This is a Java ClassLoader that will attempt to load a class from a string of source code.
CompilingClassLoader.CompilerException
Thrown when code cannot be compiled.
CompletableSpout
CompleteTopologyParam
The param class for the `Testing.completeTopology`.
Component
ComponentAggregateStats
ComponentAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentCommon
ComponentCommon._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentConfigurationDeclarer<T extends ComponentConfigurationDeclarer>
ComponentObject
ComponentObject._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentPageInfo
ComponentPageInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ComponentType
CompoundSpout
CompoundTask
Config
Topology configs are specified as a plain old map.
ConfigLoaderFactoryService
The user interface to create a concrete IConfigLoader instance for use.
ConfigMethodDef
Configs
Configs.ReaderTypeValidator
ConfigurableTopology
Extensions of this class takes a reference to one or more configuration files.
ConfigUtils
ConfigValidation
Provides functionality for validating configuration fields.
ConfigValidation.BooleanValidator
ConfigValidation.ClusterMetricRegistryValidator
ConfigValidation.CustomIsExactlyOneOfValidators
ConfigValidation.DerivedTypeValidator
Checks if the named type derives from the specified Class.
ConfigValidation.DoubleValidator
ConfigValidation.EventLoggerRegistryValidator
ConfigValidation.ImpersonationAclUserEntryValidator
Validates an entry for ImpersonationAclUser.
ConfigValidation.ImplementsClassValidator
ConfigValidation.IntegerValidator
Validates a Integer.
ConfigValidation.KryoRegValidator
Validates Kryo Registration.
ConfigValidation.ListEntryCustomValidator
Validates each entry in a list against a list of custom Validators.
ConfigValidation.ListEntryTypeValidator
Validates each entry in a list.
ConfigValidation.ListOfListOfStringValidator
Validates a list of a list of Strings.
ConfigValidation.LongValidator
Validates a Long.
ConfigValidation.MapEntryCustomValidator
validates each key and each value against the respective arrays of validators.
ConfigValidation.MapEntryTypeValidator
validates each key and value in a map of a certain type.
ConfigValidation.MapOfStringToMapOfStringToObjectValidator
ConfigValidation.MetricRegistryValidator
ConfigValidation.MetricReportersValidator
ConfigValidation.NoDuplicateInListValidator
validates a list of has no duplicates.
ConfigValidation.NotNullValidator
Validates if an object is not null.
ConfigValidation.NumberValidator
ConfigValidation.PacemakerAuthTypeValidator
ConfigValidation.PositiveNumberValidator
Validates a positive number.
ConfigValidation.PowerOf2Validator
Validates if a number is a power of 2.
ConfigValidation.RasConstraintsTypeValidator
ConfigValidation.SimpleTypeValidator
Validates basic types.
ConfigValidation.StringOrStringListValidator
Validates a String or a list of Strings.
ConfigValidation.StringValidator
ConfigValidation.UserResourcePoolEntryValidator
ConfigValidation.Validator
ConfigValidationAnnotations
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.CustomValidator
For custom validators.
ConfigValidationAnnotations.IsBoolean
ConfigValidationAnnotations.IsDerivedFrom
ConfigValidationAnnotations.IsExactlyOneOf
Custom validator where exactly one of the validations must be successful.
ConfigValidationAnnotations.IsImplementationOfClass
ConfigValidationAnnotations.IsInteger
ConfigValidationAnnotations.IsKryoReg
ConfigValidationAnnotations.IsListEntryCustom
Validates each entry in a list with a list of validators Validators with fields: validatorClass and entryValidatorClass.
ConfigValidationAnnotations.IsListEntryType
validates each entry in a list is of a certain type.
ConfigValidationAnnotations.IsLong
ConfigValidationAnnotations.IsMapEntryCustom
Validates a each key and value in a Map with a list of validators Validator with fields: validatorClass, keyValidatorClasses, valueValidatorClasses.
ConfigValidationAnnotations.IsMapEntryType
Validates the type of each key and value in a map Validator with fields: validatorClass, keyValidatorClass, valueValidatorClass.
ConfigValidationAnnotations.IsNoDuplicateInList
Validates that there are no duplicates in a list.
ConfigValidationAnnotations.IsNumber
ConfigValidationAnnotations.IsPositiveNumber
Checks if a number is positive and whether zero inclusive Validator with fields: validatorClass, includeZero.
ConfigValidationAnnotations.IsPowerOf2
ConfigValidationAnnotations.IsString
Validators with fields: validatorClass.
ConfigValidationAnnotations.IsStringList
ConfigValidationAnnotations.IsStringOrStringList
Complex/custom type validators.
ConfigValidationAnnotations.IsType
Validators with fields: validatorClass and type.
ConfigValidationAnnotations.NotNull
Validates on object is not null.
ConfigValidationAnnotations.Password
ConfigValidationAnnotations.ValidatorParams
Field names for annotations.
ConfigValidationUtils
ConfigValidationUtils.FieldValidator
Declares methods for validating configuration values.
ConfigValidationUtils.NestableFieldValidator
Declares a method for validating configuration values that is nestable.
ConfigValue
Read a value from the topology config map.
ConnectionProvider
Provides a database connection.
ConnectionState
ConnectionWithStatus
ConnectionWithStatus.Status
ConsList
ConsolePreparableReporter
ConsoleStormReporter
Constants
ConstraintSolverConfig
Component constraint as derived from configuration.
ConstraintSolverStrategy
ConstSpout
ConstSpoutIdBoltNullBoltTopo
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.
ConstSpoutNullBoltTopo
This topo helps measure the messaging peak throughput between a spout and a bolt.
ConstSpoutOnlyTopo
This topo helps measure how fast a spout can produce data (so no bolts are attached).
Consumer<T>
Represents an operation that accepts a single input argument and returns no result.
Consumer
Represents an operation that accepts a single input argument and returns no result.
ConsumerExecutor
Container
Represents a container that a worker will run in.
Container.ContainerType
ContainerLauncher
Launches containers.
ContainerMemoryTracker
ContainerRecoveryException
Could not recover the container.
Context
Context
ControlMessage
CoordinatedBolt
Coordination requires the request ids to be globally unique for awhile.
CoordinatedBolt.FinishedCallback
CoordinatedBolt.IdStreamSpec
CoordinatedBolt.SourceArgs
CoordinatedBolt.TimeoutCallback
CoordinatedBolt.TrackingInfo
Count<T>
Computes the count of values.
Count
CountAsAggregator
CountBolt
CountEvictionPolicy<T>
An eviction policy that tracks event counts and can evict based on a threshold count.
CountMetric
CountShellMetric
CountStat
Keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time.
CountSyncPolicy
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountSyncPolicy
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountTriggerPolicy<T>
A trigger that tracks event counts and calls back `TriggerHandler.onTrigger()` when the count threshold is hit.
CpuacctCore
CpuacctCore.StatType
CpuCore
CpuCore.Stat
CPUMetric
A metric using Sigar to get User and System CPU utilization for a worker.
CpusetCore
CRC32OutputStream
CredentialKeyProvider
Provider interface for credential key.
Credentials
Credentials._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
CsvPreparableReporter
CsvScheme
CsvScheme uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.
CsvSerializer
CsvSerializer uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.
CsvStormReporter
CuratorUtils
CustomStreamGrouping
DaemonCommon
DaemonConfig
Storm configs are specified as a plain old map.
DaemonConfigValidation
DaemonConfigValidation.NumaEntryValidator
DaemonType
The type of process/daemon that this server is running as.
DataPoint
DataPointExpander
DataSourcesProvider
DataSourcesRegistry
Deactivate
Debug
Filter for debugging purposes.
DebuggableExecutableExpression
DebugHelper
DebugMemoryMapState<T>
DebugMemoryMapState.Factory
DebugOptions
DebugOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DefaultBlacklistStrategy
The default strategy used for blacklisting hosts.
DefaultEvictionContext
DefaultExceptionMapper
DefaultFileNameFormat
Creates file names with the following format:
DefaultFileNameFormat
Creates file names with the following format:
DefaultHttpCredentialsPlugin
DefaultKryoFactory
DefaultKryoFactory.KryoSerializableDefault
DefaultPool
A pool of machines that anyone can use, but topologies are not isolated.
DefaultPrincipalToLocal
Storm can be configured to launch worker processed as a given user.
DefaultRackDNSToSwitchMapping
This class implements the `DNSToSwitchMapping` interface It returns the DEFAULT_RACK for every host.
DefaultRecordTranslator<K,V>
DefaultResourceAwareStrategy
DefaultResourceAwareStrategyOld
DefaultResourceDeclarer<T extends DefaultResourceDeclarer>
Default implementation of resources declarer.
DefaultResourceIsolationManager
This is the default class to manage worker processes, including launching, killing, profiling and etc.
DefaultScheduler
DefaultSchedulingPriorityStrategy
DefaultSchedulingPriorityStrategy.SimulatedUser
DefaultSequenceFormat
Basic `SequenceFormat` implementation that uses `LongWritable` for keys and `Text` for values.
DefaultSequenceFormat
Basic `SequenceFormat` implementation that uses `LongWritable` for keys and `Text` for values.
DefaultShellLogHandler
Default implementation of `ShellLogHandler`.
DefaultStateEncoder<K,V>
Default state encoder class for encoding/decoding key values.
DefaultStateSerializer<T>
A default implementation that uses Kryo to serialize and de-serialize the state.
DefaultTopicSelector
DefaultTopicSelector
DefaultTopologyValidator
DefaultUncaughtExceptionHandler
DefaultWatcherCallBack
DelimitedRecordFormat
RecordFormat implementation that uses field and record delimiters.
DelimitedRecordFormat
RecordFormat implementation that uses field and record delimiters.
DenyAuthorizer
An authorization implementation that denies everything, for testing purposes.
DependencyBlobStoreUtils
DependencyPropertiesParser
DependencyResolver
Resolver class of dependencies.
DependencyResolverMain
Main class of dependency resolver.
DependencyUploader
DeserializingConnectionCallback
A class that is called when a TaskMessage arrives.
Device
a class that represents a device in linux.
DevicesCore
DevicesCore.Record
DevNullBolt
DevZookeeper
DigestSaslTransportPlugin
DimensionalReporter
Class that allows using a ScheduledReporter to report V2 task metrics with support for dimensions.
DimensionalReporter.DimensionHandler
DirectoryCleaner
Provide methods to help Logviewer to clean up files in directories and to get a list of files without worrying about excessive memory usage.
DirLock
Facility to synchronize access to HDFS directory.
DisallowedStrategyException
DistributedRPC
DistributedRPC.AsyncClient
DistributedRPC.AsyncClient.execute_call
DistributedRPC.AsyncClient.Factory
DistributedRPC.AsyncIface
DistributedRPC.AsyncProcessor<I extends DistributedRPC.AsyncIface>
DistributedRPC.AsyncProcessor.execute<I extends DistributedRPC.AsyncIface>
DistributedRPC.Client
DistributedRPC.Client.Factory
DistributedRPC.execute_args
DistributedRPC.execute_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPC.execute_result
DistributedRPC.execute_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPC.Iface
DistributedRPC.Processor<I extends DistributedRPC.Iface>
DistributedRPC.Processor.execute<I extends DistributedRPC.Iface>
DistributedRPCInvocations
DistributedRPCInvocations.AsyncClient
DistributedRPCInvocations.AsyncClient.Factory
DistributedRPCInvocations.AsyncClient.failRequest_call
DistributedRPCInvocations.AsyncClient.failRequestV2_call
DistributedRPCInvocations.AsyncClient.fetchRequest_call
DistributedRPCInvocations.AsyncClient.result_call
DistributedRPCInvocations.AsyncIface
DistributedRPCInvocations.AsyncProcessor<I extends DistributedRPCInvocations.AsyncIface>
DistributedRPCInvocations.AsyncProcessor.failRequest<I extends DistributedRPCInvocations.AsyncIface>
DistributedRPCInvocations.AsyncProcessor.failRequestV2<I extends DistributedRPCInvocations.AsyncIface>
DistributedRPCInvocations.AsyncProcessor.fetchRequest<I extends DistributedRPCInvocations.AsyncIface>
DistributedRPCInvocations.AsyncProcessor.result<I extends DistributedRPCInvocations.AsyncIface>
DistributedRPCInvocations.Client
DistributedRPCInvocations.Client.Factory
DistributedRPCInvocations.failRequest_args
DistributedRPCInvocations.failRequest_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.failRequest_result
DistributedRPCInvocations.failRequest_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.failRequestV2_args
DistributedRPCInvocations.failRequestV2_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.failRequestV2_result
DistributedRPCInvocations.failRequestV2_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.fetchRequest_args
DistributedRPCInvocations.fetchRequest_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.fetchRequest_result
DistributedRPCInvocations.fetchRequest_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.Iface
DistributedRPCInvocations.Processor<I extends DistributedRPCInvocations.Iface>
DistributedRPCInvocations.Processor.failRequest<I extends DistributedRPCInvocations.Iface>
DistributedRPCInvocations.Processor.failRequestV2<I extends DistributedRPCInvocations.Iface>
DistributedRPCInvocations.Processor.fetchRequest<I extends DistributedRPCInvocations.Iface>
DistributedRPCInvocations.Processor.result<I extends DistributedRPCInvocations.Iface>
DistributedRPCInvocations.result_args
DistributedRPCInvocations.result_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DistributedRPCInvocations.result_result
DistributedRPCInvocations.result_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DNSToSwitchMapping
An interface that must be implemented to allow pluggable DNS-name/IP-address to RackID resolvers.
DockerCommand
DockerExecCommand
Encapsulates the docker exec command and its command line arguments.
DockerInspectCommand
Encapsulates the docker inspect command and its command line arguments.
DockerManager
For security, we can launch worker processes inside the docker container.
DockerPsCommand
DockerRmCommand
Encapsulates the docker rm command and its command line arguments.
DockerRunCommand
Encapsulates the docker run command and its command line arguments.
DockerStopCommand
Encapsulates the docker stop command and its command line arguments.
DockerWaitCommand
Encapsulates the docker wait command and its command line arguments.
DRPC
DRPCApplication
DRPCAuthorizerBase
DRPCClient
DRPCClient.LocalOverride
DRPCExceptionMapper
DRPCExceptionType
DRPCExecutionException
DRPCExecutionException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DRPCInvocationsClient
DRPCRequest
DRPCRequest._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
DRPCResource
DRPCServer
DRPCSimpleACLAuthorizer
DRPCSimpleACLAuthorizer.AclFunctionEntry
DRPCSpout
DRPCThrift
EachOperation
EachProcessor
EmitInfo
EmittingProcessorContext<T>
A context that emits the results to downstream processors which are in another bolt.
EmptyKafkaTupleListener
EnumUtil
Equals
EquivalenceUtils
ErrorEdgeFactory
ErrorInfo
ErrorInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
EstimateThroughput
Estimate the throughput of all topologies.
EvaluationCalc
EvaluationFilter
EvaluationFunction
EvenScheduler
Event<T>
An event is a wrapper object that gets stored in the window.
EventImpl<T>
EventLoggerBolt
EventManager
EventManagerImp
EventManagerPushCallback
EvictionContext
Context information that can be used by the eviction policy.
EvictionPolicy<T,S>
Eviction policy tracks events and decides whether an event should be evicted from the window or not.
EvictionPolicy.Action
The action to be taken when `EvictionPolicy.evict(Event)` is invoked.
ExampleJmsTopology
An example JMS topology.
ExceptionMapperUtils
ExceptionMeterNames
ExclamationTopology
This is a basic example of a Storm topology.
ExclamationTopology
This is a basic example of a Storm topology.
ExclamationTopology.ExclamationBolt
ExclamationTopology.ExclamationBolt
ExclamationTopology.FixedOrderWordSpout
ExecAndProcessLatencyEngine
A more accurate sleep implementation.
ExecSorterByConnectionCount
ExecSorterByConstraintSeverity
ExecSorterByProximity
ExecutableExpression
Compiled executable expression.
ExecutionContext
Container for all the objects required to instantiate a topology.
Executor
ExecutorAggregateStats
ExecutorAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ExecutorBeat
ExecutorDetails
ExecutorInfo
ExecutorInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ExecutorShutdown
ExecutorSpecificStats
ExecutorSpecificStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ExecutorStats
ExecutorStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ExecutorSummary
ExecutorSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ExecutorTransfer
ExitCodeCallback
A callback that can accept an integer.
ExtendedThreadPoolExecutor
FailedException
FastWordCountTopology
WordCount but the spout does not stop, and the bolts are implemented in java.
FastWordCountTopology.FastRandomSentenceSpout
FastWordCountTopology.SplitSentence
FastWordCountTopology.WordCount
FeederBatchSpout
FeederCommitterBatchSpout
FeederSpout
FieldIndexTopicSelector
Uses field with a given index to select the topic name from a tuple .
FieldInfo
Describe each column of the field.
FieldInfoUtils
FieldNameBasedTupleToKafkaMapper<K,V>
FieldNameBasedTupleToKafkaMapper<K,V>
FieldNameTopicSelector
Uses field name to select topic name from tuple .
Fields
Collection of unique named fields using in an ITuple.
FIFOSchedulingPriorityStrategy
FIFOSchedulingPriorityStrategy.FIFOSimulatedUser
FileBasedEventLogger
FileBlobStoreImpl
Very basic blob store impl with no ACL handling.
FileConfigLoader
Scheduler configuration loader which loads configs from a file.
FileConfigLoaderFactory
Factory class for FileConfigLoader.
FileLock
Facility to synchronize access to HDFS files.
FileLock.LogEntry
FileNameFormat
Formatter interface for determining HDFS file names.
FileNameFormat
Formatter interface for determining HDFS file names.
FileNotAvailableException
FileReadSpout
FileReadSpout.FileReader
FileReadWordCountTopo
This topo helps measure speed of word count.
FileRotationPolicy
Used by the HdfsBolt to decide when to rotate files.
FileRotationPolicy
Used by the HdfsBolt to decide when to rotate files.
FileSizeRotationPolicy
File rotation policy that will rotate files when a certain file size is reached.
FileSizeRotationPolicy
File rotation policy that will rotate files when a certain file size is reached.
FileSizeRotationPolicy.Units
FileSizeRotationPolicy.Units
FileWatcher
FileWatcher.Callback
Filter
Filters take in a tuple as input and decide whether or not to keep that tuple or not.
FilterByMetricName
FilterConfiguration
FilterExecutor
FilterNull
Simple `Filter` implementation that filters out any tuples that have fields with a value of `null`.
FilterOptions
FilterOptions provides a method to select various filtering options for doing a scan of the metrics database.
FilterProcessor<T>
FirstN
An `Assembly` implementation.
FirstN.FirstNAgg
FirstN.FirstNSortedAgg
FirstPollOffsetStrategy
Defines how the spout seeks the offset to be used in the first poll to Kafka upon topology deployment.
FixedAvroSerializer
A class to help (de)serialize a pre-defined set of Avro schemas.
FixedBatchSpout
FixedBatchSpout
FixedGroupsMapping
FixedTuple
FixedTupleSpout
FlatMapFunction<T,R>
A function that accepts one argument and returns an `Iterable` of elements as its result.
FlatMapFunction
A one to many transformation function.
FlatMapFunctionExecutor
FlatMapProcessor<T,R>
FlatMapValuesProcessor<K,V,R>
Flux
Flux entry point.
FluxBuilder
FluxParser
Static utility methods for parsing flux YAML.
FluxShellBolt
A generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.
FluxShellSpout
A generic `ShellSpout` implementation that allows you specify output fields and even streams without having to subclass `ShellSpout` to do so.
ForEachProcessor<T>
ForwardingMetricsConsumer
ForwardingProcessorContext<T>
A context that emits the results to downstream processors which are in the same bolt.
FreePool
All of the machines that currently have nothing assigned to them.
FreezerCore
FreezerCore.State
FreshCollector
FromJson<T>
Func<V,R>
A simple interface to allow compatibility with non java 8 code bases.
Function<T,R>
Represents a function that accepts one argument and produces a result.
Function
A function takes in a set of input fields and emits zero or more tuples as output.
GeneralTopologyContext
GenericAvroSerializer
A default implementation of the AvroSerializer that will just pass literal schemas back and forth.
GenericBolt
A generic `org.apache.storm.topology.IRichBolt` implementation for testing/debugging the Storm JMS Spout and example topologies.
GenericResourceAwareSchedulingPriorityStrategy
GenericResourceAwareSchedulingPriorityStrategy.GrasSimulatedUser
GenericResourceAwareStrategy
GenericResourceAwareStrategyOld
GenLoad
Generate a simulated load.
GetErrors
GetInfoOptions
GetInfoOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
GlobalAggregationScheme<S extends IAggregatableStream>
GlobalBatchToPartition
GlobalGrouping
GlobalStreamId
GlobalStreamId._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
GoodToGo
Used as a way to give feedback that the listener is ready for the caller to change the blob.
GoodToGo.GoodToGoLatch
GraphGrouper
GraphiteStormReporter
Group
GroupByKeyAndWindowExample
An example that shows the usage of `PairStream.groupByKeyAndWindow(Window)` and `PairStream.reduceByKeyAndWindow(Reducer, Window)`.
GroupCollector
GroupedAggregator
GroupedMultiReducer<T>
GroupedMultiReducerExecutor
GroupedStream
GrouperFactory
GrouperFactory.AllGrouper
GrouperFactory.BasicLoadAwareCustomStreamGrouping
A bridge between CustomStreamGrouping and LoadAwareCustomStreamGrouping.
GrouperFactory.FieldsGrouper
GrouperFactory.GlobalGrouper
GrouperFactory.NoneGrouper
Grouping
Grouping._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
GroupingDef
Bean representation of a Storm stream grouping.
GroupingDef.Type
Types of stream groupings Storm allows.
GroupingType
The different types of groupings that are supported.
GzipBridgeThriftSerializationDelegate
Always writes gzip out, but tests incoming to see if it's gzipped.
GzipSerializationDelegate
Note, this assumes it's deserializing a gzip byte stream, and will err if it encounters any other serialization.
GzipThriftSerializationDelegate
Note, this assumes it's deserializing a gzip byte stream, and will err if it encounters any other serialization.
HadoopLoginUtil
UserGroupInformation#loginUserFromKeytab(String, String) changes the static fields of UserGroupInformation, especially the current logged-in user, and UserGroupInformation itself is not thread-safe.
HashMapSerializer
HashSetSerializer
HBaseSecurityUtil
This class provides util methods for storm-hbase connector communicating with secured HBase.
HBAuthorizationException
HBAuthorizationException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBExecutionException
HBExecutionException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBMessage
HBMessage._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBMessageData
HBMessageData._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBNodes
HBNodes._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBPulse
HBPulse._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBRecords
HBRecords._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
HBServerMessageType
HdfsBlobStore
Provides a HDFS file system backed blob store implementation.
HdfsBlobStoreFile
HdfsBlobStoreImpl
HDFS blob store impl.
HdfsBolt
HdfsClientBlobStore
Client to access the HDFS blobStore.
HdfsDataSourcesProvider
Create a HDFS sink based on the URI and properties.
HdfsFileTopology
HdfsFileTopology.MyBolt
HdfsFileTopology.SentenceSpout
HdfsManifestToResourcesPlugin
HdfsOciResourcesLocalizer
HdfsSecurityUtil
This class provides util methods for storm-hdfs connector communicating with secured HDFS.
HdfsSpout
HdfsSpoutNullBoltTopo
This topo helps measure speed of reading from Hdfs.
HdfsSpoutTopology
HdfsSpoutTopology.ConstBolt
HdfsState
HdfsState.HdfsFileOptions
HdfsState.Options
HdfsState.SequenceFileOptions
HdfsStateFactory
HdfsUpdater
HdfsUtils
HdfsUtils.Pair<K,V>
HDFSWriter
HeaderResponseFilter
HeaderResponseServletFilter
HealthCheck
HealthChecker
HeartbeatCache
Holds a cache of heartbeats from the workers.
Heartbeats
Helper
Hierarchy
A class that describes a cgroup hierarchy.
HikariCPConnectionProvider
HistogramMetric
A metric wrapping an HdrHistogram.
HttpForwardingMetricsConsumer
Listens for all metrics and POSTs them serialized to a configured URL.
HttpForwardingMetricsServer
A server that can listen for metrics from the HttpForwardingMetricsConsumer.
IAdvancedFSOps
IAggregatableStream
IAuthorizer
Nimbus could be configured with an authorization plugin.
IAutoCredentials
Provides a way to automatically push credentials to a topology and to retrieve them in the worker.
IBackingMap<T>
IBasicBolt
IBasicOutputCollector
IBatchBolt<T>
IBatchID
IBatchSpout
IBlacklistStrategy
IBolt
An IBolt represents a component that takes tuples as input and produces tuples as output.
IChainedAggregatorDeclarer
IClusterMetricsConsumer
IClusterMetricsConsumer.ClusterInfo
IClusterMetricsConsumer.SupervisorInfo
ICombiner<T>
ICommitterTridentSpout<X>
ICommitterTridentSpout.Emitter
IComponent
Common methods for all possible components in a topology.
IConfigLoader
IConfigLoaderFactory
IConfigurator
IConnection
IConnectionCallback
A class that is called when a TaskMessage arrives.
IContext
This interface needs to be implemented for messaging plugin.
ICredentialsListener
Allows a bolt or a spout to be informed when the credentials of the topology have changed.
ICredentialsRenewer
Provides a way to renew credentials on behalf of a user.
IdBolt
IdentityBolt
IdentityBolt
IdentityFunction<T>
A `Function` that returns the input argument itself as the result.
IdentityGrouping
IdentityMultiReducer<T>
IErrorReporter
IEventLogger
EventLogger interface for logging the event info to a sink like log file or db for inspecting the events via UI for debugging.
IEventLogger.EventInfo
A wrapper for the fields that we would log.
IExecSorter
IFeeder
IGroupMappingServiceProvider
IHttpCredentialsPlugin
Interface for handling credentials in an HttpServletRequest.
IKryoDecorator
IKryoFactory
An interface that controls the Kryo instance used by Storm for serialization.
ILeaderElector
The interface for leader election.
IllegalStateException
IllegalStateException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ILocalAssignmentsBackend
Interface for storing local assignments.
ILocalCluster
This is here mostly for backwards compatibility.
ILocalCluster.ILocalTopology
Close this class to kill the topology.
ILocalClusterTrackedTopologyAware
This is here mostly for backwards compatibility.
ILocalDRPC
ImageManifest
The image manifest.
IMetric
Produces metrics.
IMetricsConsumer
IMetricsConsumer.DataPoint
IMetricsConsumer.TaskInfo
IMetricsContext
IMetricsRegistrant
Interface to allow registration of metrics.
ImpersonationAuthorizer
ImpersonationAuthorizer.ImpersonationACL
IMultiSchemableSpout
IncludeDef
Represents an include.
IncrementingSpout
IndexedEdge<T>
IndexHashBatchToPartition
IndexHashGrouping
IndifferentAccessMap
INettySerializable
INimbus
INimbusCredentialPlugin
Nimbus auto credential plugin that will be called on nimbus host during submit topology option.
InMemoryAssignmentBackend
An assignment backend which will keep all assignments and id-info in memory.
InMemoryKeyValueState<K,V>
An in-memory implementation of the `State`.
InMemoryKeyValueStateProvider
Provides `InMemoryKeyValueState`.
InMemoryTridentWindowManager
This `ITridentWindowManager` instance stores all the tuples and trigger related information inmemory.
InMemoryWindowsStore
Inmemory store implementation of `WindowsStore` which can be backed by persistent store.
InMemoryWindowsStoreFactory
InMemoryWindowsStoreFactory contains a single instance of `InMemoryWindowsStore` which will be used for storing tuples and triggers of the window.
INodeAssignmentSentCallBack
INodeSorter
InOrderDeliveryTest
InOrderDeliveryTest.Check
InOrderDeliveryTest.InOrderSpout
InProcessZookeeper
A local Zookeeper instance available for testing.
InprocMessaging
InputDeclarer<T extends InputDeclarer>
InputStream
A set of measurements about a stream so we can statistically reproduce it.
InputStream.Builder
InputStreamWithMeta
InterfaceStability
Annotation to inform users of how much to rely on a particular package, class or method not changing over time.
InterfaceStability.Evolving
Evolving, but can break compatibility at minor release (i.e.
InterfaceStability.Stable
Can evolve while retaining compatibility for minor release boundaries.; can break compatibility only at major release (ie.
InterfaceStability.Unstable
No guarantee is provided as to reliability or stability across any level of release granularity.
IntermediateRankingsBolt
This bolt ranks incoming objects by their count.
InvalidRequestException
InvalidTopologyException
InvalidTopologyException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
IOFunction<T,R>
IOpaquePartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,M>
This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT>
Coordinator for batches.
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,M>
IOutputCollector
IOutputSerializer
IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
IPartitionedTridentSpout.Coordinator<PartitionsT>
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,X>
IPredicate<T>
This interface is implemented by classes, instances of which can be passed into certain Util functions which test some collection for elements matching the IPredicate.
IPrincipalToLocal
Storm can be configured to launch worker processed as a given user.
IReducer<T>
IReporter
report blacklist to alert system.
IReportError
IRichBolt
When writing topologies using Java, `IRichBolt` and `IRichSpout` are the main interfaces to use to implement components of the topology.
IRichSpout
When writing topologies using Java, `IRichBolt` and `IRichSpout` are the main interfaces to use to implement components of the topology.
IRichStateSpout
IRunningExecutor
ISaslClient
ISaslServer
IScheduler
ISchedulingPriorityStrategy
ISchedulingState
An interface that provides access to the current scheduling state.
ISchemableSpout
ISerializer
The ISerializer interface describes the methods that an object should implement to provide serialization and de-serialization capabilities to non-JVM language components.
IServer
IServerMessageHandler
IShellMetric
IsolatedPool
A pool of machines that can be used to run isolated topologies.
IsolationScheduler
ISpout
ISpout is the core interface for implementing spouts.
ISpoutOutputCollector
Methods are not expected to be thread safe.
ISpoutPartition
ISqlStreamsDataSource
An ISqlStreamsDataSource specifies how an external data source produces and consumes data.
IStatefulBolt<T extends State>
A bolt abstraction for supporting stateful computation.
IStatefulComponent<T extends State>
Common methods for stateful components in the topology.
IStatefulObject
IStatefulWindowedBolt<T extends State>
A windowed bolt abstraction for supporting windowing operation with state.
IStateSpout
IStateSpoutOutputCollector
IStateStorage
StateStorage provides the API for the pluggable state store used by the Storm daemons.
IStormClusterState
IStrategy
An interface to for implementing different scheduling strategies for the resource aware scheduling.
ISubmitterHook
if FQCN of an implementation of this class is specified by setting the config storm.topology.submission.notifier.plugin.class, that class's notify method will be invoked when a topology is successfully submitted via StormSubmitter class.
ISubscribedState
ISupervisor
ISynchronizeOutputCollector
ITaskHook
ITopologyActionNotifierPlugin
A plugin interface that gets invoked any time there is an action for a topology.
ITopologyValidator
ITransportPlugin
Interface for Thrift Transport plugin.
ITridentBatchBolt
ITridentDataSource
ITridentDataSource marks all spouts that provide data into Trident.
ITridentResource
This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.
ITridentSpout<T>
ITridentSpout.BatchCoordinator<X>
ITridentSpout.Emitter<X>
ITridentWindowManager
Window manager to handle trident tuple events.
ITuple
ITupleCollection
ITupleDeserializer
ITupleSerializer
IVersionInfo
Implementation of VersionInfo that uses a properties file to get the VersionInfo.
IWaitStrategy
IWaitStrategy.WaitSituation
IWindowedBolt
A bolt abstraction for supporting time and count based sliding & tumbling windows.
IWorkerHeartbeatsRecoveryStrategy
Interface for strategy to recover heartbeats when master gains leadership.
IWorkerHook
An IWorkerHook represents a topology component that can be executed when a worker starts, and when a worker shuts down.
JassPasswordProvider
Provides passwords out of a jaas conf for typical MD5-DIGEST authentication support.
JavaObject
JavaObject._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
JavaObjectArg
JavaObjectArg._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
JCQueue
JCQueue.Consumer
JCQueue.ExitCondition
JCQueueMetrics
JCQueuePerfTest
JCToolsPerfTest
JdbcClient
JdbcInsertBolt
Basic bolt for writing to any Database table.
JdbcLookupBolt
Basic bolt for querying from any database.
JdbcLookupMapper
JdbcMapper
JdbcQuery
JdbcState
JdbcState.Options
JdbcStateFactory
JdbcUpdater
JedisClusterConfig
Configuration for JedisCluster.
JedisClusterConfig.Builder
Builder for initializing JedisClusterConfig.
JedisClusterContainer
Container for managing JedisCluster.
JedisCommandsContainer
Interfaces for containers which stores instances implementing JedisCommands.
JedisCommandsContainerBuilder
Container Builder which helps abstraction of two env.
JedisContainer
Adapter for providing a unified interface for running commands over both Jedis and JedisCluster instances.
JedisPoolConfig
Configuration for JedisPool.
JedisPoolConfig.Builder
Builder for initializing JedisPoolConfig.
JmsBatch
Batch coordination metadata object for the TridentJmsSpout.
JmsBolt
A JmsBolt receives `org.apache.storm.tuple.Tuple` objects from a Storm topology and publishes JMS Messages to a destination (topic or queue).
JmsMessageID
JmsMessageProducer
JmsMessageProducer implementations are responsible for translating a `org.apache.storm.tuple.Values` instance into a `javax.jms.Message` object.
JmsProvider
A `JmsProvider` object encapsulates the `ConnectionFactory` and `Destination` JMS objects the `JmsSpout` needs to manage a topic/queue connection over the course of it's lifecycle.
JmsSpout
A Storm `Spout` implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives.
JmsState
JmsState.Options
JmsStateFactory
JmsTupleProducer
Interface to define classes that can produce a Storm `Values` objects from a `javax.jms.Message` object>.
JmsUpdater
JmxPreparableReporter
JmxStormReporter
JoinBolt
JoinBolt.FieldSelector
JoinBolt.JoinInfo
Describes how to join the other stream with the current stream.
JoinBolt.JoinType
JoinBolt.Selector
JoinBoltExample
JoinerMultiReducer
JoinExample
An example that demonstrates the usage of `PairStream.join(PairStream)` to join multiple streams.
JoinOutFieldsMode
This enum defines how the output fields of JOIN is constructed.
JoinProcessor<K,R,V1,V2>
Provides equi-join implementation based on simple hash-join.
JoinProcessor.JoinType
JoinResult
JoinState
JoinType
JSONNonTransactionalSerializer
JSONOpaqueSerializer
JsonResponseBuilder
Response builder for JSON.
JsonScheme
JsonSerializer
JsonSerializer implements the JSON multilang protocol.
JsonSerializer
JSONTransactionalSerializer
JsonTupleProducer
A simple `JmsTupleProducer` that expects to receive JMS `TextMessage` objects with a body in JSON format.
KafkaBolt<K,V>
Bolt implementation that can send Tuple data to Kafka.
KafkaClientHdfsTopo
This topo helps measure speed of reading from Kafka and writing to Hdfs.
KafkaClientHdfsTopo.LineWriter
KafkaClientSpoutNullBoltTopo
Benchmark topology for measuring spout read/emit/ack performance.
KafkaDataSourcesProvider
Create a Kafka spout/sink based on the URI and properties.
KafkaOffsetLagResult
Class representing the log head offsets, spout offsets and the lag for a topic.
KafkaOffsetLagUtil
Utility class for querying offset lag for kafka spout.
KafkaOffsetMetricManager<K,V>
This class is used to manage both the partition and topic level offset metrics.
KafkaOffsetPartitionMetrics<K,V>
Partition level metrics.
KafkaOffsetTopicMetrics
Topic level metrics.
KafkaPartitionOffsetLag
KafkaProducerTopology
KafkaSpout<K,V>
KafkaSpoutConfig<K,V>
KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics.
KafkaSpoutConfig.Builder<K,V>
KafkaSpoutConfig.ProcessingGuarantee
This enum controls when the tuple with the `ConsumerRecord` for an offset is marked as processed, i.e.
KafkaSpoutMessageId
KafkaSpoutMigration
KafkaSpoutRetryExponentialBackoff
Implementation of `KafkaSpoutRetryService` using the exponential backoff formula.
KafkaSpoutRetryExponentialBackoff.TimeInterval
KafkaSpoutRetryService
Represents the logic that manages the retrial of failed tuples.
KafkaSpoutTestBolt
KafkaSpoutTopologyMainNamedTopics
This example sets up 3 topologies to put data in Kafka via the KafkaBolt, and shows how to set up a topology that reads from some Kafka topics using the KafkaSpout.
KafkaSpoutTopologyMainWildcardTopics
This example is similar to `KafkaSpoutTopologyMainNamedTopics`, but demonstrates subscribing to Kafka topics with a regex.
KafkaTopicSelector
KafkaTopicSelector
KafkaTridentOpaqueSpoutEmitter<K,V>
KafkaTridentSpoutBatchMetadata
Wraps transaction batch information.
KafkaTridentSpoutConfig<K,V>
Defines the required Kafka-related configuration for the Trident spouts.
KafkaTridentSpoutConfig.Builder<K,V>
KafkaTridentSpoutCoordinator<K,V>
KafkaTridentSpoutEmitter<K,V>
KafkaTridentSpoutMigration
KafkaTridentSpoutOpaque<K,V>
KafkaTridentSpoutTopicPartition
`ISpoutPartition` that wraps `TopicPartition` information.
KafkaTridentSpoutTransactional<K,V>
KafkaTridentTransactionalSpoutEmitter<K,V>
KafkaTuple
A list of Values in a tuple that can be routed to a given stream: `RecordTranslator.apply(org.apache.kafka.clients.consumer.ConsumerRecord<K, V>)`.
KafkaTupleListener
The KafkaTupleListener handles state changes of a kafka tuple inside a KafkaSpout.
KerberosPrincipalToLocal
Map a kerberos principal to a local user.
KerberosSaslClientHandler
KerberosSaslNettyClient
Implements SASL logic for storm worker client processes.
KerberosSaslServerHandler
KerberosSaslTransportPlugin
KeyAlreadyExistsException
KeyAlreadyExistsException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
KeyedFairBolt
KeyedRoundRobinQueue<V>
KeyFactory
KeyFactory defines conversion of state key (which could be compounded) -> Redis key.
KeyFactory.DefaultKeyFactory
Default Key Factory.
KeyFilter<R>
KeyNotFoundException
KeyNotFoundException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
KeySequenceNumber
Class hands over the key sequence number which implies the number of updates made to a blob.
KeyType
Specifies all the valid types of keys and their values.
KeyValueState<K,V>
A state that supports key-value mappings.
Killable
KillOptions
KillOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
KillTopology
KillWorkers
KryoTupleDeserializer
KryoTupleSerializer
KryoValuesDeserializer
KryoValuesSerializer
LambdaBiConsumerBolt
LambdaConsumerBolt
LambdaSpout
LambdaTopology
LatencyStat
Keeps track of approximate latency for the last 10 mins, 3 hours, 1 day, and all time.
LeaderElectorImp
LeaderListenerCallback
A callback function when nimbus gains leadership.
LeaderListenerCallbackFactory
LinearDRPCInputDeclarer
LinearDRPCTopologyBuilder
ListBlobsResult
ListBlobsResult._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ListDelegate
ListDelegateSerializer
ListFunctionalSupport
Implements missing sequence functions in Java compared to Clojure.
ListHDFS
ListLocalFs
ListTopologies
Load
Represents the load that a Bolt is currently under to help in deciding where to route a tuple, to help balance the load.
LoadAwareCustomStreamGrouping
LoadAwareShuffleGrouping
LoadBolt
A bolt that simulates a real world bolt based off of statistics about it.
LoadCompConf
Configuration for a simulated spout.
LoadCompConf.Builder
LoadMapping
Holds a list of the current loads.
LoadMetricsServer
A metrics server that records and reports metrics for a set of running topologies.
LoadMetricsServer.Measurements
LoadSpout
A spout that simulates a real world spout based off of statistics about it.
LocalAssignment
LocalAssignment._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LocalAssignmentsBackendFactory
Factory class for creating local assignments.
LocalCluster
A stand alone storm cluster that runs inside a single process.
LocalCluster.Builder
Simple way to configure a LocalCluster to meet your needs.
LocalContainer
LocalContainerLauncher
Launch Containers in local mode.
LocalDRPC
A Local way to test DRPC.
LocalExecutor
LocalFsBlobStore
Provides a local file system backed blob store implementation for Nimbus.
LocalFsBlobStoreFile
LocalFsBlobStoreSynchronizer
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.
LocalizedResource
Represents a resource that is localized on the supervisor.
LocalizedResourceRetentionSet
A set of resources that we can look at to see which ones we retain and which ones should be removed.
LocallyCachedBlob
Represents a blob that is cached locally on disk by the supervisor.
LocallyCachedTopologyBlob
A locally cached blob for the topology.
LocallyCachedTopologyBlob.TopologyBlobType
LocalModeClientBlobStore
A Client blob store for LocalMode.
LocalOrHdfsImageTagToManifestPlugin
LocalResource
Local Resource requested by the topology.
LocalState
A simple, durable, atomic K/V database.
LocalStateData
LocalStateData._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LogCleaner
Cleans dead workers logs and directories.
LogConfig
LogConfig._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LogConfigManager
LogFileDownloader
LoggingClusterMetricsConsumer
Listens for cluster related metrics, dumps them to log.
LoggingMetricsConsumer
Listens for all metrics, dumps them to log
Login
LogInfoBolt
Simple bolt that does nothing other than LOG.info() every tuple recieveed.
LogLevel
LogLevel._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LogLevelAction
LogReporter
LogviewerApplication
LogviewerConstant
Constants which are used across logviewer related classes.
LogviewerLogDownloadHandler
LogviewerLogPageHandler
LogviewerLogSearchHandler
LogviewerLogSearchHandler.Matched
LogviewerProfileHandler
LogviewerResource
Handles HTTP requests for Logviewer.
LogviewerResponseBuilder
LogviewerServer
The main entry of Logviewer.
LogWriter
Launch a sub process and write files out to logs.
LongSum
Computes the long sum of the input values.
LookupWordCount
LookupWordCount.PrintWordTotalCountBolt
LowThroughputTopo
LruMap<A,B>
LRUMap<A,B>
LruMap.CacheEvictionCallback<K,V>
LRUMemoryMapState<T>
LRUMemoryMapState.Factory
LSApprovedWorkers
LSApprovedWorkers._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LSSupervisorAssignments
LSSupervisorAssignments._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LSSupervisorId
LSSupervisorId._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LSTopoHistory
LSTopoHistory._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LSTopoHistoryList
LSTopoHistoryList._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
LSWorkerHeartbeat
LSWorkerHeartbeat._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ManualDRPC
ManualDRPC.ExclamationBolt
ManualPartitioner
A function used to assign partitions to this spout.
MapCombinerAggStateUpdater
MapFunction
A one-one transformation function.
MapFunctionExecutor
MapGet
MapProcessor<T,R>
MapProcessor
Processor for executing `Stream.map(MapFunction)` and `Stream.flatMap(FlatMapFunction)` functions.
MapReducerAggStateUpdater
MapState<T>
MapUtil
MapValuesProcessor<K,V,R>
MasterBatchCoordinator
Max
This aggregator computes the maximum of aggregated tuples in a stream.
MaxWithComparator<T>
This aggregator computes the maximum of aggregated tuples in a stream.
MeanReducer
MemoryBackingMap<T>
MemoryCore
MemoryCore.Stat
MemoryMapState<T>
MemoryMapState.Factory
MergeAggregateByKeyProcessor<K,V,A,R>
MergeAggregateProcessor<T,A,R>
MessageBuffer
Encapsulates the state used for batching up messages.
MessageDecoder
MessageId
Metric
Class containing metric values and all identifying fields to be stored in a MetricStore.
MetricException
A MetricException is used to describe an error using a MetricStore.
MetricRegistryProvider
MetricsCleaner
Class for removing expired metrics and unused metadata from the RocksDB store.
MetricsConsumerBolt
MetricsFilter
MetricsSample
MetricStore
MetricStore.ScanCallback
Interface used to callback metrics results from a scan.
MetricStoreConfig
MetricsUtils
MicroBatchIBackingMap<T>
MicroBatchIBackingMap.Options
MigrateBlobs
MigratorMain
Min
This aggregator computes the minimum of aggregated tuples in a stream.
MinWithComparator<T>
This aggregator computes the minimum of aggregated tuples in a stream.
MkClusterParam
The param arg for `Testing.withSimulatedTimeCluster`, `Testing.withTrackedCluster` and `Testing.withLocalCluster`.
MkTupleParam
MockedClientZookeeper
MockedCluster
MockedSources
MockedSupervisorUtils
MockedZookeeper
MockLeaderElector
ModifTimeComparator
Monitor
Monitor
MoveFileAction
MultiCountMetric
MultiCountStat<T>
Acts as a MultiCount Stat, but keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time.
MultiLatencyStat<T>
Keeps track of approximate latency for the last 10 mins, 3 hours, 1 day, and all time.
MultipleLoggerTopology
This is a basic example of a Storm topology.
MultipleLoggerTopology.ExclamationLoggingBolt
MultiReducedMetric
MultiReducer<T>
MultiReducerProcessor
MultiScheme
MultitenantScheduler
MultiThreadWordCountTopology
Some topologies might spawn some threads within bolts to do some work and emit tuples from those threads.
MultiThreadWordCountTopology.MultiThreadedSplitSentence
MultiThriftServer<T extends ThriftServer>
Manage a collection of `ThriftServer`.
MutableInt
MutableLong
MutableObject
NamedTopicFilter
Filter that returns all partitions for the specified topics.
Negate
A `Filter` implementation that inverts another delegate `Filter`.
NetClsCore
NetPrioCore
NettyRenameThreadFactory
NettySerializableMessageEncoder
NettyTlsUtils
NettyUncaughtExceptionHandler
NewKafkaSpoutOffsetQuery
Class representing information for querying kafka for log head offsets, consumer offsets and the difference for new kafka spout using new consumer api.
NGrouping
Nimbus
Nimbus
Nimbus.activate_args
Nimbus.activate_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.activate_result
Nimbus.activate_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.AsyncClient
Nimbus.AsyncClient.activate_call
Nimbus.AsyncClient.beginBlobDownload_call
Nimbus.AsyncClient.beginCreateBlob_call
Nimbus.AsyncClient.beginFileUpload_call
Nimbus.AsyncClient.beginUpdateBlob_call
Nimbus.AsyncClient.cancelBlobUpload_call
Nimbus.AsyncClient.createStateInZookeeper_call
Nimbus.AsyncClient.deactivate_call
Nimbus.AsyncClient.debug_call
Nimbus.AsyncClient.deleteBlob_call
Nimbus.AsyncClient.downloadBlobChunk_call
Nimbus.AsyncClient.downloadChunk_call
Nimbus.AsyncClient.Factory
Nimbus.AsyncClient.finishBlobUpload_call
Nimbus.AsyncClient.finishFileUpload_call
Nimbus.AsyncClient.getBlobMeta_call
Nimbus.AsyncClient.getBlobReplication_call
Nimbus.AsyncClient.getClusterInfo_call
Nimbus.AsyncClient.getComponentPageInfo_call
Nimbus.AsyncClient.getComponentPendingProfileActions_call
Nimbus.AsyncClient.getLeader_call
Nimbus.AsyncClient.getLogConfig_call
Nimbus.AsyncClient.getNimbusConf_call
Nimbus.AsyncClient.getOwnerResourceSummaries_call
Nimbus.AsyncClient.getSupervisorAssignments_call
Nimbus.AsyncClient.getSupervisorPageInfo_call
Nimbus.AsyncClient.getTopology_call
Nimbus.AsyncClient.getTopologyConf_call
Nimbus.AsyncClient.getTopologyHistory_call
Nimbus.AsyncClient.getTopologyInfo_call
Nimbus.AsyncClient.getTopologyInfoByName_call
Nimbus.AsyncClient.getTopologyInfoByNameWithOpts_call
Nimbus.AsyncClient.getTopologyInfoWithOpts_call
Nimbus.AsyncClient.getTopologyPageInfo_call
Nimbus.AsyncClient.getTopologySummaries_call
Nimbus.AsyncClient.getTopologySummary_call
Nimbus.AsyncClient.getTopologySummaryByName_call
Nimbus.AsyncClient.getUserTopology_call
Nimbus.AsyncClient.isRemoteBlobExists_call
Nimbus.AsyncClient.isTopologyNameAllowed_call
Nimbus.AsyncClient.killTopology_call
Nimbus.AsyncClient.killTopologyWithOpts_call
Nimbus.AsyncClient.listBlobs_call
Nimbus.AsyncClient.processWorkerMetrics_call
Nimbus.AsyncClient.rebalance_call
Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call
Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call
Nimbus.AsyncClient.setBlobMeta_call
Nimbus.AsyncClient.setLogConfig_call
Nimbus.AsyncClient.setWorkerProfiler_call
Nimbus.AsyncClient.submitTopology_call
Nimbus.AsyncClient.submitTopologyWithOpts_call
Nimbus.AsyncClient.updateBlobReplication_call
Nimbus.AsyncClient.uploadBlobChunk_call
Nimbus.AsyncClient.uploadChunk_call
Nimbus.AsyncClient.uploadNewCredentials_call
Nimbus.AsyncIface
Nimbus.AsyncProcessor<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.activate<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.beginBlobDownload<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.beginCreateBlob<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.beginFileUpload<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.beginUpdateBlob<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.cancelBlobUpload<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.createStateInZookeeper<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.deactivate<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.debug<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.deleteBlob<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.downloadBlobChunk<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.downloadChunk<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.finishBlobUpload<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.finishFileUpload<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getBlobMeta<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getBlobReplication<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getClusterInfo<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getComponentPageInfo<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getComponentPendingProfileActions<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getLeader<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getLogConfig<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getNimbusConf<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getOwnerResourceSummaries<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getSupervisorAssignments<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getSupervisorPageInfo<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopology<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyConf<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyHistory<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyInfo<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyInfoByName<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyInfoByNameWithOpts<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyInfoWithOpts<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologyPageInfo<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologySummaries<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologySummary<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getTopologySummaryByName<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.getUserTopology<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.isRemoteBlobExists<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.isTopologyNameAllowed<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.killTopology<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.killTopologyWithOpts<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.listBlobs<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.processWorkerMetrics<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.rebalance<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.sendSupervisorWorkerHeartbeat<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.sendSupervisorWorkerHeartbeats<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.setBlobMeta<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.setLogConfig<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.setWorkerProfiler<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.submitTopology<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.submitTopologyWithOpts<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.updateBlobReplication<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.uploadBlobChunk<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.uploadChunk<I extends Nimbus.AsyncIface>
Nimbus.AsyncProcessor.uploadNewCredentials<I extends Nimbus.AsyncIface>
Nimbus.beginBlobDownload_args
Nimbus.beginBlobDownload_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginBlobDownload_result
Nimbus.beginBlobDownload_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginCreateBlob_args
Nimbus.beginCreateBlob_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginCreateBlob_result
Nimbus.beginCreateBlob_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginFileUpload_args
Nimbus.beginFileUpload_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginFileUpload_result
Nimbus.beginFileUpload_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginUpdateBlob_args
Nimbus.beginUpdateBlob_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.beginUpdateBlob_result
Nimbus.beginUpdateBlob_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.cancelBlobUpload_args
Nimbus.cancelBlobUpload_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.cancelBlobUpload_result
Nimbus.cancelBlobUpload_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.Client
Nimbus.Client.Factory
Nimbus.createStateInZookeeper_args
Nimbus.createStateInZookeeper_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.createStateInZookeeper_result
Nimbus.createStateInZookeeper_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.deactivate_args
Nimbus.deactivate_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.deactivate_result
Nimbus.deactivate_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.debug_args
Nimbus.debug_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.debug_result
Nimbus.debug_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.deleteBlob_args
Nimbus.deleteBlob_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.deleteBlob_result
Nimbus.deleteBlob_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.downloadBlobChunk_args
Nimbus.downloadBlobChunk_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.downloadBlobChunk_result
Nimbus.downloadBlobChunk_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.downloadChunk_args
Nimbus.downloadChunk_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.downloadChunk_result
Nimbus.downloadChunk_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.finishBlobUpload_args
Nimbus.finishBlobUpload_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.finishBlobUpload_result
Nimbus.finishBlobUpload_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.finishFileUpload_args
Nimbus.finishFileUpload_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.finishFileUpload_result
Nimbus.finishFileUpload_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getBlobMeta_args
Nimbus.getBlobMeta_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getBlobMeta_result
Nimbus.getBlobMeta_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getBlobReplication_args
Nimbus.getBlobReplication_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getBlobReplication_result
Nimbus.getBlobReplication_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getClusterInfo_args
Nimbus.getClusterInfo_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getClusterInfo_result
Nimbus.getClusterInfo_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getComponentPageInfo_args
Nimbus.getComponentPageInfo_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getComponentPageInfo_result
Nimbus.getComponentPageInfo_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getComponentPendingProfileActions_args
Nimbus.getComponentPendingProfileActions_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getComponentPendingProfileActions_result
Nimbus.getComponentPendingProfileActions_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getLeader_args
Nimbus.getLeader_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getLeader_result
Nimbus.getLeader_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getLogConfig_args
Nimbus.getLogConfig_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getLogConfig_result
Nimbus.getLogConfig_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getNimbusConf_args
Nimbus.getNimbusConf_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getNimbusConf_result
Nimbus.getNimbusConf_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getOwnerResourceSummaries_args
Nimbus.getOwnerResourceSummaries_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getOwnerResourceSummaries_result
Nimbus.getOwnerResourceSummaries_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getSupervisorAssignments_args
Nimbus.getSupervisorAssignments_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getSupervisorAssignments_result
Nimbus.getSupervisorAssignments_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getSupervisorPageInfo_args
Nimbus.getSupervisorPageInfo_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getSupervisorPageInfo_result
Nimbus.getSupervisorPageInfo_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopology_args
Nimbus.getTopology_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopology_result
Nimbus.getTopology_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyConf_args
Nimbus.getTopologyConf_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyConf_result
Nimbus.getTopologyConf_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyHistory_args
Nimbus.getTopologyHistory_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyHistory_result
Nimbus.getTopologyHistory_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfo_args
Nimbus.getTopologyInfo_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfo_result
Nimbus.getTopologyInfo_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoByName_args
Nimbus.getTopologyInfoByName_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoByName_result
Nimbus.getTopologyInfoByName_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoByNameWithOpts_args
Nimbus.getTopologyInfoByNameWithOpts_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoByNameWithOpts_result
Nimbus.getTopologyInfoByNameWithOpts_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoWithOpts_args
Nimbus.getTopologyInfoWithOpts_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyInfoWithOpts_result
Nimbus.getTopologyInfoWithOpts_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyPageInfo_args
Nimbus.getTopologyPageInfo_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologyPageInfo_result
Nimbus.getTopologyPageInfo_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummaries_args
Nimbus.getTopologySummaries_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummaries_result
Nimbus.getTopologySummaries_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummary_args
Nimbus.getTopologySummary_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummary_result
Nimbus.getTopologySummary_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummaryByName_args
Nimbus.getTopologySummaryByName_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getTopologySummaryByName_result
Nimbus.getTopologySummaryByName_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getUserTopology_args
Nimbus.getUserTopology_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.getUserTopology_result
Nimbus.getUserTopology_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.Iface
Nimbus.isRemoteBlobExists_args
Nimbus.isRemoteBlobExists_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.isRemoteBlobExists_result
Nimbus.isRemoteBlobExists_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.isTopologyNameAllowed_args
Nimbus.isTopologyNameAllowed_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.isTopologyNameAllowed_result
Nimbus.isTopologyNameAllowed_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.killTopology_args
Nimbus.killTopology_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.killTopology_result
Nimbus.killTopology_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.killTopologyWithOpts_args
Nimbus.killTopologyWithOpts_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.killTopologyWithOpts_result
Nimbus.killTopologyWithOpts_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.listBlobs_args
Nimbus.listBlobs_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.listBlobs_result
Nimbus.listBlobs_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.Processor<I extends Nimbus.Iface>
Nimbus.Processor.activate<I extends Nimbus.Iface>
Nimbus.Processor.beginBlobDownload<I extends Nimbus.Iface>
Nimbus.Processor.beginCreateBlob<I extends Nimbus.Iface>
Nimbus.Processor.beginFileUpload<I extends Nimbus.Iface>
Nimbus.Processor.beginUpdateBlob<I extends Nimbus.Iface>
Nimbus.Processor.cancelBlobUpload<I extends Nimbus.Iface>
Nimbus.Processor.createStateInZookeeper<I extends Nimbus.Iface>
Nimbus.Processor.deactivate<I extends Nimbus.Iface>
Nimbus.Processor.debug<I extends Nimbus.Iface>
Nimbus.Processor.deleteBlob<I extends Nimbus.Iface>
Nimbus.Processor.downloadBlobChunk<I extends Nimbus.Iface>
Nimbus.Processor.downloadChunk<I extends Nimbus.Iface>
Nimbus.Processor.finishBlobUpload<I extends Nimbus.Iface>
Nimbus.Processor.finishFileUpload<I extends Nimbus.Iface>
Nimbus.Processor.getBlobMeta<I extends Nimbus.Iface>
Nimbus.Processor.getBlobReplication<I extends Nimbus.Iface>
Nimbus.Processor.getClusterInfo<I extends Nimbus.Iface>
Nimbus.Processor.getComponentPageInfo<I extends Nimbus.Iface>
Nimbus.Processor.getComponentPendingProfileActions<I extends Nimbus.Iface>
Nimbus.Processor.getLeader<I extends Nimbus.Iface>
Nimbus.Processor.getLogConfig<I extends Nimbus.Iface>
Nimbus.Processor.getNimbusConf<I extends Nimbus.Iface>
Nimbus.Processor.getOwnerResourceSummaries<I extends Nimbus.Iface>
Nimbus.Processor.getSupervisorAssignments<I extends Nimbus.Iface>
Nimbus.Processor.getSupervisorPageInfo<I extends Nimbus.Iface>
Nimbus.Processor.getTopology<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyConf<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyHistory<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyInfo<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyInfoByName<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyInfoByNameWithOpts<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyInfoWithOpts<I extends Nimbus.Iface>
Nimbus.Processor.getTopologyPageInfo<I extends Nimbus.Iface>
Nimbus.Processor.getTopologySummaries<I extends Nimbus.Iface>
Nimbus.Processor.getTopologySummary<I extends Nimbus.Iface>
Nimbus.Processor.getTopologySummaryByName<I extends Nimbus.Iface>
Nimbus.Processor.getUserTopology<I extends Nimbus.Iface>
Nimbus.Processor.isRemoteBlobExists<I extends Nimbus.Iface>
Nimbus.Processor.isTopologyNameAllowed<I extends Nimbus.Iface>
Nimbus.Processor.killTopology<I extends Nimbus.Iface>
Nimbus.Processor.killTopologyWithOpts<I extends Nimbus.Iface>
Nimbus.Processor.listBlobs<I extends Nimbus.Iface>
Nimbus.Processor.processWorkerMetrics<I extends Nimbus.Iface>
Nimbus.Processor.rebalance<I extends Nimbus.Iface>
Nimbus.Processor.sendSupervisorWorkerHeartbeat<I extends Nimbus.Iface>
Nimbus.Processor.sendSupervisorWorkerHeartbeats<I extends Nimbus.Iface>
Nimbus.Processor.setBlobMeta<I extends Nimbus.Iface>
Nimbus.Processor.setLogConfig<I extends Nimbus.Iface>
Nimbus.Processor.setWorkerProfiler<I extends Nimbus.Iface>
Nimbus.Processor.submitTopology<I extends Nimbus.Iface>
Nimbus.Processor.submitTopologyWithOpts<I extends Nimbus.Iface>
Nimbus.Processor.updateBlobReplication<I extends Nimbus.Iface>
Nimbus.Processor.uploadBlobChunk<I extends Nimbus.Iface>
Nimbus.Processor.uploadChunk<I extends Nimbus.Iface>
Nimbus.Processor.uploadNewCredentials<I extends Nimbus.Iface>
Nimbus.processWorkerMetrics_args
Nimbus.processWorkerMetrics_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.processWorkerMetrics_result
Nimbus.processWorkerMetrics_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.rebalance_args
Nimbus.rebalance_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.rebalance_result
Nimbus.rebalance_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.sendSupervisorWorkerHeartbeat_args
Nimbus.sendSupervisorWorkerHeartbeat_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.sendSupervisorWorkerHeartbeat_result
Nimbus.sendSupervisorWorkerHeartbeat_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.sendSupervisorWorkerHeartbeats_args
Nimbus.sendSupervisorWorkerHeartbeats_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.sendSupervisorWorkerHeartbeats_result
Nimbus.sendSupervisorWorkerHeartbeats_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setBlobMeta_args
Nimbus.setBlobMeta_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setBlobMeta_result
Nimbus.setBlobMeta_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setLogConfig_args
Nimbus.setLogConfig_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setLogConfig_result
Nimbus.setLogConfig_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setWorkerProfiler_args
Nimbus.setWorkerProfiler_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.setWorkerProfiler_result
Nimbus.setWorkerProfiler_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.StandaloneINimbus
Nimbus.submitTopology_args
Nimbus.submitTopology_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.submitTopology_result
Nimbus.submitTopology_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.submitTopologyWithOpts_args
Nimbus.submitTopologyWithOpts_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.submitTopologyWithOpts_result
Nimbus.submitTopologyWithOpts_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.updateBlobReplication_args
Nimbus.updateBlobReplication_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.updateBlobReplication_result
Nimbus.updateBlobReplication_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadBlobChunk_args
Nimbus.uploadBlobChunk_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadBlobChunk_result
Nimbus.uploadBlobChunk_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadChunk_args
Nimbus.uploadChunk_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadChunk_result
Nimbus.uploadChunk_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadNewCredentials_args
Nimbus.uploadNewCredentials_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Nimbus.uploadNewCredentials_result
Nimbus.uploadNewCredentials_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
NimbusBlobStore
NimbusBlobStore is a USER facing client API to perform basic operations such as create, update, delete and read for local and hdfs blob store.
NimbusClient
Client used for connecting to nimbus.
NimbusClient.Builder
NimbusClient.LocalOverride
NimbusClient.WithNimbus
An interface to allow callbacks with a thrift nimbus client.
NimbusHeartbeatsPressureTest
Test for nimbus heartbeats max throughput, This is a client to collect the statistics.
NimbusInfo
NimbusLeaderNotFoundException
This exception class is used to signify a problem with nimbus leader identification.
NimbusMetricProcessor
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.
NimbusPrincipal
NimbusSummary
NimbusSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Node
Represents a single node in the cluster.
Node
NodeInfo
NodeInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
NodePool
A pool of nodes that can be used to run topologies.
NodePool.NodeAndSlotCounts
NodePool.RoundRobinSlotScheduler
Place executors into slots in a round robin way, taking into account component spreading among different hosts.
NodeSorter
NodeSorter.ExistingScheduleFunc
interface for calculating the number of existing executors scheduled on a object (rack or node).
NodeSorterHostProximity
NodeSorterHostProximity.ExistingScheduleFunc
interface for calculating the number of existing executors scheduled on a object (rack or node).
NodeStateInfo
NonRichBoltTracker
NonTransactionalMap<T>
NoopAuthorizer
A no-op authorization implementation that illustrate info available for authorization decisions.
NoOpMetricStore
NoOpTTrasport
NoOutputException
A NoOutputException states that no data has been received from the connected non-JVM process.
NormalDistStats
Stats related to something with a normal distribution, and a way to randomly simulate it.
NormalizedResourceOffer
An offer of resources with normalized resource names.
NormalizedResourceRequest
A resource request with normalized resource names.
NormalizedResources
Resources that have been normalized.
NormalizedResourcesWithMemory
Intended for `NormalizedResources` wrappers that handle memory.
NoRotationPolicy
File rotation policy that will never rotate...
NoRotationPolicy
File rotation policy that will never rotate...
NotAliveException
NotAliveException._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
NotAliveExceptionMapper
NotConf
Annotation that can be used to explicitly call out public static final String fields that are not configs.
NthLastModifiedTimeTracker
This class tracks the time-since-last-modify of a "thing" in a rolling fashion.
NullPartitioner
The NullPartitioner partitions every tuple to the empty string.
NullStruct
NullStruct._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
NumErrorsChoice
ObjectDef
A representation of a Java object that given a className, constructor arguments, and properties, can be instantiated.
ObjectReader
ObjectResourcesItem
class to keep track of resources on a rack or node.
ObjectResourcesSummary
a class to contain individual object resources as well as cumulative stats.
OciContainerExecutorConfig
OciContainerExecutorConfig.OciLayer
OciContainerExecutorConfig.OciRuntimeConfig
OciContainerManager
OciContainerManager.CmdType
OciImageTagToManifestPluginInterface
OciManifestToResourcesPluginInterface
OciResource
OciResourcesLocalizerInterface
OciUtils
OffsetManager
Manages acked and committed offsets for a TopicPartition.
OnlyLatestExecutor<K>
This allows you to submit a Runnable with a key.
OnlyValueRecordTranslator<K,V>
OpaqueMap<T>
OpaquePartitionedTridentSpoutExecutor
OpaqueValue<T>
Operation
The parent interface for any kind of streaming operation.
Operation
Parent interface for Trident `Filter`s and `Function`s.
OperationAwareFlatMapFunction
A one to many transformation function which is aware of Operation (lifecycle of the Trident component).
OperationAwareMapFunction
A one-one transformation function which is aware of Operation (lifecycle of the Trident component).
Options<T>
Options of State.
It's a data structure (whole things are public) and you can access and modify all fields.
OutputCollector
This output collector exposes the API for emitting tuples from an IRichBolt.
OutputFieldsDeclarer
OutputFieldsExtractor
OutputFieldsGetter
OutputStream
A set of measurements about a stream so we can statistically reproduce it.
OutputStream.Builder
OutputStreamEngine
Provides an API to simulate the output of a stream.
OutstandingRequest
OwnerResourceSummary
OwnerResourceSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Pacemaker
PacemakerClient
PacemakerClientHandler
PacemakerClientPool
PacemakerConnectionException
PaceMakerStateStorage
PaceMakerStateStorageFactory
Pair<T1,T2>
A pair of values.
PairFlatMapFunction<T,K,V>
A function that accepts one argument and returns an `Iterable` of `Pair` as its result.
PairFunction<T,K,V>
A function that accepts an argument and produces a key-value Pair.
PairStream<K,V>
Represents a stream of key-value pairs.
PairValueJoiner<V1,V2>
A `ValueJoiner` that joins two values to produce a `Pair` of the two values as the result.
PairValueMapper<K,V>
Extracts a typed key-value pair from a tuple.
ParallelStreamableTable
Table that can be converted to a stream.
ParallelTable
ParseException
ParseException
This exception is thrown when parse errors are encountered.
PartialKeyGrouping
A variation on FieldGrouping.
PartialKeyGrouping.AssignmentCreator
This interface is responsible for choosing a subset of the target tasks to use for a given key.
PartialKeyGrouping.BalancedTargetSelector
A basic implementation of target selection.
PartialKeyGrouping.RandomTwoTaskAssignmentCreator
This implementation of AssignmentCreator chooses two arbitrary tasks.
PartialKeyGrouping.TargetSelector
This interface chooses one element from a task assignment to send a specific Tuple to.
PartitionedTridentSpoutExecutor
Partitioner
PartitionNode
PartitionPersistProcessor
PasswordProvider
A very basic API that will provide a password for a given user name.
PathUtil
Utility functions to make Path manipulation slightly less verbose.
PatternTopicFilter
Filter that returns all partitions for topics matching the given `Pattern`.
PeekProcessor<T>
PerReporterGauge<T>
PersistentWindowedBoltExecutor<T extends State>
Wraps a `IStatefulWindowedBolt` and handles the execution.
PersistentWindowingTopology
An example that demonstrates the usage of `IStatefulWindowedBolt` with window persistence.
PersistentWordCount
PlainClientCallbackHandler
Deprecated.
PlainSaslTransportPlugin
Deprecated.
PortAndAssignment
Predicate<T>
Represents a predicate (boolean-valued function) of a value.
PreparableCallback
Serializable callback for use with the KafkaProducer on KafkaBolt.
PreparableReporter
PrepareBatchBolt
PrepareRequest
PreservingFieldsOrderJoinerMultiReducer
PrintConsumer<T>
A consumer that prints the input to stdout.
PrinterBolt
PrintFunction
PrivateWorkerKey
PrivateWorkerKey._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Processor<T>
A processor processes a stream of elements and produces some result.
ProcessorContext<T>
Context information passed to the `Processor`.
ProcessorContext
ProcessorNode
Node that wraps a processor in the stream.
ProcessorNode
ProcessSimulator
In local mode, `ProcessSimulator` keeps track of Shutdownable objects in place of actual processes (in cluster mode).
ProfileAction
ProfileRequest
ProfileRequest._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ProgressTracker
ProjectedProcessor
PrometheusPreparableReporter
PrometheusReporterClient
This reporter pushes common cluster metrics towards a Prometheus Pushgateway.
PropertyDef
PythonShellMetricsBolt
PythonShellMetricsSpout
QueryFunction<S extends State,T>
QueryPlanner
RandomIntegerSpout
Emits a random integer and a timestamp value (offset by one day), every 100 ms.
RandomNumberGeneratorSpout
This spout generates random whole numbers with given `maxNumber` value as maximum with the given `fields`.
RandomSentenceSpout
RandomSentenceSpout.TimeStamped
Rankable
RankableObjectWithFields
This class wraps an objects and its associated count, including any additional data fields.
Rankings
RasBlacklistStrategy
Blacklisting strategy just like the default one, but specifically setup for use with the resource aware scheduler.
RasNode
Represents a single node in the cluster.
RasNodes
RateCounter
A Counter metric that also implements a Gauge to report the average rate of events per second over 1 minute.
RateTracker
This class is a utility to track the rate of something.
RawMultiScheme
RawScheme
ReachTopology
This is a good example of doing complex Distributed RPC on top of Storm.
ReachTopology.CountAggregator
ReachTopology.GetFollowers
ReachTopology.GetTweeters
ReachTopology.PartialUniquer
ReadableBlobMeta
ReadableBlobMeta._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ReadClusterState
ReadOnlyMapState<T>
ReadOnlySnapshottable<T>
ReadOnlyState
ReadOnlyStringMetadataCache
The read-only interface to a StringMetadataCache allowed to be used by any thread.
Rebalance
RebalanceOptions
RebalanceOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
RecordFormat
Formats a Tuple object into a byte array that will be written to HDFS.
RecordFormat
Formats a Tuple object into a byte array that will be written to HDFS.
RecordTranslator<K,V>
Translate a `ConsumerRecord` to a tuple.
RecordTranslatorSchemeAdapter
RecordTranslator that delegates to a Scheme.
RedisClusterContainer
Container for managing JedisCluster.
RedisClusterMapState<T>
IBackingMap implementation for Redis Cluster environment.
RedisClusterMapState.Factory
RedisClusterMapState.Factory provides Redis Cluster environment version of StateFactory.
RedisClusterState
Implementation of State for Redis Cluster environment.
RedisClusterState.Factory
RedisClusterState.Factory implements StateFactory for Redis Cluster environment.
RedisClusterStateQuerier
BaseQueryFunction implementation for Redis Cluster environment.
RedisClusterStateUpdater
BaseStateUpdater implementation for Redis Cluster environment.
RedisCommands
This interface represents Jedis methods exhaustively which are used on storm-redis.
RedisCommandsAdapterJedis
Adapter class to make Jedis instance play with BinaryRedisCommands interface.
RedisCommandsAdapterJedisCluster
Adapter class to make JedisCluster instance play with BinaryRedisCommands interface.
RedisCommandsContainerBuilder
The binary version of container builder which helps abstraction of two env.
RedisCommandsInstanceContainer
Interfaces for containers which stores instances implementing RedisCommands.
RedisContainer
RedisDataSourcesProvider
Create a Redis sink based on the URI and properties.
RedisDataTypeDescription
RedisDataTypeDescription defines data type and additional key if needed for lookup / store tuples.
RedisDataTypeDescription.RedisDataType
RedisFilterBolt
Basic bolt for querying from Redis and filters out if key/field doesn't exist.
RedisFilterMapper
RedisFilterMapper is for defining spec.
RedisKeyValueState<K,V>
A redis based implementation that persists the state in Redis.
RedisKeyValueStateIterator<K,V>
An iterator over `RedisKeyValueState`.
RedisKeyValueStateProvider
Provides `RedisKeyValueState`.
RedisKeyValueStateProvider.StateConfig
RedisLookupBolt
Basic bolt for querying from Redis and emits response as tuple.
RedisLookupMapper
RedisLookupMapper is for defining spec.
RedisMapper
RedisMapper is for defining data type for querying / storing from / to Redis.
RedisMapState<T>
IBackingMap implementation for single Redis environment.
RedisMapState.Factory
RedisMapState.Factory provides single Redis environment version of StateFactory.
RedisState
Implementation of State for single Redis environment.
RedisState.Factory
RedisState.Factory implements StateFactory for single Redis environment.
RedisStateQuerier
BaseQueryFunction implementation for single Redis environment.
RedisStateUpdater
BaseStateUpdater implementation for single Redis environment.
RedisStoreBolt
Basic bolt for writing to Redis.
RedisStoreMapper
RedisStoreMapper is for defining spec.
ReduceByKeyProcessor<K,V>
ReducedMetric
ReducedShellMetric
ReduceProcessor<T>
Reducer<T>
The `Reducer` performs an operation on two values of the same type producing a result of the same type.
ReducerAggregator<T>
ReducerAggregatorImpl
ReducerAggStateUpdater
ReducerValueUpdater
RefCountedTuple
Provides reference counting of tuples.
ReflectionUtils
RegexFilter
RegisteredGlobalState
This class is used as part of testing Storm.
ReloadableSslContextFactory
ReloadableTsslTransportFactory
ReloadableX509KeyManager
ReloadableX509TrustManager
RemovableMapState<T>
ReportedFailedException
ReportError
ReportErrorAndDie
ReportWorkerHeartbeats
Runnable reporting local worker reported heartbeats to master, supervisor should take care the of the heartbeats integrity for the master heartbeats recovery, a non-null node id means that the heartbeats are full, and master can go on to check and wait others nodes when doing a heartbeats recovery.
RepositorySystemFactory
Get maven repository instance.
ReqContext
Request context.
ReqContextFilter
RequestFactory<T extends OutstandingRequest>
ResourceAuthorizer
ResourceAuthorizer.LogUserGroupWhitelist
ResourceAwareExampleTopology
ResourceAwareExampleTopology.ExclamationBolt
ResourceAwareScheduler
ResourceDeclarer<T extends ResourceDeclarer>
This is a new base interface that can be used by anything that wants to mirror RAS's basic API.
ResourceIsolationInterface
A plugin to support resource isolation and limitation within Storm.
ResourceMapArrayBridge
Provides translation between normalized resource maps and resource value arrays.
ResourceMetrics
ResourceNameNormalizer
Provides resource name normalization for resource maps.
ResourceUtils
Result
ReturnResults
ReturnResultsReducer
ReturnResultsReducer.ReturnResultsState
RexNodeToJavaCodeCompiler
Compiles a scalar expression (`RexNode`) to Java source code String.
RichShellBolt
RichShellSpout
RichSpoutBatchExecutor
RichSpoutBatchId
RichSpoutBatchIdSerializer
RichSpoutBatchTriggerer
RocksDbKey
Class representing the data used as a Key in RocksDB.
RocksDbMetricsWriter
Class designed to perform all metrics inserts into RocksDB.
RocksDbStore
RollingAverageGauge
RollingCountAggBolt
This bolt aggregates counts from multiple upstream bolts.
RollingCountBolt
This bolt performs rolling counts of incoming objects, i.e.
RollingTopWords
This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.
RotatingMap<K,V>
Expires keys that have not been updated in the configured number of seconds.
RotatingMap.ExpiredCallback<K,V>
RotatingTransactionalState
RotatingTransactionalState.StateInitializer
RotationAction
RoundRobinManualPartitioner
Assign partitions in a round robin fashion for all spouts, not just the ones that are alive.
RoundRobinResourceAwareStrategy
RuncLibContainerManager
SaslMessageToken
Send and receive SASL tokens.
SaslNettyClient
Implements SASL logic for storm worker client processes.
SaslPlainServer
Deprecated.
SaslPlainServer.SaslPlainServerFactory
SaslPlainServer.SecurityProvider
SaslStormClientHandler
SaslStormServerAuthorizeHandler
Authorize or deny client requests based on existence and completeness of client's SASL authentication.
SaslStormServerHandler
SaslTransportPlugin
Base class for SASL authentication plugin.
SaslTransportPlugin.User
ScheduledStormReporter
SchedulerAssignment
SchedulerAssignmentImpl
SchedulerConfigCache<T>
A utility class to cache the scheduler config and refresh after the cache expires.
SchedulerConfigCache.Reloadable<T>
SchedulingResult
This class serves as a mechanism to return results and messages from a scheduling strategy to the Resource Aware Scheduler.
SchedulingSearcherState
SchedulingStatus
Scheme
SchemeAsMultiScheme
ScopedTopologySet
A set of topology names that will be killed when this is closed, or when the program exits.
SecurityUtils
SequenceFileBolt
SequenceFileReader<KeyT extends org.apache.hadoop.io.Writable,ValueT extends org.apache.hadoop.io.Writable>
SequenceFileReader.Offset
SequenceFileTopology
SequenceFileTopology.MyBolt
SequenceFileTopology.SentenceSpout
SequenceFileWriter
SequenceFormat
Interface for converting `Tuple` objects to HDFS sequence file key-value pairs.
SequenceFormat
Interface for converting `TridentTuple` objects to HDFS sequence file key-value pairs.
SerdeUtils
SerializableBiConsumer<T,U>
SerializableCallable<R>
SerializableConsumer<T>
SerializableSerializer
SerializableSupplier<T>
SerializationDelegate
Allow `Utils` to delegate meta serialization.
SerializationFactory
SerializationFactory.IdDictionary
SerializationRegister
Provides a way using a service loader to register Kryo serializers with the SerializationFactory without needing to modify the config.
Serializer<T>
Interface to be implemented for serlializing and de-serializing the state.
Serializer<T>
ServerAuthUtils
ServerCallbackHandler
SASL server side callback handler for kerberos auth.
ServerConfigUtils
ServerConstants
ServerUtils
ServiceRegistry
SetLogLevel
SettableBlobMeta
SettableBlobMeta._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SharedMemory
SharedMemory._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SharedOffHeapWithinNode
A request for a shared memory region off heap between workers on a node.
SharedOffHeapWithinWorker
A request for a shared memory region off heap, but only within a worker.
SharedOnHeap
A request for a shared memory region on heap.
ShellBasedGroupsMapping
ShellBolt
A bolt that shells out to another process to process tuples.
ShellBoltMessageQueue
A data structure for ShellBolt which includes two queues (FIFO), which one is for task ids (unbounded), another one is for bolt msg (bounded).
ShellCommandRunner
Contains convenience functions for running shell commands for cases that are too simple to need a full `ShellUtils` implementation.
ShellCommandRunnerImpl
ShellComponent
ShellComponent._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ShellLogHandler
Handle logging from non-JVM processes.
ShellMsg
ShellMsg is an object that represents the data sent to a shell component from a process that implements a multi-language protocol.
ShellMsg.ShellLogLevel
ShellProcess
ShellSpout
ShellSubmission
ShellUtils
ShellUtils.ExitCodeException
This is an IOException with exit code added.
ShellUtils.OSType
OSType detection.
ShellUtils.ShellCommandExecutor
A simple shell command executor.
ShuffleGrouping
Shutdownable
SimpleACLAuthorizer
An authorization implementation that simply checks if a user is allowed to perform specific operations.
SimpleCharStream
An implementation of interface CharStream, where the stream is assumed to contain only ASCII characters (without unicode processing).
SimpleFileNameFormat
SimpleFileNameFormat
SimpleGauge<T>
SimpleJdbcLookupMapper
SimpleJdbcMapper
SimpleRecordTranslator<K,V>
SimpleSaslClientCallbackHandler
A client callback handler that supports a single username and password.
SimpleSaslServerCallbackHandler
SimpleTransportPlugin
Simple transport for Thrift plugin.
SimpleVersion
Take a version string and parse out a Major.Minor version
SimpleWhitelistAuthorizer
An authorization implementation that simply checks a whitelist of users that are allowed to use the cluster.
SimpleWindowPartitionCache<K,V>
A simple implementation that evicts the largest un-pinned entry from the cache.
SimpleWindowPartitionCache.SimpleWindowPartitionCacheBuilder<K,V>
SimplifiedWordCountTopo
SingleEmitAggregator
SingleEmitAggregator.BatchToPartition
SingleJoinBolt
Example of a simple custom bolt for joining two streams.
SingleJoinExample
Example of using a simple custom join bolt.
SingleTopologyCluster
A Cluster that only allows modification to a single topology.
SingleUserPrincipal
A Principal that represents a user.
SingleUserSimpleTransport
SkewedRollingTopWords
This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.
SlidingCountWindow
Represents configuration of sliding window based on count of events.
SlidingCountWindowStrategy<T>
This class represents sliding window strategy based on the sliding window count and sliding interval count from the given `slidingCountWindow` configuration.
SlidingDurationWindow
Represents configuration of sliding window based on duration.
SlidingDurationWindowStrategy<T>
This class represents sliding window strategy based on the sliding window duration and sliding interval from the given `slidingCountWindow` configuration.
SlidingTimeCorrectness
Computes sliding window sum.
SlidingTupleTsTopology
Windowing based on tuple timestamp (e.g.
SlidingWindowCorrectness
Computes sliding window sum.
SlidingWindowCounter<T>
This class counts objects in a sliding window fashion.
SlidingWindows<L,I>
A sliding window specification based on a window length and sliding interval.
SlidingWindowSumBolt
Computes sliding window sum.
SlidingWindowTopology
A sample topology that demonstrates the usage of `IWindowedBolt` to calculate sliding window sum.
Slot
SlotBasedCounter<T>
This class provides per-slot counts of the occurrences of objects.
SlowExecutorPattern
A repeating pattern of skewedness in processing times.
SnapshotGet
Snapshottable<T>
SnapshottableMap<T>
SocketBolt
The Bolt implementation for Socket.
SocketDataSourcesProvider
Create a Socket data source based on the URI and properties.
SocketSpout
Spout for Socket data.
SpecificAggregateStats
SpecificAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Split
SplitSentenceBolt
SpoutAckInfo
SpoutAggregateStats
SpoutAggregateStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SpoutDeclarer
SpoutDef
Bean representation of a Storm spout.
SpoutExecutor
SpoutExecutorStats
SpoutFailInfo
SpoutMsg
SpoutMsg is an object that represents the data sent from a shell spout to a process that implements a multi-language spout.
SpoutNode
SpoutNode.SpoutType
SpoutOutputCollector
This output collector exposes the API for emitting tuples from an `IRichSpout`.
SpoutOutputCollectorImpl
Methods are not thread safe.
SpoutSpec
SpoutSpec._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SpoutStats
SpoutStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SpoutTracker
SpringJmsProvider
A `JmsProvider` that uses the spring framework to obtain a JMS `ConnectionFactory` and `Desitnation` objects.
SqlCreateFunction
SqlCreateTable
SqlDdlKeywords
Define the keywords that can occur in a CREATE TABLE statement.
StandaloneSupervisor
State
The state of the component that is either managed by the framework (e.g in case of `IStatefulBolt`) or managed by the the individual components themselves.
State
There's 3 different kinds of state:
StateEncoder<K,V,KENCODEDT,VENCODEDT>
The interface of State Encoder.
StateFactory
A factory for creating `State` instances.
StateFactory
StatefulBoltExecutor<T extends State>
Wraps a `IStatefulBolt` and manages the state of the bolt.
StatefulProcessor<K,V>
Top level interface for processors that does stateful processing.
StatefulTopology
An example topology that demonstrates the use of `IStatefulBolt` to manage state.
StatefulTopology.PrinterBolt
StatefulWindowedBoltExecutor<T extends State>
Wraps a `IStatefulWindowedBolt` and handles the execution.
StatefulWindowingTopology
A simple example that demonstrates the usage of `IStatefulWindowedBolt` to save the state of the windowing operation to avoid re-computation in case of failures.
StatefulWindowManager<T>
Window manager that handles windows with state persistence.
StatefulWordCount
A stateful word count that uses `PairStream.updateStateByKey(StateUpdater)` to save the counts in a key value state.
StatefulWordCounter
StateMetric
StateProvider
Used by the `StateFactory` to create a new state instances.
StateQueryExample
An example that uses `Stream.stateQuery(StreamState)` to query the state
StateQueryProcessor<K,V>
StateQueryProcessor
StateSpec
StateSpoutOutputCollector
StateSpoutSpec
StateSpoutSpec._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
StateStorageFactory
StateType
StateUpdater<T,S>
Interface for updating state.
StateUpdater<S extends State>
StatsUtil
StoreBasedTridentWindowManager
This window manager uses `WindowsStore` for storing tuples and other trigger related information.
StormApiResource
Root resource (exposed at "storm" path).
StormBase
StormBase._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
StormBoundedExponentialBackoffRetry
StormCalcRelBase
StormClientHandler
StormClusterStateImpl
StormCommon
StormCommonInstaller
StormContext
This is a hack to use Calcite Context.
StormDataContext
This is based on SlimDataContext in Calcite, and borrow some from DataContextImpl in Calcite.
StormFilterRelBase
StormJoinRelBase
StormMetricRegistry
StormMetricsFilter
StormMetricsRegistry
StormParser
StormParserImpl
SQL parser, generated from Parser.jj by JavaCC.
StormParserImplConstants
Token literal values and constants.
StormParserImplTokenManager
Token Manager.
StormProjectRelBase
StormRelDataTypeSystem
StormRelNode
StormRelUtils
StormReporter
StormServerHandler
StormSql
The StormSql class provides standalone, interactive interfaces to execute SQL statements over streaming data.
StormSqlContext
StormSqlRunner
StormSqlTypeFactoryImpl
StormStreamableTable
StormStreamInsertRelBase
StormStreamScanRelBase
StormSubmitter
Use this class to submit topologies to run on the Storm cluster.
StormSubmitter.ProgressListener
Interface use to track progress of file upload.
StormTable
StormTimer
The timer defined in this file is very similar to java.util.Timer, except it integrates with Storm's time simulation capabilities.
StormTimer.QueueEntry
StormTimer.StormTimerTask
StormTopology
StormTopology._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Stream<T>
Represents a stream of values.
Stream
A Stream represents the core data model in Trident, and can be thought of as a "stream" of tuples that are processed as a series of small batches.
StreamBuilder
A builder for constructing a `StormTopology` via storm streams api (DSL).
StreamDef
Represents a stream of tuples from one Storm component (Spout or Bolt) to another (an edge in the topology DAG).
StreamInfo
StreamInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
StreamInsertMapToPairFunction
StreamsAggregateRule
StreamsCalcRel
StreamsCalcRule
StreamsFilterRel
StreamsFilterRule
StreamsJoinRule
StreamsLogicalConvention
StreamsModifyRule
StreamsPlanCreator
StreamsProjectRel
StreamsProjectRule
StreamsRel
StreamsScanRule
StreamsScanTupleValueMapper
StreamsStormRuleSets
StreamsStreamInsertRel
StreamsStreamScanRel
StreamState<K,V>
A wrapper for the stream state which can be used to query the state via `Stream.stateQuery(StreamState)`.
StreamUtil
Utility class for (Input/Output)Stream.
StreamUtil
StrGenSpoutHdfsBoltTopo
This topo helps measure speed of writing to Hdfs.
StrGenSpoutHdfsBoltTopo.LineWriter
StrictTopologyValidator
StringDecorator
This class provides a method to pass data from the test bolts and spouts to the test method, via the worker log.
StringGenSpout
Spout pre-computes a list with 30k fixed length random strings.
StringLength
StringMetadataCache
Class to create a use a cache that stores Metadata string information in memory.
SubmitOptions
SubmitOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SubmitterHookException
This Exception is thrown when registered `ISubmitterHook` could not be initialized or invoked.
SubSystem
a class that implements operations that can be performed on a cgroup subsystem.
SubSystemType
A enum class to described the subsystems that can be used.
SubtopologyBolt
A Bolt that does processing for a subsection of the complete graph.
SubtopologyBolt.InitialReceiver
Sum
Supervisor
Supervisor
Supervisor.AsyncClient
Supervisor.AsyncClient.Factory
Supervisor.AsyncClient.getLocalAssignmentForStorm_call
Supervisor.AsyncClient.sendSupervisorAssignments_call
Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call
Supervisor.AsyncIface
Supervisor.AsyncProcessor<I extends Supervisor.AsyncIface>
Supervisor.AsyncProcessor.getLocalAssignmentForStorm<I extends Supervisor.AsyncIface>
Supervisor.AsyncProcessor.sendSupervisorAssignments<I extends Supervisor.AsyncIface>
Supervisor.AsyncProcessor.sendSupervisorWorkerHeartbeat<I extends Supervisor.AsyncIface>
Supervisor.Client
Supervisor.Client.Factory
Supervisor.getLocalAssignmentForStorm_args
Supervisor.getLocalAssignmentForStorm_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Supervisor.getLocalAssignmentForStorm_result
Supervisor.getLocalAssignmentForStorm_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Supervisor.Iface
Supervisor.Processor<I extends Supervisor.Iface>
Supervisor.Processor.getLocalAssignmentForStorm<I extends Supervisor.Iface>
Supervisor.Processor.sendSupervisorAssignments<I extends Supervisor.Iface>
Supervisor.Processor.sendSupervisorWorkerHeartbeat<I extends Supervisor.Iface>
Supervisor.sendSupervisorAssignments_args
Supervisor.sendSupervisorAssignments_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Supervisor.sendSupervisorAssignments_result
Supervisor.sendSupervisorAssignments_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Supervisor.sendSupervisorWorkerHeartbeat_args
Supervisor.sendSupervisorWorkerHeartbeat_args._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
Supervisor.sendSupervisorWorkerHeartbeat_result
Supervisor.sendSupervisorWorkerHeartbeat_result._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorAssignments
SupervisorAssignments._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorClient
Client for interacting with Supervisor server, now we use supervisor server mainly for cases below.
SupervisorClient.Builder
SupervisorDetails
SupervisorHealthCheck
SupervisorHeartbeat
SupervisorIfaceFactory
SupervisorInfo
SupervisorInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorPageInfo
SupervisorPageInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorResources
SupervisorSimpleACLAuthorizer
An authorization implementation that simply checks if a user is allowed to perform specific operations.
SupervisorSummary
SupervisorSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorUtils
SupervisorWorkerHeartbeat
SupervisorWorkerHeartbeat._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SupervisorWorkerHeartbeats
SupervisorWorkerHeartbeats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
SynchronizeAssignments
A runnable which will synchronize assignments to node local and then worker processes.
SynchronizeOutputCollector
SyncPolicy
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.
SyncPolicy
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.
SystemBolt
SystemOperation
A class that implements system operations for using cgroups.
Task
TaskBundle
TaskMessage
TaskMetricDimensions
Class to store task-related V2 metrics dimensions.
TaskMetricRepo
Metric repository to allow reporting of task-specific metrics.
TaskMetrics
TBackoffConnect
TestableTopology
TestAggregatesCounter
TestConfBolt
TestEventLogSpout
TestEventOrderCheckBolt
TestGlobalCount
Testing
A utility that helps with testing topologies, Bolts and Spouts.
Testing.CapturedTopology<T>
A topology that has all messages captured and can be read later on.
Testing.Condition
Simply produces a boolean to see if a specific state is true or false.
TestingFilter
A simple UI filter that should only be used for testing purposes.
TestJob
This is the core interface for the storm java testing, usually we put our java unit testing logic in the run method.
TestKryoDecorator
TestPlannerBolt
TestPlannerSpout
TestPrintBolt
Prints the tuples to stdout.
TestSerObject
TestTransactionalState
Facilitates testing of non-public methods in the parent class.
TestWindowBolt
TestWordBytesCounter
TestWordCounter
TestWordSpout
TextFileReader
TextFileReader.Offset
Thrift
Thrift.BoltDetails
Thrift.SpoutDetails
ThriftAccessLogger
ThriftClient
ThriftConnectionType
The purpose for which the Thrift server is created.
ThriftDecoder
ThriftEncoder
ThriftNettyClientCodec
ThriftNettyClientCodec.AuthMethod
ThriftNettyServerCodec
ThriftNettyServerCodec.AuthMethod
ThriftSerializationDelegate
ThriftSerializedObject
ThriftSerializedObject._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
ThriftServer
ThriftTopologyUtils
ThroughputMeter
ThroughputVsLatency
WordCount but the spout goes at a predefined rate and we collect proper latency statistics.
ThroughputVsLatency.FastRandomSentenceSpout
ThroughputVsLatency.SplitSentence
ThroughputVsLatency.WordCount
Time
This class implements time simulation support.
Time.SimulatedTime
TimeCacheMap<K,V>
Deprecated.
TimeCacheMap.ExpiredCallback<K,V>
Timed<T>
TimeData
TimeDataIncrementingSpout
TimeDataVerificationBolt
TimeDataWindow
TimedResource<T extends AutoCloseable>
TimedRotationPolicy
TimedRotationPolicy
TimedRotationPolicy.TimeUnit
TimedRotationPolicy.TimeUnit
TimedWritableByteChannel
TimeEvictionPolicy<T>
Eviction policy that evicts events based on time duration.
TimeOutWorkerHeartbeatsRecoveryStrategy
Wait for a node to report worker heartbeats until a configured timeout.
TimePortAndAssignment
Timer
TimerDecorated
TimerDecoratedAssignment
TimestampExtractor
Interface to be implemented for extracting timestamp from a tuple.
TimeTriggerPolicy<T>
Invokes `TriggerHandler.onTrigger()` after the duration.
TimeUtil
TlsTransportPlugin
TmpPath
Token
Describes the input token stream.
TokenMgrError
Token Manager Error.
TopicAssigner
Handles assigning partitions to the consumer and updating the rebalance listener.
TopicFilter
TopicPartitionComparator
Singleton comparator of TopicPartitions.
TopicPartitionSerializer
TopoCache
Cache topologies and topology confs from the blob store.
Topologies
TopologyActionOptions
TopologyActionOptions._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TopologyActions
Actions that can be done to a topology in nimbus.
TopologyBuilder
TopologyBuilder exposes the Java API for specifying a topology for Storm to execute.
TopologyContext
A `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.
TopologyDef
Bean represenation of a topology.
TopologyDetails
TopologyHistoryInfo
TopologyHistoryInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TopologyInfo
TopologyInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TopologyInitialStatus
TopologyLoadConf
Configuration for a simulated topology.
TopologyPageInfo
TopologyPageInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TopologyResources
TopologySource
Marker interface for objects that can produce `StormTopology` objects.
TopologySourceDef
TopologySpoutLag
TopologyStats
TopologyStats._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TopologyStatus
TopologySummary
TopologySummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
TotalRankingsBolt
This bolt merges incoming `Rankings`.
TrackedTopology
A tracked topology keeps metrics for every bolt and spout.
TransactionalMap<T>
TransactionalState
Class that contains the logic to extract the transactional state info from zookeeper.
TransactionalValue<T>
TransactionAttempt
Deprecated.
TransactionAttempt
TransferDrainer
TransportFactory
TridentBatchTuple
TridentBoltExecutor
TridentBoltExecutor.CoordCondition
TridentBoltExecutor.CoordSpec
TridentBoltExecutor.CoordType
TridentBoltExecutor.TrackedBatch
TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentContext
TridentFileTopology
TridentJmsSpout
Trident implementation of the JmsSpout.
TridentKafkaClientTopologyNamedTopics
This example sets up a few topologies to put random strings in Kafka topics via the KafkaBolt, and shows how to set up a Trident topology that reads from some Kafka topics using the KafkaSpout.
TridentKafkaClientTopologyWildcardTopics
This example is similar to `TridentKafkaClientTopologyWildcardTopics`, but demonstrates subscribing to Kafka topics with a regex.
TridentKafkaConsumerTopology
TridentKafkaState<K,V>
TridentKafkaStateFactory<K,V>
TridentKafkaStateUpdater<K,V>
TridentMapExample
A simple example that demonstrates the usage of `Stream.map(MapFunction)` and `Stream.flatMap(FlatMapFunction)` functions.
TridentMinMaxOfDevicesTopology
This class demonstrates different usages of * `Stream.minBy(String)` * `Stream.maxBy(String)` operations on trident `Stream`.
TridentMinMaxOfVehiclesTopology
This class demonstrates different usages of * `Stream.minBy(String, Comparator)` * `Stream.min(Comparator)` * `Stream.maxBy(String, Comparator)` * `Stream.max(Comparator)` operations on trident `Stream`.
TridentMultiReducerContext
TridentOperationContext
TridentProcessor
TridentReach
TridentReach.ExpandList
TridentReach.One
TridentReach.StaticSingleKeyMapState
TridentReach.StaticSingleKeyMapState.Factory
TridentSequenceTopology
TridentSpoutCoordinator
TridentSpoutExecutor
TridentState
TridentTopology
TridentTopologyBuilder
TridentTuple
TridentTuple.Factory
TridentTupleToKafkaMapper<K,V>
TridentTupleView
Extends AbstractList so that it can be emitted directly as Storm tuples.
TridentTupleView.FreshOutputFactory
TridentTupleView.OperationOutputFactory
TridentTupleView.ProjectionFactory
TridentTupleView.RootFactory
TridentUtils
TridentWindowingInmemoryStoreTopology
Sample application of trident windowing which uses inmemory store for storing tuples in window.
TridentWordCount
TridentWordCount.Split
TriggerHandler
The callback fired by `TriggerPolicy` when the trigger condition is satisfied.
TriggerPolicy<T,S>
Triggers the window calculations based on the policy.
TrueFilter
TrueFilter
TsvScheme
TsvScheme uses a simple delimited format implemention by splitting string, and it supports user defined delimiter.
TsvSerializer
TsvSerializer uses a simple delimited format implemention by splitting string, and it supports user defined delimiter.
TumblingCountWindow
Represents tumbling count window configuration.
TumblingCountWindowStrategy<T>
This class represents tumbling window strategy based on the window count from the given `slidingCountWindow` configuration.
TumblingDurationWindow
Represents tumbling duration window configuration.
TumblingDurationWindowStrategy<T>
This class represents tumbling window strategy based on the window duration from the given `slidingCountWindow` configuration.
TumblingTimeCorrectness
Computes sliding window sum.
TumblingWindowCorrectness
Computes sliding window sum.
TumblingWindows<L>
A tumbling window specification.
Tuple
The tuple is the main data structure in Storm.
Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>
A tuple of ten elements along the lines of Scala's Tuple.
Tuple3<T1,T2,T3>
A tuple of three elements along the lines of Scala's Tuple.
Tuple4<T1,T2,T3,T4>
A tuple of four elements along the lines of Scala's Tuple.
Tuple5<T1,T2,T3,T4,T5>
A tuple of five elements along the lines of Scala's Tuple.
Tuple6<T1,T2,T3,T4,T5,T6>
A tuple of six elements along the lines of Scala's Tuple.
Tuple7<T1,T2,T3,T4,T5,T6,T7>
A tuple of seven elements along the lines of Scala's Tuple.
Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>
A tuple of eight elements along the lines of Scala's Tuple.
Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>
A tuple of nine elements along the lines of Scala's Tuple.
TupleCaptureBolt
TupleCollectionGet
TupleFieldTimestampExtractor
A `TimestampExtractor` that extracts timestamp from a specific field in the tuple.
TupleImpl
TupleInfo
TupleMapper
TupleMapper defines how to extract key and value from tuple for Redis.
TupleReceiver
TupleToKafkaMapper<K,V>
Interface defining a mapping from storm tuple to kafka key and message.
TupleUtils
TupleValueMapper<T>
A generic interface for mapping a `Tuple` to typed values.
TupleValueMappers
Factory for constructing typed tuples from a `Tuple` based on indicies.
TupleWindow
A `Window` that contains `Tuple` objects.
TupleWindowImpl
Holds the expired, new and current tuples in a window.
TupleWindowIterImpl
An iterator based implementation over the events in a window.
TuplifyArgs
TypedTupleExample
An example that illustrates the usage of typed tuples (TupleN<..>) and `TupleValueMappers`.
UIHelpers
UIServer
Main class.
UniFunc<T>
UniqueIdGen
UnsupportedOperatorsVisitor
UpdateStateByKeyProcessor<K,V,R>
UploadCredentials
UrlBuilder
Convenient utility class to build the URL.
User
UserPersistenceTopology
UserPersistenceTridentTopology
UserSpout
Util
Utils
Utils
Utils.SmartThread
A thread that can answer if it is sleeping in the case of simulated time.
Utils.UptimeComputer
Validated
An interface that is used to inform config validation what to look at.
ValueJoiner<V1,V2,R>
An interface for joining two values to produce a result.
ValueMapper<T>
Extracts a single typed value from a tuple.
ValuePointer
Values
A convenience class for making tuple values using new Values("field1", 2, 3) syntax.
ValuesMapper
Constructs a `Values` from a `Tuple` based on indicies.
ValueUpdater<T>
VerificationBolt
VersionedData<D>
VersionedStore
VersionInfo
VersionInfoMojo
VertexDef
Abstract parent class of component definitions.
WaitStrategyPark
WaitStrategyProgressive
A Progressive Wait Strategy.
WatcherCallBack
WatermarkCountEvictionPolicy<T>
An eviction policy that tracks count based on watermark ts and evicts events up to the watermark based on a threshold count.
WatermarkCountTriggerPolicy<T>
A trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.
WaterMarkEvent<T>
Watermark event used for tracking progress of time when processing event based ts.
WaterMarkEventGenerator<T>
Tracks tuples across input streams and periodically emits watermark events.
WatermarkTimeEvictionPolicy<T>
An eviction policy that evicts events based on time duration taking watermark time and event lag into account.
WatermarkTimeTriggerPolicy<T>
Handles watermark events and triggers `TriggerHandler.onTrigger()` for each window interval that has events to be processed up to the watermark ts.
WebAppUtils
WhitelistWordCount
WhitelistWordCount.PrintWordTotalCountBolt
Window<L,I>
The window specification within `Stream`.
Window<T>
A view of events in a sliding window.
WindowConfig
Windowing configuration with window and sliding length.
WindowConfig.Type
WindowedBoltExecutor
An `IWindowedBolt` wrapper that does the windowing of tuples.
WindowedTimeThrottler
WindowedWordCount
A windowed word count example.
WindowKryoSerializer
Kryo serializer/deserializer for values that are stored as part of windowing.
WindowLifecycleListener<T>
A callback for expiry, activation of events tracked by the `WindowManager`.
WindowManager<T>
Tracks a window of events and fires `WindowLifecycleListener` callbacks on expiry of events or activation of the window due to `TriggerPolicy`.
WindowNode
Node that captures the windowing configurations.
WindowPartitionCache<K,V>
A loading cache abstraction for caching `WindowState.WindowPartition`.
WindowPartitionCache.Builder<K,V>
Builder interface for `WindowPartitionCache`.
WindowPartitionCache.CacheLoader<K,V>
The interface for loading entires into the cache.
WindowPartitionCache.RemovalCause
The reason why an enrty got evicted from the cache.
WindowPartitionCache.RemovalListener<K,V>
A callback interface for handling removal of events from the cache.
WindowsState
`State` implementation for windowing operation.
WindowsStateFactory
`StateFactory` instance for creating `WindowsState` instances.
WindowsStateUpdater
`StateUpdater<WindowState>` instance which removes successfully emitted triggers from store.
WindowsStore
Store for storing window related entities like windowed tuples, triggers etc.
WindowsStore.Entry
This class wraps key and value objects which can be passed to `putAll` method.
WindowsStoreFactory
Factory to create instances of `WindowsStore`.
WindowState<T>
A wrapper around the window related states that are checkpointed.
WindowState.WindowPartition<T>
WindowStrategy<T>
Strategy for windowing which will have respective trigger and eviction policies.
WindowTridentProcessor
`TridentProcessor` implementation for windowing operations on trident stream.
WindowTridentProcessor.TriggerInfo
WordCountBolt
WordCountClient
Connects to the 'WordCount' HBase table and prints counts for each word.
WordCounter
This bolt is used by the HBase example.
WordCounter
WordCountLookupMapper
WordCountStoreMapper
WordCountToBolt
An example that computes word counts and finally emits the results to an external bolt (sink).
WordCountTopology
This topology demonstrates Storm's stream groupings and multilang capabilities.
WordCountTopology.SplitSentence
WordCountTopologyNode
This topology demonstrates Storm's stream groupings and multilang capabilities.
WordCountTopologyNode.RandomSentence
WordCountTopologyNode.SplitSentence
WordCountTopologyNode.WordCount
WordCountTridentRedis
WordCountTridentRedisCluster
WordCountTridentRedisClusterMap
WordCountTridentRedisMap
WordGenSpout
WordSpout
Worker
WorkerHeartbeatsRecoveryStrategyFactory
Factory class for recovery strategy.
WorkerHookDef
Bean representation of a Storm worker hook.
WorkerLogs
A class that knows about how to operate with worker log directory.
WorkerMetricList
WorkerMetricList._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerMetricPoint
WorkerMetricPoint._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerMetricRegistrant
WorkerMetrics
WorkerMetrics._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerMetricsProcessor
WorkerResources
WorkerResources._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerSlot
WorkerState
WorkerState.ILocalTransferCallback
WorkerSummary
WorkerSummary._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerToken
WorkerToken._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerTokenAuthorizer
Allow for SASL authentication using worker tokens.
WorkerTokenClientCallbackHandler
A Client callback handler for a WorkerToken.
WorkerTokenInfo
WorkerTokenInfo._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
WorkerTokenManager
The WorkerTokenManager manages the life cycle of worker tokens in nimbus.
WorkerTokenServiceType
WorkerTopologyContext
WorkerTransfer
WorkerUserContext
WrappedAlreadyAliveException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedAuthorizationException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedDRPCExecutionException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedHBExecutionException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedIllegalStateException
WrappedInvalidTopologyException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedKeyAlreadyExistsException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedKeyNotFoundException
Wraps the generated TException to allow getMessage() to return a valid string.
WrappedNotAliveException
Wraps the generated TException to allow getMessage() to return a valid string.
WritableStringMetadataCache
The writable interface to a StringMetadataCache intended to be used by a single RocksDBMetricwWriter instance.
WritableUtils
Writer
X509CertOrKerberosPrincipalToLocal
X509CertPrincipalToLocal
ZkCli
ZkEventTypes
ZkKeeperStates
ZKStateChangedCallback
ZKStateStorage
ZKStateStorageFactory
Zookeeper
ZookeeperAuthInfo
ZookeeperServerCnxnFactory