Serialized Form (Storm 2.1.1 API)

Package org.apache.calcite.interpreter
- Class org.apache.calcite.interpreter.StormContext extends org.apache.calcite.interpreter.Context implements Serializable
Package org.apache.storm
- Class org.apache.storm.clojure$ack_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$bolt extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$bolt_execute extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$bolt$fn__702 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_bolt extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_bolt_STAR_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_spout extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_spout_STAR_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$collectify extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$defalias extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$defbolt extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$defspout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$direct_stream extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$emit_bolt_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_direct_bolt_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_direct_spout_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_spout_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$fail_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__669 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__733 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__736 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__736$G__731__745 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - G__732
```
Object G__732
```
- Class org.apache.storm.clojure$fn__736$G__732__740 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__751 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__751$iter__752__756 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__751$iter__752__756$fn__757 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - s__753
```
Object s__753
```
    - iter__752
```
Object iter__752
```
- Class org.apache.storm.clojure$fn__751$iter__752__756$fn__757$fn__758 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - size__6289__auto__
```
int size__6289__auto__
```
    - b__755
```
Object b__755
```
    - c__6288__auto__
```
Object c__6288__auto__
```
- Class org.apache.storm.clojure$fn__773 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__792 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__794 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__796 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__798 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__800 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$loading__6706__auto____667 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$local_cluster extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns$iter__677__681 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns$iter__677__681$fn__682 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - iter__677
```
Object iter__677
```
    - s__678
```
Object s__678
```
- Class org.apache.storm.clojure$normalize_fns$iter__677__681$fn__682$fn__683 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - size__6289__auto__
```
int size__6289__auto__
```
    - b__680
```
Object b__680
```
    - c__6288__auto__
```
Object c__6288__auto__
```
- Class org.apache.storm.clojure$report_error_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$reset_timeout_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$spout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$spout$fn__710 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$to_spec extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.Config extends HashMap<String,Object> implements Serializable
  
  serialVersionUID:
  
  -1550278723792864455L
- Class org.apache.storm.config$clojure_config_name extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$fn__532 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$fn__539 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$loading__6706__auto____530 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - currentIndex
```
int currentIndex
```
    - numEmitted
```
int numEmitted
```
- Class org.apache.storm.LocalCluster.LocalTopology extends StormTopology implements Serializable
  
  serialVersionUID:
  
  6145919776650637748L
  - Serialized Fields
    - topoName
```
String topoName
```
- Class org.apache.storm.log$fn__454 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.log$loading__6706__auto____273 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.log$log_debug extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_error extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_message extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_warn extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$add_supervisor extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$capture_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$complete_topology extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$fn__288 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$get_supervisor extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$global_amt extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$increment_global_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$kill_supervisor extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$loading__6706__auto____271 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$local_cluster_state extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$mkClusterParam extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mock_leader_elector extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$ms_EQ_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$read_tuples extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$simulate_wait extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects$iter__337__341 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - iter__337
```
Object iter__337
```
    - s__338
```
Object s__338
```
- Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342$fn__343 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - c__6288__auto__
```
Object c__6288__auto__
```
    - b__340
```
Object b__340
```
    - size__6289__auto__
```
int size__6289__auto__
```
- Class org.apache.storm.testing$submit_local_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$test_tuple extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$tracked_wait extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_for_condition extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_for_condition$fn__309 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$while_timeout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_local_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_timeout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$add_inputs extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$field_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$fn__545 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$grouping_type extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$instantiate_java_object$fn__548 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$loading__6706__auto____543 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_bolt_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_bolt_spec_STAR_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs$iter__589__593 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs$iter__589__593$fn__594 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - s__590
```
Object s__590
```
    - iter__589
```
Object iter__589
```
- Class org.apache.storm.thrift$mk_inputs$iter__589__593$fn__594$fn__595 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - b__592
```
Object b__592
```
    - size__6289__auto__
```
int size__6289__auto__
```
    - c__6288__auto__
```
Object c__6288__auto__
```
- Class org.apache.storm.thrift$mk_local_or_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_output_spec$fn__572 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_spout_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_spout_spec_STAR_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$output_fields extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$shell_component_params extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$with_nimbus_connection extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$__LT__GT_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$__LT__GT_$fn__526 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_error extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_structure extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_structure$fn__486 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$defnk extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$defnk$fn__480 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$dofor extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$filter_key extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$filter_key$fn__512 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - afn
```
Object afn
```
- Class org.apache.storm.util$fn__460 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$loading__6706__auto____271 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$map_val extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$map_val$iter__490__494 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - afn
```
Object afn
```
- Class org.apache.storm.util$map_val$iter__490__494$fn__495 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - s__491
```
Object s__491
```
    - iter__490
```
Object iter__490
```
    - afn
```
Object afn
```
- Class org.apache.storm.util$map_val$iter__490__494$fn__495$fn__496 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    - b__493
```
Object b__493
```
    - c__6288__auto__
```
Object c__6288__auto__
```
    - size__6289__auto__
```
int size__6289__auto__
```
    - afn
```
Object afn
```
- Class org.apache.storm.util$name_with_attributes extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$thrown_cause_QMARK_ extends clojure.lang.RestFn implements Serializable
Package org.apache.storm.bolt
- Class org.apache.storm.bolt.JoinBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - selectorType
```
JoinBolt.Selector selectorType
```
    - joinCriteria
```
LinkedHashMap<K,V> joinCriteria
```
    - outputFields
```
JoinBolt.FieldSelector[] outputFields
```
    - outputStreamName
```
String outputStreamName
```
    - hashedInputs
```
HashMap<K,V> hashedInputs
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.bolt.JoinBolt.FieldSelector extends Object implements Serializable
  - Serialized Fields
    - streamName
```
String streamName
```
    - field
```
String[] field
```
    - outputName
```
String outputName
```
- Class org.apache.storm.bolt.JoinBolt.JoinInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - joinType
```
JoinBolt.JoinType joinType
```
    - field
```
JoinBolt.FieldSelector field
```
    - other
```
JoinBolt.FieldSelector other
```
Package org.apache.storm.cassandra
- Class org.apache.storm.cassandra.AbstractExecutionResultHandler extends Object implements Serializable
- Class org.apache.storm.cassandra.BaseExecutionResultHandler extends AbstractExecutionResultHandler implements Serializable
- Class org.apache.storm.cassandra.CassandraContext extends WorkerCtx implements Serializable
- Class org.apache.storm.cassandra.CassandraContext.CassandraConfFactory extends BaseBeanFactory<CassandraConf> implements Serializable
- Class org.apache.storm.cassandra.CassandraContext.ClientFactory extends BaseBeanFactory<SimpleClient> implements Serializable
- Class org.apache.storm.cassandra.DynamicStatementBuilder extends Object implements Serializable
- Class org.apache.storm.cassandra.Murmur3StreamGrouping extends Object implements Serializable
  - Serialized Fields
    - targetTasks
```
List<E> targetTasks
```
    - partitionKeyIndexes
```
List<E> partitionKeyIndexes
```
    - partitionKeyNames
```
List<E> partitionKeyNames
```
      A list of partition key. The order of specified keys will be used to generate the partition key hash. It should respect the column order defined into the targeted CQL table.
Package org.apache.storm.cassandra.bolt
- Class org.apache.storm.cassandra.bolt.BaseCassandraBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - outputCollector
```
OutputCollector outputCollector
```
    - clientProvider
```
SimpleClientProvider clientProvider
```
    - client
```
SimpleClient client
```
    - session
```
com.datastax.driver.core.Session session
```
    - topoConfig
```
Map<K,V> topoConfig
```
    - cassandraConf
```
CassandraConf cassandraConf
```
    - mapper
```
CQLStatementTupleMapper mapper
```
    - resultHandler
```
ExecutionResultHandler resultHandler
```
    - cassandraConfig
```
Map<K,V> cassandraConfig
```
- Class org.apache.storm.cassandra.bolt.BatchCassandraWriterBolt extends BaseCassandraBolt<List<Tuple>> implements Serializable
  - Serialized Fields
    - queue
```
LinkedBlockingQueue<E> queue
```
    - tickFrequencyInSeconds
```
int tickFrequencyInSeconds
```
    - lastModifiedTimesMillis
```
long lastModifiedTimesMillis
```
    - batchMaxSize
```
int batchMaxSize
```
    - componentId
```
String componentId
```
    - asyncResultHandler
```
AsyncResultHandler<T> asyncResultHandler
```
- Class org.apache.storm.cassandra.bolt.CassandraWriterBolt extends BaseCassandraBolt<Tuple> implements Serializable
  - Serialized Fields
    - asyncResultHandler
```
AsyncResultHandler<T> asyncResultHandler
```
Package org.apache.storm.cassandra.client
- Class org.apache.storm.cassandra.client.CassandraConf extends Object implements Serializable
  - Serialized Fields
    - username
```
String username
```
      The authorized cassandra username.
    - password
```
String password
```
      The authorized cassandra password.
    - keyspace
```
String keyspace
```
      The cassandra keyspace.
    - nodes
```
String[] nodes
```
      List of contacts nodes.
    - port
```
int port
```
      The port used to connect to nodes.
    - consistencyLevel
```
com.datastax.driver.core.ConsistencyLevel consistencyLevel
```
      Consistency level used to write statements.
    - batchSizeRows
```
int batchSizeRows
```
      The maximal numbers of rows per batch.
    - retryPolicyName
```
String retryPolicyName
```
      The retry policy to use for the new cluster.
    - reconnectionPolicyBaseMs
```
long reconnectionPolicyBaseMs
```
      The base delay in milliseconds to use for the reconnection policy.
    - reconnectionPolicyMaxMs
```
long reconnectionPolicyMaxMs
```
      The maximum delay to wait between two attempts.
    - poolMaxQueueSize
```
int poolMaxQueueSize
```
      The maximum queue for connection pool.
    - loadBalancingPolicyName
```
String loadBalancingPolicyName
```
    - datacenterName
```
String datacenterName
```
    - maxRequestPerConnectionLocal
```
int maxRequestPerConnectionLocal
```
    - maxRequestPerConnectionRemote
```
int maxRequestPerConnectionRemote
```
    - heartbeatIntervalSeconds
```
int heartbeatIntervalSeconds
```
    - idleTimeoutSeconds
```
int idleTimeoutSeconds
```
    - socketReadTimeoutMillis
```
long socketReadTimeoutMillis
```
      The timeout for read for socket options.
    - socketConnectTimeoutMillis
```
long socketConnectTimeoutMillis
```
      The timeout for connect for socket options.
- Class org.apache.storm.cassandra.client.ClusterFactory extends BaseBeanFactory<com.datastax.driver.core.Cluster> implements Serializable
Package org.apache.storm.cassandra.client.impl
- Class org.apache.storm.cassandra.client.impl.DefaultClient extends Object implements Serializable
  - Serialized Fields
    - keyspace
```
String keyspace
```
    - cluster
```
com.datastax.driver.core.Cluster cluster
```
    - session
```
com.datastax.driver.core.Session session
```
Package org.apache.storm.cassandra.context
- Class org.apache.storm.cassandra.context.BaseBeanFactory extends Object implements Serializable
  - Serialized Fields
    - context
```
WorkerCtx context
```
    - instance
```
Object instance
```
- Class org.apache.storm.cassandra.context.WorkerCtx extends Object implements Serializable
  - Serialized Fields
    - componentCtx
```
Map<K,V> componentCtx
```
Package org.apache.storm.cassandra.executor
- Class org.apache.storm.cassandra.executor.AsyncExecutor extends Object implements Serializable
  - Serialized Fields
    - session
```
com.datastax.driver.core.Session session
```
    - executorService
```
ExecutorService executorService
```
    - handler
```
AsyncResultHandler<T> handler
```
    - pending
```
AtomicInteger pending
```
- Class org.apache.storm.cassandra.executor.AsyncExecutor.MultiFailedException extends FailedException implements Serializable
  - Serialized Fields
    - exceptions
```
List<E> exceptions
```
Package org.apache.storm.cassandra.executor.impl
- Class org.apache.storm.cassandra.executor.impl.BatchAsyncResultHandler extends Object implements Serializable
  - Serialized Fields
    - completed
```
ConcurrentLinkedQueue<E> completed
```
    - handler
```
ExecutionResultHandler handler
```
- Class org.apache.storm.cassandra.executor.impl.SingleAsyncResultHandler extends Object implements Serializable
  - Serialized Fields
    - completed
```
ConcurrentLinkedQueue<E> completed
```
    - handler
```
ExecutionResultHandler handler
```
Package org.apache.storm.cassandra.query
- Class org.apache.storm.cassandra.query.BaseCQLStatementTupleMapper extends Object implements Serializable
- Class org.apache.storm.cassandra.query.Column extends Object implements Serializable
  - Serialized Fields
    - columnName
```
String columnName
```
    - val
```
Object val
```
- Class org.apache.storm.cassandra.query.ContextQuery.BoundQueryContext extends Object implements Serializable
  - Serialized Fields
    - key
```
String key
```
- Class org.apache.storm.cassandra.query.ContextQuery.BoundQueryNamedByFieldContext extends Object implements Serializable
  - Serialized Fields
    - fieldName
```
String fieldName
```
- Class org.apache.storm.cassandra.query.ContextQuery.StaticContextQuery extends Object implements Serializable
  - Serialized Fields
    - value
```
String value
```
- Class org.apache.storm.cassandra.query.CqlMapper.DefaultCqlMapper extends Object implements Serializable
- Class org.apache.storm.cassandra.query.CqlMapper.SelectableCqlMapper extends Object implements Serializable
  - Serialized Fields
    - selectors
```
List<E> selectors
```
- Class org.apache.storm.cassandra.query.CQLStatementTupleMapper.DynamicCQLStatementTupleMapper extends Object implements Serializable
  - Serialized Fields
    - builders
```
List<E> builders
```
Package org.apache.storm.cassandra.query.builder
- Class org.apache.storm.cassandra.query.builder.BoundCQLStatementMapperBuilder extends Object implements Serializable
  - Serialized Fields
    - contextQuery
```
ContextQuery contextQuery
```
    - mapper
```
CqlMapper mapper
```
    - routingKeys
```
List<E> routingKeys
```
    - binder
```
PreparedStatementBinder binder
```
- Class org.apache.storm.cassandra.query.builder.ObjectMapperCqlStatementMapperBuilder extends Object implements Serializable
  - Serialized Fields
    - operationField
```
String operationField
```
    - valueField
```
String valueField
```
    - udtClasses
```
Collection<E> udtClasses
```
    - codecProducers
```
Collection<E> codecProducers
```
    - timestampField
```
String timestampField
```
    - ttlField
```
String ttlField
```
    - consistencyLevelField
```
String consistencyLevelField
```
- Class org.apache.storm.cassandra.query.builder.SimpleCQLStatementMapperBuilder extends Object implements Serializable
  - Serialized Fields
    - queryString
```
String queryString
```
    - mapper
```
CqlMapper mapper
```
    - routingKeys
```
List<E> routingKeys
```
Package org.apache.storm.cassandra.query.impl
- Class org.apache.storm.cassandra.query.impl.BatchCQLStatementTupleMapper extends Object implements Serializable
  - Serialized Fields
    - mappers
```
List<E> mappers
```
    - type
```
com.datastax.driver.core.BatchStatement.Type type
```
- Class org.apache.storm.cassandra.query.impl.BoundCQLStatementTupleMapper extends Object implements Serializable
  - Serialized Fields
    - contextQuery
```
ContextQuery contextQuery
```
    - mapper
```
CqlMapper mapper
```
    - rkGenerator
```
RoutingKeyGenerator rkGenerator
```
    - binder
```
PreparedStatementBinder binder
```
    - cache
```
Map<K,V> cache
```
- Class org.apache.storm.cassandra.query.impl.ObjectMapperCqlStatementMapper extends Object implements Serializable
  - Serialized Fields
    - operationField
```
String operationField
```
    - valueField
```
String valueField
```
    - timestampField
```
String timestampField
```
    - ttlField
```
String ttlField
```
    - consistencyLevelField
```
String consistencyLevelField
```
    - codecs
```
Collection<E> codecs
```
    - udtClasses
```
Collection<E> udtClasses
```
- Class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.CQL3NamedSettersBinder extends Object implements Serializable
- Class org.apache.storm.cassandra.query.impl.PreparedStatementBinder.DefaultBinder extends Object implements Serializable
- Class org.apache.storm.cassandra.query.impl.RoutingKeyGenerator extends Object implements Serializable
  - Serialized Fields
    - routingKeys
```
List<E> routingKeys
```
- Class org.apache.storm.cassandra.query.impl.SimpleCQLStatementMapper extends Object implements Serializable
  - Serialized Fields
    - queryString
```
String queryString
```
    - mapper
```
CqlMapper mapper
```
    - rkGenerator
```
RoutingKeyGenerator rkGenerator
```
Package org.apache.storm.cassandra.query.selector
- Class org.apache.storm.cassandra.query.selector.FieldSelector extends Object implements Serializable
  - Serialized Fields
    - field
```
String field
```
    - as
```
String as
```
    - isNow
```
boolean isNow
```
Package org.apache.storm.cassandra.trident.state
- Class org.apache.storm.cassandra.trident.state.CassandraBackingMap.Options extends Object implements Serializable
  - Serialized Fields
    - clientProvider
```
SimpleClientProvider clientProvider
```
    - keyFields
```
Fields keyFields
```
    - stateMapper
```
StateMapper<T> stateMapper
```
    - getMapper
```
CQLStatementTupleMapper getMapper
```
    - putMapper
```
CQLStatementTupleMapper putMapper
```
    - maxParallelism
```
Integer maxParallelism
```
- Class org.apache.storm.cassandra.trident.state.CassandraMapStateFactory extends Object implements Serializable
  - Serialized Fields
    - stateType
```
StateType stateType
```
    - options
```
CassandraBackingMap.Options<T> options
```
    - cacheSize
```
int cacheSize
```
    - cassandraConfig
```
Map<K,V> cassandraConfig
```
- Class org.apache.storm.cassandra.trident.state.CassandraQuery extends BaseQueryFunction<CassandraState,List<Values>> implements Serializable
- Class org.apache.storm.cassandra.trident.state.CassandraState.Options extends Object implements Serializable
  - Serialized Fields
    - clientProvider
```
SimpleClientProvider clientProvider
```
    - cqlStatementTupleMapper
```
CQLStatementTupleMapper cqlStatementTupleMapper
```
    - cqlResultSetValuesMapper
```
CQLResultSetValuesMapper cqlResultSetValuesMapper
```
    - batchingType
```
com.datastax.driver.core.BatchStatement.Type batchingType
```
- Class org.apache.storm.cassandra.trident.state.CassandraStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
CassandraState.Options options
```
- Class org.apache.storm.cassandra.trident.state.CassandraStateUpdater extends BaseStateUpdater<CassandraState> implements Serializable
- Class org.apache.storm.cassandra.trident.state.NonTransactionalTupleStateMapper extends Object implements Serializable
  - Serialized Fields
    - fields
```
Fields fields
```
- Class org.apache.storm.cassandra.trident.state.OpaqueTupleStateMapper extends Object implements Serializable
  - Serialized Fields
    - tupleFields
```
Fields tupleFields
```
    - tableFields
```
Fields tableFields
```
- Class org.apache.storm.cassandra.trident.state.SerializedStateMapper extends Object implements Serializable
  - Serialized Fields
    - stateFields
```
Fields stateFields
```
    - serializer
```
Serializer<T> serializer
```
- Class org.apache.storm.cassandra.trident.state.SimpleStateMapper extends Object implements Serializable
  - Serialized Fields
    - fields
```
Fields fields
```
    - stateType
```
StateType stateType
```
- Class org.apache.storm.cassandra.trident.state.SimpleTuple extends Object implements Serializable
  
  serialVersionUID:
  
  -4656331293513898312L
  - Serialized Fields
    - keys
```
List<E> keys
```
    - values
```
List<E> values
```
- Class org.apache.storm.cassandra.trident.state.TransactionalTupleStateMapper extends Object implements Serializable
  - Serialized Fields
    - tupleFields
```
Fields tupleFields
```
    - tableFields
```
Fields tableFields
```
- Class org.apache.storm.cassandra.trident.state.TridentAyncCQLResultSetValuesMapper extends Object implements Serializable
  - Serialized Fields
    - outputDeclaredFields
```
Fields outputDeclaredFields
```
    - throttle
```
Semaphore throttle
```
- Class org.apache.storm.cassandra.trident.state.TridentResultSetValuesMapper extends Object implements Serializable
  - Serialized Fields
    - outputDeclaredFields
```
Fields outputDeclaredFields
```
Package org.apache.storm.clojure
- Class org.apache.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 org.apache.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 org.apache.storm.clojure.RichShellBolt extends ShellBolt implements Serializable
  - Serialized Fields
    - outputs
```
Map<K,V> outputs
```
- Class org.apache.storm.clojure.RichShellSpout extends ShellSpout implements Serializable
  - Serialized Fields
    - outputs
```
Map<K,V> outputs
```
Package org.apache.storm.coordination
- Class org.apache.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 org.apache.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 org.apache.storm.coordination.CoordinatedBolt.IdStreamSpec extends Object implements Serializable
  - Serialized Fields
    - id
```
GlobalStreamId id
```
- Class org.apache.storm.coordination.CoordinatedBolt.SourceArgs extends Object implements Serializable
  - Serialized Fields
    - singleCount
