backtype.storm.generated

Interfaces

• DistributedRPC.AsyncIface
• DistributedRPC.Iface
• DistributedRPCInvocations.AsyncIface
• DistributedRPCInvocations.Iface
• Nimbus.AsyncIface
• Nimbus.Iface

Classes

• Assignment
• Bolt
• BoltStats
• ClusterSummary
• ClusterWorkerHeartbeat
• ComponentCommon
• ComponentObject
• Credentials
• DistributedRPC
• DistributedRPC.AsyncClient
• DistributedRPC.AsyncClient.execute_call
• DistributedRPC.AsyncClient.Factory
• DistributedRPC.AsyncProcessor
• DistributedRPC.AsyncProcessor.execute
• DistributedRPC.Client
• DistributedRPC.Client.Factory
• DistributedRPC.execute_args
• DistributedRPC.execute_result
• DistributedRPC.Processor
• DistributedRPC.Processor.execute
• DistributedRPCInvocations
• DistributedRPCInvocations.AsyncClient
• DistributedRPCInvocations.AsyncClient.Factory
• DistributedRPCInvocations.AsyncClient.failRequest_call
• DistributedRPCInvocations.AsyncClient.fetchRequest_call
• DistributedRPCInvocations.AsyncClient.result_call
• DistributedRPCInvocations.AsyncProcessor
• DistributedRPCInvocations.AsyncProcessor.failRequest
• DistributedRPCInvocations.AsyncProcessor.fetchRequest
• DistributedRPCInvocations.AsyncProcessor.result
• DistributedRPCInvocations.Client
• DistributedRPCInvocations.Client.Factory
• DistributedRPCInvocations.failRequest_args
• DistributedRPCInvocations.failRequest_result
• DistributedRPCInvocations.fetchRequest_args
• DistributedRPCInvocations.fetchRequest_result
• DistributedRPCInvocations.Processor
• DistributedRPCInvocations.Processor.failRequest
• DistributedRPCInvocations.Processor.fetchRequest
• DistributedRPCInvocations.Processor.result
• DistributedRPCInvocations.result_args
• DistributedRPCInvocations.result_result
• DRPCRequest
• ErrorInfo
• ExecutorInfo
• ExecutorSpecificStats
• ExecutorStats
• ExecutorSummary
• GetInfoOptions
• GlobalStreamId
• Grouping
• JavaObject
• JavaObjectArg
• KillOptions
• LocalAssignment
• LocalStateData
• LSApprovedWorkers
• LSSupervisorAssignments
• LSSupervisorId
• LSWorkerHeartbeat
• Nimbus
• Nimbus.activate_args
• Nimbus.activate_result
• Nimbus.AsyncClient
• Nimbus.AsyncClient.activate_call
• Nimbus.AsyncClient.beginFileDownload_call
• Nimbus.AsyncClient.beginFileUpload_call
• Nimbus.AsyncClient.deactivate_call
• Nimbus.AsyncClient.downloadChunk_call
• Nimbus.AsyncClient.Factory
• Nimbus.AsyncClient.finishFileUpload_call
• Nimbus.AsyncClient.getClusterInfo_call
• Nimbus.AsyncClient.getNimbusConf_call
• Nimbus.AsyncClient.getTopology_call
• Nimbus.AsyncClient.getTopologyConf_call
• Nimbus.AsyncClient.getTopologyInfo_call
• Nimbus.AsyncClient.getTopologyInfoWithOpts_call
• Nimbus.AsyncClient.getUserTopology_call
• Nimbus.AsyncClient.killTopology_call
• Nimbus.AsyncClient.killTopologyWithOpts_call
• Nimbus.AsyncClient.rebalance_call
• Nimbus.AsyncClient.submitTopology_call
• Nimbus.AsyncClient.submitTopologyWithOpts_call
• Nimbus.AsyncClient.uploadChunk_call
• Nimbus.AsyncClient.uploadNewCredentials_call
• Nimbus.AsyncProcessor
• Nimbus.AsyncProcessor.activate
• Nimbus.AsyncProcessor.beginFileDownload
• Nimbus.AsyncProcessor.beginFileUpload
• Nimbus.AsyncProcessor.deactivate
• Nimbus.AsyncProcessor.downloadChunk
• Nimbus.AsyncProcessor.finishFileUpload
• Nimbus.AsyncProcessor.getClusterInfo
• Nimbus.AsyncProcessor.getNimbusConf
• Nimbus.AsyncProcessor.getTopology
• Nimbus.AsyncProcessor.getTopologyConf
• Nimbus.AsyncProcessor.getTopologyInfo
• Nimbus.AsyncProcessor.getTopologyInfoWithOpts
• Nimbus.AsyncProcessor.getUserTopology
• Nimbus.AsyncProcessor.killTopology
• Nimbus.AsyncProcessor.killTopologyWithOpts
• Nimbus.AsyncProcessor.rebalance
• Nimbus.AsyncProcessor.submitTopology
• Nimbus.AsyncProcessor.submitTopologyWithOpts
• Nimbus.AsyncProcessor.uploadChunk
• Nimbus.AsyncProcessor.uploadNewCredentials
• Nimbus.beginFileDownload_args
• Nimbus.beginFileDownload_result
• Nimbus.beginFileUpload_args
• Nimbus.beginFileUpload_result
• Nimbus.Client
• Nimbus.Client.Factory
• Nimbus.deactivate_args
• Nimbus.deactivate_result
• Nimbus.downloadChunk_args
• Nimbus.downloadChunk_result
• Nimbus.finishFileUpload_args
• Nimbus.finishFileUpload_result
• Nimbus.getClusterInfo_args
• Nimbus.getClusterInfo_result
• Nimbus.getNimbusConf_args
• Nimbus.getNimbusConf_result
• Nimbus.getTopology_args
• Nimbus.getTopology_result
• Nimbus.getTopologyConf_args
• Nimbus.getTopologyConf_result
• Nimbus.getTopologyInfo_args
• Nimbus.getTopologyInfo_result
• Nimbus.getTopologyInfoWithOpts_args
• Nimbus.getTopologyInfoWithOpts_result
• Nimbus.getUserTopology_args
• Nimbus.getUserTopology_result
• Nimbus.killTopology_args
• Nimbus.killTopology_result
• Nimbus.killTopologyWithOpts_args
• Nimbus.killTopologyWithOpts_result
• Nimbus.Processor
• Nimbus.Processor.activate
• Nimbus.Processor.beginFileDownload
• Nimbus.Processor.beginFileUpload
• Nimbus.Processor.deactivate
• Nimbus.Processor.downloadChunk
• Nimbus.Processor.finishFileUpload
• Nimbus.Processor.getClusterInfo
• Nimbus.Processor.getNimbusConf
• Nimbus.Processor.getTopology
• Nimbus.Processor.getTopologyConf
• Nimbus.Processor.getTopologyInfo
• Nimbus.Processor.getTopologyInfoWithOpts
• Nimbus.Processor.getUserTopology
• Nimbus.Processor.killTopology
• Nimbus.Processor.killTopologyWithOpts
• Nimbus.Processor.rebalance
• Nimbus.Processor.submitTopology
• Nimbus.Processor.submitTopologyWithOpts
• Nimbus.Processor.uploadChunk
• Nimbus.Processor.uploadNewCredentials
• Nimbus.rebalance_args
• Nimbus.rebalance_result
• Nimbus.submitTopology_args
• Nimbus.submitTopology_result
• Nimbus.submitTopologyWithOpts_args
• Nimbus.submitTopologyWithOpts_result
• Nimbus.uploadChunk_args
• Nimbus.uploadChunk_result
• Nimbus.uploadNewCredentials_args
• Nimbus.uploadNewCredentials_result
• NodeInfo
• NullStruct
• RebalanceOptions
• ShellComponent
• SpoutSpec
• SpoutStats
• StateSpoutSpec
• StormBase
• StormTopology
• StreamInfo
• SubmitOptions
• SupervisorInfo
• SupervisorSummary
• ThriftSerializedObject
• TopologyActionOptions
• TopologyInfo
• TopologySummary

