Serialized Form (storm-core-java-api 0.11.0 API)

Package backtype.storm
- Class backtype.storm.Config extends HashMap<String,Object> implements Serializable
  
  serialVersionUID:
  
  -1550278723792864455L
Package backtype.storm.clojure
- Class backtype.storm.clojure.ClojureBolt extends Object implements Serializable
  - Serialized Fields
    - _fields
```
Map<K,V> _fields
```
    - _fnSpec
```
List<E> _fnSpec
```
    - _confSpec
```
List<E> _confSpec
```
    - _params
```
List<E> _params
```
    - _bolt
```
IBolt _bolt
```
- Class backtype.storm.clojure.ClojureSpout extends Object implements Serializable
  - Serialized Fields
    - _fields
```
Map<K,V> _fields
```
    - _fnSpec
```
List<E> _fnSpec
```
    - _confSpec
```
List<E> _confSpec
```
    - _params
```
List<E> _params
```
    - _spout
```
ISpout _spout
```
- Class backtype.storm.clojure.RichShellBolt extends ShellBolt implements Serializable
  - Serialized Fields
    - _outputs
```
Map<K,V> _outputs
```
- Class backtype.storm.clojure.RichShellSpout extends ShellSpout implements Serializable
  - Serialized Fields
    - _outputs
```
Map<K,V> _outputs
```
Package backtype.storm.coordination
- Class backtype.storm.coordination.BatchBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - _boltSer
```
byte[] _boltSer
```
    - _openTransactions
```
Map<K,V> _openTransactions
```
    - _conf
```
Map<K,V> _conf
```
    - _context
```
TopologyContext _context
```
    - _collector
```
BatchOutputCollectorImpl _collector
```
- Class backtype.storm.coordination.CoordinatedBolt extends Object implements Serializable
  - Serialized Fields
    - _sourceArgs
```
Map<K,V> _sourceArgs
```
    - _idStreamSpec
```
CoordinatedBolt.IdStreamSpec _idStreamSpec
```
    - _delegate
```
IRichBolt _delegate
```
    - _numSourceReports
```
Integer _numSourceReports
```
    - _countOutTasks
```
List<E> _countOutTasks
```
    - _collector
```
OutputCollector _collector
```
    - _tracked
```
TimeCacheMap<K,V> _tracked
```
- Class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec extends Object implements Serializable
  - Serialized Fields
    - _id
```
GlobalStreamId _id
```
- Class backtype.storm.coordination.CoordinatedBolt.SourceArgs extends Object implements Serializable
  - Serialized Fields
    - singleCount
```
boolean singleCount
```
Package backtype.storm.drpc
- Class backtype.storm.drpc.DRPCSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  2387848310969237877L
  - Serialized Fields
    - _collector
```
SpoutOutputCollector _collector
```
    - _clients
```
List<E> _clients
```
    - _function
```
String _function
```
    - _local_drpc_id
```
String _local_drpc_id
```
- Class backtype.storm.drpc.JoinResult extends BaseRichBolt implements Serializable
  - Serialized Fields
    - returnComponent
```
String returnComponent
```
    - returns
```
Map<K,V> returns
```
    - results
```
Map<K,V> results
```
    - _collector
```
OutputCollector _collector
```
- Class backtype.storm.drpc.KeyedFairBolt extends Object implements Serializable
  - Serialized Fields
    - _delegate
```
IRichBolt _delegate
```
    - _rrQueue
```
KeyedRoundRobinQueue<V> _rrQueue
```
    - _executor
```
Thread _executor
```
    - _callback
```
CoordinatedBolt.FinishedCallback _callback
```
- Class backtype.storm.drpc.PrepareRequest extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - rand
```
Random rand
```
- Class backtype.storm.drpc.ReturnResults extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  -774882142710631591L
  - Serialized Fields
    - _collector
```
OutputCollector _collector
```
    - local
```
boolean local
```
    - _conf
```
Map<K,V> _conf
```
    - _clients
```
Map<K,V> _clients
```

Package backtype.storm.generated

Class backtype.storm.generated.AlreadyAliveException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- msg
```
String msg
```

Class backtype.storm.generated.Assignment extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

master_code_dir
```
String master_code_dir
```
node_host
```
Map<K,V> node_host
```
executor_node_port
```
Map<K,V> executor_node_port
```
executor_start_time_secs
```
Map<K,V> executor_start_time_secs
```

Class backtype.storm.generated.AuthorizationException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- msg
```
String msg
```

Class backtype.storm.generated.Bolt extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

bolt_object
```
ComponentObject bolt_object
```
common
```
ComponentCommon common
```

Class backtype.storm.generated.BoltStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

acked
```
Map<K,V> acked
```
failed
```
Map<K,V> failed
```
process_ms_avg
```
Map<K,V> process_ms_avg
```
executed
```
Map<K,V> executed
```
execute_ms_avg
```
Map<K,V> execute_ms_avg
```

Class backtype.storm.generated.ClusterSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

supervisors
```
List<E> supervisors
```
nimbus_uptime_secs
```
int nimbus_uptime_secs
```
topologies
```
List<E> topologies
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ClusterWorkerHeartbeat extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

storm_id
```
String storm_id
```
executor_stats
```
Map<K,V> executor_stats
```
time_secs
```
int time_secs
```
uptime_secs
```
int uptime_secs
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ComponentCommon extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

inputs
```
Map<K,V> inputs
```
streams
```
Map<K,V> streams
```
parallelism_hint
```
int parallelism_hint
```
json_conf
```
String json_conf
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ComponentObject extends org.apache.thrift.TUnion<ComponentObject,ComponentObject._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.Credentials extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- creds
```
Map<K,V> creds
```

Class backtype.storm.generated.DistributedRPC.execute_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- functionName
```
String functionName
```
- funcArgs
```
String funcArgs
```

Class backtype.storm.generated.DistributedRPC.execute_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
String success
```
e
```
DRPCExecutionException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.DistributedRPCInvocations.failRequest_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.DistributedRPCInvocations.failRequest_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- aze
```
AuthorizationException aze
```

Class backtype.storm.generated.DistributedRPCInvocations.fetchRequest_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- functionName
```
String functionName
```

Class backtype.storm.generated.DistributedRPCInvocations.fetchRequest_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
DRPCRequest success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.DistributedRPCInvocations.result_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```
- result
```
String result
```