```
boolean singleCount
```
Package org.apache.storm.daemon
- Class org.apache.storm.daemon.Acker extends Object implements Serializable
  
  serialVersionUID:
  
  4430906880683183091L
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - pending
```
RotatingMap<K,V> pending
```
- Class org.apache.storm.daemon.GrouperFactory.AllGrouper extends Object implements Serializable
  - Serialized Fields
    - targetTasks
```
List<E> targetTasks
```
- Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping extends Object implements Serializable
  - Serialized Fields
    - customStreamGrouping
```
CustomStreamGrouping customStreamGrouping
```
- Class org.apache.storm.daemon.GrouperFactory.FieldsGrouper extends Object implements Serializable
  - Serialized Fields
    - outFields
```
Fields outFields
```
    - targetTasks
```
List<E> targetTasks
```
    - groupFields
```
Fields groupFields
```
    - numTasks
```
int numTasks
```
- Class org.apache.storm.daemon.GrouperFactory.GlobalGrouper extends Object implements Serializable
  - Serialized Fields
    - targetTasks
```
List<E> targetTasks
```
- Class org.apache.storm.daemon.GrouperFactory.NoneGrouper extends Object implements Serializable
  - Serialized Fields
    - random
```
Random random
```
    - targetTasks
```
List<E> targetTasks
```
    - numTasks
```
int numTasks
```
Package org.apache.storm.daemon.supervisor
- Class org.apache.storm.daemon.supervisor.ContainerRecoveryException extends RuntimeException implements Serializable
- Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignment extends LocalAssignment implements Serializable
  - Serialized Fields
    - timing
```
com.codahale.metrics.Timer.Context timing
```
Package org.apache.storm.daemon.ui
- Class org.apache.storm.daemon.ui.InvalidRequestException extends Exception implements Serializable
Package org.apache.storm.dependency
- Class org.apache.storm.dependency.FileNotAvailableException extends RuntimeException implements Serializable
Package org.apache.storm.drpc
- Class org.apache.storm.drpc.DRPCSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  2387848310969237877L
  - Serialized Fields
    - function
```
String function
```
    - localDrpcId
```
String localDrpcId
```
    - collector
```
SpoutOutputCollector collector
```
    - clients
```
List<E> clients
```
- Class org.apache.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 org.apache.storm.drpc.KeyedFairBolt extends Object implements Serializable
  - Serialized Fields
    - delegate
```
IRichBolt delegate
```
    - rrQueue
```
KeyedRoundRobinQueue<V> rrQueue
```
    - executor
```
Thread executor
```
    - callback
```
CoordinatedBolt.FinishedCallback callback
```
- Class org.apache.storm.drpc.PrepareRequest extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - rand
```
Random rand
```
- Class org.apache.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 org.apache.storm.elasticsearch
- Class org.apache.storm.elasticsearch.DefaultEsLookupResultOutput extends Object implements Serializable
  
  serialVersionUID:
  
  2932278450655703239L
  - Serialized Fields
    - objectMapper
```
com.fasterxml.jackson.databind.ObjectMapper objectMapper
```
Package org.apache.storm.elasticsearch.bolt
- Class org.apache.storm.elasticsearch.bolt.AbstractEsBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - esConfig
```
EsConfig esConfig
```
- Class org.apache.storm.elasticsearch.bolt.EsIndexBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
- Class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
      The pending values.
    - collector
```
SpoutOutputCollector collector
```
      The collector passed in EsIndexTopology.UserDataSpout.open(java.util.Map, org.apache.storm.task.TopologyContext, org.apache.storm.spout.SpoutOutputCollector).
    - sources
```
String[] sources
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
    - indexName
```
String indexName
```
    - typeName
```
String typeName
```
- Class org.apache.storm.elasticsearch.bolt.EsLookupBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
    - output
```
EsLookupResultOutput output
```
- Class org.apache.storm.elasticsearch.bolt.EsPercolateBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
Package org.apache.storm.elasticsearch.common
- Class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper extends Object implements Serializable
- Class org.apache.storm.elasticsearch.common.EsConfig extends Object implements Serializable
  - Serialized Fields
    - httpHosts
```
org.apache.http.HttpHost[] httpHosts
```
    - maxRetryTimeoutMillis
```
Integer maxRetryTimeoutMillis
```
    - defaultHeaders
```
org.apache.http.Header[] defaultHeaders
```
    - failureListener
```
org.elasticsearch.client.RestClient.FailureListener failureListener
```
    - httpClientConfigCallback
```
org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback
```
    - requestConfigCallback
```
org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback
```
    - pathPrefix
```
String pathPrefix
```
- Class org.apache.storm.elasticsearch.common.StormElasticSearchClient extends Object implements Serializable
  - Serialized Fields
    - esConfig
```
EsConfig esConfig
```
Package org.apache.storm.elasticsearch.trident
- Class org.apache.storm.elasticsearch.trident.EsStateFactory extends Object implements Serializable
  - Serialized Fields
    - esConfig
```
EsConfig esConfig
```
    - tupleMapper
```
EsTupleMapper tupleMapper
```
- Class org.apache.storm.elasticsearch.trident.EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState> implements Serializable
- Class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - maxBatchSize
```
int maxBatchSize
```
    - batches
```
HashMap<K,V> batches
```
      The passed batches.
    - outputs
```
Values[] outputs
```
      The output values.
    - index
```
int index
```
      The current index.
    - cycle
```
boolean cycle
```
      A flag indicating whether cycling ought to be performed.
Package org.apache.storm.eventhubs.bolt
- Class org.apache.storm.eventhubs.bolt.DefaultEventDataFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - delimiter
```
String delimiter
```
- Class org.apache.storm.eventhubs.bolt.EventHubBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - sender
```
com.microsoft.azure.eventhubs.PartitionSender sender
```
    - ehClient
```
com.microsoft.azure.eventhubs.EventHubClient ehClient
```
    - boltConfig
```
EventHubBoltConfig boltConfig
```
- Class org.apache.storm.eventhubs.bolt.EventHubBoltConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - entityPath
```
String entityPath
```
    - partitionMode
```
boolean partitionMode
```
    - dataFormat
```
IEventDataFormat dataFormat
```
    - connectionString
```
String connectionString
```
Package org.apache.storm.eventhubs.spout
- Class org.apache.storm.eventhubs.spout.BinaryEventDataScheme extends Object implements Serializable
- Class org.apache.storm.eventhubs.spout.EventDataScheme extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.eventhubs.spout.EventHubException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.eventhubs.spout.EventHubSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - instanceId
```
UUID instanceId
```
    - eventHubConfig
```
EventHubSpoutConfig eventHubConfig
```
    - scheme
```
IEventDataScheme scheme
```
    - checkpointIntervalInSeconds
```
int checkpointIntervalInSeconds
```
    - stateStore
```
IStateStore stateStore
```
    - partitionCoordinator
```
IPartitionCoordinator partitionCoordinator
```
    - pmFactory
```
IPartitionManagerFactory pmFactory
```
    - recvFactory
```
IEventHubReceiverFactory recvFactory
```
    - collector
```
SpoutOutputCollector collector
```
    - lastCheckpointTime
```
long lastCheckpointTime
```
    - currentPartitionIndex
```
int currentPartitionIndex
```
- Class org.apache.storm.eventhubs.spout.EventHubSpoutConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - userName
```
String userName
```
    - password
```
String password
```
    - namespace
```
String namespace
```
    - entityPath
```
String entityPath
```
    - partitionCount
```
int partitionCount
```
    - zkConnectionString
```
String zkConnectionString
```
    - checkpointIntervalInSeconds
```
int checkpointIntervalInSeconds
```
    - receiverCredits
```
int receiverCredits
```
    - maxPendingMsgsPerPartition
```
int maxPendingMsgsPerPartition
```
    - enqueueTimeFilter
```
long enqueueTimeFilter
```
    - connectionString
```
String connectionString
```
    - topologyName
```
String topologyName
```
    - receiverTimeoutInMillis
```
int receiverTimeoutInMillis
```
    - scheme
```
IEventDataScheme scheme
```
    - consumerGroupName
```
String consumerGroupName
```
    - outputStreamId
```
String outputStreamId
```
- Class org.apache.storm.eventhubs.spout.StringEventDataScheme extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.eventhubs.spout.ZookeeperStateStore extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - zookeeperConnectionString
```
String zookeeperConnectionString
```
    - curatorFramework
```
org.apache.curator.framework.CuratorFramework curatorFramework
```
Package org.apache.storm.eventhubs.trident
- Class org.apache.storm.eventhubs.trident.OpaqueTridentEventHubSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - scheme
```
IEventDataScheme scheme
```
    - spoutConfig
```
EventHubSpoutConfig spoutConfig
```
- Class org.apache.storm.eventhubs.trident.Partition extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionId
```
String partitionId
```
- Class org.apache.storm.eventhubs.trident.Partitions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionList
```
List<E> partitionList
```
- Class org.apache.storm.eventhubs.trident.TransactionalTridentEventHubSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - scheme
```
IEventDataScheme scheme
```
    - spoutConfig
```
EventHubSpoutConfig spoutConfig
```
Package org.apache.storm.executor
- Class org.apache.storm.executor.TupleInfo extends Object implements Serializable
  
  serialVersionUID:
  
  -3348670497595864118L
  - Serialized Fields
    - taskId
```
int taskId
```
    - messageId
```
Object messageId
```
    - stream
```
String stream
```
    - values
```
List<E> values
```
    - timestamp
```
long timestamp
```
    - rootId
```
long rootId
```
Package org.apache.storm.flux.examples
- Class org.apache.storm.flux.examples.OnlyValueRecordTranslator extends Object implements Serializable
- Class org.apache.storm.flux.examples.StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,Long>> implements Serializable
  - Serialized Fields
    - wordCounts
```
KeyValueState<K,V> wordCounts
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.flux.examples.TestPrintBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.flux.examples.TestWindowBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.flux.examples.WordCounter extends BaseBasicBolt implements Serializable
Package org.apache.storm.flux.wrappers.bolts
- Class org.apache.storm.flux.wrappers.bolts.FluxShellBolt extends ShellBolt implements Serializable
  - Serialized Fields
    - outputFields
```
Map<K,V> outputFields
```
    - componentConfig
```
Map<K,V> componentConfig
```
- Class org.apache.storm.flux.wrappers.bolts.LogInfoBolt extends BaseBasicBolt implements Serializable
Package org.apache.storm.flux.wrappers.spouts
- Class org.apache.storm.flux.wrappers.spouts.FluxShellSpout extends ShellSpout implements Serializable
  - Serialized Fields
    - outputFields
```
Map<K,V> outputFields
```
    - componentConfig
```
Map<K,V> componentConfig
```

Package org.apache.storm.generated

Class org.apache.storm.generated.AccessControl 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

type
```
AccessControlType type
```
name
```
String name
```
access
```
int access
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.AlreadyAliveException extends org.apache.storm.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 org.apache.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
```
worker_resources
```
Map<K,V> worker_resources
```
total_shared_off_heap
```
Map<K,V> total_shared_off_heap
```
owner
```
String owner
```

Class org.apache.storm.generated.AuthorizationException extends org.apache.storm.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 org.apache.storm.generated.BeginDownloadResult 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

version
```
long version
```
session
```
String session
```
data_size
```
long data_size
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.storm.generated.BoltAggregateStats 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

execute_latency_ms
```
double execute_latency_ms
```
process_latency_ms
```
double process_latency_ms
```
executed
```
long executed
```
capacity
```
double capacity
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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
```
topologies
```
List<E> topologies
```
nimbuses
```
List<E> nimbuses
```

Class org.apache.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 org.apache.storm.generated.CommonAggregateStats 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_executors
```
int num_executors
```
num_tasks
```
int num_tasks
```
emitted
```
long emitted
```
transferred
```
long transferred
```
acked
```
long acked
```
failed
```
long failed
```
resources_map
```
Map<K,V> resources_map
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.ComponentAggregateStats 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

type
```
ComponentType type
```
common_stats
```
CommonAggregateStats common_stats
```
specific_stats
```
SpecificAggregateStats specific_stats
```
last_error
```
ErrorInfo last_error
```

Class org.apache.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 org.apache.storm.generated.ComponentObject extends org.apache.storm.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 org.apache.storm.generated.ComponentPageInfo 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

component_id
```
String component_id
```
component_type
```
ComponentType component_type
```
topology_id
```
String topology_id
```
topology_name
```
String topology_name
```
num_executors
```
int num_executors
```
num_tasks
```
int num_tasks
```
window_to_stats
```
Map<K,V> window_to_stats
```
gsid_to_input_stats
```
Map<K,V> gsid_to_input_stats
```
sid_to_output_stats
```
Map<K,V> sid_to_output_stats
```
exec_stats
```
List<E> exec_stats
```
errors
```
List<E> errors
```
eventlog_host
```
String eventlog_host
```
eventlog_port
```
int eventlog_port
```
debug_options
```
DebugOptions debug_options
```
topology_status
```
String topology_status
```
resources_map
```
Map<K,V> resources_map
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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
```
- topoOwner
```
String topoOwner
```

Class org.apache.storm.generated.DebugOptions 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

enable
```
boolean enable
```
samplingpct
```
double samplingpct
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_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
```
- e
```
DRPCExecutionException e
```

Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_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 org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.DRPCExecutionException extends org.apache.storm.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
```
- type
```
DRPCExceptionType type
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.ExecutorAggregateStats 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

exec_summary
```
ExecutorSummary exec_summary
```
stats
```
ComponentAggregateStats stats
```

Class org.apache.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 org.apache.storm.generated.ExecutorSpecificStats extends org.apache.storm.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 org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Grouping extends org.apache.storm.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 org.apache.storm.generated.HBAuthorizationException extends org.apache.storm.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 org.apache.storm.generated.HBExecutionException extends org.apache.storm.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 org.apache.storm.generated.HBMessage 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

type
```
HBServerMessageType type
```
data
```
HBMessageData data
```
message_id
```
int message_id
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.HBMessageData extends org.apache.storm.thrift.TUnion<HBMessageData,HBMessageData._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 org.apache.storm.generated.HBNodes 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
- pulseIds
```
List<E> pulseIds
```

Class org.apache.storm.generated.HBPulse 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
```
- details
```
ByteBuffer details
```

Class org.apache.storm.generated.HBRecords 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
- pulses
```
List<E> pulses
```

Class org.apache.storm.generated.IllegalStateException extends org.apache.storm.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 org.apache.storm.generated.InvalidTopologyException extends org.apache.storm.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 org.apache.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 org.apache.storm.generated.JavaObjectArg extends org.apache.storm.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 org.apache.storm.generated.KeyAlreadyExistsException extends org.apache.storm.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 org.apache.storm.generated.KeyNotFoundException extends org.apache.storm.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 org.apache.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 org.apache.storm.generated.ListBlobsResult 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
- keys
```
List<E> keys
```
- session
```
String session
```

Class org.apache.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
```
resources
```
WorkerResources resources
```
total_node_shared
```
double total_node_shared
```
owner
```
String owner
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.storm.generated.LogConfig 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
- named_logger_level
```
Map<K,V> named_logger_level
```

Class org.apache.storm.generated.LogLevel 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

action
```
LogLevelAction action
```
target_log_level
```
String target_log_level
```
reset_log_level_timeout_secs
```
int reset_log_level_timeout_secs
```
reset_log_level_timeout_epoch
```
long reset_log_level_timeout_epoch
```
reset_log_level
```
String reset_log_level
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.LSTopoHistory 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
```
time_stamp
```
long time_stamp
```
users
```
List<E> users
```
groups
```
List<E> groups
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.LSTopoHistoryList 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
- topo_history
```
List<E> topo_history
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.beginBlobDownload_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.beginBlobDownload_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
```
BeginDownloadResult success
```
aze
```
AuthorizationException aze
```
knf
```
KeyNotFoundException knf
```

Class org.apache.storm.generated.Nimbus.beginCreateBlob_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
- key
```
String key
```
- meta
```
SettableBlobMeta meta
```

Class org.apache.storm.generated.Nimbus.beginCreateBlob_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
```
kae
```
KeyAlreadyExistsException kae
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.beginUpdateBlob_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.beginUpdateBlob_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
```
knf
```
KeyNotFoundException knf
```

Class org.apache.storm.generated.Nimbus.cancelBlobUpload_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
- session
```
String session
```

Class org.apache.storm.generated.Nimbus.cancelBlobUpload_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 org.apache.storm.generated.Nimbus.createStateInZookeeper_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.createStateInZookeeper_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

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.debug_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
```
component
```
String component
```
enable
```
boolean enable
```
samplingPercentage
```
double samplingPercentage
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.debug_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 org.apache.storm.generated.Nimbus.deleteBlob_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.deleteBlob_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

Class org.apache.storm.generated.Nimbus.downloadBlobChunk_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
- session
```
String session
```

Class org.apache.storm.generated.Nimbus.downloadBlobChunk_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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.finishBlobUpload_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
- session
```
String session
```

Class org.apache.storm.generated.Nimbus.finishBlobUpload_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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.getBlobMeta_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.getBlobMeta_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
```
ReadableBlobMeta success
```
aze
```
AuthorizationException aze
```
knf
```
KeyNotFoundException knf
```

Class org.apache.storm.generated.Nimbus.getBlobReplication_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
- key
```
String key
```

Class org.apache.storm.generated.Nimbus.getBlobReplication_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
```
int success
```
aze
```
AuthorizationException aze
```
knf
```
KeyNotFoundException knf
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.getComponentPageInfo_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

topology_id
```
String topology_id
```
component_id
```
String component_id
```
window
```
String window
```
is_include_sys
```
boolean is_include_sys
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.getComponentPageInfo_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
```
ComponentPageInfo success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_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
```
component_id
```
String component_id
```
action
```
ProfileAction action
```

Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_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
```
List<E> success
```

Class org.apache.storm.generated.Nimbus.getLeader_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 org.apache.storm.generated.Nimbus.getLeader_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
```
NimbusSummary success
```
aze
```
AuthorizationException aze
```

Class org.apache.storm.generated.Nimbus.getLogConfig_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 org.apache.storm.generated.Nimbus.getLogConfig_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
```
LogConfig success
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_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
- owner
```
String owner
```

Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_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
```
List<E> success
```
aze
```
AuthorizationException aze
```

Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_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
- node
```
String node
```

Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_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
```
SupervisorAssignments success
```
aze
```
AuthorizationException aze
```

Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_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
```
host
```
String host
```
is_include_sys
```
boolean is_include_sys
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_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
```
SupervisorPageInfo success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.getTopologyHistory_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
- user
```
String user
```

Class org.apache.storm.generated.Nimbus.getTopologyHistory_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
```
TopologyHistoryInfo success
```
aze
```
AuthorizationException aze
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.getTopologyPageInfo_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
```
window
```
String window
```
is_include_sys
```
boolean is_include_sys
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_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
```
TopologyPageInfo success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.isRemoteBlobExists_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
- blobKey
```
String blobKey
```

Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_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
```
boolean success
```
aze
```
AuthorizationException aze
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_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 org.apache.storm.generated.Nimbus.isTopologyNameAllowed_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
```
boolean success
```
aze
```
AuthorizationException aze
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.listBlobs_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
- session
```
String session
```

Class org.apache.storm.generated.Nimbus.listBlobs_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
```
ListBlobsResult success
```

Class org.apache.storm.generated.Nimbus.processWorkerMetrics_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
- metrics
```
WorkerMetrics metrics
```

Class org.apache.storm.generated.Nimbus.processWorkerMetrics_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

Class org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_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
- heatbeat
```
SupervisorWorkerHeartbeat heatbeat
```

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_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
```
e
```
NotAliveException e
```

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_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
- heartbeats
```
SupervisorWorkerHeartbeats heartbeats
```

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_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 org.apache.storm.generated.Nimbus.setBlobMeta_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
- key
```
String key
```
- meta
```
SettableBlobMeta meta
```

Class org.apache.storm.generated.Nimbus.setBlobMeta_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
```
knf
```
KeyNotFoundException knf
```

Class org.apache.storm.generated.Nimbus.setLogConfig_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
```
- config
```
LogConfig config
```

Class org.apache.storm.generated.Nimbus.setLogConfig_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

Class org.apache.storm.generated.Nimbus.setWorkerProfiler_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
```
- profileRequest
```
ProfileRequest profileRequest
```

Class org.apache.storm.generated.Nimbus.setWorkerProfiler_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

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.Nimbus.updateBlobReplication_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

key
```
String key
```
replication
```
int replication
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.updateBlobReplication_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
```
int success
```
aze
```
AuthorizationException aze
```
knf
```
KeyNotFoundException knf
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.Nimbus.uploadBlobChunk_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
- session
```
String session
```
- chunk
```
ByteBuffer chunk
```

Class org.apache.storm.generated.Nimbus.uploadBlobChunk_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 org.apache.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 org.apache.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 org.apache.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 org.apache.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 org.apache.storm.generated.NimbusSummary 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
```
port
```
int port
```
uptime_secs
```
int uptime_secs
```
isLeader
```
boolean isLeader
```
version
```
String version
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.storm.generated.NotAliveException extends org.apache.storm.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 org.apache.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 org.apache.storm.generated.OwnerResourceSummary 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

owner
```
String owner
```
total_topologies
```
int total_topologies
```
total_executors
```
int total_executors
```
total_workers
```
int total_workers
```
memory_usage
```
double memory_usage
```
cpu_usage
```
double cpu_usage
```
memory_guarantee
```
double memory_guarantee
```
cpu_guarantee
```
double cpu_guarantee
```
memory_guarantee_remaining
```
double memory_guarantee_remaining
```
cpu_guarantee_remaining
```
double cpu_guarantee_remaining
```
isolated_node_guarantee
```
int isolated_node_guarantee
```
total_tasks
```
int total_tasks
```
requested_on_heap_memory
```
double requested_on_heap_memory
```
requested_off_heap_memory
```
double requested_off_heap_memory
```
requested_total_memory
```
double requested_total_memory
```
requested_cpu
```
double requested_cpu
```
assigned_on_heap_memory
```
double assigned_on_heap_memory
```
assigned_off_heap_memory
```
double assigned_off_heap_memory
```
__isset_bitfield
```
int __isset_bitfield
```

Class org.apache.storm.generated.PrivateWorkerKey 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

key
```
ByteBuffer key
```
userName
```
String userName
```
expirationTimeMillis
```
long expirationTimeMillis
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.ProfileRequest 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

