Search Java Classes and Packages
#Backtype.storm Classes and Interfaces - 608 results found.
| Name | Description | Type | Package | Framework |
| AckFailDelegate | Interface | backtype.storm.testing | Apache Storm | |
| AckFailMapTracker | Class | backtype.storm.testing | Apache Storm | |
| AckTracker | Class | backtype.storm.testing | Apache Storm | |
| AlreadyAliveException | Class | backtype.storm.generated | Apache Storm | |
| AlreadyAliveException ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.AlreadyAliveException | Apache Storm |
| ArrayListSerializer | Class | backtype.storm.serialization.types | Apache Storm | |
| AssignableMetric | Class | backtype.storm.metric.api | Apache Storm | |
| AssignableShellMetric | Class | backtype.storm.metric.api.rpc | Apache Storm | |
| AuthorizationException | Class | backtype.storm.generated | Apache Storm | |
| AuthorizationException ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.AuthorizationException | Apache Storm |
| AuthUtils | Class | backtype.storm.security.auth | Apache Storm | |
| AutoTGT | Automatically take a user's TGT, and push it, and renew it in Nimbus. | Class | backtype.storm.security.auth.kerberos | Apache Storm |
| AutoTGTKrb5LoginModule | Class | backtype.storm.security.auth.kerberos | Apache Storm | |
| AutoTGTKrb5LoginModuleTest | Custom LoginModule extended for testing. | Class | backtype.storm.security.auth.kerberos | Apache Storm |
| BaseBasicBolt | Class | backtype.storm.topology.base | Apache Storm | |
| BaseBatchBolt | Class | backtype.storm.topology.base | Apache Storm | |
| BaseComponent | Class | backtype.storm.topology.base | Apache Storm | |
| BaseConfigurationDeclarer | Class | backtype.storm.topology | Apache Storm | |
| BaseOpaquePartitionedTransactionalSpout | Class | backtype.storm.topology.base | Apache Storm | |
| BasePartitionedTransactionalSpout | Class | backtype.storm.topology.base | Apache Storm | |
| BaseRichBolt | Class | backtype.storm.topology.base | Apache Storm | |
| BaseRichSpout | Class | backtype.storm.topology.base | Apache Storm | |
| BaseTaskHook | Class | backtype.storm.hooks | Apache Storm | |
| BaseTransactionalBolt | Class | backtype.storm.topology.base | Apache Storm | |
| BaseTransactionalSpout | Class | backtype.storm.topology.base | Apache Storm | |
| BasicBoltExecutor | Class | backtype.storm.topology | Apache Storm | |
| BasicOutputCollector | Class | backtype.storm.topology | Apache Storm | |
| BatchBoltExecutor | Class | backtype.storm.coordination | Apache Storm | |
| BatchNumberList | Class | backtype.storm.testing | Apache Storm | |
| BatchOutputCollector | Class | backtype.storm.coordination | Apache Storm | |
| BatchOutputCollectorImpl | Class | backtype.storm.coordination | Apache Storm | |
| BatchProcessWord | Class | backtype.storm.testing | Apache Storm | |
| BatchRepeatA | Class | backtype.storm.testing | Apache Storm | |
| BatchSubtopologyBuilder | Class | backtype.storm.coordination | Apache Storm | |
| BlowfishTupleSerializer | Class | backtype.storm.security.serialization | Apache Storm | |
| Bolt | Class | backtype.storm.generated | Apache Storm | |
| Bolt ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Bolt | Apache Storm |
| BoltAckInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| BoltDeclarer | BoltDeclarer includes grouping APIs for storm topology. | Interface | backtype.storm.topology | Apache Storm |
| BoltExecuteInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| BoltFailInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| BoltMsg | BoltMsg is an object that represents the data sent from a shell component to a bolt process that implements a multi-language protocol. | Class | backtype.storm.multilang | Apache Storm |
| BoltStats | Class | backtype.storm.generated | Apache Storm | |
| BoltStats ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.BoltStats | Apache Storm |
| BoltTracker | Class | backtype.storm.testing | Apache Storm | |
| BufferFileInputStream | Class | backtype.storm.utils | Apache Storm | |
| Client | A Netty client for sending task messages to a remote destination (Netty server). | Class | backtype.storm.messaging.netty | Apache Storm |
| ClientCallbackHandler | client side callback handler. | Class | backtype.storm.security.auth.digest | Apache Storm |
| ClientCallbackHandler | SASL client side callback handler. | Class | backtype.storm.security.auth.kerberos | Apache Storm |
| ClojureBolt | Class | backtype.storm.clojure | Apache Storm | |
| ClojureSpout | Class | backtype.storm.clojure | Apache Storm | |
| ClojureTimerTask | Class | backtype.storm.utils | Apache Storm | |
| Cluster | Class | backtype.storm.scheduler | Apache Storm | |
| ClusterSummary | Class | backtype.storm.generated | Apache Storm | |
| ClusterSummary ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ClusterSummary | Apache Storm |
| CombinedMetric | Class | backtype.storm.metric.api | Apache Storm | |
| CombinedShellMetric | Class | backtype.storm.metric.api.rpc | Apache Storm | |
| CompleteTopologyParam | The param class for the Testing. | Class | backtype.storm.testing | Apache Storm |
| ComponentCommon | Class | backtype.storm.generated | Apache Storm | |
| ComponentCommon ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ComponentCommon | Apache Storm |
| ComponentConfigurationDeclarer | Interface | backtype.storm.topology | Apache Storm | |
| ComponentObject | Class | backtype.storm.generated | Apache Storm | |
| ComponentObject ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ComponentObject | Apache Storm |
| CompoundSpout | Class | backtype.storm.planner | Apache Storm | |
| CompoundTask | Class | backtype.storm.planner | Apache Storm | |
| Config | Topology configs are specified as a plain old map. | Class | backtype.storm | Apache Storm |
| ConfigValidation | Provides functionality for validating configuration fields. | Class | backtype.storm | Apache Storm |
| ConfigValidation .FieldValidator | Declares methods for validating configuration values. | Interface | backtype.storm.ConfigValidation | Apache Storm |
| ConfigValidation .NestableFieldValidator | Declares a method for validating configuration values that is nestable. | Class | backtype.storm.ConfigValidation | Apache Storm |
| ConnectionWithStatus | Class | backtype.storm.messaging | Apache Storm | |
| ConnectionWithStatus .Status | The connection channel is closed or being closed. | Class | backtype.storm.messaging.ConnectionWithStatus | Apache Storm |
| Constants | Class | backtype.storm | Apache Storm | |
| Container | Class | backtype.storm.utils | Apache Storm | |
| Context | Class | backtype.storm.messaging.netty | Apache Storm | |
| CoordinatedBolt | Coordination requires the request ids to be globally unique for awhile. | Class | backtype.storm.coordination | Apache Storm |
| CoordinatedBolt .FinishedCallback | Interface | backtype.storm.coordination.CoordinatedBolt | Apache Storm | |
| CoordinatedBolt .IdStreamSpec | Class | backtype.storm.coordination.CoordinatedBolt | Apache Storm | |
| CoordinatedBolt .SourceArgs | Class | backtype.storm.coordination.CoordinatedBolt | Apache Storm | |
| CoordinatedBolt .TimeoutCallback | Interface | backtype.storm.coordination.CoordinatedBolt | Apache Storm | |
| CoordinatedBolt .TrackingInfo | Class | backtype.storm.coordination.CoordinatedBolt | Apache Storm | |
| CountingBatchBolt | Class | backtype.storm.testing | Apache Storm | |
| CountingCommitBolt | Class | backtype.storm.testing | Apache Storm | |
| CountMetric | Class | backtype.storm.metric.api | Apache Storm | |
| CountShellMetric | Class | backtype.storm.metric.api.rpc | Apache Storm | |
| CRC32OutputStream | Class | backtype.storm.utils | Apache Storm | |
| Credentials | Class | backtype.storm.generated | Apache Storm | |
| Credentials ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Credentials | Apache Storm |
| CustomStreamGrouping | Interface | backtype.storm.grouping | Apache Storm | |
| DefaultHttpCredentialsPlugin | Class | backtype.storm.security.auth | Apache Storm | |
| DefaultKryoFactory | Class | backtype.storm.serialization | Apache Storm | |
| DefaultKryoFactory .KryoSerializableDefault | Class | backtype.storm.serialization.DefaultKryoFactory | Apache Storm | |
| DefaultPool | Class | backtype.storm.scheduler.multitenant | Apache Storm | |
| DefaultPrincipalToLocal | Storm can be configured to launch worker processed as a given user. | Class | backtype.storm.security.auth | Apache Storm |
| DefaultSerializationDelegate | Class | backtype.storm.serialization | Apache Storm | |
| DefaultTopologyValidator | Class | backtype.storm.nimbus | Apache Storm | |
| DenyAuthorizer | Class | backtype.storm.security.auth.authorizer | Apache Storm | |
| DigestSaslTransportPlugin | Class | backtype.storm.security.auth.digest | Apache Storm | |
| DisruptorQueue | A single consumer queue that uses the LMAX Disruptor. | Class | backtype.storm.utils | Apache Storm |
| DisruptorQueue .ObjectEventFactory | Class | backtype.storm.utils.DisruptorQueue | Apache Storm | |
| DistributedRPC | Class | backtype.storm.generated | Apache Storm | |
| DistributedRPC .AsyncClient | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .AsyncClient .execute_call | Class | backtype.storm.generated.DistributedRPC.AsyncClient | Apache Storm | |
| DistributedRPC .AsyncClient .Factory | Class | backtype.storm.generated.DistributedRPC.AsyncClient | Apache Storm | |
| DistributedRPC .AsyncIface | Interface | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .AsyncProcessor | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .AsyncProcessor .execute | Class | backtype.storm.generated.DistributedRPC.AsyncProcessor | Apache Storm | |
| DistributedRPC .Client | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .Client .Factory | Class | backtype.storm.generated.DistributedRPC.Client | Apache Storm | |
| DistributedRPC .execute_args | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .execute_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPC.execute_args | Apache Storm |
| DistributedRPC .execute_result | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .execute_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPC.execute_result | Apache Storm |
| DistributedRPC .Iface | Interface | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .Processor | Class | backtype.storm.generated.DistributedRPC | Apache Storm | |
| DistributedRPC .Processor .execute | Class | backtype.storm.generated.DistributedRPC.Processor | Apache Storm | |
| DistributedRPCInvocations | Class | backtype.storm.generated | Apache Storm | |
| DistributedRPCInvocations .AsyncClient | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .AsyncClient .Factory | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncClient | Apache Storm | |
| DistributedRPCInvocations .AsyncClient .failRequest_call | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncClient | Apache Storm | |
| DistributedRPCInvocations .AsyncClient .fetchRequest_call | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncClient | Apache Storm | |
| DistributedRPCInvocations .AsyncClient .result_call | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncClient | Apache Storm | |
| DistributedRPCInvocations .AsyncIface | org. | Interface | backtype.storm.generated.DistributedRPCInvocations | Apache Storm |
| DistributedRPCInvocations .AsyncProcessor | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .AsyncProcessor .failRequest | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncProcessor | Apache Storm | |
| DistributedRPCInvocations .AsyncProcessor .fetchRequest | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncProcessor | Apache Storm | |
| DistributedRPCInvocations .AsyncProcessor .result | Class | backtype.storm.generated.DistributedRPCInvocations.AsyncProcessor | Apache Storm | |
| DistributedRPCInvocations .Client | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .Client .Factory | Class | backtype.storm.generated.DistributedRPCInvocations.Client | Apache Storm | |
| DistributedRPCInvocations .failRequest_args | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .failRequest_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.failRequest_args | Apache Storm |
| DistributedRPCInvocations .failRequest_result | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .failRequest_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.failRequest_result | Apache Storm |
| DistributedRPCInvocations .fetchRequest_args | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .fetchRequest_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.fetchRequest_args | Apache Storm |
| DistributedRPCInvocations .fetchRequest_result | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .fetchRequest_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.fetchRequest_result | Apache Storm |
| DistributedRPCInvocations .Iface | Interface | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .Processor | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .Processor .failRequest | Class | backtype.storm.generated.DistributedRPCInvocations.Processor | Apache Storm | |
| DistributedRPCInvocations .Processor .fetchRequest | Class | backtype.storm.generated.DistributedRPCInvocations.Processor | Apache Storm | |
| DistributedRPCInvocations .Processor .result | Class | backtype.storm.generated.DistributedRPCInvocations.Processor | Apache Storm | |
| DistributedRPCInvocations .result_args | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .result_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.result_args | Apache Storm |
| DistributedRPCInvocations .result_result | Class | backtype.storm.generated.DistributedRPCInvocations | Apache Storm | |
| DistributedRPCInvocations .result_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DistributedRPCInvocations.result_result | Apache Storm |
| DRPCAuthorizerBase | Class | backtype.storm.security.auth.authorizer | Apache Storm | |
| DRPCClient | Class | backtype.storm.utils | Apache Storm | |
| DRPCExecutionException | Class | backtype.storm.generated | Apache Storm | |
| DRPCExecutionException ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DRPCExecutionException | Apache Storm |
| DRPCInvocationsClient | Class | backtype.storm.drpc | Apache Storm | |
| DRPCRequest | Class | backtype.storm.generated | Apache Storm | |
| DRPCRequest ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.DRPCRequest | Apache Storm |
| DRPCSimpleACLAuthorizer | Class | backtype.storm.security.auth.authorizer | Apache Storm | |
| DRPCSpout | Class | backtype.storm.drpc | Apache Storm | |
| EmitInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| ErrorInfo | Class | backtype.storm.generated | Apache Storm | |
| ErrorInfo ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ErrorInfo | Apache Storm |
| ExecutorDetails | Class | backtype.storm.scheduler | Apache Storm | |
| ExecutorInfo | Class | backtype.storm.generated | Apache Storm | |
| ExecutorInfo ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ExecutorInfo | Apache Storm |
| ExecutorSpecificStats | Class | backtype.storm.generated | Apache Storm | |
| ExecutorSpecificStats ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ExecutorSpecificStats | Apache Storm |
| ExecutorStats | Class | backtype.storm.generated | Apache Storm | |
| ExecutorStats ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ExecutorStats | Apache Storm |
| ExecutorSummary | Class | backtype.storm.generated | Apache Storm | |
| ExecutorSummary ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ExecutorSummary | Apache Storm |
| FailedException | Class | backtype.storm.topology | Apache Storm | |
| FeederSpout | Class | backtype.storm.testing | Apache Storm | |
| Fields | Class | backtype.storm.tuple | Apache Storm | |
| FixedTuple | Class | backtype.storm.testing | Apache Storm | |
| FixedTupleSpout | Class | backtype.storm.testing | Apache Storm | |
| ForwardingMetricsConsumer | Class | backtype.storm.testing | Apache Storm | |
| FreePool | Class | backtype.storm.scheduler.multitenant | Apache Storm | |
| GeneralTopologyContext | Class | backtype.storm.task | Apache Storm | |
| GetInfoOptions | Class | backtype.storm.generated | Apache Storm | |
| GetInfoOptions ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.GetInfoOptions | Apache Storm |
| GlobalStreamId | Class | backtype.storm.generated | Apache Storm | |
| GlobalStreamId ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.GlobalStreamId | Apache Storm |
| Grouping | Class | backtype.storm.generated | Apache Storm | |
| Grouping ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Grouping | Apache Storm |
| GzipBridgeSerializationDelegate | Always writes gzip out, but tests incoming to see if it's gzipped. | Class | backtype.storm.serialization | Apache Storm |
| GzipSerializationDelegate | Note, this assumes it's deserializing a gzip byte stream, and will err if it encounters any other serialization. | Class | backtype.storm.serialization | Apache Storm |
| HashMapSerializer | Class | backtype.storm.serialization.types | Apache Storm | |
| HashSetSerializer | Class | backtype.storm.serialization.types | Apache Storm | |
| IAuthorizer | Nimbus could be configured with an authorization plugin. | Interface | backtype.storm.security.auth | Apache Storm |
| IAutoCredentials | Provides a way to automatically push credentials to a topology and to retreave them in the worker. | Interface | backtype.storm.security.auth | Apache Storm |
| IBasicBolt | Interface | backtype.storm.topology | Apache Storm | |
| IBasicOutputCollector | Interface | backtype.storm.topology | Apache Storm | |
| IBatchBolt | Interface | backtype.storm.coordination | Apache Storm | |
| IBolt | An IBolt represents a component that takes tuples as input and produces tuples as output. | Interface | backtype.storm.task | Apache Storm |
| ICombiner | Interface | backtype.storm.metric.api | Apache Storm | |
| ICommitterTransactionalSpout | Interface | backtype.storm.transactional | Apache Storm | |
| ICommitterTransactionalSpout .Emitter | Interface | backtype.storm.transactional.ICommitterTransactionalSpout | Apache Storm | |
| IComponent | Common methods for all possible components in a topology. | Interface | backtype.storm.topology | Apache Storm |
| IConnection | Interface | backtype.storm.messaging | Apache Storm | |
| IContext | This interface needs to be implemented for messaging plugin. | Interface | backtype.storm.messaging | Apache Storm |
| ICredentialsListener | Allows a bolt or a spout to be informed when the credentials of the topology have changed. | Interface | backtype.storm | Apache Storm |
| ICredentialsRenewer | Provides a way to renew credentials on behelf of a user. | Interface | backtype.storm.security.auth | Apache Storm |
| IdentityBolt | Class | backtype.storm.testing | Apache Storm | |
| IErrorReporter | Interface | backtype.storm.task | Apache Storm | |
| IGroupMappingServiceProvider | Get all various group memberships of a given user. | Interface | backtype.storm.security.auth | Apache Storm |
| IHttpCredentialsPlugin | Interface for handling credentials in an HttpServletRequestGets the user name from the request. | Interface | backtype.storm.security.auth | Apache Storm |
| IKryoDecorator | Interface | backtype.storm.serialization | Apache Storm | |
| IKryoFactory | An interface that controls the Kryo instance used by Storm for serialization. | Interface | backtype.storm.serialization | Apache Storm |
| ILocalCluster | Interface | backtype.storm | Apache Storm | |
| ILocalDRPC | Interface | backtype.storm | Apache Storm | |
| IMetric | Interface | backtype.storm.metric.api | Apache Storm | |
| IMetricsConsumer | Interface | backtype.storm.metric.api | Apache Storm | |
| IMetricsConsumer .DataPoint | Class | backtype.storm.metric.api.IMetricsConsumer | Apache Storm | |
| IMetricsConsumer .TaskInfo | Class | backtype.storm.metric.api.IMetricsConsumer | Apache Storm | |
| IMetricsContext | Interface | backtype.storm.task | Apache Storm | |
| IMultiSchemableSpout | Interface | backtype.storm.spout | Apache Storm | |
| IndifferentAccessMap | Class | backtype.storm.utils | Apache Storm | |
| INimbus | Interface | backtype.storm.scheduler | Apache Storm | |
| INimbusCredentialPlugin | Nimbus auto credential plugin that will be called on nimbus host during submit topology option. | Interface | backtype.storm.security | Apache Storm |
| InprocMessaging | Class | backtype.storm.utils | Apache Storm | |
| InputDeclarer | The stream is replicated across all the bolt's tasks. | Interface | backtype.storm.topology | Apache Storm |
| InvalidRequestException | Class | backtype.storm.ui | Apache Storm | |
| InvalidTopologyException | Class | backtype.storm.generated | Apache Storm | |
| InvalidTopologyException ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.InvalidTopologyException | Apache Storm |
| IOpaquePartitionedTransactionalSpout | This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id. | Interface | backtype.storm.transactional.partitioned | Apache Storm |
| IOpaquePartitionedTransactionalSpout .Coordinator | Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction). | Interface | backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout | Apache Storm |
| IOpaquePartitionedTransactionalSpout .Emitter | Interface | backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout | Apache Storm | |
| IOutputCollector | Interface | backtype.storm.task | Apache Storm | |
| IPartitionedTransactionalSpout | This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. | Interface | backtype.storm.transactional.partitioned | Apache Storm |
| IPartitionedTransactionalSpout .Coordinator | Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction). | Interface | backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout | Apache Storm |
| IPartitionedTransactionalSpout .Emitter | Interface | backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout | Apache Storm | |
| IPrincipalToLocal | Storm can be configured to launch worker processed as a given user. | Interface | backtype.storm.security.auth | Apache Storm |
| IReducer | Interface | backtype.storm.metric.api | Apache Storm | |
| IRichBolt | When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology. | Interface | backtype.storm.topology | Apache Storm |
| IRichSpout | When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology. | Interface | backtype.storm.topology | Apache Storm |
| IRichStateSpout | Interface | backtype.storm.topology | Apache Storm | |
| IScheduler | Interface | backtype.storm.scheduler | Apache Storm | |
| ISchemableSpout | Interface | backtype.storm.spout | Apache Storm | |
| ISerializer | The ISerializer interface describes the methods that an object should implement to provide serialization and de-serialization capabilities to | Interface | backtype.storm.multilang | Apache Storm |
| IShellMetric | Interface | backtype.storm.metric.api.rpc | Apache Storm | |
| IsolatedPool | Class | backtype.storm.scheduler.multitenant | Apache Storm | |
| ISpout | ISpout is the core interface for implementing spouts. | Interface | backtype.storm.spout | Apache Storm |
| ISpoutOutputCollector | Interface | backtype.storm.spout | Apache Storm | |
| ISpoutWaitStrategy | The strategy a spout needs to use when its waiting. | Interface | backtype.storm.spout | Apache Storm |
| IStateSpout | Interface | backtype.storm.state | Apache Storm | |
| IStateSpoutOutputCollector | Interface | backtype.storm.state | Apache Storm | |
| ISubscribedState | Interface | backtype.storm.state | Apache Storm | |
| ISupervisor | The id used in assignments. | Interface | backtype.storm.scheduler | Apache Storm |
| ISynchronizeOutputCollector | Interface | backtype.storm.state | Apache Storm | |
| ITaskHook | Interface | backtype.storm.hooks | Apache Storm | |
| ITopologyValidator | Interface | backtype.storm.nimbus | Apache Storm | |
| ITransactionalSpout | Interface | backtype.storm.transactional | Apache Storm | |
| ITransactionalSpout .Coordinator | Release any resources from this coordinator. | Interface | backtype.storm.transactional.ITransactionalSpout | Apache Storm |
| ITransactionalSpout .Emitter | Any state for transactions prior to the provided transaction id can be safely cleaned up, so this method should clean up that state. | Interface | backtype.storm.transactional.ITransactionalSpout | Apache Storm |
| ITransportPlugin | Interface | backtype.storm.security.auth | Apache Storm | |
| ITuple | Returns true if this tuple contains the specified name of the field. | Interface | backtype.storm.tuple | Apache Storm |
| ITupleDeserializer | Interface | backtype.storm.serialization | Apache Storm | |
| ITupleSerializer | Interface | backtype.storm.serialization | Apache Storm | |
| JavaObject | Class | backtype.storm.generated | Apache Storm | |
| JavaObject ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.JavaObject | Apache Storm |
| JavaObjectArg | Class | backtype.storm.generated | Apache Storm | |
| JavaObjectArg ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.JavaObjectArg | Apache Storm |
| JoinResult | Class | backtype.storm.drpc | Apache Storm | |
| JsonSerializer | JsonSerializer implements the JSON multilang protocol. | Class | backtype.storm.multilang | Apache Storm |
| KerberosPrincipalToLocal | Class | backtype.storm.security.auth | Apache Storm | |
| KerberosSaslTransportPlugin | Class | backtype.storm.security.auth.kerberos | Apache Storm | |
| KeyedCountingBatchBolt | Class | backtype.storm.testing | Apache Storm | |
| KeyedCountingCommitterBolt | Class | backtype.storm.testing | Apache Storm | |
| KeyedFairBolt | Class | backtype.storm.drpc | Apache Storm | |
| KeyedRoundRobinQueue | Class | backtype.storm.utils | Apache Storm | |
| KeyedSummingBatchBolt | Class | backtype.storm.testing | Apache Storm | |
| KillOptions | Class | backtype.storm.generated | Apache Storm | |
| KillOptions ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.KillOptions | Apache Storm |
| KryoTupleDeserializer | Class | backtype.storm.serialization | Apache Storm | |
| KryoTupleSerializer | Class | backtype.storm.serialization | Apache Storm | |
| KryoValuesDeserializer | Class | backtype.storm.serialization | Apache Storm | |
| KryoValuesSerializer | Class | backtype.storm.serialization | Apache Storm | |
| LinearDRPCInputDeclarer | Interface | backtype.storm.drpc | Apache Storm | |
| LinearDRPCTopologyBuilder | Class | backtype.storm.drpc | Apache Storm | |
| ListDelegate | Class | backtype.storm.utils | Apache Storm | |
| ListDelegateSerializer | Class | backtype.storm.serialization.types | Apache Storm | |
| LocalState | A simple, durable, atomic K/V database. | Class | backtype.storm.utils | Apache Storm |
| LoggingMetricsConsumer | Class | backtype.storm.metric | Apache Storm | |
| MeanReducer | Class | backtype.storm.metric.api | Apache Storm | |
| MemoryTransactionalSpout | Class | backtype.storm.testing | Apache Storm | |
| MemoryTransactionalSpoutMeta | Class | backtype.storm.testing | Apache Storm | |
| MessageDecoder | Class | backtype.storm.messaging.netty | Apache Storm | |
| MessageEncoder | Class | backtype.storm.messaging.netty | Apache Storm | |
| MessageId | Class | backtype.storm.tuple | Apache Storm | |
| MetricsConsumerBolt | Class | backtype.storm.metric | Apache Storm | |
| MkClusterParam | The param arg for Testing. | Class | backtype.storm.testing | Apache Storm |
| MkTupleParam | Class | backtype.storm.testing | Apache Storm | |
| MockedSources | Class | backtype.storm.testing | Apache Storm | |
| Monitor | Class | backtype.storm.utils | Apache Storm | |
| MultiCountMetric | Class | backtype.storm.metric.api | Apache Storm | |
| MultiReducedMetric | Class | backtype.storm.metric.api | Apache Storm | |
| MultiScheme | Interface | backtype.storm.spout | Apache Storm | |
| MultitenantScheduler | Class | backtype.storm.scheduler.multitenant | Apache Storm | |
| MutableInt | Class | backtype.storm.utils | Apache Storm | |
| MutableLong | Class | backtype.storm.utils | Apache Storm | |
| MutableObject | Class | backtype.storm.utils | Apache Storm | |
| NettyRenameThreadFactory | Class | backtype.storm.messaging.netty | Apache Storm | |
| NGrouping | Class | backtype.storm.testing | Apache Storm | |
| Nimbus | Class | backtype.storm.generated | Apache Storm | |
| Nimbus .activate_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .activate_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.activate_args | Apache Storm |
| Nimbus .activate_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .activate_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.activate_result | Apache Storm |
| Nimbus .AsyncClient | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .AsyncClient .activate_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .beginFileDownload_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .beginFileUpload_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .deactivate_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .downloadChunk_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .Factory | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .finishFileUpload_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getClusterInfo_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getNimbusConf_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getTopology_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getTopologyConf_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getTopologyInfo_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getTopologyInfoWithOpts_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .getUserTopology_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .killTopology_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .killTopologyWithOpts_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .rebalance_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .submitTopology_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .submitTopologyWithOpts_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .uploadChunk_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncClient .uploadNewCredentials_call | Class | backtype.storm.generated.Nimbus.AsyncClient | Apache Storm | |
| Nimbus .AsyncIface | org. | Interface | backtype.storm.generated.Nimbus | Apache Storm |
| Nimbus .AsyncProcessor | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .AsyncProcessor .activate | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .beginFileDownload | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .beginFileUpload | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .deactivate | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .downloadChunk | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .finishFileUpload | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getClusterInfo | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getNimbusConf | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getTopology | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getTopologyConf | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getTopologyInfo | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getTopologyInfoWithOpts | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .getUserTopology | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .killTopology | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .killTopologyWithOpts | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .rebalance | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .submitTopology | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .submitTopologyWithOpts | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .uploadChunk | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .AsyncProcessor .uploadNewCredentials | Class | backtype.storm.generated.Nimbus.AsyncProcessor | Apache Storm | |
| Nimbus .beginFileDownload_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .beginFileDownload_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.beginFileDownload_args | Apache Storm |
| Nimbus .beginFileDownload_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .beginFileDownload_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.beginFileDownload_result | Apache Storm |
| Nimbus .beginFileUpload_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .beginFileUpload_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.beginFileUpload_args | Apache Storm |
| Nimbus .beginFileUpload_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .beginFileUpload_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.beginFileUpload_result | Apache Storm |
| Nimbus .Client | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .Client .Factory | Class | backtype.storm.generated.Nimbus.Client | Apache Storm | |
| Nimbus .deactivate_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .deactivate_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.deactivate_args | Apache Storm |
| Nimbus .deactivate_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .deactivate_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.deactivate_result | Apache Storm |
| Nimbus .downloadChunk_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .downloadChunk_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.downloadChunk_args | Apache Storm |
| Nimbus .downloadChunk_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .downloadChunk_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.downloadChunk_result | Apache Storm |
| Nimbus .finishFileUpload_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .finishFileUpload_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.finishFileUpload_args | Apache Storm |
| Nimbus .finishFileUpload_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .finishFileUpload_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.finishFileUpload_result | Apache Storm |
| Nimbus .getClusterInfo_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getClusterInfo_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getClusterInfo_args | Apache Storm |
| Nimbus .getClusterInfo_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getClusterInfo_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getClusterInfo_result | Apache Storm |
| Nimbus .getNimbusConf_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getNimbusConf_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getNimbusConf_args | Apache Storm |
| Nimbus .getNimbusConf_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getNimbusConf_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getNimbusConf_result | Apache Storm |
| Nimbus .getTopology_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopology_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopology_args | Apache Storm |
| Nimbus .getTopology_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopology_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopology_result | Apache Storm |
| Nimbus .getTopologyConf_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyConf_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyConf_args | Apache Storm |
| Nimbus .getTopologyConf_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyConf_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyConf_result | Apache Storm |
| Nimbus .getTopologyInfo_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyInfo_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyInfo_args | Apache Storm |
| Nimbus .getTopologyInfo_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyInfo_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyInfo_result | Apache Storm |
| Nimbus .getTopologyInfoWithOpts_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyInfoWithOpts_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyInfoWithOpts_args | Apache Storm |
| Nimbus .getTopologyInfoWithOpts_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getTopologyInfoWithOpts_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getTopologyInfoWithOpts_result | Apache Storm |
| Nimbus .getUserTopology_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getUserTopology_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getUserTopology_args | Apache Storm |
| Nimbus .getUserTopology_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .getUserTopology_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.getUserTopology_result | Apache Storm |
| Nimbus .Iface | Interface | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .killTopology_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .killTopology_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.killTopology_args | Apache Storm |
| Nimbus .killTopology_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .killTopology_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.killTopology_result | Apache Storm |
| Nimbus .killTopologyWithOpts_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .killTopologyWithOpts_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.killTopologyWithOpts_args | Apache Storm |
| Nimbus .killTopologyWithOpts_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .killTopologyWithOpts_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.killTopologyWithOpts_result | Apache Storm |
| Nimbus .Processor | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .Processor .activate | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .beginFileDownload | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .beginFileUpload | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .deactivate | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .downloadChunk | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .finishFileUpload | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getClusterInfo | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getNimbusConf | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getTopology | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getTopologyConf | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getTopologyInfo | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getTopologyInfoWithOpts | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .getUserTopology | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .killTopology | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .killTopologyWithOpts | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .rebalance | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .submitTopology | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .submitTopologyWithOpts | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .uploadChunk | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .Processor .uploadNewCredentials | Class | backtype.storm.generated.Nimbus.Processor | Apache Storm | |
| Nimbus .rebalance_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .rebalance_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.rebalance_args | Apache Storm |
| Nimbus .rebalance_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .rebalance_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.rebalance_result | Apache Storm |
| Nimbus .submitTopology_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .submitTopology_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.submitTopology_args | Apache Storm |
| Nimbus .submitTopology_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .submitTopology_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.submitTopology_result | Apache Storm |
| Nimbus .submitTopologyWithOpts_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .submitTopologyWithOpts_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.submitTopologyWithOpts_args | Apache Storm |
| Nimbus .submitTopologyWithOpts_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .submitTopologyWithOpts_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.submitTopologyWithOpts_result | Apache Storm |
| Nimbus .uploadChunk_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .uploadChunk_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.uploadChunk_args | Apache Storm |
| Nimbus .uploadChunk_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .uploadChunk_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.uploadChunk_result | Apache Storm |
| Nimbus .uploadNewCredentials_args | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .uploadNewCredentials_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.uploadNewCredentials_args | Apache Storm |
| Nimbus .uploadNewCredentials_result | Class | backtype.storm.generated.Nimbus | Apache Storm | |
| Nimbus .uploadNewCredentials_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.Nimbus.uploadNewCredentials_result | Apache Storm |
| NimbusClient | Class | backtype.storm.utils | Apache Storm | |
| Node | Represents a single node in the cluster. | Class | backtype.storm.scheduler.multitenant | Apache Storm |
| NodePool | A pool of nodes that can be used to run topologies. | Class | backtype.storm.scheduler.multitenant | Apache Storm |
| NodePool .NodeAndSlotCounts | Class | backtype.storm.scheduler.multitenant.NodePool | Apache Storm | |
| NodePool .RoundRobinSlotScheduler | Place executors into slots in a round robin way, taking into account component spreading among different hosts. | Class | backtype.storm.scheduler.multitenant.NodePool | Apache Storm |
| NonRichBoltTracker | Class | backtype.storm.testing | Apache Storm | |
| NoopAuthorizer | A no-op authorization implementation that illustrate info available for authorization decisions. | Class | backtype.storm.security.auth.authorizer | Apache Storm |
| NoOutputException | A NoOutputException states that no data has been received from the connectedSee Also:Serialized Form | Class | backtype.storm.multilang | Apache Storm |
| NotAliveException | Class | backtype.storm.generated | Apache Storm | |
| NotAliveException ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.NotAliveException | Apache Storm |
| NothingEmptyEmitStrategy | Class | backtype.storm.spout | Apache Storm | |
| NullStruct | Class | backtype.storm.generated | Apache Storm | |
| NullStruct ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.NullStruct | Apache Storm |
| NumErrorsChoice | enum NumErrorsChoiceEnum Constant Summary | Class | backtype.storm.generated | Apache Storm |
| OpaqueMemoryTransactionalSpout | This spout only works in local mode. | Class | backtype.storm.testing | Apache Storm |
| OpaquePartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |
| OutputCollector | This output collector exposes the API for emitting tuples from an IRichBolt. | Class | backtype.storm.task | Apache Storm |
| OutputFieldsDeclarer | Interface | backtype.storm.topology | Apache Storm | |
| OutputFieldsGetter | Class | backtype.storm.topology | Apache Storm | |
| PartialKeyGrouping | Class | backtype.storm.grouping | Apache Storm | |
| PartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |
| PrepareBatchBolt | Class | backtype.storm.testing | Apache Storm | |
| PrepareRequest | Class | backtype.storm.drpc | Apache Storm | |
| PythonShellMetricsBolt | Class | backtype.storm.testing | Apache Storm | |
| PythonShellMetricsSpout | Class | backtype.storm.testing | Apache Storm | |
| RawMultiScheme | Class | backtype.storm.spout | Apache Storm | |
| RawScheme | Class | backtype.storm.spout | Apache Storm | |
| RebalanceOptions | Class | backtype.storm.generated | Apache Storm | |
| RebalanceOptions ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.RebalanceOptions | Apache Storm |
| ReducedMetric | Class | backtype.storm.metric.api | Apache Storm | |
| ReducedShellMetric | Class | backtype.storm.metric.api.rpc | Apache Storm | |
| RegisteredGlobalState | This class is used as part of testing Storm. | Class | backtype.storm.utils | Apache Storm |
| ReportedFailedException | Class | backtype.storm.topology | Apache Storm | |
| ReqContext | context request context includes info about (1) remote address, | Class | backtype.storm.security.auth | Apache Storm |
| ReturnResults | Class | backtype.storm.drpc | Apache Storm | |
| RichShellBolt | Class | backtype.storm.clojure | Apache Storm | |
| RichShellSpout | Class | backtype.storm.clojure | Apache Storm | |
| RotatingMap | Expires keys that have not been updated in the configured number of seconds. | Class | backtype.storm.utils | Apache Storm |
| RotatingMap .ExpiredCallback | Skip navigation linksOverviewPackageClassUseTreeDeprecatedIndexHelp | Interface | backtype.storm.utils.RotatingMap | Apache Storm |
| RotatingTransactionalState | A map from txid to a value. | Class | backtype.storm.transactional.state | Apache Storm |
| RotatingTransactionalState .StateInitializer | Interface | backtype.storm.transactional.state.RotatingTransactionalState | Apache Storm | |
| SaslMessageToken | Send and receive SASL tokens. | Class | backtype.storm.messaging.netty | Apache Storm |
| SaslNettyClient | Class | backtype.storm.messaging.netty | Apache Storm | |
| SaslStormClientHandler | Class | backtype.storm.messaging.netty | Apache Storm | |
| SaslStormServerAuthorizeHandler | Authorize or deny client requests based on existence and completeness of client's SASL authentication. | Class | backtype.storm.messaging.netty | Apache Storm |
| SaslStormServerHandler | Class | backtype.storm.messaging.netty | Apache Storm | |
| SaslTransportPlugin | Base class for SASL authentication plugin. | Class | backtype.storm.security.auth | Apache Storm |
| SaslTransportPlugin .User | Class | backtype.storm.security.auth.SaslTransportPlugin | Apache Storm | |
| SchedulerAssignment | Return the executors covered by this assignmentsMap | Interface | backtype.storm.scheduler | Apache Storm |
| SchedulerAssignmentImpl | Class | backtype.storm.scheduler | Apache Storm | |
| Scheme | Interface | backtype.storm.spout | Apache Storm | |
| SchemeAsMultiScheme | Class | backtype.storm.spout | Apache Storm | |
| SerializableSerializer | Class | backtype.storm.serialization | Apache Storm | |
| SerializationDelegate | Allow Utils to delegate meta serialization. | Interface | backtype.storm.serialization | Apache Storm |
| SerializationFactory | Class | backtype.storm.serialization | Apache Storm | |
| SerializationFactory .IdDictionary | Class | backtype.storm.serialization.SerializationFactory | Apache Storm | |
| ServerCallbackHandler | Class | backtype.storm.security.auth.digest | Apache Storm | |
| ServerCallbackHandler | Class | backtype.storm.security.auth.kerberos | Apache Storm | |
| ServiceRegistry | Class | backtype.storm.utils | Apache Storm | |
| ShellBasedGroupsMapping | Class | backtype.storm.security.auth | Apache Storm | |
| ShellBolt | A bolt that shells out to another process to process tuples. | Class | backtype.storm.task | Apache Storm |
| ShellComponent | Class | backtype.storm.generated | Apache Storm | |
| ShellComponent ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.ShellComponent | Apache Storm |
| ShellMsg | ShellMsg is an object that represents the data sent to a shell component from a process that implements a multi-language protocol. | Class | backtype.storm.multilang | Apache Storm |
| ShellMsg .ShellLogLevel | Returns the enum constant of this type with the specified name. | Class | backtype.storm.multilang.ShellMsg | Apache Storm |
| ShellProcess | Class | backtype.storm.utils | Apache Storm | |
| ShellSpout | Class | backtype.storm.spout | Apache Storm | |
| ShellUtils | Class | backtype.storm.utils | Apache Storm | |
| ShellUtils .ExitCodeException | This is an IOException with exit code added. | Class | backtype.storm.utils.ShellUtils | Apache Storm |
| ShellUtils .OSType | Returns the enum constant of this type with the specified name. | Class | backtype.storm.utils.ShellUtils | Apache Storm |
| ShellUtils .ShellCommandExecutor | A simple shell command executor. | Class | backtype.storm.utils.ShellUtils | Apache Storm |
| SimpleACLAuthorizer | Class | backtype.storm.security.auth.authorizer | Apache Storm | |
| SimpleTransportPlugin | Simple transport for Thrift plugin. | Class | backtype.storm.security.auth | Apache Storm |
| SimpleWhitelistAuthorizer | An authorization implementation that simply checks a whitelist of users that are allowed to use the cluster. | Class | backtype.storm.security.auth.authorizer | Apache Storm |
| SingleUserPrincipal | A Principal that represents a user. | Class | backtype.storm.security.auth | Apache Storm |
| SingleUserSimpleTransport | Class | backtype.storm.testing | Apache Storm | |
| SleepSpoutWaitStrategy | Class | backtype.storm.spout | Apache Storm | |
| SpoutAckInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| SpoutDeclarer | Interface | backtype.storm.topology | Apache Storm | |
| SpoutFailInfo | Class | backtype.storm.hooks.info | Apache Storm | |
| SpoutMsg | SpoutMsg is an object that represents the data sent from a shell spout to a process that implements a multi-language spout. | Class | backtype.storm.multilang | Apache Storm |
| SpoutOutputCollector | This output collector exposes the API for emitting tuples from an IRichSpout. | Class | backtype.storm.spout | Apache Storm |
| SpoutSpec | Class | backtype.storm.generated | Apache Storm | |
| SpoutSpec ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.SpoutSpec | Apache Storm |
| SpoutStats | Class | backtype.storm.generated | Apache Storm | |
| SpoutStats ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.SpoutStats | Apache Storm |
| SpoutTracker | Class | backtype.storm.testing | Apache Storm | |
| StateMetric | Class | backtype.storm.metric.api | Apache Storm | |
| StateSpoutOutputCollector | Class | backtype.storm.state | Apache Storm | |
| StateSpoutSpec | Class | backtype.storm.generated | Apache Storm | |
| StateSpoutSpec ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.StateSpoutSpec | Apache Storm |
| StormBoundedExponentialBackoffRetry | Class | backtype.storm.utils | Apache Storm | |
| StormClientErrorHandler | Class | backtype.storm.messaging.netty | Apache Storm | |
| StormSubmitter | Use this class to submit topologies to run on the Storm cluster. | Class | backtype.storm | Apache Storm |
| StormSubmitter .ProgressListener | Interface | backtype.storm.StormSubmitter | Apache Storm | |
| StormTopology | Class | backtype.storm.generated | Apache Storm | |
| StormTopology ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.StormTopology | Apache Storm |
| StreamInfo | Class | backtype.storm.generated | Apache Storm | |
| StreamInfo ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.StreamInfo | Apache Storm |
| SubmitOptions | Class | backtype.storm.generated | Apache Storm | |
| SubmitOptions ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.SubmitOptions | Apache Storm |
| SupervisorDetails | Class | backtype.storm.scheduler | Apache Storm | |
| SupervisorSummary | Class | backtype.storm.generated | Apache Storm | |
| SupervisorSummary ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.SupervisorSummary | Apache Storm |
| SynchronizeOutputCollector | Class | backtype.storm.state | Apache Storm | |
| SystemBolt | Class | backtype.storm.metric | Apache Storm | |
| TaskBundle | Class | backtype.storm.planner | Apache Storm | |
| TaskMessage | Class | backtype.storm.messaging | Apache Storm | |
| TBackoffConnect | Class | backtype.storm.security.auth | Apache Storm | |
| TestAggregatesCounter | Class | backtype.storm.testing | Apache Storm | |
| TestConfBolt | Class | backtype.storm.testing | Apache Storm | |
| TestEventLogSpout | Class | backtype.storm.testing | Apache Storm | |
| TestEventOrderCheckBolt | Class | backtype.storm.testing | Apache Storm | |
| TestGlobalCount | Class | backtype.storm.testing | Apache Storm | |
| TestJob | This is the core interface for the storm java testing, usually we put our java unit testing logic in the run method. | Interface | backtype.storm.testing | Apache Storm |
| TestKryoDecorator | Class | backtype.storm.testing | Apache Storm | |
| TestPlannerBolt | Class | backtype.storm.testing | Apache Storm | |
| TestPlannerSpout | Class | backtype.storm.testing | Apache Storm | |
| TestSerObject | Class | backtype.storm.testing | Apache Storm | |
| TestTransactionalState | Facilitates testing of non-public methods in the parent class. | Class | backtype.storm.transactional.state | Apache Storm |
| TestUtils | Class | backtype.storm.utils | Apache Storm | |
| TestWordCounter | Class | backtype.storm.testing | Apache Storm | |
| TestWordSpout | Class | backtype.storm.testing | Apache Storm | |
| ThriftClient | Class | backtype.storm.security.auth | Apache Storm | |
| ThriftConnectionType | enum ThriftConnectionTypeThe purpose for which the Thrift server is created. | Class | backtype.storm.security.auth | Apache Storm |
| ThriftServer | Class | backtype.storm.security.auth | Apache Storm | |
| ThriftTopologyUtils | Class | backtype.storm.utils | Apache Storm | |
| Time | Class | backtype.storm.utils | Apache Storm | |
| TimeCacheMap | Expires keys that have not been updated in the configured number of seconds. | Class | backtype.storm.utils | Apache Storm |
| TimeCacheMap .ExpiredCallback | Skip navigation linksOverviewPackageClassUseTreeDeprecatedIndexHelp | Interface | backtype.storm.utils.TimeCacheMap | Apache Storm |
| Topologies | Class | backtype.storm.scheduler | Apache Storm | |
| TopologyBuilder | TopologyBuilder exposes the Java API for specifying a topology for Storm to execute. | Class | backtype.storm.topology | Apache Storm |
| TopologyContext | A TopologyContext is given to bolts and spouts in their "prepare" and "open" methods, respectively. | Class | backtype.storm.task | Apache Storm |
| TopologyDetails | Class | backtype.storm.scheduler | Apache Storm | |
| TopologyInfo | Class | backtype.storm.generated | Apache Storm | |
| TopologyInfo ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.TopologyInfo | Apache Storm |
| TopologyInitialStatus | enum TopologyInitialStatusEnum Constant Summary | Class | backtype.storm.generated | Apache Storm |
| TopologySummary | Class | backtype.storm.generated | Apache Storm | |
| TopologySummary ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | backtype.storm.generated.TopologySummary | Apache Storm |
| TrackedTopology | Class | backtype.storm.testing | Apache Storm | |
| TransactionalSpoutBatchExecutor | Class | backtype.storm.transactional | Apache Storm | |
| TransactionalSpoutCoordinator | Class | backtype.storm.transactional | Apache Storm | |
| TransactionalState | Class | backtype.storm.transactional.state | Apache Storm | |
| TransactionalTopologyBuilder | Trident subsumes the functionality provided by transactional topologies, so this class is deprecated. | Class | backtype.storm.transactional | Apache Storm |
| TransactionAttempt | Class | backtype.storm.transactional | Apache Storm | |
| TransferDrainer | Class | backtype.storm.utils | Apache Storm | |
| TransportFactory | Class | backtype.storm.messaging | Apache Storm | |
| Tuple | The tuple is the main data structure in Storm. | Interface | backtype.storm.tuple | Apache Storm |
| TupleCaptureBolt | Class | backtype.storm.testing | Apache Storm | |
| TupleImpl | Class | backtype.storm.tuple | Apache Storm | |
| Utils | Class | backtype.storm.utils | Apache Storm | |
| Values | A convenience class for making tuple values using new Values("field1", 2, 3)See Also:Serialized Form | Class | backtype.storm.tuple | Apache Storm |
| VersionedStore | Class | backtype.storm.utils | Apache Storm | |
| VersionInfo | Class | backtype.storm.utils | Apache Storm | |
| WindowedTimeThrottler | Class | backtype.storm.utils | Apache Storm | |
| WorkerSlot | Class | backtype.storm.scheduler | Apache Storm | |
| WorkerTopologyContext | Class | backtype.storm.task | Apache Storm | |
| WritableUtils | Class | backtype.storm.utils | Apache Storm | |
| ZookeeperAuthInfo | Class | backtype.storm.utils | Apache Storm | |
| ZookeeperServerCnxnFactory | Class | backtype.storm.utils | Apache Storm | |