Class backtype.storm.generated.DistributedRPCInvocations.result_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- aze
```
AuthorizationException aze
```

Class backtype.storm.generated.DRPCExecutionException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- msg
```
String msg
```

Class backtype.storm.generated.DRPCRequest extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- func_args
```
String func_args
```
- request_id
```
String request_id
```

Class backtype.storm.generated.ErrorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

error
```
String error
```
error_time_secs
```
int error_time_secs
```
host
```
String host
```
port
```
int port
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ExecutorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- task_start
```
int task_start
```
- task_end
```
int task_end
```
- __isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ExecutorSpecificStats extends org.apache.thrift.TUnion<ExecutorSpecificStats,ExecutorSpecificStats._Fields> implements Serializable
- Serialization Methods
  - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
    Throws:
    
    IOException
    
    ClassNotFoundException
  - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
    Throws:
    
    IOException

Class backtype.storm.generated.ExecutorStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

emitted
```
Map<K,V> emitted
```
transferred
```
Map<K,V> transferred
```
specific
```
ExecutorSpecificStats specific
```
rate
```
double rate
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ExecutorSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

executor_info
```
ExecutorInfo executor_info
```
component_id
```
String component_id
```
host
```
String host
```
port
```
int port
```
uptime_secs
```
int uptime_secs
```
stats
```
ExecutorStats stats
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.GetInfoOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- num_err_choice
```
NumErrorsChoice num_err_choice
```

Class backtype.storm.generated.GlobalStreamId extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- componentId
```
String componentId
```
- streamId
```
String streamId
```

Class backtype.storm.generated.Grouping extends org.apache.thrift.TUnion<Grouping,Grouping._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.InvalidTopologyException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- msg
```
String msg
```

Class backtype.storm.generated.JavaObject extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- full_class_name
```
String full_class_name
```
- args_list
```
List<E> args_list
```

Class backtype.storm.generated.JavaObjectArg extends org.apache.thrift.TUnion<JavaObjectArg,JavaObjectArg._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.KillOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- wait_secs
```
int wait_secs
```
- __isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.LocalAssignment extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- topology_id
```
String topology_id
```
- executors
```
List<E> executors
```

Class backtype.storm.generated.LocalStateData extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- serialized_parts
```
Map<K,V> serialized_parts
```

Class backtype.storm.generated.LSApprovedWorkers extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- approved_workers
```
Map<K,V> approved_workers
```

Class backtype.storm.generated.LSSupervisorAssignments extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- assignments
```
Map<K,V> assignments
```

Class backtype.storm.generated.LSSupervisorId extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- supervisor_id
```
String supervisor_id
```

Class backtype.storm.generated.LSWorkerHeartbeat extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

time_secs
```
int time_secs
```
topology_id
```
String topology_id
```
executors
```
List<E> executors
```
port
```
int port
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.Nimbus.activate_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```

Class backtype.storm.generated.Nimbus.activate_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.beginFileDownload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- file
```
String file
```

Class backtype.storm.generated.Nimbus.beginFileDownload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
String success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.beginFileUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.Nimbus.beginFileUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
String success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.deactivate_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```

Class backtype.storm.generated.Nimbus.deactivate_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.downloadChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.Nimbus.downloadChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
ByteBuffer success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.finishFileUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- location
```
String location
```

Class backtype.storm.generated.Nimbus.finishFileUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getClusterInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.Nimbus.getClusterInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
ClusterSummary success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getNimbusConf_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.Nimbus.getNimbusConf_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
String success
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.Nimbus.getTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
StormTopology success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getTopologyConf_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.Nimbus.getTopologyConf_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
String success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getTopologyInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.Nimbus.getTopologyInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
TopologyInfo success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getTopologyInfoWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```
- options
```
GetInfoOptions options
```

Class backtype.storm.generated.Nimbus.getTopologyInfoWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
TopologyInfo success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.getUserTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- id
```
String id
```

Class backtype.storm.generated.Nimbus.getUserTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

success
```
StormTopology success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.killTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```

Class backtype.storm.generated.Nimbus.killTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.killTopologyWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```
- options
```
KillOptions options
```

Class backtype.storm.generated.Nimbus.killTopologyWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.rebalance_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```
- options
```
RebalanceOptions options
```

Class backtype.storm.generated.Nimbus.rebalance_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
ite
```
InvalidTopologyException ite
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.submitTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

name
```
String name
```
uploadedJarLocation
```
String uploadedJarLocation
```
jsonConf
```
String jsonConf
```
topology
```
StormTopology topology
```

Class backtype.storm.generated.Nimbus.submitTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
AlreadyAliveException e
```
ite
```
InvalidTopologyException ite
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.submitTopologyWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

name
```
String name
```
uploadedJarLocation
```
String uploadedJarLocation
```
jsonConf
```
String jsonConf
```
topology
```
StormTopology topology
```
options
```
SubmitOptions options
```

Class backtype.storm.generated.Nimbus.submitTopologyWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
AlreadyAliveException e
```
ite
```
InvalidTopologyException ite
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.uploadChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- location
```
String location
```
- chunk
```
ByteBuffer chunk
```

Class backtype.storm.generated.Nimbus.uploadChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- aze
```
AuthorizationException aze
```

Class backtype.storm.generated.Nimbus.uploadNewCredentials_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```
- creds
```
Credentials creds
```

Class backtype.storm.generated.Nimbus.uploadNewCredentials_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

e
```
NotAliveException e
```
ite
```
InvalidTopologyException ite
```
aze
```
AuthorizationException aze
```

Class backtype.storm.generated.NodeInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- node
```
String node
```
- port
```
Set<E> port
```

Class backtype.storm.generated.NotAliveException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- msg
```
String msg
```

Class backtype.storm.generated.NullStruct extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Class backtype.storm.generated.RebalanceOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

wait_secs
```
int wait_secs
```
num_workers
```
int num_workers
```
num_executors
```
Map<K,V> num_executors
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ShellComponent extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- execution_command
```
String execution_command
```
- script
```
String script
```

Class backtype.storm.generated.SpoutSpec extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

spout_object
```
ComponentObject spout_object
```
common
```
ComponentCommon common
```