nodeInfo
```
NodeInfo nodeInfo
```
action
```
ProfileAction action
```
time_stamp
```
long time_stamp
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.ReadableBlobMeta 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

settable
```
SettableBlobMeta settable
```
version
```
long version
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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
```
topology_resources_overrides
```
Map<K,V> topology_resources_overrides
```
topology_conf_overrides
```
String topology_conf_overrides
```
principal
```
String principal
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.SettableBlobMeta 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

acl
```
List<E> acl
```
replication_factor
```
int replication_factor
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.SharedMemory 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
```
on_heap
```
double on_heap
```
off_heap_worker
```
double off_heap_worker
```
off_heap_node
```
double off_heap_node
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.storm.generated.SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats,SpecificAggregateStats._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 org.apache.storm.generated.SpoutAggregateStats 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
- complete_latency_ms
```
double complete_latency_ms
```
- __isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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 org.apache.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 org.apache.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 org.apache.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
```
component_debug
```
Map<K,V> component_debug
```
principal
```
String principal
```
topology_version
```
String topology_version
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.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
```
worker_hooks
```
List<E> worker_hooks
```
dependency_jars
```
List<E> dependency_jars
```
dependency_artifacts
```
List<E> dependency_artifacts
```
storm_version
```
String storm_version
```
jdk_version
```
String jdk_version
```
component_to_shared_memory
```
Map<K,V> component_to_shared_memory
```
shared_memory
```
Map<K,V> shared_memory
```

Class org.apache.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 org.apache.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 org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_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 org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_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
```
Assignment success
```
e
```
NotAliveException e
```
aze
```
AuthorizationException aze
```

Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_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
- assignments
```
SupervisorAssignments assignments
```

Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_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 org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_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
- heartbeat
```
SupervisorWorkerHeartbeat heartbeat
```

Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_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 org.apache.storm.generated.SupervisorAssignments 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_assignment
```
Map<K,V> storm_assignment
```

Class org.apache.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
```
resources_map
```
Map<K,V> resources_map
```
server_port
```
int server_port
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.SupervisorPageInfo 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_summaries
```
List<E> supervisor_summaries
```
- worker_summaries
```
List<E> worker_summaries
```

Class org.apache.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
```
total_resources
```
Map<K,V> total_resources
```
used_mem
```
double used_mem
```
used_cpu
```
double used_cpu
```
fragmented_mem
```
double fragmented_mem
```
fragmented_cpu
```
double fragmented_cpu
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.SupervisorWorkerHeartbeat 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
```
executors
```
List<E> executors
```
time_secs
```
int time_secs
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.SupervisorWorkerHeartbeats 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
```
- worker_heartbeats
```
List<E> worker_heartbeats
```

Class org.apache.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 org.apache.storm.generated.TopologyActionOptions extends org.apache.storm.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 org.apache.storm.generated.TopologyHistoryInfo 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
- topo_ids
```
List<E> topo_ids
```

Class org.apache.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
```
component_debug
```
Map<K,V> component_debug
```
storm_version
```
String storm_version
```
sched_status
```
String sched_status
```
owner
```
String owner
```
replication_count
```
int replication_count
```
requested_memonheap
```
double requested_memonheap
```
requested_memoffheap
```
double requested_memoffheap
```
requested_cpu
```
double requested_cpu
```
assigned_memonheap
```
double assigned_memonheap
```
assigned_memoffheap
```
double assigned_memoffheap
```
assigned_cpu
```
double assigned_cpu
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.TopologyPageInfo 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
```
status
```
String status
```
num_tasks
```
int num_tasks
```
num_workers
```
int num_workers
```
num_executors
```
int num_executors
```
topology_conf
```
String topology_conf
```
id_to_spout_agg_stats
```
Map<K,V> id_to_spout_agg_stats
```
id_to_bolt_agg_stats
```
Map<K,V> id_to_bolt_agg_stats
```
sched_status
```
String sched_status
```
topology_stats
```
TopologyStats topology_stats
```
owner
```
String owner
```
debug_options
```
DebugOptions debug_options
```
replication_count
```
int replication_count
```
workers
```
List<E> workers
```
storm_version
```
String storm_version
```
topology_version
```
String topology_version
```
requested_memonheap
```
double requested_memonheap
```
requested_memoffheap
```
double requested_memoffheap
```
requested_cpu
```
double requested_cpu
```
assigned_memonheap
```
double assigned_memonheap
```
assigned_memoffheap
```
double assigned_memoffheap
```
assigned_cpu
```
double assigned_cpu
```
requested_regular_on_heap_memory
```
double requested_regular_on_heap_memory
```
requested_shared_on_heap_memory
```
double requested_shared_on_heap_memory
```

requested_regular_off_heap_memory

double requested_regular_off_heap_memory

requested_shared_off_heap_memory
```
double requested_shared_off_heap_memory
```
assigned_regular_on_heap_memory
```
double assigned_regular_on_heap_memory
```
assigned_shared_on_heap_memory
```
double assigned_shared_on_heap_memory
```
assigned_regular_off_heap_memory
```
double assigned_regular_off_heap_memory
```
assigned_shared_off_heap_memory
```
double assigned_shared_off_heap_memory
```
__isset_bitfield
```
int __isset_bitfield
```

Class org.apache.storm.generated.TopologyStats 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

window_to_emitted
```
Map<K,V> window_to_emitted
```
window_to_transferred
```
Map<K,V> window_to_transferred
```

window_to_complete_latencies_ms

Map<K,V> window_to_complete_latencies_ms

window_to_acked
```
Map<K,V> window_to_acked
```
window_to_failed
```
Map<K,V> window_to_failed
```

Class org.apache.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
```
storm_version
```
String storm_version
```
topology_version
```
String topology_version
```
sched_status
```
String sched_status
```
owner
```
String owner
```
replication_count
```
int replication_count
```
requested_memonheap
```
double requested_memonheap
```
requested_memoffheap
```
double requested_memoffheap
```
requested_cpu
```
double requested_cpu
```
assigned_memonheap
```
double assigned_memonheap
```
assigned_memoffheap
```
double assigned_memoffheap
```
assigned_cpu
```
double assigned_cpu
```
__isset_bitfield
```
short __isset_bitfield
```

Class org.apache.storm.generated.WorkerMetricList 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
- metrics
```
List<E> metrics
```

Class org.apache.storm.generated.WorkerMetricPoint 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

metricName
```
String metricName
```
timestamp
```
long timestamp
```
metricValue
```
double metricValue
```
componentId
```
String componentId
```
executorId
```
String executorId
```
streamId
```
String streamId
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.WorkerMetrics 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

topologyId
```
String topologyId
```
port
```
int port
```
hostname
```
String hostname
```
metricList
```
WorkerMetricList metricList
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.WorkerResources 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

mem_on_heap
```
double mem_on_heap
```
mem_off_heap
```
double mem_off_heap
```
cpu
```
double cpu
```
shared_mem_on_heap
```
double shared_mem_on_heap
```
shared_mem_off_heap
```
double shared_mem_off_heap
```
resources
```
Map<K,V> resources
```
shared_resources
```
Map<K,V> shared_resources
```
__isset_bitfield
```
byte __isset_bitfield
```

Class org.apache.storm.generated.WorkerSummary 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
```
host
```
String host
```
port
```
int port
```
topology_id
```
String topology_id
```
topology_name
```
String topology_name
```
num_executors
```
int num_executors
```
component_to_num_tasks
```
Map<K,V> component_to_num_tasks
```
time_secs
```
int time_secs
```
uptime_secs
```
int uptime_secs
```
requested_memonheap
```
double requested_memonheap
```
requested_memoffheap
```
double requested_memoffheap
```
requested_cpu
```
double requested_cpu
```
assigned_memonheap
```
double assigned_memonheap
```
assigned_memoffheap
```
double assigned_memoffheap
```
assigned_cpu
```
double assigned_cpu
```
owner
```
String owner
```
__isset_bitfield
```
short __isset_bitfield
```

Class org.apache.storm.generated.WorkerToken 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

serviceType
```
WorkerTokenServiceType serviceType
```
info
```
ByteBuffer info
```
signature
```
ByteBuffer signature
```

Class org.apache.storm.generated.WorkerTokenInfo 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

userName
```
String userName
```
topologyId
```
String topologyId
```
secretVersion
```
long secretVersion
```
expirationTimeMillis
```
long expirationTimeMillis
```
__isset_bitfield
```
byte __isset_bitfield
```

Package org.apache.storm.grouping
- Class org.apache.storm.grouping.LoadAwareShuffleGrouping extends Object implements Serializable
  - Serialized Fields
    - orig
```
Map<K,V> orig
```
    - rets
```
List<E>[] rets
```
    - choices
```
int[] choices
```
    - capacity
```
int capacity
```
    - random
```
Random random
```
    - prepareChoices
```
int[] prepareChoices
```
    - current
```
AtomicInteger current
```
    - currentScope
```
org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope currentScope
```
    - sourceNodeInfo
```
NodeInfo sourceNodeInfo
```
    - targetTasks
```
List<E> targetTasks
```
    - taskToNodePort
```
AtomicReference<V> taskToNodePort
```
    - conf
```
Map<K,V> conf
```
    - dnsToSwitchMapping
```
DNSToSwitchMapping dnsToSwitchMapping
```
    - localityGroup
```
Map<K,V> localityGroup
```
    - higherBound
```
double higherBound
```
    - lowerBound
```
double lowerBound
```
- Class org.apache.storm.grouping.PartialKeyGrouping extends Object implements Serializable
  
  serialVersionUID:
  
  -1672360572274911808L
  - Serialized Fields
    - targetTasks
```
List<E> targetTasks
```
    - fields
```
Fields fields
```
    - outFields
```
Fields outFields
```
    - assignmentCreator
```
PartialKeyGrouping.AssignmentCreator assignmentCreator
```
    - targetSelector
```
PartialKeyGrouping.TargetSelector targetSelector
```
- Class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelector extends Object implements Serializable
  - Serialized Fields
    - targetTaskStats
```
Map<K,V> targetTaskStats
```
- Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator extends Object implements Serializable
- Class org.apache.storm.grouping.ShuffleGrouping extends Object implements Serializable
  - Serialized Fields
    - choices
```
ArrayList<E> choices
```
    - current
```
AtomicInteger current
```
Package org.apache.storm.hbase.bolt
- Class org.apache.storm.hbase.bolt.AbstractHBaseBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - tableName
```
String tableName
```
    - mapper
```
HBaseMapper mapper
```
    - configKey
```
String configKey
```
- Class org.apache.storm.hbase.bolt.HBaseBolt extends AbstractHBaseBolt implements Serializable
  - Serialized Fields
    - writeToWAL
```
boolean writeToWAL
```
    - batchMutations
```
List<E> batchMutations
```
    - flushIntervalSecs
```
int flushIntervalSecs
```
    - batchSize
```
int batchSize
```
    - batchHelper
```
BatchHelper batchHelper
```
- Class org.apache.storm.hbase.bolt.HBaseLookupBolt extends AbstractHBaseBolt implements Serializable
  - Serialized Fields
    - rowToTupleMapper
```
HBaseValueMapper rowToTupleMapper
```
    - projectionCriteria
```
HBaseProjectionCriteria projectionCriteria
```
Package org.apache.storm.hbase.bolt.mapper
- Class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria extends Object implements Serializable
  - Serialized Fields
    - columnFamilies
```
List<E> columnFamilies
```
    - columns
```
List<E> columns
```
- Class org.apache.storm.hbase.bolt.mapper.HBaseProjectionCriteria.ColumnMetaData extends Object implements Serializable
  - Serialized Fields
    - columnFamily
```
byte[] columnFamily
```
    - qualifier
```
byte[] qualifier
```
- Class org.apache.storm.hbase.bolt.mapper.SimpleHBaseMapper extends Object implements Serializable
  - Serialized Fields
    - rowKeyField
```
String rowKeyField
```
    - columnFamily
```
byte[] columnFamily
```
    - columnFields
```
Fields columnFields
```
    - counterFields
```
Fields counterFields
```
Package org.apache.storm.hbase.topology
- Class org.apache.storm.hbase.topology.TotalWordCounter extends Object implements Serializable
  - Serialized Fields
    - total
```
BigInteger total
```
- Class org.apache.storm.hbase.topology.WordCounter extends Object implements Serializable
- Class org.apache.storm.hbase.topology.WordCountValueMapper extends Object implements Serializable
- Class org.apache.storm.hbase.topology.WordSpout extends Object implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.hbase.trident
- Class org.apache.storm.hbase.trident.PrintFunction extends BaseFunction implements Serializable
Package org.apache.storm.hbase.trident.mapper
- Class org.apache.storm.hbase.trident.mapper.SimpleTridentHBaseMapMapper extends Object implements Serializable
  - Serialized Fields
    - qualifier
```
String qualifier
```
- Class org.apache.storm.hbase.trident.mapper.SimpleTridentHBaseMapper extends Object implements Serializable
  - Serialized Fields
    - rowKeyField
```
String rowKeyField
```
    - columnFamily
```
byte[] columnFamily
```
    - columnFields
```
Fields columnFields
```
    - counterFields
```
Fields counterFields
```
Package org.apache.storm.hbase.trident.state
- Class org.apache.storm.hbase.trident.state.HBaseMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - stateType
```
StateType stateType
```
    - options
```
HBaseMapState.Options<T> options
```
- Class org.apache.storm.hbase.trident.state.HBaseMapState.Options extends Object implements Serializable
  - Serialized Fields
    - serializer
```
Serializer<T> serializer
```
    - cacheSize
```
int cacheSize
```
    - globalKey
```
String globalKey
```
    - configKey
```
String configKey
```
    - tableName
```
String tableName
```
    - columnFamily
```
String columnFamily
```
    - mapMapper
```
TridentHBaseMapMapper mapMapper
```
- Class org.apache.storm.hbase.trident.state.HBaseQuery extends BaseQueryFunction<HBaseState,List<Values>> implements Serializable
- Class org.apache.storm.hbase.trident.state.HBaseState.Options extends Object implements Serializable
  - Serialized Fields
    - mapper
```
TridentHBaseMapper mapper
```
    - durability
```
org.apache.hadoop.hbase.client.Durability durability
```
    - projectionCriteria
```
HBaseProjectionCriteria projectionCriteria
```
    - rowToStormValueMapper
```
HBaseValueMapper rowToStormValueMapper
```
    - configKey
```
String configKey
```
    - tableName
```
String tableName
```
- Class org.apache.storm.hbase.trident.state.HBaseStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
HBaseState.Options options
```
- Class org.apache.storm.hbase.trident.state.HBaseUpdater extends BaseStateUpdater<HBaseState> implements Serializable
Package org.apache.storm.hbase.trident.windowing
- Class org.apache.storm.hbase.trident.windowing.HBaseWindowsStore extends Object implements Serializable
  - Serialized Fields
    - threadLocalHtable
```
ThreadLocal<T> threadLocalHtable
```
    - threadLocalWindowKryoSerializer
```
ThreadLocal<T> threadLocalWindowKryoSerializer
```
    - htables
```
Queue<E> htables
```
    - family
```
byte[] family
```
    - qualifier
```
byte[] qualifier
```
- Class org.apache.storm.hbase.trident.windowing.HBaseWindowsStoreFactory extends Object implements Serializable
  - Serialized Fields
    - config
```
Map<K,V> config
```
    - tableName
```
String tableName
```
    - family
```
byte[] family
```
    - qualifier
```
byte[] qualifier
```
Package org.apache.storm.hdfs.avro
- Class org.apache.storm.hdfs.avro.AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable
- Class org.apache.storm.hdfs.avro.ConfluentAvroSerializer extends AbstractAvroSerializer implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - theClient
```
io.confluent.kafka.schemaregistry.client.SchemaRegistryClient theClient
```
- Class org.apache.storm.hdfs.avro.FixedAvroSerializer extends AbstractAvroSerializer implements Serializable
  - Serialized Fields
    - fingerprint2schemaMap
```
Map<K,V> fingerprint2schemaMap
```
    - schema2fingerprintMap
```
Map<K,V> schema2fingerprintMap
```
- Class org.apache.storm.hdfs.avro.GenericAvroSerializer extends AbstractAvroSerializer implements Serializable
Package org.apache.storm.hdfs.bolt
- Class org.apache.storm.hdfs.bolt.AbstractHdfsBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - writers
```
Map<K,V> writers
```
    - rotationCounterMap
```
Map<K,V> rotationCounterMap
```
    - rotationActions
```
List<E> rotationActions
```
    - collector
```
OutputCollector collector
```
    - syncPolicy
```
SyncPolicy syncPolicy
```
    - rotationPolicy
```
FileRotationPolicy rotationPolicy
```
    - fileNameFormat
```
FileNameFormat fileNameFormat
```
    - fsUrl
```
String fsUrl
```
    - configKey
```
String configKey
```
    - offset
```
long offset
```
    - fileRetryCount
```
Integer fileRetryCount
```
    - tickTupleInterval
```
Integer tickTupleInterval
```
    - maxOpenFiles
```
Integer maxOpenFiles
```
    - partitioner
```
Partitioner partitioner
```
    - tupleBatch
```
List<E> tupleBatch
```
- Class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt extends AbstractHdfsBolt implements Serializable
- Class org.apache.storm.hdfs.bolt.HdfsBolt extends AbstractHdfsBolt implements Serializable
  - Serialized Fields
    - format
```
RecordFormat format
```
- Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - counts
```
HashMap<K,V> counts
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
    - collector
```
SpoutOutputCollector collector
```
    - sentences
```
String[] sentences
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
- Class org.apache.storm.hdfs.bolt.SequenceFileBolt extends AbstractHdfsBolt implements Serializable
  - Serialized Fields
    - format
```
SequenceFormat format
```
    - compressionType
```
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
```
    - compressionCodec
```
String compressionCodec
```
- Class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - counts
```
HashMap<K,V> counts
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
    - collector
```
SpoutOutputCollector collector
```
    - sentences