Enums

• AlreadyAliveException._Fields
• Assignment._Fields
• AuthorizationException._Fields
• Bolt._Fields
• BoltStats._Fields
• ClusterSummary._Fields
• ClusterWorkerHeartbeat._Fields
• ComponentCommon._Fields
• ComponentObject._Fields
• Credentials._Fields
• DistributedRPC.execute_args._Fields
• DistributedRPC.execute_result._Fields
• DistributedRPCInvocations.failRequest_args._Fields
• DistributedRPCInvocations.failRequest_result._Fields
• DistributedRPCInvocations.fetchRequest_args._Fields
• DistributedRPCInvocations.fetchRequest_result._Fields
• DistributedRPCInvocations.result_args._Fields
• DistributedRPCInvocations.result_result._Fields
• DRPCExecutionException._Fields
• DRPCRequest._Fields
• ErrorInfo._Fields
• ExecutorInfo._Fields
• ExecutorSpecificStats._Fields
• ExecutorStats._Fields
• ExecutorSummary._Fields
• GetInfoOptions._Fields
• GlobalStreamId._Fields
• Grouping._Fields
• InvalidTopologyException._Fields
• JavaObject._Fields
• JavaObjectArg._Fields
• KillOptions._Fields
• LocalAssignment._Fields
• LocalStateData._Fields
• LSApprovedWorkers._Fields
• LSSupervisorAssignments._Fields
• LSSupervisorId._Fields
• LSWorkerHeartbeat._Fields
• Nimbus.activate_args._Fields
• Nimbus.activate_result._Fields
• Nimbus.beginFileDownload_args._Fields
• Nimbus.beginFileDownload_result._Fields
• Nimbus.beginFileUpload_args._Fields
• Nimbus.beginFileUpload_result._Fields
• Nimbus.deactivate_args._Fields
• Nimbus.deactivate_result._Fields
• Nimbus.downloadChunk_args._Fields
• Nimbus.downloadChunk_result._Fields
• Nimbus.finishFileUpload_args._Fields
• Nimbus.finishFileUpload_result._Fields
• Nimbus.getClusterInfo_args._Fields
• Nimbus.getClusterInfo_result._Fields
• Nimbus.getNimbusConf_args._Fields
• Nimbus.getNimbusConf_result._Fields
• Nimbus.getTopology_args._Fields
• Nimbus.getTopology_result._Fields
• Nimbus.getTopologyConf_args._Fields
• Nimbus.getTopologyConf_result._Fields
• Nimbus.getTopologyInfo_args._Fields
• Nimbus.getTopologyInfo_result._Fields
• Nimbus.getTopologyInfoWithOpts_args._Fields
• Nimbus.getTopologyInfoWithOpts_result._Fields
• Nimbus.getUserTopology_args._Fields
• Nimbus.getUserTopology_result._Fields
• Nimbus.killTopology_args._Fields
• Nimbus.killTopology_result._Fields
• Nimbus.killTopologyWithOpts_args._Fields
• Nimbus.killTopologyWithOpts_result._Fields
• Nimbus.rebalance_args._Fields
• Nimbus.rebalance_result._Fields
• Nimbus.submitTopology_args._Fields
• Nimbus.submitTopology_result._Fields
• Nimbus.submitTopologyWithOpts_args._Fields
• Nimbus.submitTopologyWithOpts_result._Fields
• Nimbus.uploadChunk_args._Fields
• Nimbus.uploadChunk_result._Fields
• Nimbus.uploadNewCredentials_args._Fields
• Nimbus.uploadNewCredentials_result._Fields
• NodeInfo._Fields
• NotAliveException._Fields
• NullStruct._Fields
• NumErrorsChoice
• RebalanceOptions._Fields
• ShellComponent._Fields
• SpoutSpec._Fields
• SpoutStats._Fields
• StateSpoutSpec._Fields
• StormBase._Fields
• StormTopology._Fields
• StreamInfo._Fields
• SubmitOptions._Fields
• SupervisorInfo._Fields
• SupervisorSummary._Fields
• ThriftSerializedObject._Fields
• TopologyActionOptions._Fields
• TopologyInfo._Fields
• TopologyInitialStatus
• TopologyStatus
• TopologySummary._Fields

Exceptions

• AlreadyAliveException
• AuthorizationException
• DRPCExecutionException
• InvalidTopologyException
• NotAliveException