Class backtype.storm.generated.SpoutStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

acked
```
Map<K,V> acked
```
failed
```
Map<K,V> failed
```
complete_ms_avg
```
Map<K,V> complete_ms_avg
```

Class backtype.storm.generated.StateSpoutSpec extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

state_spout_object
```
ComponentObject state_spout_object
```
common
```
ComponentCommon common
```

Class backtype.storm.generated.StormBase extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

name
```
String name
```
status
```
TopologyStatus status
```
num_workers
```
int num_workers
```
component_executors
```
Map<K,V> component_executors
```
launch_time_secs
```
int launch_time_secs
```
owner
```
String owner
```

topology_action_options

TopologyActionOptions topology_action_options

prev_status
```
TopologyStatus prev_status
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.StormTopology extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

spouts
```
Map<K,V> spouts
```
bolts
```
Map<K,V> bolts
```
state_spouts
```
Map<K,V> state_spouts
```

Class backtype.storm.generated.StreamInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

output_fields
```
List<E> output_fields
```
direct
```
boolean direct
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.SubmitOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

initial_status
```
TopologyInitialStatus initial_status
```
creds
```
Credentials creds
```

Class backtype.storm.generated.SupervisorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

time_secs
```
long time_secs
```
hostname
```
String hostname
```
assignment_id
```
String assignment_id
```
used_ports
```
List<E> used_ports
```
meta
```
List<E> meta
```
scheduler_meta
```
Map<K,V> scheduler_meta
```
uptime_secs
```
long uptime_secs
```
version
```
String version
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.SupervisorSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

host
```
String host
```
uptime_secs
```
int uptime_secs
```
num_workers
```
int num_workers
```
num_used_workers
```
int num_used_workers
```
supervisor_id
```
String supervisor_id
```
version
```
String version
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.ThriftSerializedObject extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields
- name
```
String name
```
- bits
```
ByteBuffer bits
```

Class backtype.storm.generated.TopologyActionOptions extends org.apache.thrift.TUnion<TopologyActionOptions,TopologyActionOptions._Fields> implements Serializable
- Serialization Methods
  - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
    Throws:
    
    IOException
    
    ClassNotFoundException
  - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
    Throws:
    
    IOException

Class backtype.storm.generated.TopologyInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

id
```
String id
```
name
```
String name
```
uptime_secs
```
int uptime_secs
```
executors
```
List<E> executors
```
status
```
String status
```
errors
```
Map<K,V> errors
```
sched_status
```
String sched_status
```
owner
```
String owner
```
__isset_bitfield
```
byte __isset_bitfield
```

Class backtype.storm.generated.TopologySummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:: IOException; ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:: IOException

Serialized Fields

id
```
String id
```
name
```
String name
```
num_tasks
```
int num_tasks
```
num_executors
```
int num_executors
```
num_workers
```
int num_workers
```
uptime_secs
```
int uptime_secs
```
status
```
String status
```
sched_status
```
String sched_status
```
owner
```
String owner
```
__isset_bitfield
```
byte __isset_bitfield
```

Package backtype.storm.grouping
- Class backtype.storm.grouping.PartialKeyGrouping extends Object implements Serializable
  
  serialVersionUID:
  
  -447379837314000353L
  - Serialized Fields
    - targetTasks
```
List<E> targetTasks
```
    - targetTaskStats
```
long[] targetTaskStats
```
    - h1
```
com.google.common.hash.HashFunction h1
```
    - h2
```
com.google.common.hash.HashFunction h2
```
    - fields
```
Fields fields
```
    - outFields
```
Fields outFields
```
Package backtype.storm.metric
- Class backtype.storm.metric.MetricsConsumerBolt extends Object implements Serializable
  - Serialized Fields
    - _metricsConsumer
```
IMetricsConsumer _metricsConsumer
```
    - _consumerClassName
```
String _consumerClassName
```
    - _collector
```
OutputCollector _collector
```
    - _registrationArgument
```
Object _registrationArgument
```
- Class backtype.storm.metric.SystemBolt extends Object implements Serializable
Package backtype.storm.multilang
- Class backtype.storm.multilang.JsonSerializer extends Object implements Serializable
  - Serialized Fields
    - processIn
```
DataOutputStream processIn
```
    - processOut
```
BufferedReader processOut
```
- Class backtype.storm.multilang.NoOutputException extends Exception implements Serializable
Package backtype.storm.planner
- Class backtype.storm.planner.TaskBundle extends Object implements Serializable
  - Serialized Fields
    - task
```
IBolt task
```
    - componentId
```
int componentId
```
Package backtype.storm.spout
- Class backtype.storm.spout.RawMultiScheme extends Object implements Serializable
- Class backtype.storm.spout.RawScheme extends Object implements Serializable
- Class backtype.storm.spout.SchemeAsMultiScheme extends Object implements Serializable
  - Serialized Fields
    - scheme
```
Scheme scheme
```
- Class backtype.storm.spout.ShellSpout extends Object implements Serializable
  - Serialized Fields
    - _collector
```
SpoutOutputCollector _collector
```
    - _command
```
String[] _command
```
    - _process
```
ShellProcess _process
```
    - _context
```
TopologyContext _context
```
    - _spoutMsg
```
SpoutMsg _spoutMsg
```
    - workerTimeoutMills
```
int workerTimeoutMills
```
    - heartBeatExecutorService
```
ScheduledExecutorService heartBeatExecutorService
```
    - lastHeartbeatTimestamp
```
AtomicLong lastHeartbeatTimestamp
```
Package backtype.storm.state

Package backtype.storm.task

Class backtype.storm.task.ShellBolt extends Object implements Serializable

Serialized Fields

_subprocess
```
Process _subprocess
```
_collector
```
OutputCollector _collector
```
_inputs
```
Map<K,V> _inputs
```
_command
```
String[] _command
```
_process
```
ShellProcess _process
```
_running
```
boolean _running
```
_exception
```
Throwable _exception
```
_pendingWrites
```
LinkedBlockingQueue<E> _pendingWrites
```
_rand
```
Random _rand
```
_readerThread
```
Thread _readerThread
```
_writerThread
```
Thread _writerThread
```
_context
```
TopologyContext _context
```
workerTimeoutMills
```
int workerTimeoutMills
```