```
String[] sentences
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
Package org.apache.storm.hdfs.bolt.format
- Class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat extends Object implements Serializable
  - Serialized Fields
    - componentId
```
String componentId
```
    - taskId
```
int taskId
```
    - path
```
String path
```
    - prefix
```
String prefix
```
    - extension
```
String extension
```
- Class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat extends Object implements Serializable
  - Serialized Fields
    - keyField
```
String keyField
```
    - valueField
```
String valueField
```
- Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat extends Object implements Serializable
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - fields
```
Fields fields
```
- Class org.apache.storm.hdfs.bolt.format.SimpleFileNameFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - componentId
```
String componentId
```
    - taskId
```
int taskId
```
    - host
```
String host
```
    - path
```
String path
```
    - name
```
String name
```
    - timeFormat
```
String timeFormat
```
Package org.apache.storm.hdfs.bolt.rotation
- Class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy extends Object implements Serializable
  - Serialized Fields
    - maxBytes
```
long maxBytes
```
    - lastOffset
```
long lastOffset
```
    - currentBytesWritten
```
long currentBytesWritten
```
- Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy extends Object implements Serializable
- Class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy extends Object implements Serializable
  - Serialized Fields
    - interval
```
long interval
```
Package org.apache.storm.hdfs.bolt.sync
- Class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy extends Object implements Serializable
  - Serialized Fields
    - count
```
int count
```
    - executeCount
```
int executeCount
```
Package org.apache.storm.hdfs.common
- Class org.apache.storm.hdfs.common.NullPartitioner extends Object implements Serializable
Package org.apache.storm.hdfs.common.rotation
- Class org.apache.storm.hdfs.common.rotation.MoveFileAction extends Object implements Serializable
  - Serialized Fields
    - destination
```
String destination
```

Package org.apache.storm.hdfs.spout

Class org.apache.storm.hdfs.spout.HdfsSpout extends BaseRichSpout implements Serializable

Serialized Fields

commitTimeElapsed
```
AtomicBoolean commitTimeElapsed
```
inflight
```
HashMap<K,V> inflight
```
retryList
```
LinkedBlockingQueue<E> retryList
```
lastExpiredLock
```
HdfsUtils.Pair<K,V> lastExpiredLock
```
hdfsUri
```
String hdfsUri
```
readerType
```
String readerType
```
outputFields
```
Fields outputFields
```
sourceDir
```
String sourceDir
```
sourceDirPath
```
org.apache.hadoop.fs.Path sourceDirPath
```
archiveDir
```
String archiveDir
```

archiveDirPath

org.apache.hadoop.fs.Path archiveDirPath

badFilesDir
```
String badFilesDir
```

badFilesDirPath

org.apache.hadoop.fs.Path badFilesDirPath

lockDir
```
String lockDir
```
lockDirPath
```
org.apache.hadoop.fs.Path lockDirPath
```
commitFrequencyCount
```
int commitFrequencyCount
```
commitFrequencySec
```
int commitFrequencySec
```
maxOutstanding
```
int maxOutstanding
```
lockTimeoutSec
```
int lockTimeoutSec
```
clocksInSync
```
boolean clocksInSync
```
inprogressSuffix
```
String inprogressSuffix
```
ignoreSuffix
```
String ignoreSuffix
```
outputStreamName
```
String outputStreamName
```
tracker
```
ProgressTracker tracker
```
hdfs
```
org.apache.hadoop.fs.FileSystem hdfs
```

reader

org.apache.storm.hdfs.spout.FileReader reader

collector
```
SpoutOutputCollector collector
```

hdfsConfig

org.apache.hadoop.conf.Configuration hdfsConfig

conf
```
Map<K,V> conf
```
lock
```
FileLock lock
```
spoutId
```
String spoutId
```
lastExpiredLockTime
```
long lastExpiredLockTime
```
tupleCounter
```
long tupleCounter
```
ackEnabled
```
boolean ackEnabled
```
acksSinceLastCommit
```
int acksSinceLastCommit
```
commitTimer
```
Timer commitTimer
```
fileReadCompletely
```
boolean fileReadCompletely
```
configKey
```
String configKey
```

Class org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBolt extends BaseRichBolt implements Serializable

serialVersionUID:

-5313598399155365865L
- Serialized Fields
  - count
```
int count
```
  - collector
```
OutputCollector collector
```
Class org.apache.storm.hdfs.spout.ParseException extends Exception implements Serializable

Package org.apache.storm.hdfs.trident
- Class org.apache.storm.hdfs.trident.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 org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions extends HdfsState.Options implements Serializable
  - Serialized Fields
    - format
```
RecordFormat format
```
    - offset
```
long offset
```
    - bufferSize
```
int bufferSize
```
- Class org.apache.storm.hdfs.trident.HdfsState.Options extends Object implements Serializable
  - Serialized Fields
    - fsUrl
```
String fsUrl
```
    - configKey
```
String configKey
```
    - rotationPolicy
```
FileRotationPolicy rotationPolicy
```
    - fileNameFormat
```
FileNameFormat fileNameFormat
```
    - rotation
```
int rotation
```
    - rotationActions
```
ArrayList<E> rotationActions
```
    - currentFile
```
org.apache.hadoop.fs.Path currentFile
```
- Class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions extends HdfsState.Options implements Serializable
  - Serialized Fields
    - format
```
SequenceFormat format
```
    - compressionType
```
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
```
    - compressionCodec
```
String compressionCodec
```
- Class org.apache.storm.hdfs.trident.HdfsStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
HdfsState.Options options
```
- Class org.apache.storm.hdfs.trident.HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable
Package org.apache.storm.hdfs.trident.format
- Class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat extends Object implements Serializable
  - Serialized Fields
    - partitionIndex
```
int partitionIndex
```
    - path
```
String path
```
    - prefix
```
String prefix
```
    - extension
```
String extension
```
- Class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat extends Object implements Serializable
  - Serialized Fields
    - keyField
```
String keyField
```
    - valueField
```
String valueField
```
- Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat extends Object implements Serializable
  - Serialized Fields
    - fieldDelimiter
```
String fieldDelimiter
```
    - recordDelimiter
```
String recordDelimiter
```
    - fields
```
Fields fields
```
- Class org.apache.storm.hdfs.trident.format.SimpleFileNameFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionIndex
```
int partitionIndex
```
    - host
```
String host
```
    - path
```
String path
```
    - name
```
String name
```
    - timeFormat
```
String timeFormat
```
Package org.apache.storm.hdfs.trident.rotation
- Class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy extends Object implements Serializable
  - Serialized Fields
    - maxBytes
```
long maxBytes
```
    - lastOffset
```
long lastOffset
```
    - currentBytesWritten
```
long currentBytesWritten
```
- Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy extends Object implements Serializable
- Class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy extends Object implements Serializable
  - Serialized Fields
    - interval
```
long interval
```
    - rotationTimer
```
Timer rotationTimer
```
    - rotationTimerTriggered
```
AtomicBoolean rotationTimerTriggered
```
Package org.apache.storm.hdfs.trident.sync
- Class org.apache.storm.hdfs.trident.sync.CountSyncPolicy extends Object implements Serializable
  - Serialized Fields
    - count
```
int count
```
    - executeCount
```
int executeCount
```
Package org.apache.storm.hive.bolt
- Class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
    - collector
```
SpoutOutputCollector collector
```
    - filePath
```
String filePath
```
    - br
```
BufferedReader br
```
    - count
```
int count
```
    - total
```
long total
```
    - outputFields
```
String[] outputFields
```
- Class org.apache.storm.hive.bolt.HiveBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - allWriters
```
Map<K,V> allWriters
```
    - collector
```
OutputCollector collector
```
    - options
```
HiveOptions options
```
    - callTimeoutPool
```
ExecutorService callTimeoutPool
```
    - sendHeartBeat
```
AtomicBoolean sendHeartBeat
```
    - ugi
```
org.apache.hadoop.security.UserGroupInformation ugi
```
    - batchHelper
```
BatchHelper batchHelper
```
    - tokenAuthEnabled
```
boolean tokenAuthEnabled
```
- Class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
    - collector
```
SpoutOutputCollector collector
```
    - sentences
```
String[] sentences
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
- Class org.apache.storm.hive.bolt.HiveTopologyPartitioned.UserDataSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
    - collector
```
SpoutOutputCollector collector
```
    - sentences
```
String[] sentences
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
Package org.apache.storm.hive.bolt.mapper
- Class org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper extends Object implements Serializable
  - Serialized Fields
    - columnFields
```
Fields columnFields
```
    - partitionFields
```
Fields partitionFields
```
    - columnNames
```
String[] columnNames
```
    - timeFormat
```
String timeFormat
```
    - fieldDelimiter
```
String fieldDelimiter
```
    - parseDate
```
SimpleDateFormat parseDate
```
- Class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper extends Object implements Serializable
  - Serialized Fields
    - columnFields
```
Fields columnFields
```
    - partitionFields
```
Fields partitionFields
```
    - timeFormat
```
String timeFormat
```
    - parseDate
```
SimpleDateFormat parseDate
```
Package org.apache.storm.hive.common
- Class org.apache.storm.hive.common.HiveOptions extends Object implements Serializable
  - Serialized Fields
    - mapper
```
HiveMapper mapper
```
    - databaseName
```
String databaseName
```
    - tableName
```
String tableName
```
    - metaStoreURI
```
String metaStoreURI
```
    - txnsPerBatch
```
Integer txnsPerBatch
```
    - maxOpenConnections
```
Integer maxOpenConnections
```
    - batchSize
```
Integer batchSize
```
    - idleTimeout
```
Integer idleTimeout
```
    - callTimeout
```
Integer callTimeout
```
    - heartBeatInterval
```
Integer heartBeatInterval
```
    - autoCreatePartitions
```
Boolean autoCreatePartitions
```
    - kerberosPrincipal
```
String kerberosPrincipal
```
    - kerberosKeytab
```
String kerberosKeytab
```
    - tickTupleInterval
```
Integer tickTupleInterval
```
- Class org.apache.storm.hive.common.HiveUtils.AuthenticationFailed extends Exception implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.CommitFailure extends HiveWriter.Failure implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.ConnectFailure extends HiveWriter.Failure implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.Failure extends Exception implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.TxnBatchFailure extends HiveWriter.Failure implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.TxnFailure extends HiveWriter.Failure implements Serializable
- Class org.apache.storm.hive.common.HiveWriter.WriteFailure extends HiveWriter.Failure implements Serializable
Package org.apache.storm.hive.trident
- Class org.apache.storm.hive.trident.HiveStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
HiveOptions options
```
- Class org.apache.storm.hive.trident.HiveUpdater extends BaseStateUpdater<HiveState> implements Serializable
- Class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout extends Object implements Serializable
  - Serialized Fields
    - maxBatchSize
```
int maxBatchSize
```
    - batches
```
HashMap<K,V> batches
```
    - outputs
```
Values[] outputs
```
    - index
```
int index
```
    - cycle
```
boolean cycle
```
Package org.apache.storm.hooks
- Class org.apache.storm.hooks.BaseWorkerHook extends Object implements Serializable
  
  serialVersionUID:
  
  2589466485198339529L
- Class org.apache.storm.hooks.SubmitterHookException extends RuntimeException implements Serializable
Package org.apache.storm.jdbc.bolt
- Class org.apache.storm.jdbc.bolt.AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - configKey
```
String configKey
```
    - queryTimeoutSecs
```
Integer queryTimeoutSecs
```
    - connectionProvider
```
ConnectionProvider connectionProvider
```
- Class org.apache.storm.jdbc.bolt.JdbcInsertBolt extends AbstractJdbcBolt implements Serializable
  - Serialized Fields
    - tableName
```
String tableName
```
    - insertQuery
```
String insertQuery
```
    - jdbcMapper
```
JdbcMapper jdbcMapper
```
- Class org.apache.storm.jdbc.bolt.JdbcLookupBolt extends AbstractJdbcBolt implements Serializable
  - Serialized Fields
    - selectQuery
```
String selectQuery
```
    - jdbcLookupMapper
```
JdbcLookupMapper jdbcLookupMapper
```
Package org.apache.storm.jdbc.common
- Class org.apache.storm.jdbc.common.Column extends Object implements Serializable
  - Serialized Fields
    - columnName
```
String columnName
```
    - val
```
Object val
```
    - sqlType
```
int sqlType
```
      The sql type(e.g. varchar, date, int) Ideally we would have an enum but java's jdbc API uses integer. See Types
- Class org.apache.storm.jdbc.common.HikariCPConnectionProvider extends Object implements Serializable
  - Serialized Fields
    - configMap
```
Map<K,V> configMap
```
Package org.apache.storm.jdbc.mapper
- Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable
  - Serialized Fields
    - outputFields
```
Fields outputFields
```
- Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper extends Object implements Serializable
  - Serialized Fields
    - schemaColumns
```
List<E> schemaColumns
```
Package org.apache.storm.jdbc.spout
- Class org.apache.storm.jdbc.spout.UserSpout extends Object implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.jdbc.trident.state
- Class org.apache.storm.jdbc.trident.state.JdbcQuery extends BaseQueryFunction<JdbcState,List<Values>> implements Serializable
- Class org.apache.storm.jdbc.trident.state.JdbcState.Options extends Object implements Serializable
  - Serialized Fields
    - mapper
```
JdbcMapper mapper
```
    - jdbcLookupMapper
```
JdbcLookupMapper jdbcLookupMapper
```
    - connectionProvider
```
ConnectionProvider connectionProvider
```
    - tableName
```
String tableName
```
    - insertQuery
```
String insertQuery
```
    - selectQuery
```
String selectQuery
```
    - queryTimeoutSecs
```
Integer queryTimeoutSecs
```
- Class org.apache.storm.jdbc.trident.state.JdbcStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
JdbcState.Options options
```
- Class org.apache.storm.jdbc.trident.state.JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable
Package org.apache.storm.jms
Package org.apache.storm.jms.bolt
- Class org.apache.storm.jms.bolt.JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - autoAck
```
boolean autoAck
```
    - connection
```
javax.jms.Connection connection
```
    - session
```
javax.jms.Session session
```
    - messageProducer
```
javax.jms.MessageProducer messageProducer
```
    - jmsTransactional
```
boolean jmsTransactional
```
    - jmsAcknowledgeMode
```
int jmsAcknowledgeMode
```
    - jmsProvider
```
JmsProvider jmsProvider
```
    - producer
```
JmsMessageProducer producer
```
    - collector
```
OutputCollector collector
```
Package org.apache.storm.jms.example
- Class org.apache.storm.jms.example.GenericBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - autoAck
```
boolean autoAck
```
    - autoAnchor
```
boolean autoAnchor
```
    - declaredFields
```
Fields declaredFields
```
    - name
```
String name
```
- Class org.apache.storm.jms.example.JsonTupleProducer extends Object implements Serializable
- Class org.apache.storm.jms.example.SpringJmsProvider extends Object implements Serializable
  - Serialized Fields
    - connectionFactory
```
javax.jms.ConnectionFactory connectionFactory
```
    - destination
```
javax.jms.Destination destination
```
Package org.apache.storm.jms.spout
- Class org.apache.storm.jms.spout.JmsMessageID extends Object implements Serializable
  - Serialized Fields
    - jmsId
```
String jmsId
```
    - sequence
```
Long sequence
```
- Class org.apache.storm.jms.spout.JmsSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - jmsAcknowledgeMode
```
int jmsAcknowledgeMode
```
      The acknowledgment mode used for this instance.
      
      See Also:
      
      Session
    - distributed
```
boolean distributed
```
      Indicates whether or not this spout should run as a singleton.
    - messageHandler
```
org.apache.storm.jms.spout.JmsSpout.MessageHandler messageHandler
```
      Sets up the way we want to handle the emit, ack and fails.
    - tupleProducer
```
JmsTupleProducer tupleProducer
```
      Used to generate tuples from incoming messages.
    - jmsProvider
```
JmsProvider jmsProvider
```
      Encapsulates jms related classes needed to communicate with the mq.
    - messageSequence
```
long messageSequence
```
      Counter of handled messages.
    - collector
```
SpoutOutputCollector collector
```
      The collector used to emit tuples.
    - consumer
```
javax.jms.MessageConsumer consumer
```
      The message consumer.
    - individualAcks
```
boolean individualAcks
```
      If JMS provider supports ack-ing individual messages.
Package org.apache.storm.jms.trident
- Class org.apache.storm.jms.trident.JmsState.Options extends Object implements Serializable
  - Serialized Fields
    - jmsProvider
```
JmsProvider jmsProvider
```
    - msgProducer
```
JmsMessageProducer msgProducer
```
    - jmsAcknowledgeMode
```
int jmsAcknowledgeMode
```
    - jmsTransactional
```
boolean jmsTransactional
```
- Class org.apache.storm.jms.trident.JmsStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
JmsState.Options options
```
- Class org.apache.storm.jms.trident.JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable
- Class org.apache.storm.jms.trident.TridentJmsSpout extends Object implements Serializable
  
  serialVersionUID:
  
  -3469351154693356655L
  - Serialized Fields
    - tupleProducer
```
JmsTupleProducer tupleProducer
```
    - jmsProvider
```
JmsProvider jmsProvider
```
    - jmsAcknowledgeMode
```
int jmsAcknowledgeMode
```
    - name
```
String name
```
Package org.apache.storm.kafka.bolt
- Class org.apache.storm.kafka.bolt.KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable
  
  serialVersionUID:
  
  -5205886631877033478L
  - Serialized Fields
    - producer
```
org.apache.kafka.clients.producer.Producer<K,V> producer
```
    - collector
```
OutputCollector collector
```
    - mapper
```
TupleToKafkaMapper<K,V> mapper
```
    - topicSelector
```
KafkaTopicSelector topicSelector
```
    - providedCallback
```
PreparableCallback providedCallback
```
    - boltSpecifiedProperties
```
Properties boltSpecifiedProperties
```
    - fireAndForget
```
boolean fireAndForget
```
      KafkaBolt.setFireAndForget(boolean) for more details on this.
    - async
```
boolean async
```
      KafkaBolt.setAsync(boolean) for more details on this.
Package org.apache.storm.kafka.bolt.mapper
- Class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
  
  serialVersionUID:
  
  -8794262989021702349L
  - Serialized Fields
    - boltKeyField
```
String boltKeyField
```
    - boltMessageField
```
String boltMessageField
```
Package org.apache.storm.kafka.bolt.selector
- Class org.apache.storm.kafka.bolt.selector.DefaultTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  4601118062437851265L
  - Serialized Fields
    - topicName
```
String topicName
```
- Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3830575380208166367L
  - Serialized Fields
    - fieldIndex
```
int fieldIndex
```
    - defaultTopicName
```
String defaultTopicName
```
- Class org.apache.storm.kafka.bolt.selector.FieldNameTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3903708904533396833L
  - Serialized Fields
    - fieldName
```
String fieldName
```
    - defaultTopicName
```
String defaultTopicName
```
Package org.apache.storm.kafka.spout
- Class org.apache.storm.kafka.spout.ByTopicRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -121699733778988688L
  - Serialized Fields
    - defaultTranslator
```
RecordTranslator<K,V> defaultTranslator
```
    - topicToTranslator
```
Map<K,V> topicToTranslator
```
    - streamToFields
```
Map<K,V> streamToFields
```
- Class org.apache.storm.kafka.spout.DefaultRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -5782462870112305750L
- Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener extends Object implements Serializable
- Class org.apache.storm.kafka.spout.KafkaSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  4151921085047987154L
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - kafkaSpoutConfig
```
KafkaSpoutConfig<K,V> kafkaSpoutConfig
```
    - kafkaConsumerFactory
```
ConsumerFactory<K,V> kafkaConsumerFactory
```
    - topicAssigner
```
TopicAssigner topicAssigner
```
- Class org.apache.storm.kafka.spout.KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
  
  serialVersionUID:
  
  141902646130682494L
  - Serialized Fields
    - offsetCommitPeriodMs
```
long offsetCommitPeriodMs
```
    - maxUncommittedOffsets
```
int maxUncommittedOffsets
```
    - retryService
```
KafkaSpoutRetryService retryService
```
    - tupleListener
```
KafkaTupleListener tupleListener
```
    - emitNullTuples
```
boolean emitNullTuples
```
    - processingGuarantee
```
KafkaSpoutConfig.ProcessingGuarantee processingGuarantee
```
    - tupleTrackingEnforced
```
boolean tupleTrackingEnforced
```
    - metricsTimeBucketSizeInSecs
```
int metricsTimeBucketSizeInSecs
```
- Class org.apache.storm.kafka.spout.KafkaSpoutMessageId extends Object implements Serializable
  - Serialized Fields
    - topicPart
```
org.apache.kafka.common.TopicPartition topicPart
```
    - offset
```
long offset
```
    - numFails
```
int numFails
```
    - nullTuple
```
boolean nullTuple
```
      false if the record was emitted using a form of collector.emit(...). true when skipping null tuples as configured by the user in KafkaSpoutConfig
- Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff extends Object implements Serializable
  - Serialized Fields
    - initialDelay
```
KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay
```
    - delayPeriod
```
KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod
```
    - maxDelay
```
KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay
```
    - maxRetries
```
int maxRetries
```
    - retrySchedules
```
Set<E> retrySchedules
```
    - toRetryMsgs
```
Set<E> toRetryMsgs
```
- Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval extends Object implements Serializable
  - Serialized Fields
    - lengthNanos
```
long lengthNanos
```
    - timeUnit
```
TimeUnit timeUnit
```
    - length
```
long length
```
- Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.kafka.spout.KafkaTuple extends Values implements Serializable
  
  serialVersionUID:
  
  4803794470450587992L
  - Serialized Fields
    - stream
```
String stream
```
- Class org.apache.storm.kafka.spout.SimpleRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  4678369144122009596L
  - Serialized Fields
    - fields
```
Fields fields
```
    - func
```
Func<V,R> func
```
    - stream
```
String stream
```
Package org.apache.storm.kafka.spout.internal
- Class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig extends Object implements Serializable
  - Serialized Fields
    - kafkaProps
```
Map<K,V> kafkaProps
```
    - topicFilter
```
TopicFilter topicFilter
```
    - topicPartitioner
```
ManualPartitioner topicPartitioner
```
    - pollTimeoutMs
```
long pollTimeoutMs
```
    - translator
```
RecordTranslator<K,V> translator
```
    - firstPollOffsetStrategy
```
FirstPollOffsetStrategy firstPollOffsetStrategy
```
    - partitionRefreshPeriodMs
```
long partitionRefreshPeriodMs
```
    - startTimeStamp
```
long startTimeStamp
```
- Class org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault extends Object implements Serializable
Package org.apache.storm.kafka.spout.subscription
- Class org.apache.storm.kafka.spout.subscription.NamedTopicFilter extends Object implements Serializable
  - Serialized Fields
    - topics
```
Set<E> topics
```
- Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter extends Object implements Serializable
  - Serialized Fields
    - pattern
```
Pattern pattern
```
    - topics
```
Set<E> topics
```
- Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner extends Object implements Serializable
- Class org.apache.storm.kafka.spout.subscription.TopicAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  5423018073527583826L
Package org.apache.storm.kafka.spout.trident
- Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - emitter
```
KafkaTridentSpoutEmitter<K,V> emitter
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata extends Object implements Serializable
  - Serialized Fields
    - firstOffset
```
long firstOffset
```
    - lastOffset
```
long lastOffset
```
    - topologyId
```
String topologyId
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator extends Object implements Serializable
  - Serialized Fields
    - tpSerializer
```
TopicPartitionSerializer tpSerializer
```
    - kafkaSpoutConfig
```
KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
```
    - refreshAssignmentTimer
```
Timer refreshAssignmentTimer
```
    - consumer
```
org.apache.kafka.clients.consumer.Consumer<K,V> consumer
```
    - partitionsForBatch
```
Set<E> partitionsForBatch
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  -7343927794834130435L
  - Serialized Fields
    - consumer
```
org.apache.kafka.clients.consumer.Consumer<K,V> consumer
```
    - kafkaSpoutConfig
