# 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

            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

      - #### b__755

            Object b__755

      - #### c__6288__auto__

            Object c__6288__auto__

      - #### size__6289__auto__

            int size__6289__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

      - #### b__680

            Object b__680

      - #### c__6288__auto__

            Object c__6288__auto__

      - #### size__6289__auto__

            int size__6289__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

      - #### s__338

            Object s__338

      - #### iter__337

            Object iter__337

  - ### Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342$fn__343 extends clojure.lang.AFunction implements Serializable

    - ### Serialized Fields

      - #### size__6289__auto__

            int size__6289__auto__

      - #### b__340

            Object b__340

      - #### c__6288__auto__

            Object c__6288__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

      - #### iter__589

            Object iter__589

      - #### s__590

            Object s__590

  - ### Class org.apache.storm.thrift$mk_inputs$iter__589__593$fn__594$fn__595 extends clojure.lang.AFunction implements Serializable

    - ### Serialized Fields

      - #### size__6289__auto__

            int size__6289__auto__

      - #### b__592

            Object b__592

      - #### 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

      - #### afn

            Object afn

      - #### b__493

            Object b__493

      - #### size__6289__auto__

            int size__6289__auto__

      - #### c__6288__auto__

            Object c__6288__auto__

  - ### 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

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### ise

            IllegalStateException ise

  - ### 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.getTopologyInfoByName_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.getTopologyInfoByName_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.getTopologyInfoByNameWithOpts_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

            GetInfoOptions options

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_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.getTopologySummaries_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.getTopologySummaries_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.getTopologySummary_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.getTopologySummary_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

            TopologySummary success

      - #### e

            NotAliveException e

      - #### aze

            AuthorizationException aze

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

            TopologySummary 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

      - #### blacklisted

            boolean blacklisted

      - #### used_generic_resources

            Map<K,V> used_generic_resources

      - #### __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

      - #### requested_generic_resources

            Map<K,V> requested_generic_resources

      - #### assigned_generic_resources

            Map<K,V> assigned_generic_resources

      - #### __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

      - #### requested_generic_resources

            Map<K,V> requested_generic_resources

      - #### assigned_generic_resources

            Map<K,V> assigned_generic_resources

      - #### __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

      - #### nodeToHost

            AtomicReference<V> nodeToHost

      - #### 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.MultiThreadWordCountTopology.MultiThreadedSplitSentence extends Object implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### executor

            ExecutorService executor

  - ### 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.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

  - ### Class org.apache.storm.starter.bolt.WordCountBolt extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<K,V> counts

- ## 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

Copyright © 2021 The Apache Software Foundation. All rights reserved.