heartBeatExecutorService

ScheduledExecutorService heartBeatExecutorService

lastHeartbeatTimestamp
```
AtomicLong lastHeartbeatTimestamp
```
sendHeartbeatFlag
```
AtomicBoolean sendHeartbeatFlag
```

Package backtype.storm.testing
- Class backtype.storm.testing.AckFailMapTracker extends Object implements Serializable
  - Serialized Fields
    - _acked
```
String _acked
```
    - _failed
```
String _failed
```
- Class backtype.storm.testing.AckTracker extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
- Class backtype.storm.testing.BatchNumberList extends BaseBatchBolt implements Serializable
  - Serialized Fields
    - _wordComponent
```
String _wordComponent
```
    - word
```
String word
```
    - intSet
```
List<E> intSet
```
    - _collector
```
BatchOutputCollector _collector
```
- Class backtype.storm.testing.BatchProcessWord extends BaseBasicBolt implements Serializable
- Class backtype.storm.testing.BatchRepeatA extends BaseBasicBolt implements Serializable
- Class backtype.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable
  - Serialized Fields
    - _richDelegate
```
IRichBolt _richDelegate
```
- Class backtype.storm.testing.CountingBatchBolt extends BaseBatchBolt implements Serializable
  - Serialized Fields
    - _collector
```
BatchOutputCollector _collector
```
    - _id
```
Object _id
```
    - _count
```
int _count
```
- Class backtype.storm.testing.CountingCommitBolt extends BaseTransactionalBolt implements Serializable
  - Serialized Fields
    - _collector
```
BatchOutputCollector _collector
```
    - _id
```
TransactionAttempt _id
```
    - _count
```
int _count
```
- Class backtype.storm.testing.FeederSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - _id
```
int _id
```
    - _outFields
```
Fields _outFields
```
    - _collector
```
SpoutOutputCollector _collector
```
    - _ackFailDelegate
```
AckFailDelegate _ackFailDelegate
```
- Class backtype.storm.testing.FixedTuple extends Object implements Serializable
  - Serialized Fields
    - stream
```
String stream
```
    - values
```
List<E> values
```
- Class backtype.storm.testing.FixedTupleSpout extends Object implements Serializable
  - Serialized Fields
    - _tuples
```
List<E> _tuples
```
    - _collector
```
SpoutOutputCollector _collector
```
    - _context
```
TopologyContext _context
```
    - _serveTuples
```
List<E> _serveTuples
```
    - _pending
```
Map<K,V> _pending
```
    - _id
```
String _id
```
    - _fieldName
```
String _fieldName
```
- Class backtype.storm.testing.IdentityBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - _fields
```
Fields _fields
```
- Class backtype.storm.testing.KeyedCountingBatchBolt extends BaseBatchBolt implements Serializable
  - Serialized Fields
    - _collector
```
BatchOutputCollector _collector
```
    - _id
```
Object _id
```
    - _counts
```
Map<K,V> _counts
```
- Class backtype.storm.testing.KeyedCountingCommitterBolt extends KeyedCountingBatchBolt implements Serializable
- Class backtype.storm.testing.KeyedSummingBatchBolt extends BaseBatchBolt implements Serializable
  - Serialized Fields
    - _collector
```
BatchOutputCollector _collector
```
    - _id
```
Object _id
```
    - _sums
```
Map<K,V> _sums
```
- Class backtype.storm.testing.MemoryTransactionalSpout extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
    - _finishedPartitionsId
```
String _finishedPartitionsId
```
    - _takeAmt
```
int _takeAmt
```
    - _outFields
```
Fields _outFields
```
    - _initialPartitions
```
Map<K,V> _initialPartitions
```
- Class backtype.storm.testing.NGrouping extends Object implements Serializable
  - Serialized Fields
    - _n
```
int _n
```
    - _outTasks
```
List<E> _outTasks
```
- Class backtype.storm.testing.NonRichBoltTracker extends Object implements Serializable
  - Serialized Fields
    - _delegate
```
IBolt _delegate
```
    - _trackId
```
String _trackId
```
- Class backtype.storm.testing.OpaqueMemoryTransactionalSpout extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
    - _finishedPartitionsId
```
String _finishedPartitionsId
```
    - _disabledId
```
String _disabledId
```
    - _takeAmt
```
int _takeAmt
```
    - _outFields
```
Fields _outFields
```
- Class backtype.storm.testing.PrepareBatchBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - _outFields
```
Fields _outFields
```
- Class backtype.storm.testing.PythonShellMetricsBolt extends ShellBolt implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class backtype.storm.testing.PythonShellMetricsSpout extends ShellSpout implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class backtype.storm.testing.SpoutTracker extends BaseRichSpout implements Serializable
  - Serialized Fields
    - _delegate
```
IRichSpout _delegate
```
    - _tracker
```
backtype.storm.testing.SpoutTracker.SpoutTrackOutputCollector _tracker
```
    - _trackId
```
String _trackId
```
- Class backtype.storm.testing.TestAggregatesCounter extends BaseRichBolt implements Serializable
  - Serialized Fields
    - _counts
```
Map<K,V> _counts
```
    - _collector
```
OutputCollector _collector
```
- Class backtype.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - _componentConf
```
Map<K,V> _componentConf
```
    - _conf
```
Map<K,V> _conf
```
- Class backtype.storm.testing.TestEventLogSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - uid
```
String uid
```
    - totalCount
```
long totalCount
```
    - _collector
```
SpoutOutputCollector _collector
```
    - eventId
```
long eventId
```
    - myCount
```
long myCount
```
    - source
```
int source
```
- Class backtype.storm.testing.TestEventOrderCheckBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - _count
```
int _count
```
    - _collector
```
OutputCollector _collector
```
    - recentEventId
```
Map<K,V> recentEventId
```
- Class backtype.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable
  - Serialized Fields
    - _count
```
int _count
```
    - _collector
```
OutputCollector _collector
```
- Class backtype.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable
- Class backtype.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - _isDistributed
```
boolean _isDistributed
```
    - _outFields
```
Fields _outFields
```
- Class backtype.storm.testing.TestSerObject extends Object implements Serializable
  - Serialized Fields
    - f1
```
int f1
```
    - f2