```
KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
```
    - topicAssigner
```
TopicAssigner topicAssigner
```
    - tpToFirstSeekOffset
```
Map<K,V> tpToFirstSeekOffset
```
    - pollTimeoutMs
```
long pollTimeoutMs
```
    - firstPollOffsetStrategy
```
FirstPollOffsetStrategy firstPollOffsetStrategy
```
    - translator
```
RecordTranslator<K,V> translator
```
    - tpSerializer
```
TopicPartitionSerializer tpSerializer
```
    - topologyContext
```
TopologyContext topologyContext
```
    - startTimeStamp
```
long startTimeStamp
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaque extends Object implements Serializable
  
  serialVersionUID:
  
  -8003272486566259640L
  - Serialized Fields
    - kafkaSpoutConfig
```
KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
```
    - outputFieldsExtractor
```
OutputFieldsExtractor outputFieldsExtractor
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition extends Object implements Serializable
  - Serialized Fields
    - topicPartition
```
org.apache.kafka.common.TopicPartition topicPartition
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - kafkaSpoutConfig
```
KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
```
    - outputFieldsExtractor
```
OutputFieldsExtractor outputFieldsExtractor
```
- Class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - emitter
```
KafkaTridentSpoutEmitter<K,V> emitter
```
Package org.apache.storm.kafka.spout.trident.internal
- Class org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.storm.kafka.trident
- Class org.apache.storm.kafka.trident.TridentKafkaStateFactory extends Object implements Serializable
  
  serialVersionUID:
  
  -3613240970062343385L
  - Serialized Fields
    - mapper
```
TridentTupleToKafkaMapper<K,V> mapper
```
    - topicSelector
```
KafkaTopicSelector topicSelector
```
    - producerProperties
```
Properties producerProperties
```
- Class org.apache.storm.kafka.trident.TridentKafkaStateUpdater extends BaseStateUpdater<TridentKafkaState<K,V>> implements Serializable
  
  serialVersionUID:
  
  3352659585225274402L
Package org.apache.storm.kafka.trident.mapper
- Class org.apache.storm.kafka.trident.mapper.FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
  - Serialized Fields
    - keyFieldName
```
String keyFieldName
```
    - msgFieldName
```
String msgFieldName
```
Package org.apache.storm.kafka.trident.selector
- Class org.apache.storm.kafka.trident.selector.DefaultTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -1172454882072591493L
  - Serialized Fields
    - topicName
```
String topicName
```
Package org.apache.storm.kinesis.spout
- Class org.apache.storm.kinesis.spout.ExponentialBackoffRetrier extends Object implements Serializable
  - Serialized Fields
    - initialDelayMillis
```
Long initialDelayMillis
```
    - baseSeconds
```
Long baseSeconds
```
    - maxRetries
```
Long maxRetries
```
    - failCounts
```
Map<K,V> failCounts
```
    - retryTimes
```
Map<K,V> retryTimes
```
    - retryMessageSet
```
SortedSet<E> retryMessageSet
```
- Class org.apache.storm.kinesis.spout.KinesisConfig extends Object implements Serializable
  - Serialized Fields
    - streamName
```
String streamName
```
    - shardIteratorType
```
com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType
```
    - recordToTupleMapper
```
RecordToTupleMapper recordToTupleMapper
```
    - timestamp
```
Date timestamp
```
    - failedMessageRetryHandler
```
FailedMessageRetryHandler failedMessageRetryHandler
```
    - zkInfo
```
ZkInfo zkInfo
```
    - kinesisConnectionInfo
```
KinesisConnectionInfo kinesisConnectionInfo
```
    - maxUncommittedRecords
```
Long maxUncommittedRecords
```
      This number represents the number of messages that are still not committed to zk. it will prevent the spout from emitting further. for e.g. if 1 failed and 2,3,4,5..... all have been acked by storm, they still can't be committed to zk because 1 is still in failed set. As a result the acked queue can infinitely grow without any of them being committed to zk. topology max pending does not help since from storm's view they are acked
- Class org.apache.storm.kinesis.spout.KinesisConnectionInfo extends Object implements Serializable
  - Serialized Fields
    - serializedKinesisCredsProvider
```
byte[] serializedKinesisCredsProvider
```
    - serializedkinesisClientConfig
```
byte[] serializedkinesisClientConfig
```
    - recordsLimit
```
Integer recordsLimit
```
    - region
```
com.amazonaws.regions.Regions region
```
- Class org.apache.storm.kinesis.spout.KinesisSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - kinesisConfig
```
KinesisConfig kinesisConfig
```
- Class org.apache.storm.kinesis.spout.ZkInfo extends Object implements Serializable
  - Serialized Fields
    - zkUrl
```
String zkUrl
```
    - zkNode
```
String zkNode
```
    - sessionTimeoutMs
```
Integer sessionTimeoutMs
```
    - connectionTimeoutMs
```
Integer connectionTimeoutMs
```
    - commitIntervalMs
```
Long commitIntervalMs
```
    - retryAttempts
```
Integer retryAttempts
```
    - retryIntervalMs
```
Integer retryIntervalMs
```
Package org.apache.storm.lambda
- Class org.apache.storm.lambda.LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - biConsumer
```
SerializableBiConsumer<T,U> biConsumer
```
    - fields
```
String[] fields
```
- Class org.apache.storm.lambda.LambdaConsumerBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - consumer
```
SerializableConsumer<T> consumer
```
- Class org.apache.storm.lambda.LambdaSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - supplier
```
SerializableSupplier<T> supplier
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.loadgen
- Class org.apache.storm.loadgen.ExecAndProcessLatencyEngine extends Object implements Serializable
  - Serialized Fields
    - skewedPattern
```
SlowExecutorPattern skewedPattern
```
    - parkOffset
```
AtomicLong parkOffset
```
    - rand
```
Random rand
```
    - timer
```
ScheduledExecutorService timer
```
- Class org.apache.storm.loadgen.InputStream extends Object implements Serializable
  - Serialized Fields
    - fromComponent
```
String fromComponent
```
    - toComponent
```
String toComponent
```
    - id
```
String id
```
    - execTime
```
NormalDistStats execTime
```
    - processTime
```
NormalDistStats processTime
```
    - groupingType
```
GroupingType groupingType
```
    - gsid
```
GlobalStreamId gsid
```
- Class org.apache.storm.loadgen.LoadBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - outputStreamStats
```
List<E> outputStreamStats
```
    - outputStreams
```
List<E> outputStreams
```
    - inputStreams
```
Map<K,V> inputStreams
```
    - collector
```
OutputCollector collector
```
    - sleep
```
ExecAndProcessLatencyEngine sleep
```
    - executorIndex
```
int executorIndex
```
- Class org.apache.storm.loadgen.LoadSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - streamStats
```
List<E> streamStats
```
    - streams
```
List<E> streams
```
    - collector
```
SpoutOutputCollector collector
```
    - nextStreamCounter
```
long nextStreamCounter
```
    - numStreams
```
int numStreams
```
    - replays
```
Queue<E> replays
```
- Class org.apache.storm.loadgen.NormalDistStats extends Object implements Serializable
  - Serialized Fields
    - mean
```
double mean
```
    - stddev
```
double stddev
```
    - min
```
double min
```
    - max
```
double max
```
- Class org.apache.storm.loadgen.OutputStream extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
    - rate
```
NormalDistStats rate
```
    - areKeysSkewed
```
boolean areKeysSkewed
```
- Class org.apache.storm.loadgen.ScopedTopologySet extends HashSet<String> implements Serializable
  - Serialized Fields
    - client
```
Nimbus.Iface client
```
    - closed
```
boolean closed
```
- Class org.apache.storm.loadgen.SlowExecutorPattern extends Object implements Serializable
  - Serialized Fields
    - maxSlownessMs
```
double maxSlownessMs
```
    - count
```
int count
```
- Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout extends LoadSpout implements Serializable
- Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - sleep
```
ExecAndProcessLatencyEngine sleep
```
    - executorIndex
```
int executorIndex
```
- Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
Package org.apache.storm.metric
- Class org.apache.storm.metric.EventLoggerBolt extends Object implements Serializable
  - Serialized Fields
    - eventLoggers
```
List<E> eventLoggers
```
- Class org.apache.storm.metric.MetricsConsumerBolt extends Object implements Serializable
  - Serialized Fields
    - maxRetainMetricTuples
```
int maxRetainMetricTuples
```
    - filterPredicate
```
org.apache.storm.shade.com.google.common.base.Predicate<T> filterPredicate
```
    - expander
```
DataPointExpander expander
```
    - taskQueue
```
BlockingQueue<E> taskQueue
```
    - metricsConsumer
```
IMetricsConsumer metricsConsumer
```
    - consumerClassName
```
String consumerClassName
```
    - collector
```
OutputCollector collector
```
    - registrationArgument
```
Object registrationArgument
```
    - taskExecuteThread
```
Thread taskExecuteThread
```
    - running
```
boolean running
```
- Class org.apache.storm.metric.SystemBolt extends Object implements Serializable
Package org.apache.storm.metric.filter
- Class org.apache.storm.metric.filter.FilterByMetricName extends Object implements Serializable
  - Serialized Fields
    - filterCache
```
org.apache.storm.shade.com.google.common.cache.Cache<K,V> filterCache
```
    - whitelistPattern
```
List<E> whitelistPattern
```
    - blacklistPattern
```
List<E> blacklistPattern
```
    - noneSpecified
```
boolean noneSpecified
```
Package org.apache.storm.metric.util
- Class org.apache.storm.metric.util.DataPointExpander extends Object implements Serializable
  - Serialized Fields
    - expandMapType
```
boolean expandMapType
```
    - metricNameSeparator
```
String metricNameSeparator
```
Package org.apache.storm.metricstore
- Class org.apache.storm.metricstore.MetricException extends Exception implements Serializable
Package org.apache.storm.mongodb.bolt
- Class org.apache.storm.mongodb.bolt.AbstractMongoBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - collectionName
```
String collectionName
```
    - collector
```
OutputCollector collector
```
    - mongoClient
```
MongoDbClient mongoClient
```
- Class org.apache.storm.mongodb.bolt.MongoInsertBolt extends AbstractMongoBolt implements Serializable
  - Serialized Fields
    - mapper
```
MongoMapper mapper
```
    - ordered
```
boolean ordered
```
    - batchSize
```
int batchSize
```
    - batchHelper
```
BatchHelper batchHelper
```
    - flushIntervalSecs
```
int flushIntervalSecs
```
- Class org.apache.storm.mongodb.bolt.MongoLookupBolt extends AbstractMongoBolt implements Serializable
  - Serialized Fields
    - queryCreator
```
QueryFilterCreator queryCreator
```
    - mapper
```
MongoLookupMapper mapper
```
- Class org.apache.storm.mongodb.bolt.MongoUpdateBolt extends AbstractMongoBolt implements Serializable
  - Serialized Fields
    - queryCreator
```
QueryFilterCreator queryCreator
```
    - mapper
```
MongoUpdateMapper mapper
```
    - upsert
```
boolean upsert
```
    - many
```
boolean many
```
Package org.apache.storm.mongodb.common
- Class org.apache.storm.mongodb.common.SimpleQueryFilterCreator extends Object implements Serializable
  - Serialized Fields
    - field
```
String field
```
Package org.apache.storm.mongodb.common.mapper
- Class org.apache.storm.mongodb.common.mapper.SimpleMongoLookupMapper extends Object implements Serializable
  - Serialized Fields
    - fields
```
String[] fields
```
- Class org.apache.storm.mongodb.common.mapper.SimpleMongoMapper extends Object implements Serializable
  - Serialized Fields
    - fields
```
String[] fields
```
- Class org.apache.storm.mongodb.common.mapper.SimpleMongoUpdateMapper extends SimpleMongoMapper implements Serializable
  - Serialized Fields
    - fields
```
String[] fields
```
Package org.apache.storm.mongodb.topology
- Class org.apache.storm.mongodb.topology.TotalWordCounter extends Object implements Serializable
  - Serialized Fields
    - total
```
BigInteger total
```
- Class org.apache.storm.mongodb.topology.WordCounter extends Object implements Serializable
  - Serialized Fields
    - wordCounter
```
Map<K,V> wordCounter
```
- Class org.apache.storm.mongodb.topology.WordSpout extends Object implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.mongodb.trident
- Class org.apache.storm.mongodb.trident.PrintFunction extends BaseFunction implements Serializable
Package org.apache.storm.mongodb.trident.state
- Class org.apache.storm.mongodb.trident.state.MongoMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - stateType
```
StateType stateType
```
    - options
```
MongoMapState.Options<T> options
```
- Class org.apache.storm.mongodb.trident.state.MongoMapState.Options extends Object implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - collectionName
```
String collectionName
```
    - mapper
```
MongoMapper mapper
```
    - queryCreator
```
QueryFilterCreator queryCreator
```
    - serializer
```
Serializer<T> serializer
```
    - cacheSize
```
int cacheSize
```
    - globalKey
```
String globalKey
```
    - serDocumentField
```
String serDocumentField
```
- Class org.apache.storm.mongodb.trident.state.MongoState.Options extends Object implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - collectionName
```
String collectionName
```
    - mapper
```
MongoMapper mapper
```
    - lookupMapper
```
MongoLookupMapper lookupMapper
```
    - queryCreator
```
QueryFilterCreator queryCreator
```
- Class org.apache.storm.mongodb.trident.state.MongoStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
MongoState.Options options
```
- Class org.apache.storm.mongodb.trident.state.MongoStateQuery extends BaseQueryFunction<MongoState,List<Values>> implements Serializable
- Class org.apache.storm.mongodb.trident.state.MongoStateUpdater extends BaseStateUpdater<MongoState> implements Serializable
Package org.apache.storm.mqtt
Package org.apache.storm.mqtt.bolt
- Class org.apache.storm.mqtt.bolt.MqttBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - mapper
```
MqttTupleMapper mapper
```
    - retain
```
boolean retain
```
    - options
```
MqttOptions options
```
    - keyStoreLoader
```
KeyStoreLoader keyStoreLoader
```
Package org.apache.storm.mqtt.common
- Class org.apache.storm.mqtt.common.MqttOptions extends Object implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - topics
```
List<E> topics
```
    - cleanConnection
```
boolean cleanConnection
```
    - willTopic
```
String willTopic
```
    - willPayload
```
String willPayload
```
    - willQos
```
int willQos
```
    - willRetain
```
boolean willRetain
```
    - reconnectDelay
```
long reconnectDelay
```
    - reconnectDelayMax
```
long reconnectDelayMax
```
    - reconnectBackOffMultiplier
```
double reconnectBackOffMultiplier
```
    - reconnectAttemptsMax
```
long reconnectAttemptsMax
```
    - connectAttemptsMax
```
long connectAttemptsMax
```
    - userName
```
String userName
```
    - password
```
String password
```
    - qos
```
int qos
```
Package org.apache.storm.mqtt.examples
- Class org.apache.storm.mqtt.examples.CustomMessageMapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.storm.mqtt.mappers
- Class org.apache.storm.mqtt.mappers.ByteArrayMessageMapper extends Object implements Serializable
- Class org.apache.storm.mqtt.mappers.StringMessageMapper extends Object implements Serializable
Package org.apache.storm.mqtt.spout
- Class org.apache.storm.mqtt.spout.MqttSpout extends Object implements Serializable
  - Serialized Fields
    - type
```
MqttMessageMapper type
```
    - options
```
MqttOptions options
```
    - keyStoreLoader
```
KeyStoreLoader keyStoreLoader
```
    - topologyName
```
String topologyName
```
    - connection
```
org.fusesource.mqtt.client.CallbackConnection connection
```
    - mqttConnected
```
boolean mqttConnected
```
    - mqttConnectFailed
```
boolean mqttConnectFailed
```
    - sequence
```
Long sequence
```
Package org.apache.storm.mqtt.ssl
- Class org.apache.storm.mqtt.ssl.DefaultKeyStoreLoader extends Object implements Serializable
  - Serialized Fields
    - ksFile
```
String ksFile
```
    - tsFile
```
String tsFile
```
    - keyStorePassword
```
String keyStorePassword
```
    - trustStorePassword
```
String trustStorePassword
```
    - keyPassword
```
String keyPassword
```
Package org.apache.storm.mqtt.trident
- Class org.apache.storm.mqtt.trident.MqttPublishFunction extends BaseFunction implements Serializable
  - Serialized Fields
    - mapper
```
MqttTupleMapper mapper
```
    - retain
```
boolean retain
```
    - options
```
MqttOptions options
```
    - keyStoreLoader
```
KeyStoreLoader keyStoreLoader
```
Package org.apache.storm.multilang
- Class org.apache.storm.multilang.JsonSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  2548814660410474022L
- Class org.apache.storm.multilang.NoOutputException extends Exception implements Serializable
Package org.apache.storm.nimbus
- Class org.apache.storm.nimbus.NimbusInfo extends Object implements Serializable
  
  serialVersionUID:
  
  2161446155116099333L
  - Serialized Fields
    - host
```
String host
```
    - port
```
int port
```
    - isLeader
```
boolean isLeader
```
Package org.apache.storm.opentsdb
- Class org.apache.storm.opentsdb.MetricGenBatchSpout extends Object implements Serializable
  - Serialized Fields
    - batchSize
```
int batchSize
```
    - batches
```
Map<K,V> batches
```
- Class org.apache.storm.opentsdb.MetricGenSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - conf
```
Map<K,V> conf
```
    - context
```
TopologyContext context
```
    - collector
```
SpoutOutputCollector collector
```
- Class org.apache.storm.opentsdb.OpenTsdbMetricDatapoint extends Object implements Serializable
  - Serialized Fields
    - metric
```
String metric
```
    - tags
```
Map<K,V> tags
```
    - timestamp
```
long timestamp
```
    - value
```
Number value
```
Package org.apache.storm.opentsdb.bolt
- Class org.apache.storm.opentsdb.bolt.OpenTsdbBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - openTsdbClientBuilder
```
OpenTsdbClient.Builder openTsdbClientBuilder
```
    - tupleOpenTsdbDatapointMappers
```
List<E> tupleOpenTsdbDatapointMappers
```
    - batchSize
```
int batchSize
```
    - flushIntervalInSeconds
```
int flushIntervalInSeconds
```
    - failTupleForFailedMetrics
```
boolean failTupleForFailedMetrics
```
    - batchHelper
```
BatchHelper batchHelper
```
    - openTsdbClient
```
OpenTsdbClient openTsdbClient
```
    - metricPointsWithTuple
```
Map<K,V> metricPointsWithTuple
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.opentsdb.bolt.TupleOpenTsdbDatapointMapper extends Object implements Serializable
  - Serialized Fields
    - metricField
```
String metricField
```
    - timestampField
```
String timestampField
```
    - valueField
```
String valueField
```
    - tagsField
```
String tagsField
```
Package org.apache.storm.opentsdb.client
- Class org.apache.storm.opentsdb.client.ClientResponse.Details extends ClientResponse.Summary implements Serializable
  - Serialized Fields
    - errors
```
List<E> errors
```
- Class org.apache.storm.opentsdb.client.ClientResponse.Details.Error extends Object implements Serializable
  - Serialized Fields
    - error
```
String error
```
    - datapoint
```
OpenTsdbMetricDatapoint datapoint
```
- Class org.apache.storm.opentsdb.client.ClientResponse.Summary extends Object implements Serializable
  - Serialized Fields
    - failed
```
int failed
```
    - success
```
int success
```
    - timeouts
```
int timeouts
```
- Class org.apache.storm.opentsdb.client.OpenTsdbClient.Builder extends Object implements Serializable
  - Serialized Fields
    - url
```
String url
```
    - sync
```
boolean sync
```
    - syncTimeOut
```
long syncTimeOut
```
    - enableChunkedEncoding
```
boolean enableChunkedEncoding
```
    - responseType
```
OpenTsdbClient.ResponseType responseType
```
Package org.apache.storm.opentsdb.trident
- Class org.apache.storm.opentsdb.trident.OpenTsdbStateFactory extends Object implements Serializable
  - Serialized Fields
    - builder
```
OpenTsdbClient.Builder builder
```
    - tridentTupleOpenTsdbDatapointMappers
```
List<E> tridentTupleOpenTsdbDatapointMappers
```
- Class org.apache.storm.opentsdb.trident.OpenTsdbStateUpdater extends BaseStateUpdater<OpenTsdbState> implements Serializable
Package org.apache.storm.pacemaker
- Class org.apache.storm.pacemaker.PacemakerConnectionException extends Exception implements Serializable
Package org.apache.storm.perf
- Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter extends Object implements Serializable
  - Serialized Fields
    - lineDelimiter
```
String lineDelimiter
```
    - fieldName
```
String fieldName
```
- Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.LineWriter extends Object implements Serializable
  
  serialVersionUID:
  
  7524288317405514146L
  - Serialized Fields
    - lineDelimiter
```
String lineDelimiter
```
    - fieldName
```
String fieldName
```
Package org.apache.storm.perf.bolt
- Class org.apache.storm.perf.bolt.CountBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
- Class org.apache.storm.perf.bolt.DevNullBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - sleepNanos
```
Long sleepNanos
```
    - count
```
int count
```
- Class org.apache.storm.perf.bolt.IdBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.perf.bolt.SplitSentenceBolt extends BaseBasicBolt implements Serializable
Package org.apache.storm.perf.spout
- Class org.apache.storm.perf.spout.ConstSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - value
```
String value
```
    - fieldName
```
String fieldName
```
    - collector