```
int f2
```
- Class backtype.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - _counts
```
Map<K,V> _counts
```
- Class backtype.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - _isDistributed
```
boolean _isDistributed
```
    - _collector
```
SpoutOutputCollector _collector
```
- Class backtype.storm.testing.TrackedTopology extends HashMap implements Serializable
- Class backtype.storm.testing.TupleCaptureBolt extends Object implements Serializable
  - Serialized Fields
    - _name
```
String _name
```
    - _collector
```
OutputCollector _collector
```
Package backtype.storm.topology
- Class backtype.storm.topology.BasicBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - _bolt
```
IBasicBolt _bolt
```
- Class backtype.storm.topology.FailedException extends RuntimeException implements Serializable
- Class backtype.storm.topology.ReportedFailedException extends FailedException implements Serializable
Package backtype.storm.topology.base
- Class backtype.storm.topology.base.BaseBasicBolt extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BaseBatchBolt extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BaseComponent extends Object implements Serializable
- Class backtype.storm.topology.base.BaseOpaquePartitionedTransactionalSpout extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BasePartitionedTransactionalSpout extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable
- Class backtype.storm.topology.base.BaseTransactionalBolt extends BaseBatchBolt<TransactionAttempt> implements Serializable
- Class backtype.storm.topology.base.BaseTransactionalSpout extends BaseComponent implements Serializable

Package backtype.storm.transactional

Class backtype.storm.transactional.TransactionalSpoutBatchExecutor extends Object implements Serializable
- Serialized Fields
  - _collector
```
BatchOutputCollectorImpl _collector
```
  - _spout
```
ITransactionalSpout<T> _spout
```
  - _emitter
```
ITransactionalSpout.Emitter<X> _emitter
```
  - _activeTransactions
```
TreeMap<K,V> _activeTransactions
```

Class backtype.storm.transactional.TransactionalSpoutCoordinator extends BaseRichSpout implements Serializable

Serialized Fields

_spout
```
ITransactionalSpout<T> _spout
```

_coordinator

ITransactionalSpout.Coordinator<X> _coordinator

_state
```
TransactionalState _state
```

_coordinatorState

RotatingTransactionalState _coordinatorState

_activeTx
```
TreeMap<K,V> _activeTx
```
_collector
```
SpoutOutputCollector _collector
```
_rand
```
Random _rand
```
_currTransaction
```
BigInteger _currTransaction
```
_maxTransactionActive
```
int _maxTransactionActive
```

_initializer

backtype.storm.transactional.TransactionalSpoutCoordinator.StateInitializer _initializer

Package backtype.storm.transactional.partitioned
- Class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IOpaquePartitionedTransactionalSpout<T> _spout
```
- Class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IPartitionedTransactionalSpout<T> _spout
```
Package backtype.storm.tuple
- Class backtype.storm.tuple.Fields extends Object implements Serializable
  - Serialized Fields
    - _fields
```
List<E> _fields
```
    - _index
```
Map<K,V> _index
```
- Class backtype.storm.tuple.Values extends ArrayList<Object> implements Serializable
Package backtype.storm.ui
- Class backtype.storm.ui.InvalidRequestException extends Exception implements Serializable
Package backtype.storm.utils
- Class backtype.storm.utils.Container extends Object implements Serializable
  - Serialized Fields
    - object
```
Object object
```
- Class backtype.storm.utils.ShellProcess extends Object implements Serializable
  - Serialized Fields
    - _subprocess
```
Process _subprocess
```
    - processErrorStream
```
InputStream processErrorStream
```
    - command
```
String[] command
```
    - serializer
```
ISerializer serializer
```
    - pid
```
Number pid
```
    - componentName
```
String componentName
```
- Class backtype.storm.utils.ShellUtils.ExitCodeException extends IOException implements Serializable
  - Serialized Fields
    - exitCode
```
int exitCode
```
Package storm.trident.drpc
- Class storm.trident.drpc.ReturnResultsReducer extends Object implements Serializable
  - Serialized Fields
    - local
```
boolean local
```
    - conf
```
Map<K,V> conf
```
    - _clients
```
Map<K,V> _clients
```
Package storm.trident.operation
- Class storm.trident.operation.BaseAggregator extends BaseOperation implements Serializable
- Class storm.trident.operation.BaseFilter extends BaseOperation implements Serializable
- Class storm.trident.operation.BaseFunction extends BaseOperation implements Serializable
- Class storm.trident.operation.BaseMultiReducer extends Object implements Serializable
- Class storm.trident.operation.BaseOperation extends Object implements Serializable
Package storm.trident.operation.builtin
- Class storm.trident.operation.builtin.Count extends Object implements Serializable
- Class storm.trident.operation.builtin.Debug extends BaseFilter implements Serializable
  - Serialized Fields
    - name
```
String name
```
- Class storm.trident.operation.builtin.Equals extends BaseFilter implements Serializable
- Class storm.trident.operation.builtin.FilterNull extends BaseFilter implements Serializable
- Class storm.trident.operation.builtin.FirstN.FirstNAgg extends BaseAggregator<storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable
  - Serialized Fields
    - _n
```
int _n
```
- Class storm.trident.operation.builtin.FirstN.FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable
  - Serialized Fields
    - _n
```
int _n
```
    - _sortField
```
String _sortField
```
    - _reverse
```
boolean _reverse
```
- Class storm.trident.operation.builtin.MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable
- Class storm.trident.operation.builtin.Negate extends Object implements Serializable
  - Serialized Fields
    - _delegate
```
Filter _delegate
```
- Class storm.trident.operation.builtin.SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable
- Class storm.trident.operation.builtin.Sum extends Object implements Serializable
- Class storm.trident.operation.builtin.TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable
Package storm.trident.operation.impl
- Class storm.trident.operation.impl.ChainedAggregatorImpl extends Object implements Serializable
  - Serialized Fields
    - _aggs
```
Aggregator<T>[] _aggs
```
    - _inputFactories
```
TridentTupleView.ProjectionFactory[] _inputFactories
```
    - _fact
```
ComboList.Factory _fact
```
    - _inputFields
```
Fields[] _inputFields
```
- Class storm.trident.operation.impl.CombinerAggregatorCombineImpl extends Object implements Serializable
  - Serialized Fields
    - _agg
```
CombinerAggregator<T> _agg
```
- Class storm.trident.operation.impl.CombinerAggregatorInitImpl extends Object implements Serializable
  - Serialized Fields
    - _agg
```
CombinerAggregator<T> _agg
```
- Class storm.trident.operation.impl.CombinerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - _agg
```
CombinerAggregator<T> _agg
```
- Class storm.trident.operation.impl.FilterExecutor extends Object implements Serializable
  - Serialized Fields
    - _filter
```
Filter _filter
```
- Class storm.trident.operation.impl.GlobalBatchToPartition extends Object implements Serializable
- Class storm.trident.operation.impl.GroupedAggregator extends Object implements Serializable
  - Serialized Fields
    - _groupFactory
```
TridentTupleView.ProjectionFactory _groupFactory
```
    - _inputFactory
```
TridentTupleView.ProjectionFactory _inputFactory
```
    - _agg
```
Aggregator<T> _agg
```
    - _fact
```
ComboList.Factory _fact
```
    - _inFields
```
Fields _inFields
```
    - _groupFields
```
Fields _groupFields
```
- Class storm.trident.operation.impl.GroupedMultiReducerExecutor extends Object implements Serializable
  - Serialized Fields
    - _reducer
```
GroupedMultiReducer<T> _reducer
```
    - _groupFields
```
List<E> _groupFields
```
    - _inputFields
```
List<E> _inputFields
```
    - _groupFactories
```
List<E> _groupFactories
```
    - _inputFactories
```
List<E> _inputFactories
```
- Class storm.trident.operation.impl.IdentityMultiReducer extends Object implements Serializable
- Class storm.trident.operation.impl.IndexHashBatchToPartition extends Object implements Serializable
- Class storm.trident.operation.impl.JoinerMultiReducer extends Object implements Serializable
  - Serialized Fields
    - _types
```
List<E> _types
```
    - _sideFields
```
List<E> _sideFields
```
    - _numGroupFields
```
int _numGroupFields
```
    - _factory
```
ComboList.Factory _factory
```
- Class storm.trident.operation.impl.ReducerAggregatorImpl extends Object implements Serializable
  - Serialized Fields
    - _agg
```
ReducerAggregator<T> _agg
```
- Class storm.trident.operation.impl.ReducerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - _agg
```
ReducerAggregator<T> _agg
```
- Class storm.trident.operation.impl.SingleEmitAggregator extends Object implements Serializable
  - Serialized Fields
    - _agg
```
Aggregator<T> _agg
```
    - _batchToPartition
```
SingleEmitAggregator.BatchToPartition _batchToPartition
```
    - myPartitionIndex
```
int myPartitionIndex
```
    - totalPartitions
```
int totalPartitions
```
- Class storm.trident.operation.impl.TrueFilter extends Object implements Serializable
Package storm.trident.partition
- Class storm.trident.partition.GlobalGrouping extends Object implements Serializable
  - Serialized Fields
    - target
```
List<E> target
```
- Class storm.trident.partition.IdentityGrouping extends Object implements Serializable
  - Serialized Fields
    - ret
```
List<E> ret
```
    - _precomputed
```
Map<K,V> _precomputed
```
- Class storm.trident.partition.IndexHashGrouping extends Object implements Serializable
  - Serialized Fields
    - _index
```
int _index
```
    - _targets
```
List<E> _targets
```
Package storm.trident.planner
- Class storm.trident.planner.Node extends Object implements Serializable
  - Serialized Fields
    - nodeId
```
String nodeId
```
    - name
```
String name
```
    - allOutputFields
```
Fields allOutputFields
```
    - streamId
```
String streamId
```
    - parallelismHint
```
Integer parallelismHint
```
    - stateInfo
```
NodeStateInfo stateInfo
```
    - creationIndex
```
int creationIndex
```
- Class storm.trident.planner.NodeStateInfo extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
    - spec
```
StateSpec spec
```
- Class storm.trident.planner.PartitionNode extends Node implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
- Class storm.trident.planner.ProcessorNode extends Node implements Serializable
  - Serialized Fields
    - committer
```
boolean committer
```
    - processor
```
TridentProcessor processor
```
    - selfOutFields
```
Fields selfOutFields
```
- Class storm.trident.planner.SpoutNode extends Node implements Serializable
  - Serialized Fields
    - spout
```
Object spout
```
    - txId
```
String txId
```
    - type
```
SpoutNode.SpoutType type
```
- Class storm.trident.planner.SubtopologyBolt extends Object implements Serializable
  - Serialized Fields
    - _graph
```
org.jgrapht.DirectedGraph<V,E> _graph
```
    - _nodes
```
Set<E> _nodes
```
    - _roots
```
Map<K,V> _roots
```
    - _outputFactories
```
Map<K,V> _outputFactories
```
    - _myTopologicallyOrdered
```
Map<K,V> _myTopologicallyOrdered
```
    - _batchGroups
```
Map<K,V> _batchGroups
```
Package storm.trident.planner.processor
- Class storm.trident.planner.processor.AggregateProcessor extends Object implements Serializable
  - Serialized Fields
    - _agg
```
Aggregator<T> _agg
```
    - _context
```
TridentContext _context
```
    - _collector
```
FreshCollector _collector
```
    - _inputFields
```
Fields _inputFields
```
    - _projection
```
TridentTupleView.ProjectionFactory _projection
```
- Class storm.trident.planner.processor.EachProcessor extends Object implements Serializable
  - Serialized Fields
    - _function
```
Function _function
```
    - _context
```
TridentContext _context
```
    - _collector
```
AppendCollector _collector
```
    - _inputFields
```
Fields _inputFields
```
    - _projection
```
TridentTupleView.ProjectionFactory _projection
```
- Class storm.trident.planner.processor.MultiReducerProcessor extends Object implements Serializable
  - Serialized Fields
    - _reducer
```
MultiReducer<T> _reducer
```
    - _context
```
TridentContext _context
```
    - _streamToIndex
```
Map<K,V> _streamToIndex
```
    - _projectFields
```
List<E> _projectFields
```
    - _projectionFactories
```
TridentTupleView.ProjectionFactory[] _projectionFactories
```
    - _collector
```
FreshCollector _collector
```
- Class storm.trident.planner.processor.PartitionPersistProcessor extends Object implements Serializable
  - Serialized Fields
    - _updater