```
SpoutOutputCollector collector
```
    - count
```
int count
```
    - sleep
```
Long sleep
```
    - ackCount
```
int ackCount
```
- Class org.apache.storm.perf.spout.FileReadSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  -2582705611472467172L
  - Serialized Fields
    - file
```
String file
```
    - ackEnabled
```
boolean ackEnabled
```
    - collector
```
SpoutOutputCollector collector
```
    - count
```
long count
```
- Class org.apache.storm.perf.spout.FileReadSpout.FileReader extends Object implements Serializable
  
  serialVersionUID:
  
  -7012334600647556267L
  - Serialized Fields
    - file
```
String file
```
    - contents
```
List<E> contents
```
    - index
```
int index
```
    - limit
```
int limit
```
- Class org.apache.storm.perf.spout.StringGenSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - strCount
```
int strCount
```
    - records
```
ArrayList<E> records
```
    - strLen
```
int strLen
```
    - fieldName
```
String fieldName
```
    - collector
```
SpoutOutputCollector collector
```
    - curr
```
int curr
```
    - count
```
int count
```
- Class org.apache.storm.perf.spout.WordGenSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  -2582705611472467172L
  - Serialized Fields
    - file
```
String file
```
    - ackEnabled
```
boolean ackEnabled
```
    - collector
```
SpoutOutputCollector collector
```
    - count
```
long count
```
    - index
```
int index
```
    - emitMeter
```
ThroughputMeter emitMeter
```
    - words
```
ArrayList<E> words
```
Package org.apache.storm.perf.utils
- Class org.apache.storm.perf.utils.IdentityBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
Package org.apache.storm.planner
- Class org.apache.storm.planner.TaskBundle extends Object implements Serializable
  - Serialized Fields
    - task
```
IBolt task
```
    - componentId
```
int componentId
```
Package org.apache.storm.pmml
- Class org.apache.storm.pmml.PMMLPredictorBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - outputs
```
ModelOutputs outputs
```
    - runnerFactory
```
ModelRunnerFactory runnerFactory
```
    - runner
```
ModelRunner runner
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.pmml.RawInputFromCSVSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - csv
```
File csv
```
    - outputFields
```
List<E> outputFields
```
    - br
```
BufferedReader br
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.pmml.model
Package org.apache.storm.pmml.model.jpmml
- Class org.apache.storm.pmml.model.jpmml.JpmmlModelOutputs extends Object implements Serializable
  - Serialized Fields
    - declared
```
Map<K,V> declared
```
Package org.apache.storm.pmml.runner
Package org.apache.storm.pmml.runner.jpmml
- Class org.apache.storm.pmml.runner.jpmml.JpmmlFactory.ModelRunnerFromBlobStore extends Object implements Serializable
  - Serialized Fields
    - blobKey
```
String blobKey
```
    - modelOutputs
```
ModelOutputs modelOutputs
```
    - config
```
Map<K,V> config
```
- Class org.apache.storm.pmml.runner.jpmml.JpmmlFactory.ModelRunnerFromFile extends Object implements Serializable
  - Serialized Fields
    - model
```
File model
```
    - outFields
```
ModelOutputs outFields
```
Package org.apache.storm.redis.bolt
- Class org.apache.storm.redis.bolt.AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - jedisPoolConfig
```
JedisPoolConfig jedisPoolConfig
```
    - jedisClusterConfig
```
JedisClusterConfig jedisClusterConfig
```
- Class org.apache.storm.redis.bolt.RedisFilterBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    - filterMapper
```
RedisFilterMapper filterMapper
```
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
- Class org.apache.storm.redis.bolt.RedisLookupBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    - lookupMapper
```
RedisLookupMapper lookupMapper
```
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
- Class org.apache.storm.redis.bolt.RedisStoreBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    - storeMapper
```
RedisStoreMapper storeMapper
```
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
Package org.apache.storm.redis.common.config
- Class org.apache.storm.redis.common.config.JedisClusterConfig extends Object implements Serializable
  - Serialized Fields
    - nodes
```
Set<E> nodes
```
    - timeout
```
int timeout
```
    - maxRedirections
```
int maxRedirections
```
    - password
```
String password
```
- Class org.apache.storm.redis.common.config.JedisPoolConfig extends Object implements Serializable
  - Serialized Fields
    - host
```
String host
```
    - port
```
int port
```
    - timeout
```
int timeout
```
    - database
```
int database
```
    - password
```
String password
```
Package org.apache.storm.redis.common.mapper
- Class org.apache.storm.redis.common.mapper.RedisDataTypeDescription extends Object implements Serializable
  - Serialized Fields
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
Package org.apache.storm.redis.topology
- Class org.apache.storm.redis.topology.LookupWordCount.PrintWordTotalCountBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.redis.topology.WordCounter extends Object implements Serializable
  - Serialized Fields
    - wordCounter
```
Map<K,V> wordCounter
```
- Class org.apache.storm.redis.topology.WordSpout extends Object implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.redis.trident
- Class org.apache.storm.redis.trident.PrintFunction extends BaseFunction implements Serializable
- Class org.apache.storm.redis.trident.WordCountLookupMapper extends Object implements Serializable
- Class org.apache.storm.redis.trident.WordCountStoreMapper extends Object implements Serializable
Package org.apache.storm.redis.trident.state
- Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,List<Values>> implements Serializable
  - Serialized Fields
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
    - lookupMapper
```
RedisLookupMapper lookupMapper
```
- Class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater extends BaseStateUpdater<T extends State> implements Serializable
  - Serialized Fields
    - dataType
```
RedisDataTypeDescription.RedisDataType dataType
```
    - additionalKey
```
String additionalKey
```
    - storeMapper
```
RedisStoreMapper storeMapper
```
    - expireIntervalSec
```
int expireIntervalSec
```
- Class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory extends Object implements Serializable
- Class org.apache.storm.redis.trident.state.Options extends Object implements Serializable
  - Serialized Fields
    - localCacheSize
```
int localCacheSize
```
    - globalKey
```
String globalKey
```
    - keyFactory
```
KeyFactory keyFactory
```
    - serializer
```
Serializer<T> serializer
```
    - dataTypeDescription
```
RedisDataTypeDescription dataTypeDescription
```
    - expireIntervalSec
```
int expireIntervalSec
```
- Class org.apache.storm.redis.trident.state.RedisClusterMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - jedisClusterConfig
```
JedisClusterConfig jedisClusterConfig
```
    - type
```
StateType type
```
    - serializer
```
Serializer<T> serializer
```
    - keyFactory
```
KeyFactory keyFactory
```
    - options
```
Options<T> options
```
- Class org.apache.storm.redis.trident.state.RedisClusterState.Factory extends Object implements Serializable
  - Serialized Fields
    - jedisClusterConfig
```
JedisClusterConfig jedisClusterConfig
```
- Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - jedisPoolConfig
```
JedisPoolConfig jedisPoolConfig
```
    - type
```
StateType type
```
    - serializer
```
Serializer<T> serializer
```
    - keyFactory
```
KeyFactory keyFactory
```
    - options
```
Options<T> options
```
- Class org.apache.storm.redis.trident.state.RedisState.Factory extends Object implements Serializable
  - Serialized Fields
    - jedisPoolConfig
```
JedisPoolConfig jedisPoolConfig
```
- Class org.apache.storm.redis.trident.state.RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable
Package org.apache.storm.rocketmq
- Class org.apache.storm.rocketmq.DefaultMessageBodySerializer extends Object implements Serializable

Package org.apache.storm.rocketmq.bolt

Class org.apache.storm.rocketmq.bolt.RocketMqBolt extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

producer

org.apache.rocketmq.client.producer.DefaultMQProducer producer

collector
```
OutputCollector collector
```
selector
```
TopicSelector selector
```
mapper
```
TupleToMessageMapper mapper
```
properties
```
Properties properties
```
async
```
boolean async
```
batch
```
boolean batch
```
batchSize
```
int batchSize
```
flushIntervalSecs
```
int flushIntervalSecs
```
batchHelper
```
BatchHelper batchHelper
```
messages
```
List<E> messages
```

Package org.apache.storm.rocketmq.common.mapper
- Class org.apache.storm.rocketmq.common.mapper.FieldNameBasedTupleToMessageMapper extends Object implements Serializable
  - Serialized Fields
    - boltKeyField
```
String boltKeyField
```
    - boltMessageField
```
String boltMessageField
```
    - messageBodySerializer
```
MessageBodySerializer messageBodySerializer
```
Package org.apache.storm.rocketmq.common.selector
- Class org.apache.storm.rocketmq.common.selector.DefaultTopicSelector extends Object implements Serializable
  - Serialized Fields
    - topicName
```
String topicName
```
    - tagName
```
String tagName
```
- Class org.apache.storm.rocketmq.common.selector.FieldNameBasedTopicSelector extends Object implements Serializable
  - Serialized Fields
    - topicFieldName
```
String topicFieldName
```
    - defaultTopicName
```
String defaultTopicName
```
    - tagFieldName
```
String tagFieldName
```
    - defaultTagName
```
String defaultTagName
```
Package org.apache.storm.rocketmq.spout
- Class org.apache.storm.rocketmq.spout.RocketMqSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - consumer
```
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer consumer
```
    - collector
```
SpoutOutputCollector collector
```
    - queue
```
BlockingQueue<E> queue
```
    - cache
```
Map<K,V> cache
```
    - properties
```
Properties properties
```
    - scheme
```
Scheme scheme
```
    - batchProcessTimeout
```
long batchProcessTimeout
```
Package org.apache.storm.rocketmq.spout.scheme
- Class org.apache.storm.rocketmq.spout.scheme.StringKeyValueScheme extends StringScheme implements Serializable
- Class org.apache.storm.rocketmq.spout.scheme.StringScheme extends Object implements Serializable
Package org.apache.storm.rocketmq.topology
- Class org.apache.storm.rocketmq.topology.WordCounter extends Object implements Serializable
  - Serialized Fields
    - wordCounter
```
Map<K,V> wordCounter
```
Package org.apache.storm.rocketmq.trident.state
- Class org.apache.storm.rocketmq.trident.state.RocketMqState.Options extends Object implements Serializable
  - Serialized Fields
    - selector
```
TopicSelector selector
```
    - mapper
```
TupleToMessageMapper mapper
```
    - properties
```
Properties properties
```
- Class org.apache.storm.rocketmq.trident.state.RocketMqStateFactory extends Object implements Serializable
  - Serialized Fields
    - options
```
RocketMqState.Options options
```
- Class org.apache.storm.rocketmq.trident.state.RocketMqStateUpdater extends BaseStateUpdater<RocketMqState> implements Serializable
Package org.apache.storm.security.auth.plain
- Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider extends Provider implements Serializable
Package org.apache.storm.shade.org.apache.zookeeper
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException extends Exception implements Serializable
  - Serialized Fields
    - results
```
List<E> results
```
    - code
```
org.apache.storm.shade.org.apache.zookeeper.KeeperException.Code code
```
    - path
```
String path
```
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Class org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException extends IOException implements Serializable
  - Serialized Fields
    - exitCode
```
int exitCode
```
Package org.apache.storm.solr.bolt
- Class org.apache.storm.solr.bolt.SolrUpdateBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - solrConfig
```
SolrConfig solrConfig
```
    - solrMapper
```
SolrMapper solrMapper
```
    - commitStgy
```
SolrCommitStrategy commitStgy
```
    - solrClient
```
org.apache.solr.client.solrj.SolrClient solrClient
```
    - collector
```
OutputCollector collector
```
    - toCommitTuples
```
List<E> toCommitTuples
```
    - tickTupleInterval
```
int tickTupleInterval
```
Package org.apache.storm.solr.config
- Class org.apache.storm.solr.config.CountBasedCommit extends Object implements Serializable
  - Serialized Fields
    - threshold
```
int threshold
```
    - count
```
int count
```
- Class org.apache.storm.solr.config.SolrConfig extends Object implements Serializable
  - Serialized Fields
    - zkHostString
```
String zkHostString
```
    - tickTupleInterval
```
int tickTupleInterval
```
    - enableKerberos
```
boolean enableKerberos
```
Package org.apache.storm.solr.mapper
- Class org.apache.storm.solr.mapper.SolrFieldsMapper extends Object implements Serializable
  - Serialized Fields
    - collection
```
String collection
```
    - typeFinder
```
SolrFieldTypeFinder typeFinder
```
    - multiValueFieldToken
```
String multiValueFieldToken
```
- Class org.apache.storm.solr.mapper.SolrJsonMapper extends Object implements Serializable
  - Serialized Fields
    - jsonUpdateUrl
```
String jsonUpdateUrl
```
    - jsonTupleField
```
String jsonTupleField
```
    - collection
```
String collection
```
- Class org.apache.storm.solr.mapper.SolrMapperException extends Exception implements Serializable
Package org.apache.storm.solr.schema
- Class org.apache.storm.solr.schema.CopyField extends Object implements Serializable
  - Serialized Fields
    - source
```
String source
```
    - dest
```
String dest
```
- Class org.apache.storm.solr.schema.Field extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - type
```
String type
```
- Class org.apache.storm.solr.schema.FieldType extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - clazz
```
String clazz
```
    - multiValued
```
boolean multiValued
```
- Class org.apache.storm.solr.schema.Schema extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - version
```
String version
```
    - uniqueKey
```
String uniqueKey
```
    - fieldTypes
```
List<E> fieldTypes
```
    - fields
```
List<E> fields
```
    - dynamicFields
```
List<E> dynamicFields
```
    - copyFields
```
List<E> copyFields
```
- Class org.apache.storm.solr.schema.Schema.SchemaWrapper extends Object implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
- Class org.apache.storm.solr.schema.SolrFieldTypeFinder extends Object implements Serializable
  - Serialized Fields
    - schemaBuilder
```
SchemaBuilder schemaBuilder
```
    - schema
```
Schema schema
```
    - fieldToWrapper
```
Map<K,V> fieldToWrapper
```
- Class org.apache.storm.solr.schema.SolrFieldTypeFinder.FieldTypeWrapper extends Object implements Serializable
  - Serialized Fields
    - field
```
Field field
```
    - type
```
FieldType type
```
Package org.apache.storm.solr.schema.builder
- Class org.apache.storm.solr.schema.builder.RestJsonSchemaBuilder extends Object implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
      Deprecated.
- Class org.apache.storm.solr.schema.builder.RestJsonSchemaBuilderV2 extends Object implements Serializable
  - Serialized Fields
    - schema
```
Schema schema
```
    - solrConfig
```
SolrConfig solrConfig
```
    - collection
```
String collection
```
Package org.apache.storm.solr.spout
- Class org.apache.storm.solr.spout.SolrFieldsSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
- Class org.apache.storm.solr.spout.SolrJsonSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
Package org.apache.storm.solr.trident
- Class org.apache.storm.solr.trident.SolrStateFactory extends Object implements Serializable
  - Serialized Fields
    - solrConfig
```
SolrConfig solrConfig
```
    - solrMapper
```
SolrMapper solrMapper
```
- Class org.apache.storm.solr.trident.SolrUpdater extends BaseStateUpdater<SolrState> implements Serializable
Package org.apache.storm.spout
- Class org.apache.storm.spout.CheckpointSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - context
```
TopologyContext context
```
    - collector
```
SpoutOutputCollector collector
```
    - lastCheckpointTs
```
long lastCheckpointTs
```
    - checkpointInterval
```
int checkpointInterval
```
    - sleepInterval
```
int sleepInterval
```
    - recoveryStepInProgress
```
boolean recoveryStepInProgress
```
    - checkpointStepInProgress
```
boolean checkpointStepInProgress
```
    - recovering
```
boolean recovering
```
    - checkpointState
```
KeyValueState<K,V> checkpointState
```
    - curTxState
```
CheckPointState curTxState
```
- Class org.apache.storm.spout.RawMultiScheme extends Object implements Serializable
- Class org.apache.storm.spout.RawScheme extends Object implements Serializable
- Class org.apache.storm.spout.SchemeAsMultiScheme extends Object implements Serializable
  - Serialized Fields
    - scheme
```
Scheme scheme
```
- Class org.apache.storm.spout.ShellSpout extends Object implements Serializable
  
  serialVersionUID:
  
  5982357019665454L
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - command
```
String[] command
```
    - env
```
Map<K,V> env
```
    - logHandler
```
ShellLogHandler logHandler
```
    - process
```
ShellProcess process
```
    - running
```
boolean running
```
    - exception
```
RuntimeException exception
```
    - context
```
TopologyContext context
```
    - spoutMsg
```
SpoutMsg spoutMsg
```
    - workerTimeoutMills
```
int workerTimeoutMills
```
    - heartBeatExecutorService
```
ScheduledExecutorService heartBeatExecutorService
```
    - lastHeartbeatTimestamp
```
AtomicLong lastHeartbeatTimestamp
```
    - waitingOnSubprocess
```
AtomicBoolean waitingOnSubprocess
```
    - changeDirectory
```
boolean changeDirectory
```
Package org.apache.storm.sql.javac
- Class org.apache.storm.sql.javac.CompilingClassLoader.CompilerException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2936958840023603270L
Package org.apache.storm.sql.kafka
- Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - delegate
```
Scheme delegate
```
Package org.apache.storm.sql.parser.impl
- Class org.apache.storm.sql.parser.impl.ParseException extends Exception implements Serializable
  - Serialized Fields
    - specialConstructor
```
boolean specialConstructor
```
      This variable determines which constructor was used to create this object and thereby affects the semantics of the “getMessage” method (see below).
    - currentToken
```
Token currentToken
```
      This is the last token that has been consumed successfully. If this object has been created due to a parse error, the token followng this token will (therefore) be the first error token.
    - expectedTokenSequences
```
int[][] expectedTokenSequences
```
      Each entry in this array is an array of integers. Each array of integers represents a sequence of tokens (by their ordinal values) that is expected at this point of the parse.
    - tokenImage
```
String[] tokenImage
```
      This is a reference to the “tokenImage” array of the generated parser within which the parse error occurred. This array is defined in the generated …Constants interface.
    - eol
```
String eol
```
      The end of line string for this machine.
- Class org.apache.storm.sql.parser.impl.TokenMgrError extends Error implements Serializable
  - Serialized Fields
    - errorCode
```
int errorCode
```
      Indicates the reason why the exception is thrown. It will have one of the above 4 values.
Package org.apache.storm.sql.runtime
- Class org.apache.storm.sql.runtime.FieldInfo extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - type
```
Class<T> type
```
    - isPrimary
```
boolean isPrimary
```
Package org.apache.storm.sql.runtime.calcite
- Class org.apache.storm.sql.runtime.calcite.DebuggableExecutableExpression extends Object implements Serializable
  - Serialized Fields
    - delegate
```
ExecutableExpression delegate
```
    - delegateCode
```
String delegateCode
```
- Class org.apache.storm.sql.runtime.calcite.StormDataContext extends Object implements Serializable
  - Serialized Fields
    - map
```
com.google.common.collect.ImmutableMap<K,V> map
```
Package org.apache.storm.sql.runtime.datasource.socket.bolt
- Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - serializer
```
IOutputSerializer serializer
```
    - host
```
String host
```
    - port
```
int port
```
Package org.apache.storm.sql.runtime.datasource.socket.spout
- Class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout extends Object implements Serializable
  - Serialized Fields
    - host
```
String host
```
    - port
```
int port
```
    - scheme
```
Scheme scheme
```
    - running
```
boolean running
```
    - queue
```
BlockingDeque<E> queue
```
    - socket
```
Socket socket
```
    - readerThread
```
Thread readerThread
```
    - in
```
BufferedReader in
```
    - objectMapper
```
com.fasterxml.jackson.databind.ObjectMapper objectMapper
```
    - collector
```
SpoutOutputCollector collector
```
    - emitted
```
Map<K,V> emitted
```
Package org.apache.storm.sql.runtime.serde.avro
- Class org.apache.storm.sql.runtime.serde.avro.AvroScheme extends Object implements Serializable
  - Serialized Fields
    - schemaString
```
String schemaString
```
    - fieldNames
```
List<E> fieldNames
```
    - schemas
```
CachedSchemas schemas
```
- Class org.apache.storm.sql.runtime.serde.avro.AvroSerializer extends Object implements Serializable
  - Serialized Fields
    - schemaString
```
String schemaString
```
    - fieldNames
```
List<E> fieldNames
```
    - schemas
```
CachedSchemas schemas
```
- Class org.apache.storm.sql.runtime.serde.avro.CachedSchemas extends Object implements Serializable
  - Serialized Fields
    - cache
```
Map<K,V> cache
```
Package org.apache.storm.sql.runtime.serde.csv
- Class org.apache.storm.sql.runtime.serde.csv.CsvScheme extends Object implements Serializable
  - Serialized Fields
    - fieldNames
```
List<E> fieldNames
```
- Class org.apache.storm.sql.runtime.serde.csv.CsvSerializer extends Object implements Serializable
  - Serialized Fields
    - fields
```
List<E> fields
```
Package org.apache.storm.sql.runtime.serde.json
- Class org.apache.storm.sql.runtime.serde.json.JsonScheme extends Object implements Serializable
  - Serialized Fields
    - fields
```
List<E> fields
```
- Class org.apache.storm.sql.runtime.serde.json.JsonSerializer extends Object implements Serializable
  - Serialized Fields
    - fieldNames
```
List<E> fieldNames
```
    - jsonFactory