```
StateUpdater<S extends State> _updater
```
    - _state
```
State _state
```
    - _stateId
```
String _stateId
```
    - _context
```
TridentContext _context
```
    - _inputFields
```
Fields _inputFields
```
    - _projection
```
TridentTupleView.ProjectionFactory _projection
```
    - _collector
```
FreshCollector _collector
```
- Class storm.trident.planner.processor.ProjectedProcessor extends Object implements Serializable
  - Serialized Fields
    - _projectFields
```
Fields _projectFields
```
    - _factory
```
TridentTupleView.ProjectionFactory _factory
```
    - _context
```
TridentContext _context
```
- Class storm.trident.planner.processor.StateQueryProcessor extends Object implements Serializable
  - Serialized Fields
    - _function
```
QueryFunction<S extends State,T> _function
```
    - _state
```
State _state
```
    - _stateId
```
String _stateId
```
    - _context
```
TridentContext _context
```
    - _inputFields
```
Fields _inputFields
```
    - _projection
```
TridentTupleView.ProjectionFactory _projection
```
    - _collector
```
AppendCollector _collector
```
Package storm.trident.spout
- Class storm.trident.spout.BatchSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IBatchSpout _spout
```
- Class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M> _spout
```
- Class storm.trident.spout.PartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T> _spout
```
- Class storm.trident.spout.RichSpoutBatchExecutor extends Object implements Serializable
  - Serialized Fields
    - _spout
```
IRichSpout _spout
```
- Class storm.trident.spout.RichSpoutBatchTriggerer extends Object implements Serializable
  - Serialized Fields
    - _stream
```
String _stream
```
    - _delegate
```
IRichSpout _delegate
```
    - _outputTasks
```
List<E> _outputTasks
```
    - _rand
```
Random _rand
```
    - _coordStream
```
String _coordStream
```
    - _msgIdToBatchId
```
Map<K,V> _msgIdToBatchId
```
    - _finishConditions
```
Map<K,V> _finishConditions
```
- Class storm.trident.spout.TridentSpoutCoordinator extends Object implements Serializable
  - Serialized Fields
    - _spout
```
ITridentSpout<T> _spout
```
    - _coord
```
ITridentSpout.BatchCoordinator<X> _coord
```
    - _state
```
RotatingTransactionalState _state
```
    - _underlyingState
```
TransactionalState _underlyingState
```
    - _id
```
String _id
```
- Class storm.trident.spout.TridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - _collector
```
storm.trident.spout.TridentSpoutExecutor.AddIdCollector _collector
```
    - _spout
```
ITridentSpout<T> _spout
```
    - _emitter
```
ITridentSpout.Emitter<X> _emitter
```
    - _streamName
```
String _streamName
```
    - _txStateId
```
String _txStateId
```
    - _activeBatches
```
TreeMap<K,V> _activeBatches
```
Package storm.trident.state
- Class storm.trident.state.BaseQueryFunction extends BaseOperation implements Serializable
- Class storm.trident.state.BaseStateUpdater extends BaseOperation implements Serializable
- Class storm.trident.state.JSONNonTransactionalSerializer extends Object implements Serializable
- Class storm.trident.state.JSONOpaqueSerializer extends Object implements Serializable
- Class storm.trident.state.JSONTransactionalSerializer extends Object implements Serializable
- Class storm.trident.state.StateSpec extends Object implements Serializable
  - Serialized Fields
    - stateFactory
```
StateFactory stateFactory
```
    - requiredNumPartitions
```
Integer requiredNumPartitions
```
Package storm.trident.state.map
- Class storm.trident.state.map.MapCombinerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - _agg
```
CombinerAggregator<T> _agg
```
    - _groupFields
```
Fields _groupFields
```
    - _inputFields
```
Fields _inputFields
```
    - _groupFactory
```
TridentTupleView.ProjectionFactory _groupFactory
```
    - _inputFactory
```
TridentTupleView.ProjectionFactory _inputFactory
```
    - _factory
```
ComboList.Factory _factory
```
- Class storm.trident.state.map.MapReducerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - _agg
```
ReducerAggregator<T> _agg
```
    - _groupFields
```
Fields _groupFields
```
    - _inputFields
```
Fields _inputFields
```
    - _groupFactory
```
TridentTupleView.ProjectionFactory _groupFactory
```
    - _inputFactory
```
TridentTupleView.ProjectionFactory _inputFactory
```
    - _factory
```
ComboList.Factory _factory
```
- Class storm.trident.state.map.MicroBatchIBackingMap.Options extends Object implements Serializable
  - Serialized Fields
    - maxMultiGetBatchSize
```
int maxMultiGetBatchSize
```
    - maxMultiPutBatchSize
```
int maxMultiPutBatchSize
```
Package storm.trident.testing
- Class storm.trident.testing.CountAsAggregator extends BaseAggregator<storm.trident.testing.CountAsAggregator.State> implements Serializable
- Class storm.trident.testing.FeederBatchSpout extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
    - _semaphoreId
```
String _semaphoreId
```
    - _outFields
```
Fields _outFields
```
    - _waitToEmit
```
boolean _waitToEmit
```
- Class storm.trident.testing.FeederCommitterBatchSpout extends Object implements Serializable
  - Serialized Fields
    - _spout
```
FeederBatchSpout _spout
```
- Class storm.trident.testing.FixedBatchSpout extends Object implements Serializable
  - Serialized Fields
    - fields
```
Fields fields
```
    - outputs
```
List<E>[] outputs
```
    - maxBatchSize
```
int maxBatchSize
```
    - batches
```
HashMap<K,V> batches
```
    - index
```
int index
```
    - cycle
```
boolean cycle
```
- Class storm.trident.testing.LRUMemoryMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
    - _maxSize
```
int _maxSize
```
- Class storm.trident.testing.MemoryMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - _id
```
String _id
```
- Class storm.trident.testing.Split extends BaseFunction implements Serializable
- Class storm.trident.testing.StringLength extends BaseFunction implements Serializable
- Class storm.trident.testing.TrueFilter extends BaseFilter implements Serializable
- Class storm.trident.testing.TuplifyArgs extends BaseFunction implements Serializable
Package storm.trident.topology
- Class storm.trident.topology.MasterBatchCoordinator extends BaseRichSpout implements Serializable
  - Serialized Fields
    - _states
```
List<E> _states
```
    - _activeTx
```
TreeMap<K,V> _activeTx
```
    - _attemptIds
```
TreeMap<K,V> _attemptIds
```
    - _collector
```
SpoutOutputCollector _collector
```
    - _currTransaction
```
Long _currTransaction
```
    - _maxTransactionActive
```
int _maxTransactionActive
```
    - _coordinators
```
List<E> _coordinators
```
    - _managedSpoutIds
```
List<E> _managedSpoutIds
```
    - _spouts
```
List<E> _spouts
```
    - _throttler
```
WindowedTimeThrottler _throttler
```
    - _active
```
boolean _active
```
- Class storm.trident.topology.TridentBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - _batchGroupIds
```
Map<K,V> _batchGroupIds
```
    - _coordSpecs
```
Map<K,V> _coordSpecs
```
    - _coordConditions
```
Map<K,V> _coordConditions
```
    - _bolt
```
ITridentBatchBolt _bolt
```
    - _messageTimeoutMs
```
long _messageTimeoutMs
```
    - _lastRotate
```
long _lastRotate
```
    - _batches
```
RotatingMap<K,V> _batches
```
    - _collector
```
OutputCollector _collector
```
    - _coordCollector
```
TridentBoltExecutor.CoordinatedOutputCollector _coordCollector
```
    - _coordOutputCollector
```
BatchOutputCollector _coordOutputCollector
```
    - _context
```
TopologyContext _context
```
- Class storm.trident.topology.TridentBoltExecutor.CoordCondition extends Object implements Serializable
  - Serialized Fields
    - commitStream
```
GlobalStreamId commitStream
```
    - expectedTaskReports
```
int expectedTaskReports
```
    - targetTasks
```
Set<E> targetTasks
```
- Class storm.trident.topology.TridentBoltExecutor.CoordSpec extends Object implements Serializable
  - Serialized Fields
    - commitStream
```
GlobalStreamId commitStream
```
    - coords
```
Map<K,V> coords
```
- Class storm.trident.topology.TridentBoltExecutor.CoordType extends Object implements Serializable
  - Serialized Fields
    - singleCount
```
boolean singleCount
```
Package storm.trident.tuple
- Class storm.trident.tuple.ComboList.Factory extends Object implements Serializable
  - Serialized Fields
    - index
```
storm.trident.tuple.ComboList.Pointer[] index
```
    - sizes
```
int[] sizes
```
- Class storm.trident.tuple.TridentTupleView.FreshOutputFactory extends Object implements Serializable
  - Serialized Fields
    - _fieldIndex
```
Map<K,V> _fieldIndex
```
    - _index
```
ValuePointer[] _index
```
- Class storm.trident.tuple.TridentTupleView.OperationOutputFactory extends Object implements Serializable
  - Serialized Fields
    - _fieldIndex
```
Map<K,V> _fieldIndex
```
    - _index
```
ValuePointer[] _index
```
    - _parent
```
TridentTuple.Factory _parent
```
- Class storm.trident.tuple.TridentTupleView.ProjectionFactory extends Object implements Serializable
  - Serialized Fields
    - _fieldIndex
```
Map<K,V> _fieldIndex
```
    - _index
```
ValuePointer[] _index
```
    - _parent
```
TridentTuple.Factory _parent
```
- Class storm.trident.tuple.TridentTupleView.RootFactory extends Object implements Serializable
  - Serialized Fields
    - index
```
ValuePointer[] index
```
    - fieldIndex
```
Map<K,V> fieldIndex
```
Package storm.trident.util
- Class storm.trident.util.ErrorEdgeFactory extends Object implements Serializable
- Class storm.trident.util.IndexedEdge extends Object implements Serializable
  - Serialized Fields
    - source
```
Object source
```
    - target
```
Object target
```
    - index
```
int index
```
- Class storm.trident.util.LRUMap extends LinkedHashMap<A,B> implements Serializable
  - Serialized Fields
    - _maxSize
```
int _maxSize
```

Serialized Form

Package backtype.storm

Class backtype.storm.Config extends HashMap<String,Object> implements Serializable

Package backtype.storm.clojure

Class backtype.storm.clojure.ClojureBolt extends Object implements Serializable

Serialized Fields

_fields

_fnSpec

_confSpec

_params

_bolt

Class backtype.storm.clojure.ClojureSpout extends Object implements Serializable

Serialized Fields

_fields

_fnSpec

_confSpec

_params

_spout

Class backtype.storm.clojure.RichShellBolt extends ShellBolt implements Serializable

Serialized Fields

_outputs

Class backtype.storm.clojure.RichShellSpout extends ShellSpout implements Serializable

Serialized Fields

_outputs

Package backtype.storm.coordination

Class backtype.storm.coordination.BatchBoltExecutor extends Object implements Serializable

Serialized Fields

_boltSer

_openTransactions

_conf

_context

_collector

Class backtype.storm.coordination.CoordinatedBolt extends Object implements Serializable

Serialized Fields

_sourceArgs

_idStreamSpec

_delegate

_numSourceReports

_countOutTasks

_collector

_tracked

Class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec extends Object implements Serializable

Serialized Fields

_id

Class backtype.storm.coordination.CoordinatedBolt.SourceArgs extends Object implements Serializable

Serialized Fields

singleCount

Package backtype.storm.drpc

Class backtype.storm.drpc.DRPCSpout extends BaseRichSpout implements Serializable

Serialized Fields

_collector

_clients

_function

_local_drpc_id

Class backtype.storm.drpc.JoinResult extends BaseRichBolt implements Serializable

Serialized Fields

returnComponent

returns

results

_collector

Class backtype.storm.drpc.KeyedFairBolt extends Object implements Serializable

Serialized Fields

_delegate

_rrQueue

_executor

_callback

Class backtype.storm.drpc.PrepareRequest extends BaseBasicBolt implements Serializable

Serialized Fields

rand

Class backtype.storm.drpc.ReturnResults extends BaseRichBolt implements Serializable

Serialized Fields

_collector

local

_conf

_clients

Package backtype.storm.generated

Class backtype.storm.generated.AlreadyAliveException extends org.apache.thrift.TException implements Serializable

Serialization Methods

readObject

writeObject