```
com.fasterxml.jackson.core.JsonFactory jsonFactory
```
Package org.apache.storm.sql.runtime.serde.tsv
- Class org.apache.storm.sql.runtime.serde.tsv.TsvScheme extends Object implements Serializable
  - Serialized Fields
    - fieldNames
```
List<E> fieldNames
```
    - delimiter
```
char delimiter
```
- Class org.apache.storm.sql.runtime.serde.tsv.TsvSerializer extends Object implements Serializable
  - Serialized Fields
    - fields
```
List<E> fields
```
    - delimiter
```
char delimiter
```
Package org.apache.storm.sql.runtime.streams.functions
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationCalc extends Object implements Serializable
  - Serialized Fields
    - filterInstance
```
ExecutableExpression filterInstance
```
    - projectionInstance
```
ExecutableExpression projectionInstance
```
    - outputValues
```
Object[] outputValues
```
    - dataContext
```
org.apache.calcite.DataContext dataContext
```
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationFilter extends Object implements Serializable
  - Serialized Fields
    - filterInstance
```
ExecutableExpression filterInstance
```
    - dataContext
```
org.apache.calcite.DataContext dataContext
```
    - outputValues
```
Object[] outputValues
```
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationFunction extends Object implements Serializable
  - Serialized Fields
    - projectionInstance
```
ExecutableExpression projectionInstance
```
    - outputValues
```
Object[] outputValues
```
    - dataContext
```
org.apache.calcite.DataContext dataContext
```
- Class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction extends Object implements Serializable
  - Serialized Fields
    - primaryKeyIndex
```
int primaryKeyIndex
```
- Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper extends Object implements Serializable
  - Serialized Fields
    - fieldNames
```
List<E> fieldNames
```
Package org.apache.storm.st.topology.window
- Class org.apache.storm.st.topology.window.IncrementingSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - currentNum
```
int currentNum
```
    - componentId
```
String componentId
```
- Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - currentNum
```
int currentNum
```
    - componentId
```
String componentId
```
- Class org.apache.storm.st.topology.window.TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - componentId
```
String componentId
```
- Class org.apache.storm.st.topology.window.VerificationBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - componentId
```
String componentId
```
Package org.apache.storm.starter
- Class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - random
```
Random random
```
- Class org.apache.storm.starter.AnchoredWordCount.SplitSentence extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.AnchoredWordCount.WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
- Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - poll
```
boolean poll
```
    - pollTime
```
long pollTime
```
    - wordSet
```
Set<E> wordSet
```
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - rand
```
Random rand
```
- Class org.apache.storm.starter.FastWordCountTopology.SplitSentence extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.FastWordCountTopology.WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
- Class org.apache.storm.starter.InOrderDeliveryTest.Check extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - expected
```
Map<K,V> expected
```
- Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - base
```
int base
```
    - count
```
int count
```
- Class org.apache.storm.starter.ManualDRPC.ExclamationBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - rootLogger
```
org.slf4j.Logger rootLogger
```
    - logger
```
org.slf4j.Logger logger
```
    - subLogger
```
org.slf4j.Logger subLogger
```
- Class org.apache.storm.starter.ReachTopology.CountAggregator extends BaseBatchBolt<Object> implements Serializable
  - Serialized Fields
    - collector
```
BatchOutputCollector collector
```
    - id
```
Object id
```
    - count
```
int count
```
- Class org.apache.storm.starter.ReachTopology.GetFollowers extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.ReachTopology.GetTweeters extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.ReachTopology.PartialUniquer extends BaseBatchBolt<Object> implements Serializable
  - Serialized Fields
    - collector
```
BatchOutputCollector collector
```
    - id
```
Object id
```
    - followers
```
Set<E> followers
```
- Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.starter.StatefulTopology.PrinterBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopology.SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopology.WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
- Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence extends ShellSpout implements Serializable
- Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopologyNode.WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
Package org.apache.storm.starter.bolt
- Class org.apache.storm.starter.bolt.AbstractRankerBolt extends BaseBasicBolt implements Serializable
  
  serialVersionUID:
  
  4931640198501530202L
  - Serialized Fields
    - emitFrequencyInSeconds
```
int emitFrequencyInSeconds
```
    - count
```
int count
```
    - rankings
```
Rankings rankings
```
- Class org.apache.storm.starter.bolt.IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable
  
  serialVersionUID:
  
  -1369800530256637409L
- Class org.apache.storm.starter.bolt.PrinterBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.bolt.RollingCountAggBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  5537727428628598519L
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.starter.bolt.RollingCountBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  5537727428628598519L
  - Serialized Fields
    - counter
```
SlidingWindowCounter<T> counter
```
    - windowLengthInSeconds
```
int windowLengthInSeconds
```
    - emitFrequencyInSeconds
```
int emitFrequencyInSeconds
```
    - collector
```
OutputCollector collector
```
    - lastModifiedTracker
```
NthLastModifiedTimeTracker lastModifiedTracker
```
- Class org.apache.storm.starter.bolt.SingleJoinBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - idFields
```
Fields idFields
```
    - outFields
```
Fields outFields
```
    - numSources
```
int numSources
```
    - pending
```
TimeCacheMap<K,V> pending
```
    - fieldLocations
```
Map<K,V> fieldLocations
```
- Class org.apache.storm.starter.bolt.SlidingWindowSumBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - sum
```
int sum
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.starter.bolt.TotalRankingsBolt extends AbstractRankerBolt implements Serializable
  
  serialVersionUID:
  
  -8447525895532302198L
Package org.apache.storm.starter.spout
- Class org.apache.storm.starter.spout.RandomIntegerSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - rand
```
Random rand
```
    - msgId
```
long msgId
```
- Class org.apache.storm.starter.spout.RandomNumberGeneratorSpout extends Object implements Serializable
  - Serialized Fields
    - fields
```
Fields fields
```
    - batchSize
```
int batchSize
```
    - maxNumber
```
int maxNumber
```
    - batches
```
Map<K,V> batches
```
- Class org.apache.storm.starter.spout.RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - rand
```
Random rand
```
- Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped extends RandomSentenceSpout implements Serializable
  - Serialized Fields
    - prefix
```
String prefix
```
Package org.apache.storm.starter.tools
- Class org.apache.storm.starter.tools.RankableObjectWithFields extends Object implements Serializable
  
  serialVersionUID:
  
  -9102878650001058090L
  - Serialized Fields
    - obj
```
Object obj
```
    - count
```
long count
```
    - fields
```
com.google.common.collect.ImmutableList<E> fields
```
- Class org.apache.storm.starter.tools.Rankings extends Object implements Serializable
  
  serialVersionUID:
  
  -1549827195410578903L
  - Serialized Fields
    - maxSize
```
int maxSize
```
    - rankedItems
```
List<E> rankedItems
```
- Class org.apache.storm.starter.tools.SlidingWindowCounter extends Object implements Serializable
  
  serialVersionUID:
  
  -2645063988768785810L
  - Serialized Fields
    - objCounter
```
SlotBasedCounter<T> objCounter
```
    - headSlot
```
int headSlot
```
    - tailSlot
```
int tailSlot
```
    - windowLengthInSlots
```
int windowLengthInSlots
```
- Class org.apache.storm.starter.tools.SlotBasedCounter extends Object implements Serializable
  
  serialVersionUID:
  
  4858185737378394432L
  - Serialized Fields
    - objToCounts
```
Map<K,V> objToCounts
```
    - numSlots
```
int numSlots
```
Package org.apache.storm.starter.trident
- Class org.apache.storm.starter.trident.DebugMemoryMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
- Class org.apache.storm.starter.trident.TridentReach.ExpandList extends BaseFunction implements Serializable
- Class org.apache.storm.starter.trident.TridentReach.One extends Object implements Serializable
- Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - map
```
Map<K,V> map
```
- Class org.apache.storm.starter.trident.TridentWordCount.Split extends BaseFunction implements Serializable
Package org.apache.storm.state
- Class org.apache.storm.state.DefaultStateSerializer extends Object implements Serializable
  - Serialized Fields
    - context
```
TopologyContext context
```
    - topoConf
```
Map<K,V> topoConf
```
    - registrations
```
List<E> registrations
```
    - kryo
```
ThreadLocal<T> kryo
```
    - output
```
ThreadLocal<T> output
```
Package org.apache.storm.streams
- Class org.apache.storm.streams.Pair extends Object implements Serializable
  - Serialized Fields
    - value1
```
Object value1
```
      The first value.
    - value2
```
Object value2
```
      The second value.
- Class org.apache.storm.streams.ProcessorNode extends org.apache.storm.streams.Node implements Serializable
  - Serialized Fields
    - processor
```
Processor<T> processor
```
    - isBatch
```
boolean isBatch
```
    - preservesKey
```
boolean preservesKey
```
    - windowedParentStreams
```
Set<E> windowedParentStreams
```
- Class org.apache.storm.streams.StreamState extends Object implements Serializable
- Class org.apache.storm.streams.WindowNode extends org.apache.storm.streams.Node implements Serializable
  - Serialized Fields
    - windowParams
```
Window<L,I> windowParams
```
Package org.apache.storm.streams.operations
- Class org.apache.storm.streams.operations.IdentityFunction extends Object implements Serializable
- Class org.apache.storm.streams.operations.PairValueJoiner extends Object implements Serializable
- Class org.apache.storm.streams.operations.PrintConsumer extends Object implements Serializable
Package org.apache.storm.streams.operations.aggregators
- Class org.apache.storm.streams.operations.aggregators.Count extends Object implements Serializable
- Class org.apache.storm.streams.operations.aggregators.LongSum extends Object implements Serializable
Package org.apache.storm.streams.operations.mappers
- Class org.apache.storm.streams.operations.mappers.PairValueMapper extends Object implements Serializable
  - Serialized Fields
    - keyIndex
```
int keyIndex
```
    - valueIndex
```
int valueIndex
```
- Class org.apache.storm.streams.operations.mappers.ValueMapper extends Object implements Serializable
  - Serialized Fields
    - index
```
int index
```
- Class org.apache.storm.streams.operations.mappers.ValuesMapper extends Object implements Serializable
  - Serialized Fields
    - indices
```
int[] indices
```
Package org.apache.storm.streams.processors
- Class org.apache.storm.streams.processors.AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    - aggregator
```
CombinerAggregator<T,A,R> aggregator
```
    - emitAggregate
```
boolean emitAggregate
```
    - state
```
Map<K,V> state
```
- Class org.apache.storm.streams.processors.AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - aggregator
```
CombinerAggregator<T,A,R> aggregator
```
    - emitAggregate
```
boolean emitAggregate
```
    - state
```
Object state
```
- Class org.apache.storm.streams.processors.BranchProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - predicateToStream
```
Map<K,V> predicateToStream
```
- Class org.apache.storm.streams.processors.ChainedProcessorContext extends Object implements Serializable
  - Serialized Fields
    - processorNode
```
ProcessorNode processorNode
```
    - contexts
```
List<E> contexts
```
- Class org.apache.storm.streams.processors.CoGroupByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable
  - Serialized Fields
    - firstStream
```
String firstStream
```
    - secondStream
```
String secondStream
```
    - firstMap
```
org.apache.storm.shade.com.google.common.collect.Multimap<K,V> firstMap
```
    - secondMap
```
org.apache.storm.shade.com.google.common.collect.Multimap<K,V> secondMap
```
- Class org.apache.storm.streams.processors.EmittingProcessorContext extends Object implements Serializable
  - Serialized Fields
    - processorNode
```
ProcessorNode processorNode
```
    - outputStreamId
```
String outputStreamId
```
    - punctuationStreamId
```
String punctuationStreamId
```
    - collector
```
OutputCollector collector
```
    - outputFields
```
Fields outputFields
```
    - punctuation
```
Values punctuation
```
    - anchors
```
List<E> anchors
```
    - eventTimestamp
```
long eventTimestamp
```
    - timestampField
```
String timestampField
```
- Class org.apache.storm.streams.processors.FilterProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - predicate
```
Predicate<T> predicate
```
- Class org.apache.storm.streams.processors.FlatMapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - function
```
FlatMapFunction<T,R> function
```
- Class org.apache.storm.streams.processors.FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    - function
```
FlatMapFunction<T,R> function
```
- Class org.apache.storm.streams.processors.ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - consumer
```
Consumer<T> consumer
```
- Class org.apache.storm.streams.processors.ForwardingProcessorContext extends Object implements Serializable
  - Serialized Fields
    - processorNode
```
ProcessorNode processorNode
```
    - streamToChildren
```
org.apache.storm.shade.com.google.common.collect.Multimap<K,V> streamToChildren
```
    - streams
```
Set<E> streams
```
- Class org.apache.storm.streams.processors.JoinProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable
  - Serialized Fields
    - valueJoiner
```
ValueJoiner<V1,V2,R> valueJoiner
```
    - leftStream
```
String leftStream
```
    - rightStream
```
String rightStream
```
    - leftRows
```
List<E> leftRows
```
    - rightRows
```
List<E> rightRows
```
    - leftType
```
JoinProcessor.JoinType leftType
```
    - rightType
```
JoinProcessor.JoinType rightType
```
- Class org.apache.storm.streams.processors.MapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - function
```
Function<T,R> function
```
- Class org.apache.storm.streams.processors.MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    - function
```
Function<T,R> function
```
- Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,A>> implements Serializable
  - Serialized Fields
    - aggregator
```
CombinerAggregator<T,A,R> aggregator
```
    - state
```
Map<K,V> state
```
- Class org.apache.storm.streams.processors.MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable
  - Serialized Fields
    - aggregator
```
CombinerAggregator<T,A,R> aggregator
```
    - state
```
Object state
```
- Class org.apache.storm.streams.processors.PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - consumer
```
Consumer<T> consumer
```
- Class org.apache.storm.streams.processors.ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    - reducer
```
Reducer<T> reducer
```
    - state
```
Map<K,V> state
```
- Class org.apache.storm.streams.processors.ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    - reducer
```
Reducer<T> reducer
```
    - agg
```
Object agg
```
- Class org.apache.storm.streams.processors.StateQueryProcessor extends org.apache.storm.streams.processors.BaseProcessor<K> implements Serializable
  - Serialized Fields
    - streamState
```
StreamState<K,V> streamState
```
    - keyValueState
```
KeyValueState<K,V> keyValueState
```
- Class org.apache.storm.streams.processors.UpdateStateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    - stateUpdater
```
StateUpdater<T,S> stateUpdater
```
    - keyValueState
```
KeyValueState<K,V> keyValueState
```
Package org.apache.storm.streams.windowing
- Class org.apache.storm.streams.windowing.BaseWindow extends Object implements Serializable
  - Serialized Fields
    - timestampField
```
String timestampField
```
    - lateTupleStream
```
String lateTupleStream
```
    - lag
```
BaseWindowedBolt.Duration lag
```
- Class org.apache.storm.streams.windowing.SlidingWindows extends BaseWindow<L,I> implements Serializable
  - Serialized Fields
    - windowLength
```
Object windowLength
```
    - slidingInterval
```
Object slidingInterval
```
- Class org.apache.storm.streams.windowing.TumblingWindows extends BaseWindow<L,L> implements Serializable
  - Serialized Fields
    - windowLength
```
Object windowLength
```

Package org.apache.storm.task

Class org.apache.storm.task.ShellBolt extends Object implements Serializable

serialVersionUID:: -339575186639193348L

Serialized Fields

collector
```
OutputCollector collector
```
inputs
```
Map<K,V> inputs
```
command
```
String[] command
```
env
```
Map<K,V> env
```
logHandler
```
ShellLogHandler logHandler
```
process
```
ShellProcess process
```
running
```
boolean running
```
exception
```
Throwable exception
```
pendingWrites
```
ShellBoltMessageQueue 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
```
isLocalMode
```
boolean isLocalMode
```
changeDirectory
```
boolean changeDirectory
```

Package org.apache.storm.testing
- Class org.apache.storm.testing.AckFailMapTracker extends Object implements Serializable
  - Serialized Fields
    - acked
```
String acked
```
    - failed
```
String failed
```
- Class org.apache.storm.testing.AckTracker extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
- Class org.apache.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable
  - Serialized Fields
    - richDelegate
```
IRichBolt richDelegate
```
- Class org.apache.storm.testing.FeederSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - id
```
int id
```
    - outFields
```
Fields outFields
```
    - collector
```
SpoutOutputCollector collector
```
    - ackFailDelegate
```
AckFailDelegate ackFailDelegate
```
- Class org.apache.storm.testing.FixedTuple extends Object implements Serializable
  - Serialized Fields
    - stream
```
String stream
```
    - values
```
List<E> values
```
- Class org.apache.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
```
    - fields
```
Fields fields
```
- Class org.apache.storm.testing.IdentityBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - fields
```
Fields fields
```
- Class org.apache.storm.testing.NGrouping extends Object implements Serializable
  - Serialized Fields
    - number
```
int number
```
    - outTasks
```
List<E> outTasks
```
- Class org.apache.storm.testing.NonRichBoltTracker extends Object implements Serializable
  - Serialized Fields
    - delegate
```
IBolt delegate
```
    - trackId
```
String trackId
```
- Class org.apache.storm.testing.PrepareBatchBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - outFields
```
Fields outFields
```
- Class org.apache.storm.testing.PythonShellMetricsBolt extends ShellBolt implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class org.apache.storm.testing.PythonShellMetricsSpout extends ShellSpout implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class org.apache.storm.testing.SpoutTracker extends BaseRichSpout implements Serializable
  - Serialized Fields
    - delegate
```
IRichSpout delegate
```
    - tracker
```
org.apache.storm.testing.SpoutTracker.SpoutTrackOutputCollector tracker
```
    - trackId
```
String trackId
```
- Class org.apache.storm.testing.TestAggregatesCounter extends BaseRichBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
    - collector
```
OutputCollector collector
```
- Class org.apache.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - componentConf
```
Map<K,V> componentConf
```
    - conf
```
Map<K,V> conf
```
- Class org.apache.storm.testing.TestEventLogSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - collector
```
SpoutOutputCollector collector
```
    - uid
```
String uid
```
    - totalCount
```
long totalCount
```
    - eventId
```
long eventId
```
    - myCount
```
long myCount
```
    - source
```
int source
```
- Class org.apache.storm.testing.TestEventOrderCheckBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - recentEventId
```
Map<K,V> recentEventId
```
    - count
```
int count
```
- Class org.apache.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - count
```
int count
```
- Class org.apache.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable
- Class org.apache.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - outFields
```
Fields outFields
```
- Class org.apache.storm.testing.TestSerObject extends Object implements Serializable
  - Serialized Fields
    - f1
```
int f1
```
    - f2
```
int f2
```
- Class org.apache.storm.testing.TestWordBytesCounter extends TestWordCounter implements Serializable
- Class org.apache.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable
  - Serialized Fields
    - counts
```
Map<K,V> counts
```
- Class org.apache.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    - isDistributed
```
boolean isDistributed
```
    - collector
```
SpoutOutputCollector collector
```
- Class org.apache.storm.testing.TupleCaptureBolt extends Object implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - collector
```
OutputCollector collector
```
Package org.apache.storm.topology
- Class org.apache.storm.topology.BaseStatefulBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - transactionRequestCount
```
Map<K,V> transactionRequestCount
```
    - collector
```
OutputCollector collector
```
    - checkPointInputTaskCount
```
int checkPointInputTaskCount
```
    - lastTxid
```
long lastTxid
```
- Class org.apache.storm.topology.BasicBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - bolt
```
IBasicBolt bolt
```
- Class org.apache.storm.topology.CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable
  - Serialized Fields
    - bolt
```
IRichBolt bolt
```
- Class org.apache.storm.topology.FailedException extends RuntimeException implements Serializable
- Class org.apache.storm.topology.PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable
  - Serialized Fields
    - statefulWindowedBolt
```
IStatefulWindowedBolt<T extends State> statefulWindowedBolt
```
- Class org.apache.storm.topology.ReportedFailedException extends FailedException implements Serializable
- Class org.apache.storm.topology.SharedOffHeapWithinNode extends SharedMemory implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.topology.SharedOffHeapWithinWorker extends SharedMemory implements Serializable
- Class org.apache.storm.topology.SharedOnHeap extends SharedMemory implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.topology.StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable
  - Serialized Fields
    - bolt
```
IStatefulBolt<T extends State> bolt
```
    - state
```
State state
```
    - boltInitialized
```
boolean boltInitialized
```
    - pendingTuples
```
List<E> pendingTuples
```
    - preparedTuples
```
List<E> preparedTuples
```
    - collector
```
org.apache.storm.topology.StatefulBoltExecutor.AckTrackingOutputCollector collector
```
- Class org.apache.storm.topology.StatefulWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable
  - Serialized Fields
    - statefulWindowedBolt
```
IStatefulWindowedBolt<T extends State> statefulWindowedBolt
```
- Class org.apache.storm.topology.TupleFieldTimestampExtractor extends Object implements Serializable
  - Serialized Fields
    - fieldName
```
String fieldName
```
- Class org.apache.storm.topology.WindowedBoltExecutor extends Object implements Serializable
  - Serialized Fields
    - bolt
```
IWindowedBolt bolt
```
    - timestampExtractor
```
TimestampExtractor timestampExtractor
```
Package org.apache.storm.topology.base
- Class org.apache.storm.topology.base.BaseBasicBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseBatchBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseComponent extends Object implements Serializable
- Class org.apache.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseStatefulBolt extends Object implements Serializable
- Class org.apache.storm.topology.base.BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    - persistent
```
boolean persistent
```
    - maxEventsInMemory
```
long maxEventsInMemory
```
- Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable
- Class org.apache.storm.topology.base.BaseWindowedBolt extends Object implements Serializable
  - Serialized Fields
    - timestampExtractor
```
TimestampExtractor timestampExtractor
```
- Class org.apache.storm.topology.base.BaseWindowedBolt.Count extends Object implements Serializable
  - Serialized Fields
    - value
```
int value
```
- Class org.apache.storm.topology.base.BaseWindowedBolt.Duration extends Object implements Serializable
  - Serialized Fields
    - value
```
int value
```
Package org.apache.storm.trident.drpc
- Class org.apache.storm.trident.drpc.ReturnResultsReducer extends Object implements Serializable
  - Serialized Fields
    - local
```
boolean local
```
    - conf
```
Map<K,V> conf
```
    - clients
```
Map<K,V> clients
```
Package org.apache.storm.trident.operation
- Class org.apache.storm.trident.operation.BaseAggregator extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseFilter extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseFunction extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseMultiReducer extends Object implements Serializable
- Class org.apache.storm.trident.operation.BaseOperation extends Object implements Serializable
Package org.apache.storm.trident.operation.builtin
- Class org.apache.storm.trident.operation.builtin.ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable
  - Serialized Fields
    - inputFieldName
```
String inputFieldName
```
    - batchId
```
Object batchId
```
- Class org.apache.storm.trident.operation.builtin.Count extends Object implements Serializable
- Class org.apache.storm.trident.operation.builtin.Debug extends BaseFilter implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - useLogger
```
boolean useLogger
```
- Class org.apache.storm.trident.operation.builtin.Equals extends BaseFilter implements Serializable
- Class org.apache.storm.trident.operation.builtin.FilterNull extends BaseFilter implements Serializable
- Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable
  - Serialized Fields
    - number
```
int number
```
- Class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable
  - Serialized Fields
    - number
```
int number
```
    - sortField
```
String sortField
```
    - reverse
```
boolean reverse
```
- Class org.apache.storm.trident.operation.builtin.MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable
- Class org.apache.storm.trident.operation.builtin.Max extends ComparisonAggregator<Comparable<Object>> implements Serializable
- Class org.apache.storm.trident.operation.builtin.MaxWithComparator extends ComparisonAggregator<T> implements Serializable
  - Serialized Fields
    - comparator
```
Comparator<T> comparator
```
- Class org.apache.storm.trident.operation.builtin.Min extends ComparisonAggregator<Comparable<Object>> implements Serializable
- Class org.apache.storm.trident.operation.builtin.MinWithComparator extends ComparisonAggregator<T> implements Serializable
  - Serialized Fields
    - comparator
```
Comparator<T> comparator
```
- Class org.apache.storm.trident.operation.builtin.Negate extends Object implements Serializable
  - Serialized Fields
    - delegate
```
Filter delegate
```
- Class org.apache.storm.trident.operation.builtin.SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable
- Class org.apache.storm.trident.operation.builtin.Sum extends Object implements Serializable
- Class org.apache.storm.trident.operation.builtin.TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable
Package org.apache.storm.trident.operation.impl
- Class org.apache.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 org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl extends Object implements Serializable
  - Serialized Fields
    - agg
```
CombinerAggregator<T> agg
```
- Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl extends Object implements Serializable
  - Serialized Fields
    - agg
```
CombinerAggregator<T> agg
```
- Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - agg
```
CombinerAggregator<T> agg
```
- Class org.apache.storm.trident.operation.impl.ConsumerExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    - consumer
```
Consumer consumer
```
- Class org.apache.storm.trident.operation.impl.FilterExecutor extends Object implements Serializable
  - Serialized Fields
    - filter
```
Filter filter
```
- Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    - function
```
FlatMapFunction function
```
- Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition extends Object implements Serializable
- Class org.apache.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 org.apache.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 org.apache.storm.trident.operation.impl.IdentityMultiReducer extends Object implements Serializable
- Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition extends Object implements Serializable
- Class org.apache.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 org.apache.storm.trident.operation.impl.MapFunctionExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    - function
```
MapFunction function
```
- Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable
  - Serialized Fields
    - types
```
List<E> types
```
    - sideFields
```
List<E> sideFields
```
    - joiningFields
```
List<E> joiningFields
```
    - originFields
```
List<E> originFields
```
    - numGroupFields
```
int numGroupFields
```
    - factory
```
ComboList.Factory factory
```
- Class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl extends Object implements Serializable
  - Serialized Fields
    - agg
```
ReducerAggregator<T> agg
```
- Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    - agg
```
ReducerAggregator<T> agg
```
- Class org.apache.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 org.apache.storm.trident.operation.impl.TrueFilter extends Object implements Serializable
Package org.apache.storm.trident.partition
- Class org.apache.storm.trident.partition.GlobalGrouping extends Object implements Serializable
  - Serialized Fields
    - target
```
List<E> target
```
- Class org.apache.storm.trident.partition.IdentityGrouping extends Object implements Serializable
  - Serialized Fields
    - precomputed
```
Map<K,V> precomputed
```
- Class org.apache.storm.trident.partition.IndexHashGrouping extends Object implements Serializable
  - Serialized Fields
    - index
```
int index
```
    - targets
```
List<E> targets
```
Package org.apache.storm.trident.planner
- Class org.apache.storm.trident.planner.Node extends DefaultResourceDeclarer<Node> implements Serializable
  - Serialized Fields
    - name
```
String name
```
    - allOutputFields
```
Fields allOutputFields
```
    - streamId
```
String streamId
```
    - parallelismHint
```
Integer parallelismHint
```
    - stateInfo
```
NodeStateInfo stateInfo
```
    - creationIndex
```
int creationIndex
```
    - nodeId
```
String nodeId
```
- Class org.apache.storm.trident.planner.NodeStateInfo extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
    - spec
```
StateSpec spec
```
- Class org.apache.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 org.apache.storm.trident.planner.ProcessorNode extends Node implements Serializable
  - Serialized Fields
    - committer
```
boolean committer
```
    - processor
```
TridentProcessor processor
```
    - selfOutFields
```
Fields selfOutFields
```
- Class org.apache.storm.trident.planner.SpoutNode extends Node implements Serializable
  - Serialized Fields
    - spout
```
Object spout
```
    - txId
```
String txId
```
    - type
```
SpoutNode.SpoutType type
```
- Class org.apache.storm.trident.planner.SubtopologyBolt extends Object implements Serializable
  
  serialVersionUID:
  
  1475508603138688412L
  - Serialized Fields
    - graph
```
org.apache.storm.shade.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 org.apache.storm.trident.planner.processor
- Class org.apache.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 org.apache.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 org.apache.storm.trident.planner.processor.MapProcessor extends Object implements Serializable
  - Serialized Fields
    - function
```
Function function
```
    - context
```
TridentContext context
```
    - collector
```
FreshCollector collector
```
    - inputFields
```
Fields inputFields
```
    - projection
```
TridentTupleView.ProjectionFactory projection
```
- Class org.apache.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 org.apache.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 org.apache.storm.trident.planner.processor.ProjectedProcessor extends Object implements Serializable
  - Serialized Fields
    - projectFields
```
Fields projectFields
```
    - factory
```
TridentTupleView.ProjectionFactory factory
```
    - context
```
TridentContext context
```
- Class org.apache.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 org.apache.storm.trident.spout
- Class org.apache.storm.trident.spout.BatchSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - spout
```
IBatchSpout spout
```
- Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - spout
```
IOpaquePartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,M> spout
```
- Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - spout
```
IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T> spout
```
- Class org.apache.storm.trident.spout.RichSpoutBatchExecutor extends Object implements Serializable
  - Serialized Fields
    - spout
```
IRichSpout spout
```
- Class org.apache.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 org.apache.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 org.apache.storm.trident.spout.TridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    - collector
```
org.apache.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 org.apache.storm.trident.state
- Class org.apache.storm.trident.state.BaseQueryFunction extends BaseOperation implements Serializable
- Class org.apache.storm.trident.state.BaseStateUpdater extends BaseOperation implements Serializable
- Class org.apache.storm.trident.state.JSONNonTransactionalSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.JSONOpaqueSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.JSONTransactionalSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.StateSpec extends Object implements Serializable
  - Serialized Fields
    - stateFactory
```
StateFactory stateFactory
```
    - requiredNumPartitions
```
Integer requiredNumPartitions
```
Package org.apache.storm.trident.state.map
- Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater extends Object implements Serializable
  
  serialVersionUID:
  
  -3960578785572592092L
  - Serialized Fields
    - agg
```
CombinerAggregator<T> agg
```
    - groupFields
```
Fields groupFields
```
    - inputFields
```
Fields inputFields
```
    - factory
```
ComboList.Factory factory
```
- Class org.apache.storm.trident.state.map.MapReducerAggStateUpdater extends Object implements Serializable
  
  serialVersionUID:
  
  8667174018978959987L
  - Serialized Fields
    - agg
```
ReducerAggregator<T> agg
```
    - groupFields
```
Fields groupFields
```
    - inputFields
```
Fields inputFields
```
    - factory
```
ComboList.Factory factory
```
- Class org.apache.storm.trident.state.map.MicroBatchIBackingMap.Options extends Object implements Serializable
  - Serialized Fields
    - maxMultiGetBatchSize
```
int maxMultiGetBatchSize
```
    - maxMultiPutBatchSize
```
int maxMultiPutBatchSize
```
Package org.apache.storm.trident.testing
- Class org.apache.storm.trident.testing.CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable
- Class org.apache.storm.trident.testing.FeederBatchSpout extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
    - semaphoreId
```
String semaphoreId
```
    - outFields
```
Fields outFields
```
    - waitToEmit
```
boolean waitToEmit
```
- Class org.apache.storm.trident.testing.FeederCommitterBatchSpout extends Object implements Serializable
  - Serialized Fields
    - spout
```
FeederBatchSpout spout
```
- Class org.apache.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 org.apache.storm.trident.testing.LRUMemoryMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
    - maxSize
```
int maxSize
```
- Class org.apache.storm.trident.testing.MemoryMapState.Factory extends Object implements Serializable
  - Serialized Fields
    - id
```
String id
```
- Class org.apache.storm.trident.testing.Split extends BaseFunction implements Serializable
- Class org.apache.storm.trident.testing.StringLength extends BaseFunction implements Serializable
- Class org.apache.storm.trident.testing.TrueFilter extends BaseFilter implements Serializable
- Class org.apache.storm.trident.testing.TuplifyArgs extends BaseFunction implements Serializable
Package org.apache.storm.trident.topology
- Class org.apache.storm.trident.topology.MasterBatchCoordinator extends BaseRichSpout implements Serializable
  - Serialized Fields
    - activeTx
```
TreeMap<K,V> activeTx
```
    - attemptIds
```
TreeMap<K,V> attemptIds
```
    - currTransaction
```
Long currTransaction
```
    - maxTransactionActive
```
int maxTransactionActive
```
    - coordinators
```
List<E> coordinators
```
    - managedSpoutIds
```
List<E> managedSpoutIds
```
    - spouts
```
List<E> spouts
```
    - throttler
```
WindowedTimeThrottler throttler
```
    - active
```
boolean active
```
    - states
```
List<E> states
```
    - collector
```
SpoutOutputCollector collector
```
- Class org.apache.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
```
org.apache.storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector coordCollector
```
    - coordOutputCollector
```
BatchOutputCollector coordOutputCollector
```
    - context
```
TopologyContext context
```
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition extends Object implements Serializable
  - Serialized Fields
    - commitStream
```
GlobalStreamId commitStream
```
    - expectedTaskReports
```
int expectedTaskReports
```
    - targetTasks
```
Set<E> targetTasks
```
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec extends Object implements Serializable
  - Serialized Fields
    - commitStream
```
GlobalStreamId commitStream
```
    - coords
```
Map<K,V> coords
```
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType extends Object implements Serializable
  - Serialized Fields
    - singleCount
```
boolean singleCount
```
Package org.apache.storm.trident.tuple
- Class org.apache.storm.trident.tuple.ComboList.Factory extends Object implements Serializable
  - Serialized Fields
    - index
```
org.apache.storm.trident.tuple.ComboList.Pointer[] index
```
    - sizes
```
int[] sizes
```
- Class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory extends Object implements Serializable
  - Serialized Fields
    - fieldIndex
```
Map<K,V> fieldIndex
```
    - index
```
ValuePointer[] index
```
- Class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory extends Object implements Serializable
  - Serialized Fields
    - fieldIndex
```
Map<K,V> fieldIndex
```
    - index
```
ValuePointer[] index
```
    - parent
```
TridentTuple.Factory parent
```
- Class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory extends Object implements Serializable
  - Serialized Fields
    - fieldIndex
```
Map<K,V> fieldIndex
```
    - index
```
ValuePointer[] index
```
    - parent
```
TridentTuple.Factory parent
```
- Class org.apache.storm.trident.tuple.TridentTupleView.RootFactory extends Object implements Serializable
  - Serialized Fields
    - index
```
ValuePointer[] index
```
    - fieldIndex
```
Map<K,V> fieldIndex
```
Package org.apache.storm.trident.util
- Class org.apache.storm.trident.util.ErrorEdgeFactory extends Object implements Serializable
- Class org.apache.storm.trident.util.IndexedEdge extends Object implements Serializable
  - Serialized Fields
    - source
```
Object source
```
    - target
```
Object target
```
    - index
```
int index
```
- Class org.apache.storm.trident.util.LRUMap extends LinkedHashMap<A,B> implements Serializable
  - Serialized Fields
    - maxSize
```
int maxSize
```
Package org.apache.storm.trident.windowing
- Class org.apache.storm.trident.windowing.InMemoryWindowsStore extends Object implements Serializable
  - Serialized Fields
    - store
```
ConcurrentHashMap<K,V> store
```
    - maxSize
```
int maxSize
```
    - currentSize
```
AtomicInteger currentSize
```
    - backingStore
```
WindowsStore backingStore
```
- Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory extends Object implements Serializable
  - Serialized Fields
    - inMemoryWindowsStore
```
InMemoryWindowsStore inMemoryWindowsStore
```
- Class org.apache.storm.trident.windowing.WindowsStateFactory extends Object implements Serializable
- Class org.apache.storm.trident.windowing.WindowsStateUpdater extends Object implements Serializable
  - Serialized Fields
    - windowStoreFactory
```
WindowsStoreFactory windowStoreFactory
```
    - windowsStore
```
WindowsStore windowsStore
```
- Class org.apache.storm.trident.windowing.WindowsStore.Entry extends Object implements Serializable
  - Serialized Fields
    - key
```
String key
```
    - value
```
Object value
```
- Class org.apache.storm.trident.windowing.WindowTridentProcessor extends Object implements Serializable
  - Serialized Fields
    - windowId
```
String windowId
```
    - inputFields
```
Fields inputFields
```
    - aggregator
```
Aggregator<T> aggregator
```
    - storeTuplesInStore
```
boolean storeTuplesInStore
```
    - windowTriggerInprocessId
```
String windowTriggerInprocessId
```
    - windowConfig
```
WindowConfig windowConfig
```
    - windowStoreFactory
```
WindowsStoreFactory windowStoreFactory
```
    - windowStore
```
WindowsStore windowStore
```
    - topologyContext
```
TopologyContext topologyContext
```
    - collector
```
FreshCollector collector
```
    - projection
```
TridentTupleView.ProjectionFactory projection
```
    - tridentContext
```
TridentContext tridentContext
```
    - tridentWindowManager
```
ITridentWindowManager tridentWindowManager
```
    - windowTaskId
```
String windowTaskId
```
- Class org.apache.storm.trident.windowing.WindowTridentProcessor.TriggerInfo extends Object implements Serializable
  - Serialized Fields
    - windowTaskId
```
String windowTaskId
```
    - triggerId
```
int triggerId
```
Package org.apache.storm.trident.windowing.config
- Class org.apache.storm.trident.windowing.config.BaseWindowConfig extends Object implements Serializable
  - Serialized Fields
    - windowLength
```
int windowLength
```
    - slideLength
```
int slideLength
```
- Class org.apache.storm.trident.windowing.config.SlidingCountWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.SlidingDurationWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.TumblingCountWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.TumblingDurationWindow extends BaseWindowConfig implements Serializable
Package org.apache.storm.tuple
- Class org.apache.storm.tuple.Fields extends Object implements Serializable
  
  serialVersionUID:
  
  -3377931843059975424L
  - Serialized Fields
    - fields
```
List<E> fields
```
    - index
```
Map<K,V> index
```
- Class org.apache.storm.tuple.Values extends ArrayList<Object> implements Serializable
Package org.apache.storm.utils
- Class org.apache.storm.utils.DisallowedStrategyException extends RuntimeException implements Serializable
  - Serialized Fields
    - attemptedClass
```
String attemptedClass
```
    - allowedStrategies
```
List<E> allowedStrategies
```
- Class org.apache.storm.utils.LruMap extends LinkedHashMap<A,B> implements Serializable
  - Serialized Fields
    - maxSize
```
int maxSize
```
    - evCb
```
LruMap.CacheEvictionCallback<K,V> evCb
```
- Class org.apache.storm.utils.NimbusLeaderNotFoundException extends RuntimeException implements Serializable
- Class org.apache.storm.utils.ShellBoltMessageQueue extends Object implements Serializable
  - Serialized Fields
    - taskIdsQueue
```
LinkedList<E> taskIdsQueue
```
    - boltMsgQueue
```
LinkedBlockingQueue<E> boltMsgQueue
```
    - takeLock
```
ReentrantLock takeLock
```
    - notEmpty
```
Condition notEmpty
```
- Class org.apache.storm.utils.ShellProcess extends Object implements Serializable
  - Serialized Fields
    - serializer
```
ISerializer serializer
```
    - pid
```
Number pid
```
    - componentName
```
String componentName
```
    - subprocess
```
Process subprocess
```
    - processErrorStream
```
InputStream processErrorStream
```
    - command
```
String[] command
```
    - env
```
Map<K,V> env
```
- Class org.apache.storm.utils.ShellUtils.ExitCodeException extends IOException implements Serializable
  - Serialized Fields
    - exitCode
```
int exitCode
```
- Class org.apache.storm.utils.WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable
- Class org.apache.storm.utils.WrappedAuthorizationException extends AuthorizationException implements Serializable
- Class org.apache.storm.utils.WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable
- Class org.apache.storm.utils.WrappedHBExecutionException extends HBExecutionException implements Serializable
- Class org.apache.storm.utils.WrappedIllegalStateException extends IllegalStateException implements Serializable
- Class org.apache.storm.utils.WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable
- Class org.apache.storm.utils.WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable
- Class org.apache.storm.utils.WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable
- Class org.apache.storm.utils.WrappedNotAliveException extends NotAliveException implements Serializable
Package org.apache.storm.windowing

Serialized Form

Package org.apache.calcite.interpreter

Class org.apache.calcite.interpreter.StormContext extends org.apache.calcite.interpreter.Context implements Serializable

Package org.apache.storm

Class org.apache.storm.clojure$ack_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$bolt extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$bolt_execute extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$bolt$fn__702 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_bolt extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_bolt_STAR_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_spout extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_spout_STAR_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$collectify extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$defalias extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$defbolt extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$defspout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$direct_stream extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$emit_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_direct_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_direct_spout_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_spout_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$fail_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__669 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__733 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__736 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__736$G__731__745 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__732

Class org.apache.storm.clojure$fn__736$G__732__740 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__751 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__751$iter__752__756 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__751$iter__752__756$fn__757 extends clojure.lang.AFunction implements Serializable

Serialized Fields

s__753

iter__752

Class org.apache.storm.clojure$fn__751$iter__752__756$fn__757$fn__758 extends clojure.lang.AFunction implements Serializable

Serialized Fields

size__6289__auto__

b__755

c__6288__auto__

Class org.apache.storm.clojure$fn__773 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__792 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__794 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__796 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__798 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__800 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$loading__6706__auto____667 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$local_cluster extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter__677__681 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter__677__681$fn__682 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__677

s__678

Class org.apache.storm.clojure$normalize_fns$iter__677__681$fn__682$fn__683 extends clojure.lang.AFunction implements Serializable

Serialized Fields

size__6289__auto__

b__680

c__6288__auto__

Class org.apache.storm.clojure$report_error_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$reset_timeout_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$spout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$spout$fn__710 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$to_spec extends clojure.lang.AFunction implements Serializable

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

Class org.apache.storm.config$clojure_config_name extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$fn__532 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$fn__539 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$loading__6706__auto____530 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

currentIndex

numEmitted

Class org.apache.storm.LocalCluster.LocalTopology extends StormTopology implements Serializable

Serialized Fields

Class org.apache.storm.clojure$fn736$G731__745 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn736$G732__740 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn751$iter752__756 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn751$iter752756$fn757 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn751$iter752756$fn757$fn__758 extends clojure.lang.AFunction implements Serializable

size6289auto__

c6288auto__

Class org.apache.storm.clojure$loading6706auto____667 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter677681 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter677681$fn__682 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter677681$fn682$fn683 extends clojure.lang.AFunction implements Serializable

size6289auto__

c6288auto__

Class org.apache.storm.config$loading6706auto____530 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.log$loading6706auto____273 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$loading6706auto____271 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects$iter337341 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects$iter337341$fn__342 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects$iter337341$fn342$fn343 extends clojure.lang.AFunction implements Serializable

c6288auto__

size6289auto__

Class org.apache.storm.thrift$loading6706auto____543 extends clojure.lang.AFunction implements Serializable