# Serialized Form

- ## Package org.apache.calcite.interpreter

  - ### Class org.apache.calcite.interpreter.StormContext

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

- ## Package org.apache.storm

  - ### Class org.apache.storm.clojure$ack_BANG_

    class clojure$ack_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$bolt

    class clojure$bolt extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$bolt_execute

    class clojure$bolt_execute extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$bolt$fn__728

    class clojure$bolt$fn__728 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$clojure_bolt

    class clojure$clojure_bolt extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$clojure_bolt_STAR_

    class clojure$clojure_bolt_STAR_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$clojure_spout

    class clojure$clojure_spout extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$clojure_spout_STAR_

    class clojure$clojure_spout_STAR_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$collectify

    class clojure$collectify extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$defalias

    class clojure$defalias extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$defbolt

    class clojure$defbolt extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$defspout

    class clojure$defspout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$direct_stream

    class clojure$direct_stream extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$emit_bolt_BANG_

    class clojure$emit_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$emit_direct_bolt_BANG_

    class clojure$emit_direct_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$emit_direct_spout_BANG_

    class clojure$emit_direct_spout_BANG_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$emit_spout_BANG_

    class clojure$emit_spout_BANG_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$fail_BANG_

    class clojure$fail_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__695

    class clojure$fn__695 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__759

    class clojure$fn__759 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__762

    class clojure$fn__762 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__762$G__757__771

    class clojure$fn__762$G__757__771 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### G__758

            Object G__758

  - ### Class org.apache.storm.clojure$fn__762$G__758__766

    class clojure$fn__762$G__758__766 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__777

    class clojure$fn__777 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__777$iter__778__782

    class clojure$fn__777$iter__778__782 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783

    class clojure$fn__777$iter__778__782$fn__783 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### iter__778

            Object iter__778

      - ##### s__779

            Object s__779

  - ### Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783$fn__784

    class clojure$fn__777$iter__778__782$fn__783$fn__784 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### b__781

            Object b__781

      - ##### c__6394__auto__

            Object c__6394__auto__

      - ##### size__6395__auto__

            int size__6395__auto__

  - ### Class org.apache.storm.clojure$fn__799

    class clojure$fn__799 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__818

    class clojure$fn__818 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__820

    class clojure$fn__820 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__822

    class clojure$fn__822 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__824

    class clojure$fn__824 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__826

    class clojure$fn__826 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$loading__6812__auto____693

    class clojure$loading__6812__auto____693 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$local_cluster

    class clojure$local_cluster extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$normalize_fns

    class clojure$normalize_fns extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$normalize_fns$iter__703__707

    class clojure$normalize_fns$iter__703__707 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708

    class clojure$normalize_fns$iter__703__707$fn__708 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### iter__703

            Object iter__703

      - ##### s__704

            Object s__704

  - ### Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708$fn__709

    class clojure$normalize_fns$iter__703__707$fn__708$fn__709 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### b__706

            Object b__706

      - ##### c__6394__auto__

            Object c__6394__auto__

      - ##### size__6395__auto__

            int size__6395__auto__

  - ### Class org.apache.storm.clojure$report_error_BANG_

    class clojure$report_error_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$reset_timeout_BANG_

    class clojure$reset_timeout_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$spout

    class clojure$spout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.clojure$spout$fn__736

    class clojure$spout$fn__736 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$submit_remote_topology

    class clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$to_spec

    class clojure$to_spec extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.Config

    class Config extends HashMap<String,Object> implements Serializable
    serialVersionUID:
      -1550278723792864455L

  - ### Class org.apache.storm.config$clojure_config_name

    class config$clojure_config_name extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.config$fn__269

    class config$fn__269 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.config$fn__276

    class config$fn__276 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.config$loading__6812__auto____267

    class config$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.ExclamationTopology.ExclamationBolt

    class ExclamationBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout

    class FixedOrderWordSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### currentIndex

            int currentIndex

      - ##### numEmitted

            int numEmitted

  - ### Class org.apache.storm.LocalCluster.LocalTopology

    class LocalTopology extends StormTopology implements Serializable
    serialVersionUID:
      6145919776650637748L

    - #### Serialized Fields

      - ##### topoName

            String topoName

  - ### Class org.apache.storm.log$fn__495

    class log$fn__495 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.log$loading__6812__auto____284

    class log$loading__6812__auto____284 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.log$log_debug

    class log$log_debug extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_error

    class log$log_error extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_message

    class log$log_message extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_warn

    class log$log_warn extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$add_supervisor

    class testing$add_supervisor extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$advance_cluster_time

    class testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$capture_topology

    class testing$capture_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$complete_topology

    class testing$complete_topology extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$fn__478

    class testing$fn__478 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$get_supervisor

    class testing$get_supervisor extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$global_amt

    class testing$global_amt extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$increment_global_BANG_

    class testing$increment_global_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$kill_local_storm_cluster

    class testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$kill_supervisor

    class testing$kill_supervisor extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$loading__6812__auto____267

    class testing$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$local_cluster_state

    class testing$local_cluster_state extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$mk_local_storm_cluster

    class testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mk_mocked_nimbus

    class testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mk_tracked_topology

    class testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$mkClusterParam

    class testing$mkClusterParam extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mock_leader_elector

    class testing$mock_leader_elector extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$ms_EQ_

    class testing$ms_EQ_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$read_tuples

    class testing$read_tuples extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$simulate_wait

    class testing$simulate_wait extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$spout_objects

    class testing$spout_objects extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$spout_objects$iter__527__531

    class testing$spout_objects$iter__527__531 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532

    class testing$spout_objects$iter__527__531$fn__532 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### iter__527

            Object iter__527

      - ##### s__528

            Object s__528

  - ### Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532$fn__533

    class testing$spout_objects$iter__527__531$fn__532$fn__533 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### b__530

            Object b__530

      - ##### c__6394__auto__

            Object c__6394__auto__

      - ##### size__6395__auto__

            int size__6395__auto__

  - ### Class org.apache.storm.testing$submit_local_topology

    class testing$submit_local_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$submit_local_topology_with_opts

    class testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$test_tuple

    class testing$test_tuple extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$tracked_wait

    class testing$tracked_wait extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_for_condition

    class testing$wait_for_condition extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_for_condition$fn__499

    class testing$wait_for_condition$fn__499 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_until_cluster_waiting

    class testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$while_timeout

    class testing$while_timeout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_inprocess_zookeeper

    class testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_local_cluster

    class testing$with_local_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_mocked_nimbus

    class testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_simulated_time_local_cluster

    class testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_timeout

    class testing$with_timeout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_tracked_cluster

    class testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$add_inputs

    class thrift$add_inputs extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$deserialized_component_object

    class thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$direct_output_fields

    class thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$field_grouping

    class thrift$field_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$fn__571

    class thrift$fn__571 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$global_grouping_QMARK_

    class thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$grouping_type

    class thrift$grouping_type extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$instantiate_java_object

    class thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$instantiate_java_object$fn__574

    class thrift$instantiate_java_object$fn__574 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$loading__6812__auto____280

    class thrift$loading__6812__auto____280 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_all_grouping

    class thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_bolt_spec

    class thrift$mk_bolt_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_bolt_spec_STAR_

    class thrift$mk_bolt_spec_STAR_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_direct_grouping

    class thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_fields_grouping

    class thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_global_grouping

    class thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_grouping

    class thrift$mk_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_inputs

    class thrift$mk_inputs extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_inputs$iter__615__619

    class thrift$mk_inputs$iter__615__619 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620

    class thrift$mk_inputs$iter__615__619$fn__620 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### iter__615

            Object iter__615

      - ##### s__616

            Object s__616

  - ### Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620$fn__621

    class thrift$mk_inputs$iter__615__619$fn__620$fn__621 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### b__618

            Object b__618

      - ##### c__6394__auto__

            Object c__6394__auto__

      - ##### size__6395__auto__

            int size__6395__auto__

  - ### Class org.apache.storm.thrift$mk_local_or_shuffle_grouping

    class thrift$mk_local_or_shuffle_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_none_grouping

    class thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_output_spec

    class thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_output_spec$fn__598

    class thrift$mk_output_spec$fn__598 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_plain_component_common

    class thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shell_bolt_spec

    class thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shell_spout_spec

    class thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shuffle_grouping

    class thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_spout_spec

    class thrift$mk_spout_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_spout_spec_STAR_

    class thrift$mk_spout_spec_STAR_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_topology

    class thrift$mk_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$nimbus_client_and_conn

    class thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$output_fields

    class thrift$output_fields extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$parallelism_hint

    class thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$serialize_component_object

    class thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$shell_component_params

    class thrift$shell_component_params extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$with_configured_nimbus_connection

    class thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$with_nimbus_connection

    class thrift$with_nimbus_connection extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$__LT__GT_

    class util$__LT__GT_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$__LT__GT_$fn__567

    class util$__LT__GT_$fn__567 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_error

    class util$clojurify_error extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_structure

    class util$clojurify_structure extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_structure$fn__527

    class util$clojurify_structure$fn__527 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$defnk

    class util$defnk extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$defnk$fn__521

    class util$defnk$fn__521 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$dofor

    class util$dofor extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$filter_key

    class util$filter_key extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$filter_key$fn__553

    class util$filter_key$fn__553 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### afn

            Object afn

  - ### Class org.apache.storm.util$fn__501

    class util$fn__501 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$hashmap_to_persistent

    class util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$loading__6812__auto____282

    class util$loading__6812__auto____282 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$map_val

    class util$map_val extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$map_val$iter__531__535

    class util$map_val$iter__531__535 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### afn

            Object afn

  - ### Class org.apache.storm.util$map_val$iter__531__535$fn__536

    class util$map_val$iter__531__535$fn__536 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### afn

            Object afn

      - ##### iter__531

            Object iter__531

      - ##### s__532

            Object s__532

  - ### Class org.apache.storm.util$map_val$iter__531__535$fn__536$fn__537

    class util$map_val$iter__531__535$fn__536$fn__537 extends clojure.lang.AFunction implements Serializable

    - #### Serialized Fields

      - ##### afn

            Object afn

      - ##### b__534

            Object b__534

      - ##### c__6394__auto__

            Object c__6394__auto__

      - ##### size__6395__auto__

            int size__6395__auto__

  - ### Class org.apache.storm.util$name_with_attributes

    class util$name_with_attributes extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$thrown_cause_QMARK_

    class util$thrown_cause_QMARK_ extends clojure.lang.RestFn implements Serializable

- ## Package org.apache.storm.bolt

  - ### Class org.apache.storm.bolt.JoinBolt

    class JoinBolt extends BaseWindowedBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### hashedInputs

            HashMap<String,HashMap<Object,ArrayList<Tuple>>> hashedInputs

      - ##### joinCriteria

            LinkedHashMap<String,JoinBolt.JoinInfo> joinCriteria

      - ##### outputFields

            JoinBolt.FieldSelector[] outputFields

      - ##### outputStreamName

            String outputStreamName

      - ##### selectorType

            JoinBolt.Selector selectorType

  - ### Class org.apache.storm.bolt.JoinBolt.FieldSelector

    class FieldSelector extends Object implements Serializable

    - #### Serialized Fields

      - ##### field

            String[] field

      - ##### outputName

            String outputName

      - ##### streamName

            String streamName

  - ### Class org.apache.storm.bolt.JoinBolt.JoinInfo

    class JoinInfo extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### field

            JoinBolt.FieldSelector field

      - ##### joinType

            JoinBolt.JoinType joinType

      - ##### other

            JoinBolt.FieldSelector other

- ## Package org.apache.storm.clojure

  - ### Class org.apache.storm.clojure.ClojureBolt

    class ClojureBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### bolt

            IBolt bolt

      - ##### confSpec

            List<String> confSpec

      - ##### fields

            Map<String,StreamInfo> fields

      - ##### fnSpec

            List<String> fnSpec

      - ##### params

            List<Object> params

  - ### Class org.apache.storm.clojure.ClojureSpout

    class ClojureSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### confSpec

            List<String> confSpec

      - ##### fields

            Map<String,StreamInfo> fields

      - ##### fnSpec

            List<String> fnSpec

      - ##### params

            List<Object> params

      - ##### spout

            ISpout spout

  - ### Class org.apache.storm.clojure.RichShellBolt

    class RichShellBolt extends ShellBolt implements Serializable

    - #### Serialized Fields

      - ##### outputs

            Map<String,StreamInfo> outputs

  - ### Class org.apache.storm.clojure.RichShellSpout

    class RichShellSpout extends ShellSpout implements Serializable

    - #### Serialized Fields

      - ##### outputs

            Map<String,StreamInfo> outputs

- ## Package org.apache.storm.coordination

  - ### Class org.apache.storm.coordination.BatchBoltExecutor

    class BatchBoltExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### boltSer

            byte[] boltSer

      - ##### collector

            BatchOutputCollectorImpl collector

      - ##### conf

            Map conf

      - ##### context

            TopologyContext context

      - ##### openTransactions

            Map<Object,IBatchBolt> openTransactions

  - ### Class org.apache.storm.coordination.CoordinatedBolt

    class CoordinatedBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### countOutTasks

            List<Integer> countOutTasks

      - ##### delegate

            IRichBolt delegate

      - ##### idStreamSpec

            CoordinatedBolt.IdStreamSpec idStreamSpec

      - ##### numSourceReports

            Integer numSourceReports

      - ##### sourceArgs

            Map<String,CoordinatedBolt.SourceArgs> sourceArgs

      - ##### tracked

            TimeCacheMap<Object,CoordinatedBolt.TrackingInfo> tracked

  - ### Class org.apache.storm.coordination.CoordinatedBolt.IdStreamSpec

    class IdStreamSpec extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            GlobalStreamId id

  - ### Class org.apache.storm.coordination.CoordinatedBolt.SourceArgs

    class SourceArgs extends Object implements Serializable

    - #### Serialized Fields

      - ##### singleCount

            boolean singleCount

- ## Package org.apache.storm.daemon

  - ### Class org.apache.storm.daemon.Acker

    class Acker extends Object implements Serializable
    serialVersionUID:
      4430906880683183091L

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### pending

            RotatingMap<Object,org.apache.storm.daemon.Acker.AckObject> pending

  - ### Class org.apache.storm.daemon.GrouperFactory.AllGrouper

    class AllGrouper extends Object implements Serializable

    - #### Serialized Fields

      - ##### targetTasks

            List<Integer> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping

    class BasicLoadAwareCustomStreamGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### customStreamGrouping

            CustomStreamGrouping customStreamGrouping

  - ### Class org.apache.storm.daemon.GrouperFactory.FieldsGrouper

    class FieldsGrouper extends Object implements Serializable

    - #### Serialized Fields

      - ##### groupFields

            Fields groupFields

      - ##### numTasks

            int numTasks

      - ##### outFields

            Fields outFields

      - ##### targetTasks

            List<List<Integer>> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.GlobalGrouper

    class GlobalGrouper extends Object implements Serializable

    - #### Serialized Fields

      - ##### targetTasks

            List<Integer> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.NoneGrouper

    class NoneGrouper extends Object implements Serializable

    - #### Serialized Fields

      - ##### numTasks

            int numTasks

      - ##### random

            Random random

      - ##### targetTasks

            List<Integer> targetTasks

- ## Package org.apache.storm.daemon.supervisor

  - ### Exception org.apache.storm.daemon.supervisor.ContainerRecoveryException

    class ContainerRecoveryException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignment

    class TimerDecoratedAssignment extends LocalAssignment implements Serializable

    - #### Serialized Fields

      - ##### timing

            com.codahale.metrics.Timer.Context timing

- ## Package org.apache.storm.daemon.ui

  - ### Exception org.apache.storm.daemon.ui.InvalidRequestException

    class InvalidRequestException extends Exception implements Serializable

- ## Package org.apache.storm.dependency

  - ### Exception org.apache.storm.dependency.FileNotAvailableException

    class FileNotAvailableException extends RuntimeException implements Serializable

- ## Package org.apache.storm.drpc

  - ### Class org.apache.storm.drpc.DRPCSpout

    class DRPCSpout extends BaseRichSpout implements Serializable
    serialVersionUID:
      2387848310969237877L

    - #### Serialized Fields

      - ##### clients

            List<DRPCInvocationsClient> clients

      - ##### collector

            SpoutOutputCollector collector

      - ##### function

            String function

      - ##### localDrpcId

            String localDrpcId

  - ### Class org.apache.storm.drpc.JoinResult

    class JoinResult extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### results

            Map<Object,Tuple> results

      - ##### returnComponent

            String returnComponent

      - ##### returns

            Map<Object,Tuple> returns

  - ### Class org.apache.storm.drpc.KeyedFairBolt

    class KeyedFairBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### callback

            CoordinatedBolt.FinishedCallback callback

      - ##### delegate

            IRichBolt delegate

      - ##### executor

            Thread executor

      - ##### rrQueue

            KeyedRoundRobinQueue<Tuple> rrQueue

  - ### Class org.apache.storm.drpc.PrepareRequest

    class PrepareRequest extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### rand

            Random rand

  - ### Class org.apache.storm.drpc.ReturnResults

    class ReturnResults extends BaseRichBolt implements Serializable
    serialVersionUID:
      -774882142710631591L

    - #### Serialized Fields

      - ##### clients

            Map<List,DRPCInvocationsClient> clients

      - ##### collector

            OutputCollector collector

      - ##### conf

            Map<String,Object> conf

      - ##### local

            boolean local

- ## Package org.apache.storm.executor

  - ### Class org.apache.storm.executor.TupleInfo

    class TupleInfo extends Object implements Serializable
    serialVersionUID:
      -3348670497595864118L

    - #### Serialized Fields

      - ##### messageId

            Object messageId

      - ##### rootId

            long rootId

      - ##### stream

            String stream

      - ##### taskId

            int taskId

      - ##### timestamp

            long timestamp

      - ##### values

            List<Object> values

- ## Package org.apache.storm.flux.examples

  - ### Class org.apache.storm.flux.examples.OnlyValueRecordTranslator

    class OnlyValueRecordTranslator extends Object implements Serializable

  - ### Class org.apache.storm.flux.examples.StatefulWordCounter

    class StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,Long>> implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### wordCounts

            KeyValueState<String,Long> wordCounts

  - ### Class org.apache.storm.flux.examples.TestPrintBolt

    class TestPrintBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.flux.examples.TestWindowBolt

    class TestWindowBolt extends BaseWindowedBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.flux.examples.WordCounter

    class WordCounter extends BaseBasicBolt implements Serializable

- ## Package org.apache.storm.flux.wrappers.bolts

  - ### Class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

    class FluxShellBolt extends ShellBolt implements Serializable

    - #### Serialized Fields

      - ##### componentConfig

            Map<String,Object> componentConfig

      - ##### outputFields

            Map<String,String[]> outputFields

  - ### Class org.apache.storm.flux.wrappers.bolts.LogInfoBolt

    class LogInfoBolt extends BaseBasicBolt implements Serializable

- ## Package org.apache.storm.flux.wrappers.spouts

  - ### Class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

    class FluxShellSpout extends ShellSpout implements Serializable

    - #### Serialized Fields

      - ##### componentConfig

            Map<String,Object> componentConfig

      - ##### outputFields

            Map<String,String[]> outputFields

- ## Package org.apache.storm.generated

  - ### Class org.apache.storm.generated.AccessControl

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### access

            int access

      - ##### name

            String name

      - ##### type

            AccessControlType type

  - ### Exception org.apache.storm.generated.AlreadyAliveException

    class 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

    class 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

      - ##### executor_node_port

            Map<List<Long>,NodeInfo> executor_node_port

      - ##### executor_start_time_secs

            Map<List<Long>,Long> executor_start_time_secs

      - ##### master_code_dir

            String master_code_dir

      - ##### node_host

            Map<String,String> node_host

      - ##### owner

            String owner

      - ##### total_shared_off_heap

            Map<String,Double> total_shared_off_heap

      - ##### worker_resources

            Map<NodeInfo,WorkerResources> worker_resources

  - ### Exception org.apache.storm.generated.AuthorizationException

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### data_size

            long data_size

      - ##### session

            String session

      - ##### version

            long version

  - ### Class org.apache.storm.generated.Bolt

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### capacity

            double capacity

      - ##### execute_latency_ms

            double execute_latency_ms

      - ##### executed

            long executed

      - ##### process_latency_ms

            double process_latency_ms

  - ### Class org.apache.storm.generated.BoltStats

    class 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<String,Map<GlobalStreamId,Long>> acked

      - ##### execute_ms_avg

            Map<String,Map<GlobalStreamId,Double>> execute_ms_avg

      - ##### executed

            Map<String,Map<GlobalStreamId,Long>> executed

      - ##### failed

            Map<String,Map<GlobalStreamId,Long>> failed

      - ##### process_ms_avg

            Map<String,Map<GlobalStreamId,Double>> process_ms_avg

  - ### Class org.apache.storm.generated.ClusterSummary

    class 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

      - ##### nimbuses

            List<NimbusSummary> nimbuses

      - ##### supervisors

            List<SupervisorSummary> supervisors

      - ##### topologies

            List<TopologySummary> topologies

  - ### Class org.apache.storm.generated.ClusterWorkerHeartbeat

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### executor_stats

            Map<ExecutorInfo,ExecutorStats> executor_stats

      - ##### storm_id

            String storm_id

      - ##### time_secs

            int time_secs

      - ##### uptime_secs

            int uptime_secs

  - ### Class org.apache.storm.generated.CommonAggregateStats

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### acked

            long acked

      - ##### emitted

            long emitted

      - ##### failed

            long failed

      - ##### num_executors

            int num_executors

      - ##### num_tasks

            int num_tasks

      - ##### resources_map

            Map<String,Double> resources_map

      - ##### transferred

            long transferred

  - ### Class org.apache.storm.generated.ComponentAggregateStats

    class 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

      - ##### common_stats

            CommonAggregateStats common_stats

      - ##### last_error

            ErrorInfo last_error

      - ##### specific_stats

            SpecificAggregateStats specific_stats

      - ##### type

            ComponentType type

  - ### Class org.apache.storm.generated.ComponentCommon

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### inputs

            Map<GlobalStreamId,Grouping> inputs

      - ##### json_conf

            String json_conf

      - ##### parallelism_hint

            int parallelism_hint

      - ##### streams

            Map<String,StreamInfo> streams

  - ### Class org.apache.storm.generated.ComponentObject

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### component_id

            String component_id

      - ##### component_type

            ComponentType component_type

      - ##### debug_options

            DebugOptions debug_options

      - ##### errors

            List<ErrorInfo> errors

      - ##### eventlog_host

            String eventlog_host

      - ##### eventlog_port

            int eventlog_port

      - ##### exec_stats

            List<ExecutorAggregateStats> exec_stats

      - ##### gsid_to_input_stats

            Map<GlobalStreamId,ComponentAggregateStats> gsid_to_input_stats

      - ##### num_executors

            int num_executors

      - ##### num_tasks

            int num_tasks

      - ##### resources_map

            Map<String,Double> resources_map

      - ##### sid_to_output_stats

            Map<String,ComponentAggregateStats> sid_to_output_stats

      - ##### topology_id

            String topology_id

      - ##### topology_name

            String topology_name

      - ##### topology_status

            String topology_status

      - ##### window_to_stats

            Map<String,ComponentAggregateStats> window_to_stats

  - ### Class org.apache.storm.generated.Credentials

    class 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<String,String> creds

      - ##### topoOwner

            String topoOwner

  - ### Class org.apache.storm.generated.DebugOptions

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### enable

            boolean enable

      - ##### samplingpct

            double samplingpct

  - ### Class org.apache.storm.generated.DistributedRPC.execute_args

    class 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

      - ##### funcArgs

            String funcArgs

      - ##### functionName

            String functionName

  - ### Class org.apache.storm.generated.DistributedRPC.execute_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            DRPCExecutionException e

      - ##### success

            String success

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args

    class 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

    class 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

    class 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

      - ##### e

            DRPCExecutionException e

      - ##### id

            String id

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_result

    class 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

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            DRPCRequest success

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.result_args

    class 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

    class 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

  - ### Exception org.apache.storm.generated.DRPCExecutionException

    class 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

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### error

            String error

      - ##### error_time_secs

            int error_time_secs

      - ##### host

            String host

      - ##### port

            int port

  - ### Class org.apache.storm.generated.ExecutorAggregateStats

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### task_end

            int task_end

      - ##### task_start

            int task_start

  - ### Class org.apache.storm.generated.ExecutorSpecificStats

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### emitted

            Map<String,Map<String,Long>> emitted

      - ##### rate

            double rate

      - ##### specific

            ExecutorSpecificStats specific

      - ##### transferred

            Map<String,Map<String,Long>> transferred

  - ### Class org.apache.storm.generated.ExecutorSummary

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### component_id

            String component_id

      - ##### executor_info

            ExecutorInfo executor_info

      - ##### host

            String host

      - ##### port

            int port

      - ##### stats

            ExecutorStats stats

      - ##### uptime_secs

            int uptime_secs

  - ### Class org.apache.storm.generated.GetInfoOptions

    class 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

    class 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

    class 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`

  - ### Exception org.apache.storm.generated.HBAuthorizationException

    class 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

  - ### Exception org.apache.storm.generated.HBExecutionException

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### data

            HBMessageData data

      - ##### message_id

            int message_id

      - ##### type

            HBServerMessageType type

  - ### Class org.apache.storm.generated.HBMessageData

    class 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

    class 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<String> pulseIds

  - ### Class org.apache.storm.generated.HBPulse

    class 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

      - ##### details

            ByteBuffer details

      - ##### id

            String id

  - ### Class org.apache.storm.generated.HBRecords

    class 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<HBPulse> pulses

  - ### Exception org.apache.storm.generated.IllegalStateException

    class 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

  - ### Exception org.apache.storm.generated.InvalidTopologyException

    class 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

    class 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

      - ##### args_list

            List<JavaObjectArg> args_list

      - ##### full_class_name

            String full_class_name

  - ### Class org.apache.storm.generated.JavaObjectArg

    class 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`

  - ### Exception org.apache.storm.generated.KeyAlreadyExistsException

    class 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

  - ### Exception org.apache.storm.generated.KeyNotFoundException

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### wait_secs

            int wait_secs

  - ### Class org.apache.storm.generated.ListBlobsResult

    class 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<String> keys

      - ##### session

            String session

  - ### Class org.apache.storm.generated.LocalAssignment

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### executors

            List<ExecutorInfo> executors

      - ##### owner

            String owner

      - ##### resources

            WorkerResources resources

      - ##### topology_id

            String topology_id

      - ##### total_node_shared

            double total_node_shared

  - ### Class org.apache.storm.generated.LocalStateData

    class 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<String,ThriftSerializedObject> serialized_parts

  - ### Class org.apache.storm.generated.LogConfig

    class 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<String,LogLevel> named_logger_level

  - ### Class org.apache.storm.generated.LogLevel

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### action

            LogLevelAction action

      - ##### reset_log_level

            String reset_log_level

      - ##### reset_log_level_timeout_epoch

            long reset_log_level_timeout_epoch

      - ##### reset_log_level_timeout_secs

            int reset_log_level_timeout_secs

      - ##### target_log_level

            String target_log_level

  - ### Class org.apache.storm.generated.LSApprovedWorkers

    class 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<String,Integer> approved_workers

  - ### Class org.apache.storm.generated.LSSupervisorAssignments

    class 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<Integer,LocalAssignment> assignments

  - ### Class org.apache.storm.generated.LSSupervisorId

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### groups

            List<String> groups

      - ##### time_stamp

            long time_stamp

      - ##### topology_id

            String topology_id

      - ##### users

            List<String> users

  - ### Class org.apache.storm.generated.LSTopoHistoryList

    class 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<LSTopoHistory> topo_history

  - ### Class org.apache.storm.generated.LSWorkerHeartbeat

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### executors

            List<ExecutorInfo> executors

      - ##### port

            int port

      - ##### time_secs

            int time_secs

      - ##### topology_id

            String topology_id

  - ### Class org.apache.storm.generated.Nimbus.activate_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.beginBlobDownload_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### knf

            KeyNotFoundException knf

      - ##### success

            BeginDownloadResult success

  - ### Class org.apache.storm.generated.Nimbus.beginCreateBlob_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### kae

            KeyAlreadyExistsException kae

      - ##### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.beginFileUpload_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.beginUpdateBlob_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### knf

            KeyNotFoundException knf

      - ##### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.cancelBlobUpload_args

    class 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

    class 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

    class 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

    class 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

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.debug_args

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### component

            String component

      - ##### enable

            boolean enable

      - ##### name

            String name

      - ##### samplingPercentage

            double samplingPercentage

  - ### Class org.apache.storm.generated.Nimbus.debug_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.deleteBlob_args

    class 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

    class 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

      - ##### ise

            IllegalStateException ise

      - ##### knf

            KeyNotFoundException knf

  - ### Class org.apache.storm.generated.Nimbus.downloadBlobChunk_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            ByteBuffer success

  - ### Class org.apache.storm.generated.Nimbus.downloadChunk_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            ByteBuffer success

  - ### Class org.apache.storm.generated.Nimbus.finishBlobUpload_args

    class 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

    class 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

    class 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

    class 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

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### knf

            KeyNotFoundException knf

      - ##### success

            ReadableBlobMeta success

  - ### Class org.apache.storm.generated.Nimbus.getBlobReplication_args

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### aze

            AuthorizationException aze

      - ##### knf

            KeyNotFoundException knf

      - ##### success

            int success

  - ### Class org.apache.storm.generated.Nimbus.getClusterInfo_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            ClusterSummary success

  - ### Class org.apache.storm.generated.Nimbus.getComponentPageInfo_args

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### component_id

            String component_id

      - ##### is_include_sys

            boolean is_include_sys

      - ##### topology_id

            String topology_id

      - ##### window

            String window

  - ### Class org.apache.storm.generated.Nimbus.getComponentPageInfo_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            ComponentPageInfo success

  - ### Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args

    class 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

      - ##### action

            ProfileAction action

      - ##### component_id

            String component_id

      - ##### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result

    class 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<ProfileRequest> success

  - ### Class org.apache.storm.generated.Nimbus.getLeader_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            NimbusSummary success

  - ### Class org.apache.storm.generated.Nimbus.getLogConfig_args

    class 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

    class 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

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            List<OwnerResourceSummary> success

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            SupervisorAssignments success

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### host

            String host

      - ##### id

            String id

      - ##### is_include_sys

            boolean is_include_sys

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            SupervisorPageInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopology_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            StormTopology success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyConf_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyHistory_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            TopologyHistoryInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfo_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### id

            String id

      - ##### is_include_sys

            boolean is_include_sys

      - ##### window

            String window

  - ### Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologyPageInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummaries_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### success

            List<TopologySummary> success

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummary_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologySummary success

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            TopologySummary success

  - ### Class org.apache.storm.generated.Nimbus.getUserTopology_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            StormTopology success

  - ### Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_args

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### aze

            AuthorizationException aze

      - ##### success

            boolean success

  - ### Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### aze

            AuthorizationException aze

      - ##### success

            boolean success

  - ### Class org.apache.storm.generated.Nimbus.killTopology_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.listBlobs_args

    class 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

    class 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

    class 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

    class 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

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_args

    class 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

    class 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

    class 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

    class 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

    class 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

    class 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

    class 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

      - ##### config

            LogConfig config

      - ##### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.setLogConfig_result

    class 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

    class 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

    class 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

    class 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

      - ##### jsonConf

            String jsonConf

      - ##### name

            String name

      - ##### topology

            StormTopology topology

      - ##### uploadedJarLocation

            String uploadedJarLocation

  - ### Class org.apache.storm.generated.Nimbus.submitTopology_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            AlreadyAliveException e

      - ##### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args

    class 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

      - ##### jsonConf

            String jsonConf

      - ##### name

            String name

      - ##### options

            SubmitOptions options

      - ##### topology

            StormTopology topology

      - ##### uploadedJarLocation

            String uploadedJarLocation

  - ### Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            AlreadyAliveException e

      - ##### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.updateBlobReplication_args

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### key

            String key

      - ##### replication

            int replication

  - ### Class org.apache.storm.generated.Nimbus.updateBlobReplication_result

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### aze

            AuthorizationException aze

      - ##### knf

            KeyNotFoundException knf

      - ##### success

            int success

  - ### Class org.apache.storm.generated.Nimbus.uploadBlobChunk_args

    class 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

      - ##### chunk

            ByteBuffer chunk

      - ##### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.uploadBlobChunk_result

    class 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

    class 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

      - ##### chunk

            ByteBuffer chunk

      - ##### location

            String location

  - ### Class org.apache.storm.generated.Nimbus.uploadChunk_result

    class 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

    class 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

      - ##### creds

            Credentials creds

      - ##### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.uploadNewCredentials_result

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.NimbusSummary

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### host

            String host

      - ##### isLeader

            boolean isLeader

      - ##### port

            int port

      - ##### tlsPort

            int tlsPort

      - ##### uptime_secs

            int uptime_secs

      - ##### version

            String version

  - ### Class org.apache.storm.generated.NodeInfo

    class 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<Long> port

  - ### Exception org.apache.storm.generated.NotAliveException

    class 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

    class 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

    class 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

      - ##### __isset_bitfield

            int __isset_bitfield

      - ##### assigned_off_heap_memory

            double assigned_off_heap_memory

      - ##### assigned_on_heap_memory

            double assigned_on_heap_memory

      - ##### cpu_guarantee

            double cpu_guarantee

      - ##### cpu_guarantee_remaining

            double cpu_guarantee_remaining

      - ##### cpu_usage

            double cpu_usage

      - ##### isolated_node_guarantee

            int isolated_node_guarantee

      - ##### memory_guarantee

            double memory_guarantee

      - ##### memory_guarantee_remaining

            double memory_guarantee_remaining

      - ##### memory_usage

            double memory_usage

      - ##### owner

            String owner

      - ##### requested_cpu

            double requested_cpu

      - ##### requested_off_heap_memory

            double requested_off_heap_memory

      - ##### requested_on_heap_memory

            double requested_on_heap_memory

      - ##### requested_total_memory

            double requested_total_memory

      - ##### total_executors

            int total_executors

      - ##### total_tasks

            int total_tasks

      - ##### total_topologies

            int total_topologies

      - ##### total_workers

            int total_workers

  - ### Class org.apache.storm.generated.PrivateWorkerKey

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### expirationTimeMillis

            long expirationTimeMillis

      - ##### key

            ByteBuffer key

      - ##### userName

            String userName

  - ### Class org.apache.storm.generated.ProfileRequest

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### action

            ProfileAction action

      - ##### nodeInfo

            NodeInfo nodeInfo

      - ##### time_stamp

            long time_stamp

  - ### Class org.apache.storm.generated.ReadableBlobMeta

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### settable

            SettableBlobMeta settable

      - ##### version

            long version

  - ### Class org.apache.storm.generated.RebalanceOptions

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### num_executors

            Map<String,Integer> num_executors

      - ##### num_workers

            int num_workers

      - ##### principal

            String principal

      - ##### topology_conf_overrides

            String topology_conf_overrides

      - ##### topology_resources_overrides

            Map<String,Map<String,Double>> topology_resources_overrides

      - ##### wait_secs

            int wait_secs

  - ### Class org.apache.storm.generated.SettableBlobMeta

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### acl

            List<AccessControl> acl

      - ##### replication_factor

            int replication_factor

  - ### Class org.apache.storm.generated.SharedMemory

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### name

            String name

      - ##### off_heap_node

            double off_heap_node

      - ##### off_heap_worker

            double off_heap_worker

      - ##### on_heap

            double on_heap

  - ### Class org.apache.storm.generated.ShellComponent

    class 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

    class 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

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### complete_latency_ms

            double complete_latency_ms

  - ### Class org.apache.storm.generated.SpoutSpec

    class 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

      - ##### common

            ComponentCommon common

      - ##### spout_object

            ComponentObject spout_object

  - ### Class org.apache.storm.generated.SpoutStats

    class 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<String,Map<String,Long>> acked

      - ##### complete_ms_avg

            Map<String,Map<String,Double>> complete_ms_avg

      - ##### failed

            Map<String,Map<String,Long>> failed

  - ### Class org.apache.storm.generated.StateSpoutSpec

    class 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

      - ##### common

            ComponentCommon common

      - ##### state_spout_object

            ComponentObject state_spout_object

  - ### Class org.apache.storm.generated.StormBase

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### component_debug

            Map<String,DebugOptions> component_debug

      - ##### component_executors

            Map<String,Integer> component_executors

      - ##### launch_time_secs

            int launch_time_secs

      - ##### name

            String name

      - ##### num_workers

            int num_workers

      - ##### owner

            String owner

      - ##### prev_status

            TopologyStatus prev_status

      - ##### principal

            String principal

      - ##### status

            TopologyStatus status

      - ##### topology_action_options

            TopologyActionOptions topology_action_options

      - ##### topology_version

            String topology_version

  - ### Class org.apache.storm.generated.StormTopology

    class 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

      - ##### bolts

            Map<String,Bolt> bolts

      - ##### component_to_shared_memory

            Map<String,Set<String>> component_to_shared_memory

      - ##### dependency_artifacts

            List<String> dependency_artifacts

      - ##### dependency_jars

            List<String> dependency_jars

      - ##### jdk_version

            String jdk_version

      - ##### shared_memory

            Map<String,SharedMemory> shared_memory

      - ##### spouts

            Map<String,SpoutSpec> spouts

      - ##### state_spouts

            Map<String,StateSpoutSpec> state_spouts

      - ##### storm_version

            String storm_version

      - ##### worker_hooks

            List<ByteBuffer> worker_hooks

  - ### Class org.apache.storm.generated.StreamInfo

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### direct

            boolean direct

      - ##### output_fields

            List<String> output_fields

  - ### Class org.apache.storm.generated.SubmitOptions

    class 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

      - ##### creds

            Credentials creds

      - ##### initial_status

            TopologyInitialStatus initial_status

  - ### Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_args

    class 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

    class 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

      - ##### aze

            AuthorizationException aze

      - ##### e

            NotAliveException e

      - ##### success

            Assignment success

  - ### Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args

    class 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

    class 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

    class 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

    class 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

    class 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<String,Assignment> storm_assignment

  - ### Class org.apache.storm.generated.SupervisorInfo

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### assignment_id

            String assignment_id

      - ##### hostname

            String hostname

      - ##### meta

            List<Long> meta

      - ##### resources_map

            Map<String,Double> resources_map

      - ##### scheduler_meta

            Map<String,String> scheduler_meta

      - ##### server_port

            int server_port

      - ##### time_secs

            long time_secs

      - ##### uptime_secs

            long uptime_secs

      - ##### used_ports

            List<Long> used_ports

      - ##### version

            String version

  - ### Class org.apache.storm.generated.SupervisorPageInfo

    class 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<SupervisorSummary> supervisor_summaries

      - ##### worker_summaries

            List<WorkerSummary> worker_summaries

  - ### Class org.apache.storm.generated.SupervisorSummary

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### blacklisted

            boolean blacklisted

      - ##### fragmented_cpu

            double fragmented_cpu

      - ##### fragmented_mem

            double fragmented_mem

      - ##### host

            String host

      - ##### num_used_workers

            int num_used_workers

      - ##### num_workers

            int num_workers

      - ##### supervisor_id

            String supervisor_id

      - ##### total_resources

            Map<String,Double> total_resources

      - ##### uptime_secs

            int uptime_secs

      - ##### used_cpu

            double used_cpu

      - ##### used_generic_resources

            Map<String,Double> used_generic_resources

      - ##### used_mem

            double used_mem

      - ##### version

            String version

  - ### Class org.apache.storm.generated.SupervisorWorkerHeartbeat

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### executors

            List<ExecutorInfo> executors

      - ##### storm_id

            String storm_id

      - ##### time_secs

            int time_secs

  - ### Class org.apache.storm.generated.SupervisorWorkerHeartbeats

    class 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<SupervisorWorkerHeartbeat> worker_heartbeats

  - ### Class org.apache.storm.generated.ThriftSerializedObject

    class 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

      - ##### bits

            ByteBuffer bits

      - ##### name

            String name

  - ### Class org.apache.storm.generated.TopologyActionOptions

    class 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

    class 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<String> topo_ids

  - ### Class org.apache.storm.generated.TopologyInfo

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### assigned_cpu

            double assigned_cpu

      - ##### assigned_memoffheap

            double assigned_memoffheap

      - ##### assigned_memonheap

            double assigned_memonheap

      - ##### component_debug

            Map<String,DebugOptions> component_debug

      - ##### errors

            Map<String,List<ErrorInfo>> errors

      - ##### executors

            List<ExecutorSummary> executors

      - ##### id

            String id

      - ##### name

            String name

      - ##### owner

            String owner

      - ##### replication_count

            int replication_count

      - ##### requested_cpu

            double requested_cpu

      - ##### requested_memoffheap

            double requested_memoffheap

      - ##### requested_memonheap

            double requested_memonheap

      - ##### sched_status

            String sched_status

      - ##### status

            String status

      - ##### storm_version

            String storm_version

      - ##### uptime_secs

            int uptime_secs

  - ### Class org.apache.storm.generated.TopologyPageInfo

    class 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

      - ##### __isset_bitfield

            int __isset_bitfield

      - ##### assigned_cpu

            double assigned_cpu

      - ##### assigned_generic_resources

            Map<String,Double> assigned_generic_resources

      - ##### assigned_memoffheap

            double assigned_memoffheap

      - ##### assigned_memonheap

            double assigned_memonheap

      - ##### assigned_regular_off_heap_memory

            double assigned_regular_off_heap_memory

      - ##### assigned_regular_on_heap_memory

            double assigned_regular_on_heap_memory

      - ##### assigned_shared_off_heap_memory

            double assigned_shared_off_heap_memory

      - ##### assigned_shared_on_heap_memory

            double assigned_shared_on_heap_memory

      - ##### debug_options

            DebugOptions debug_options

      - ##### id

            String id

      - ##### id_to_bolt_agg_stats

            Map<String,ComponentAggregateStats> id_to_bolt_agg_stats

      - ##### id_to_spout_agg_stats

            Map<String,ComponentAggregateStats> id_to_spout_agg_stats

      - ##### name

            String name

      - ##### num_executors

            int num_executors

      - ##### num_tasks

            int num_tasks

      - ##### num_workers

            int num_workers

      - ##### owner

            String owner

      - ##### replication_count

            int replication_count

      - ##### requested_cpu

            double requested_cpu

      - ##### requested_generic_resources

            Map<String,Double> requested_generic_resources

      - ##### requested_memoffheap

            double requested_memoffheap

      - ##### requested_memonheap

            double requested_memonheap

      - ##### requested_regular_off_heap_memory

            double requested_regular_off_heap_memory

      - ##### requested_regular_on_heap_memory

            double requested_regular_on_heap_memory

      - ##### requested_shared_off_heap_memory

            double requested_shared_off_heap_memory

      - ##### requested_shared_on_heap_memory

            double requested_shared_on_heap_memory

      - ##### sched_status

            String sched_status

      - ##### status

            String status

      - ##### storm_version

            String storm_version

      - ##### topology_conf

            String topology_conf

      - ##### topology_stats

            TopologyStats topology_stats

      - ##### topology_version

            String topology_version

      - ##### uptime_secs

            int uptime_secs

      - ##### workers

            List<WorkerSummary> workers

  - ### Class org.apache.storm.generated.TopologyStats

    class 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_acked

            Map<String,Long> window_to_acked

      - ##### window_to_complete_latencies_ms

            Map<String,Double> window_to_complete_latencies_ms

      - ##### window_to_emitted

            Map<String,Long> window_to_emitted

      - ##### window_to_failed

            Map<String,Long> window_to_failed

      - ##### window_to_transferred

            Map<String,Long> window_to_transferred

  - ### Class org.apache.storm.generated.TopologySummary

    class 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

      - ##### __isset_bitfield

            short __isset_bitfield

      - ##### assigned_cpu

            double assigned_cpu

      - ##### assigned_generic_resources

            Map<String,Double> assigned_generic_resources

      - ##### assigned_memoffheap

            double assigned_memoffheap

      - ##### assigned_memonheap

            double assigned_memonheap

      - ##### id

            String id

      - ##### name

            String name

      - ##### num_executors

            int num_executors

      - ##### num_tasks

            int num_tasks

      - ##### num_workers

            int num_workers

      - ##### owner

            String owner

      - ##### replication_count

            int replication_count

      - ##### requested_cpu

            double requested_cpu

      - ##### requested_generic_resources

            Map<String,Double> requested_generic_resources

      - ##### requested_memoffheap

            double requested_memoffheap

      - ##### requested_memonheap

            double requested_memonheap

      - ##### sched_status

            String sched_status

      - ##### status

            String status

      - ##### storm_version

            String storm_version

      - ##### topology_version

            String topology_version

      - ##### uptime_secs

            int uptime_secs

  - ### Class org.apache.storm.generated.WorkerMetricList

    class 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<WorkerMetricPoint> metrics

  - ### Class org.apache.storm.generated.WorkerMetricPoint

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### componentId

            String componentId

      - ##### executorId

            String executorId

      - ##### metricName

            String metricName

      - ##### metricValue

            double metricValue

      - ##### streamId

            String streamId

      - ##### timestamp

            long timestamp

  - ### Class org.apache.storm.generated.WorkerMetrics

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### hostname

            String hostname

      - ##### metricList

            WorkerMetricList metricList

      - ##### port

            int port

      - ##### topologyId

            String topologyId

  - ### Class org.apache.storm.generated.WorkerResources

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### cpu

            double cpu

      - ##### mem_off_heap

            double mem_off_heap

      - ##### mem_on_heap

            double mem_on_heap

      - ##### resources

            Map<String,Double> resources

      - ##### shared_mem_off_heap

            double shared_mem_off_heap

      - ##### shared_mem_on_heap

            double shared_mem_on_heap

      - ##### shared_resources

            Map<String,Double> shared_resources

  - ### Class org.apache.storm.generated.WorkerSummary

    class 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

      - ##### __isset_bitfield

            short __isset_bitfield

      - ##### assigned_cpu

            double assigned_cpu

      - ##### assigned_memoffheap

            double assigned_memoffheap

      - ##### assigned_memonheap

            double assigned_memonheap

      - ##### component_to_num_tasks

            Map<String,Long> component_to_num_tasks

      - ##### host

            String host

      - ##### num_executors

            int num_executors

      - ##### owner

            String owner

      - ##### port

            int port

      - ##### requested_cpu

            double requested_cpu

      - ##### requested_memoffheap

            double requested_memoffheap

      - ##### requested_memonheap

            double requested_memonheap

      - ##### supervisor_id

            String supervisor_id

      - ##### time_secs

            int time_secs

      - ##### topology_id

            String topology_id

      - ##### topology_name

            String topology_name

      - ##### uptime_secs

            int uptime_secs

  - ### Class org.apache.storm.generated.WorkerToken

    class 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

      - ##### info

            ByteBuffer info

      - ##### serviceType

            WorkerTokenServiceType serviceType

      - ##### signature

            ByteBuffer signature

  - ### Class org.apache.storm.generated.WorkerTokenInfo

    class 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

      - ##### __isset_bitfield

            byte __isset_bitfield

      - ##### expirationTimeMillis

            long expirationTimeMillis

      - ##### secretVersion

            long secretVersion

      - ##### topologyId

            String topologyId

      - ##### userName

            String userName

- ## Package org.apache.storm.grouping

  - ### Class org.apache.storm.grouping.LoadAwareShuffleGrouping

    class LoadAwareShuffleGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### capacity

            int capacity

      - ##### choices

            int[] choices

      - ##### conf

            Map<String,Object> conf

      - ##### current

            AtomicInteger current

      - ##### currentScope

            org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope currentScope

      - ##### dnsToSwitchMapping

            DNSToSwitchMapping dnsToSwitchMapping

      - ##### higherBound

            double higherBound

      - ##### localityGroup

            Map<org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope,List<Integer>> localityGroup

      - ##### lowerBound

            double lowerBound

      - ##### nodeToHost

            AtomicReference<Map<String,String>> nodeToHost

      - ##### orig

            Map<Integer,org.apache.storm.grouping.LoadAwareShuffleGrouping.IndexAndWeights> orig

      - ##### prepareChoices

            int[] prepareChoices

      - ##### random

            Random random

      - ##### rets

            List<Integer>[] rets

      - ##### sourceNodeInfo

            NodeInfo sourceNodeInfo

      - ##### targetTasks

            List<Integer> targetTasks

      - ##### taskToNodePort

            AtomicReference<Map<Integer,NodeInfo>> taskToNodePort

  - ### Class org.apache.storm.grouping.PartialKeyGrouping

    class PartialKeyGrouping extends Object implements Serializable
    serialVersionUID:
      -1672360572274911808L

    - #### Serialized Fields

      - ##### assignmentCreator

            PartialKeyGrouping.AssignmentCreator assignmentCreator

      - ##### fields

            Fields fields

      - ##### outFields

            Fields outFields

      - ##### targetSelector

            PartialKeyGrouping.TargetSelector targetSelector

      - ##### targetTasks

            List<Integer> targetTasks

  - ### Class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelector

    class BalancedTargetSelector extends Object implements Serializable

    - #### Serialized Fields

      - ##### targetTaskStats

            Map<Integer,Long> targetTaskStats

  - ### Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator

    class RandomTwoTaskAssignmentCreator extends Object implements Serializable

  - ### Class org.apache.storm.grouping.ShuffleGrouping

    class ShuffleGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### choices

            ArrayList<List<Integer>> choices

      - ##### current

            AtomicInteger current

- ## Package org.apache.storm.hdfs.avro

  - ### Class org.apache.storm.hdfs.avro.AbstractAvroSerializer

    class AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable

  - ### Class org.apache.storm.hdfs.avro.FixedAvroSerializer

    class FixedAvroSerializer extends AbstractAvroSerializer implements Serializable

    - #### Serialized Fields

      - ##### fingerprint2schemaMap

            Map<String,org.apache.avro.Schema> fingerprint2schemaMap

      - ##### schema2fingerprintMap

            Map<org.apache.avro.Schema,String> schema2fingerprintMap

  - ### Class org.apache.storm.hdfs.avro.GenericAvroSerializer

    class GenericAvroSerializer extends AbstractAvroSerializer implements Serializable

- ## Package org.apache.storm.hdfs.bolt

  - ### Class org.apache.storm.hdfs.bolt.AbstractHdfsBolt

    class AbstractHdfsBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### configKey

            String configKey

      - ##### fileNameFormat

            FileNameFormat fileNameFormat

      - ##### fileRetryCount

            Integer fileRetryCount

      - ##### fsUrl

            String fsUrl

      - ##### maxOpenFiles

            Integer maxOpenFiles

      - ##### offset

            long offset

      - ##### partitioner

            Partitioner partitioner

      - ##### rotationActions

            List<RotationAction> rotationActions

      - ##### rotationCounterMap

            Map<String,Integer> rotationCounterMap

      - ##### rotationPolicy

            FileRotationPolicy rotationPolicy

      - ##### syncPolicy

            SyncPolicy syncPolicy

      - ##### tickTupleInterval

            Integer tickTupleInterval

      - ##### tupleBatch

            List<Tuple> tupleBatch

      - ##### writers

            Map<String,Writer> writers

  - ### Class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt

    class AvroGenericRecordBolt extends AbstractHdfsBolt implements Serializable

  - ### Class org.apache.storm.hdfs.bolt.HdfsBolt

    class HdfsBolt extends AbstractHdfsBolt implements Serializable

    - #### Serialized Fields

      - ##### format

            RecordFormat format

  - ### Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt

    class MyBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### counts

            HashMap<String,Long> counts

  - ### Class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpout

    class SentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            int count

      - ##### index

            int index

      - ##### pending

            ConcurrentHashMap<UUID,Values> pending

      - ##### sentences

            String[] sentences

      - ##### total

            long total

  - ### Class org.apache.storm.hdfs.bolt.SequenceFileBolt

    class SequenceFileBolt extends AbstractHdfsBolt implements Serializable

    - #### Serialized Fields

      - ##### compressionCodec

            String compressionCodec

      - ##### compressionType

            org.apache.hadoop.io.SequenceFile.CompressionType compressionType

      - ##### format

            SequenceFormat format

  - ### Class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt

    class MyBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### counts

            HashMap<String,Long> counts

  - ### Class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpout

    class SentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            int count

      - ##### index

            int index

      - ##### pending

            ConcurrentHashMap<UUID,Values> pending

      - ##### sentences

            String[] sentences

      - ##### total

            long total

- ## Package org.apache.storm.hdfs.bolt.format

  - ### Class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat

    class DefaultFileNameFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### componentId

            String componentId

      - ##### extension

            String extension

      - ##### path

            String path

      - ##### prefix

            String prefix

      - ##### taskId

            int taskId

  - ### Class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat

    class DefaultSequenceFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### keyField

            String keyField

      - ##### valueField

            String valueField

  - ### Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat

    class DelimitedRecordFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldDelimiter

            String fieldDelimiter

      - ##### fields

            Fields fields

      - ##### recordDelimiter

            String recordDelimiter

  - ### Class org.apache.storm.hdfs.bolt.format.SimpleFileNameFormat

    class SimpleFileNameFormat extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### componentId

            String componentId

      - ##### host

            String host

      - ##### name

            String name

      - ##### path

            String path

      - ##### taskId

            int taskId

      - ##### timeFormat

            String timeFormat

- ## Package org.apache.storm.hdfs.bolt.rotation

  - ### Class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy

    class FileSizeRotationPolicy extends Object implements Serializable

    - #### Serialized Fields

      - ##### currentBytesWritten

            long currentBytesWritten

      - ##### lastOffset

            long lastOffset

      - ##### maxBytes

            long maxBytes

  - ### Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy

    class NoRotationPolicy extends Object implements Serializable

  - ### Class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy

    class 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

    class 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

    class NullPartitioner extends Object implements Serializable

- ## Package org.apache.storm.hdfs.common.rotation

  - ### Class org.apache.storm.hdfs.common.rotation.MoveFileAction

    class MoveFileAction extends Object implements Serializable

    - #### Serialized Fields

      - ##### destination

            String destination

- ## Package org.apache.storm.hdfs.spout

  - ### Class org.apache.storm.hdfs.spout.HdfsSpout

    class HdfsSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### ackEnabled

            boolean ackEnabled

      - ##### acksSinceLastCommit

            int acksSinceLastCommit

      - ##### archiveDir

            String archiveDir

      - ##### archiveDirPath

            org.apache.hadoop.fs.Path archiveDirPath

      - ##### badFilesDir

            String badFilesDir

      - ##### badFilesDirPath

            org.apache.hadoop.fs.Path badFilesDirPath

      - ##### clocksInSync

            boolean clocksInSync

      - ##### collector

            SpoutOutputCollector collector

      - ##### commitFrequencyCount

            int commitFrequencyCount

      - ##### commitFrequencySec

            int commitFrequencySec

      - ##### commitTimeElapsed

            AtomicBoolean commitTimeElapsed

      - ##### commitTimer

            Timer commitTimer

      - ##### conf

            Map<String,Object> conf

      - ##### configKey

            String configKey

      - ##### fileReadCompletely

            boolean fileReadCompletely

      - ##### hdfs

            org.apache.hadoop.fs.FileSystem hdfs

      - ##### hdfsConfig

            org.apache.hadoop.conf.Configuration hdfsConfig

      - ##### hdfsUri

            String hdfsUri

      - ##### ignoreSuffix

            String ignoreSuffix

      - ##### inflight

            HashMap<org.apache.storm.hdfs.spout.HdfsSpout.MessageId,List<Object>> inflight

      - ##### inprogressSuffix

            String inprogressSuffix

      - ##### lastExpiredLock

            HdfsUtils.Pair<org.apache.hadoop.fs.Path,FileLock.LogEntry> lastExpiredLock

      - ##### lastExpiredLockTime

            long lastExpiredLockTime

      - ##### lock

            FileLock lock

      - ##### lockDir

            String lockDir

      - ##### lockDirPath

            org.apache.hadoop.fs.Path lockDirPath

      - ##### lockTimeoutSec

            int lockTimeoutSec

      - ##### maxOutstanding

            int maxOutstanding

      - ##### outputFields

            Fields outputFields

      - ##### outputStreamName

            String outputStreamName

      - ##### reader

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

      - ##### readerType

            String readerType

      - ##### retryList

            LinkedBlockingQueue<HdfsUtils.Pair<org.apache.storm.hdfs.spout.HdfsSpout.MessageId,List<Object>>> retryList

      - ##### sourceDir

            String sourceDir

      - ##### sourceDirPath

            org.apache.hadoop.fs.Path sourceDirPath

      - ##### spoutId

            String spoutId

      - ##### tracker

            ProgressTracker tracker

      - ##### tupleCounter

            long tupleCounter

  - ### Class org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBolt

    class ConstBolt extends BaseRichBolt implements Serializable
    serialVersionUID:
      -5313598399155365865L

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### count

            int count

  - ### Exception org.apache.storm.hdfs.spout.ParseException

    class ParseException extends Exception implements Serializable

- ## Package org.apache.storm.hdfs.trident

  - ### Class org.apache.storm.hdfs.trident.FixedBatchSpout

    class FixedBatchSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### batches

            HashMap<Long,List<List<Object>>> batches

      - ##### cycle

            boolean cycle

      - ##### fields

            Fields fields

      - ##### index

            int index

      - ##### maxBatchSize

            int maxBatchSize

      - ##### outputs

            List<Object>[] outputs

  - ### Class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions

    class HdfsFileOptions extends HdfsState.Options implements Serializable

    - #### Serialized Fields

      - ##### bufferSize

            int bufferSize

      - ##### format

            RecordFormat format

      - ##### offset

            long offset

  - ### Class org.apache.storm.hdfs.trident.HdfsState.Options

    class Options extends Object implements Serializable

    - #### Serialized Fields

      - ##### configKey

            String configKey

      - ##### currentFile

            org.apache.hadoop.fs.Path currentFile

      - ##### fileNameFormat

            FileNameFormat fileNameFormat

      - ##### fsUrl

            String fsUrl

      - ##### rotation

            int rotation

      - ##### rotationActions

            ArrayList<RotationAction> rotationActions

      - ##### rotationPolicy

            FileRotationPolicy rotationPolicy

  - ### Class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions

    class SequenceFileOptions extends HdfsState.Options implements Serializable

    - #### Serialized Fields

      - ##### compressionCodec

            String compressionCodec

      - ##### compressionType

            org.apache.hadoop.io.SequenceFile.CompressionType compressionType

      - ##### format

            SequenceFormat format

  - ### Class org.apache.storm.hdfs.trident.HdfsStateFactory

    class HdfsStateFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### options

            HdfsState.Options options

  - ### Class org.apache.storm.hdfs.trident.HdfsUpdater

    class HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable

- ## Package org.apache.storm.hdfs.trident.format

  - ### Class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat

    class DefaultFileNameFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### extension

            String extension

      - ##### partitionIndex

            int partitionIndex

      - ##### path

            String path

      - ##### prefix

            String prefix

  - ### Class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat

    class DefaultSequenceFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### keyField

            String keyField

      - ##### valueField

            String valueField

  - ### Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat

    class DelimitedRecordFormat extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldDelimiter

            String fieldDelimiter

      - ##### fields

            Fields fields

      - ##### recordDelimiter

            String recordDelimiter

  - ### Class org.apache.storm.hdfs.trident.format.SimpleFileNameFormat

    class SimpleFileNameFormat extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### host

            String host

      - ##### name

            String name

      - ##### partitionIndex

            int partitionIndex

      - ##### path

            String path

      - ##### timeFormat

            String timeFormat

- ## Package org.apache.storm.hdfs.trident.rotation

  - ### Class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy

    class FileSizeRotationPolicy extends Object implements Serializable

    - #### Serialized Fields

      - ##### currentBytesWritten

            long currentBytesWritten

      - ##### lastOffset

            long lastOffset

      - ##### maxBytes

            long maxBytes

  - ### Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy

    class NoRotationPolicy extends Object implements Serializable

  - ### Class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy

    class 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

    class CountSyncPolicy extends Object implements Serializable

    - #### Serialized Fields

      - ##### count

            int count

      - ##### executeCount

            int executeCount

- ## Package org.apache.storm.hooks

  - ### Class org.apache.storm.hooks.BaseWorkerHook

    class BaseWorkerHook extends Object implements Serializable
    serialVersionUID:
      2589466485198339529L

  - ### Exception org.apache.storm.hooks.SubmitterHookException

    class SubmitterHookException extends RuntimeException implements Serializable

- ## Package org.apache.storm.jdbc.bolt

  - ### Class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

    class AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### configKey

            String configKey

      - ##### connectionProvider

            ConnectionProvider connectionProvider

      - ##### queryTimeoutSecs

            Integer queryTimeoutSecs

  - ### Class org.apache.storm.jdbc.bolt.JdbcInsertBolt

    class JdbcInsertBolt extends AbstractJdbcBolt implements Serializable

    - #### Serialized Fields

      - ##### insertQuery

            String insertQuery

      - ##### jdbcMapper

            JdbcMapper jdbcMapper

      - ##### tableName

            String tableName

  - ### Class org.apache.storm.jdbc.bolt.JdbcLookupBolt

    class JdbcLookupBolt extends AbstractJdbcBolt implements Serializable

    - #### Serialized Fields

      - ##### jdbcLookupMapper

            JdbcLookupMapper jdbcLookupMapper

      - ##### selectQuery

            String selectQuery

- ## Package org.apache.storm.jdbc.common

  - ### Class org.apache.storm.jdbc.common.Column

    class Column extends Object implements Serializable

    - #### Serialized Fields

      - ##### columnName

            String columnName

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

      - ##### val

            T val

  - ### Class org.apache.storm.jdbc.common.HikariCPConnectionProvider

    class HikariCPConnectionProvider extends Object implements Serializable

    - #### Serialized Fields

      - ##### configMap

            Map<String,Object> configMap

- ## Package org.apache.storm.jdbc.mapper

  - ### Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper

    class SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable

    - #### Serialized Fields

      - ##### outputFields

            Fields outputFields

  - ### Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper

    class SimpleJdbcMapper extends Object implements Serializable

    - #### Serialized Fields

      - ##### schemaColumns

            List<Column> schemaColumns

- ## Package org.apache.storm.jdbc.spout

  - ### Class org.apache.storm.jdbc.spout.UserSpout

    class UserSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### isDistributed

            boolean isDistributed

- ## Package org.apache.storm.jdbc.trident.state

  - ### Class org.apache.storm.jdbc.trident.state.JdbcQuery

    class JdbcQuery extends BaseQueryFunction<JdbcState,List<Values>> implements Serializable

  - ### Class org.apache.storm.jdbc.trident.state.JdbcState.Options

    class Options extends Object implements Serializable

    - #### Serialized Fields

      - ##### connectionProvider

            ConnectionProvider connectionProvider

      - ##### insertQuery

            String insertQuery

      - ##### jdbcLookupMapper

            JdbcLookupMapper jdbcLookupMapper

      - ##### mapper

            JdbcMapper mapper

      - ##### queryTimeoutSecs

            Integer queryTimeoutSecs

      - ##### selectQuery

            String selectQuery

      - ##### tableName

            String tableName

  - ### Class org.apache.storm.jdbc.trident.state.JdbcStateFactory

    class JdbcStateFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### options

            JdbcState.Options options

  - ### Class org.apache.storm.jdbc.trident.state.JdbcUpdater

    class JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable

- ## Package org.apache.storm.jms

- ## Package org.apache.storm.jms.bolt

  - ### Class org.apache.storm.jms.bolt.JmsBolt

    class JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - #### Serialized Fields

      - ##### autoAck

            boolean autoAck

      - ##### collector

            OutputCollector collector

      - ##### connection

            javax.jms.Connection connection

      - ##### jmsAcknowledgeMode

            int jmsAcknowledgeMode

      - ##### jmsProvider

            JmsProvider jmsProvider

      - ##### jmsTransactional

            boolean jmsTransactional

      - ##### messageProducer

            javax.jms.MessageProducer messageProducer

      - ##### producer

            JmsMessageProducer producer

      - ##### session

            javax.jms.Session session

- ## Package org.apache.storm.jms.example

  - ### Class org.apache.storm.jms.example.GenericBolt

    class GenericBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### autoAck

            boolean autoAck

      - ##### autoAnchor

            boolean autoAnchor

      - ##### collector

            OutputCollector collector

      - ##### declaredFields

            Fields declaredFields

      - ##### name

            String name

  - ### Class org.apache.storm.jms.example.JsonTupleProducer

    class JsonTupleProducer extends Object implements Serializable

  - ### Class org.apache.storm.jms.example.SpringJmsProvider

    class 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

    class JmsMessageID extends Object implements Serializable

    - #### Serialized Fields

      - ##### jmsId

            String jmsId

      - ##### sequence

            Long sequence

  - ### Class org.apache.storm.jms.spout.JmsSpout

    class JmsSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

        The collector used to emit tuples.

      - ##### consumer

            javax.jms.MessageConsumer consumer

        The message consumer.

      - ##### distributed

            boolean distributed

        Indicates whether or not this spout should run as a singleton.

      - ##### individualAcks

            boolean individualAcks

        If JMS provider supports ack-ing individual messages.

      - ##### jmsAcknowledgeMode

            int jmsAcknowledgeMode

        The acknowledgment mode used for this instance.
        See Also:
          - `Session`

      - ##### jmsProvider

            JmsProvider jmsProvider

        Encapsulates jms related classes needed to communicate with the mq.

      - ##### messageHandler

            org.apache.storm.jms.spout.JmsSpout.MessageHandler messageHandler

        Sets up the way we want to handle the emit, ack and fails.

      - ##### messageSequence

            long messageSequence

        Counter of handled messages.

      - ##### tupleProducer

            JmsTupleProducer tupleProducer

        Used to generate tuples from incoming messages.

- ## Package org.apache.storm.jms.trident

  - ### Class org.apache.storm.jms.trident.JmsState.Options

    class Options extends Object implements Serializable

    - #### Serialized Fields

      - ##### jmsAcknowledgeMode

            int jmsAcknowledgeMode

      - ##### jmsProvider

            JmsProvider jmsProvider

      - ##### jmsTransactional

            boolean jmsTransactional

      - ##### msgProducer

            JmsMessageProducer msgProducer

  - ### Class org.apache.storm.jms.trident.JmsStateFactory

    class JmsStateFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### options

            JmsState.Options options

  - ### Class org.apache.storm.jms.trident.JmsUpdater

    class JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable

  - ### Class org.apache.storm.jms.trident.TridentJmsSpout

    class TridentJmsSpout extends Object implements Serializable
    serialVersionUID:
      -3469351154693356655L

    - #### Serialized Fields

      - ##### jmsAcknowledgeMode

            int jmsAcknowledgeMode

      - ##### jmsProvider

            JmsProvider jmsProvider

      - ##### name

            String name

      - ##### tupleProducer

            JmsTupleProducer tupleProducer

- ## Package org.apache.storm.kafka.bolt

  - ### Class org.apache.storm.kafka.bolt.KafkaBolt

    class KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable
    serialVersionUID:
      -5205886631877033478L

    - #### Serialized Fields

      - ##### async

            boolean async

        `KafkaBolt.setAsync(boolean)` for more details on this.

      - ##### boltSpecifiedProperties

            Properties boltSpecifiedProperties

      - ##### collector

            OutputCollector collector

      - ##### fireAndForget

            boolean fireAndForget

        `KafkaBolt.setFireAndForget(boolean)` for more details on this.

      - ##### mapper

            TupleToKafkaMapper<K,V> mapper

      - ##### producer

            org.apache.kafka.clients.producer.Producer<K,V> producer

      - ##### providedCallback

            PreparableCallback providedCallback

      - ##### topicSelector

            KafkaTopicSelector topicSelector

- ## Package org.apache.storm.kafka.bolt.mapper

  - ### Class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

    class 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

    class DefaultTopicSelector extends Object implements Serializable
    serialVersionUID:
      4601118062437851265L

    - #### Serialized Fields

      - ##### topicName

            String topicName

  - ### Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector

    class FieldIndexTopicSelector extends Object implements Serializable
    serialVersionUID:
      -3830575380208166367L

    - #### Serialized Fields

      - ##### defaultTopicName

            String defaultTopicName

      - ##### fieldIndex

            int fieldIndex

  - ### Class org.apache.storm.kafka.bolt.selector.FieldNameTopicSelector

    class FieldNameTopicSelector extends Object implements Serializable
    serialVersionUID:
      -3903708904533396833L

    - #### Serialized Fields

      - ##### defaultTopicName

            String defaultTopicName

      - ##### fieldName

            String fieldName

- ## Package org.apache.storm.kafka.spout

  - ### Class org.apache.storm.kafka.spout.ByTopicRecordTranslator

    class ByTopicRecordTranslator extends Object implements Serializable
    serialVersionUID:
      -121699733778988688L

    - #### Serialized Fields

      - ##### defaultTranslator

            RecordTranslator<K,V> defaultTranslator

      - ##### streamToFields

            Map<String,Fields> streamToFields

      - ##### topicToTranslator

            Map<String,RecordTranslator<K,V>> topicToTranslator

  - ### Class org.apache.storm.kafka.spout.DefaultRecordTranslator

    class DefaultRecordTranslator extends Object implements Serializable
    serialVersionUID:
      -5782462870112305750L

  - ### Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener

    class EmptyKafkaTupleListener extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.KafkaSpout

    class KafkaSpout extends BaseRichSpout implements Serializable
    serialVersionUID:
      4151921085047987154L

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### kafkaClientFactory

            ClientFactory<K,V> kafkaClientFactory

      - ##### kafkaSpoutConfig

            KafkaSpoutConfig<K,V> kafkaSpoutConfig

      - ##### topicAssigner

            TopicAssigner topicAssigner

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutConfig

    class KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
    serialVersionUID:
      141902646130682494L

    - #### Serialized Fields

      - ##### emitNullTuples

            boolean emitNullTuples

      - ##### maxUncommittedOffsets

            int maxUncommittedOffsets

      - ##### metricsTimeBucketSizeInSecs

            int metricsTimeBucketSizeInSecs

      - ##### offsetCommitPeriodMs

            long offsetCommitPeriodMs

      - ##### processingGuarantee

            KafkaSpoutConfig.ProcessingGuarantee processingGuarantee

      - ##### retryService

            KafkaSpoutRetryService retryService

      - ##### tupleListener

            KafkaTupleListener tupleListener

      - ##### tupleTrackingEnforced

            boolean tupleTrackingEnforced

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutMessageId

    class KafkaSpoutMessageId extends Object implements Serializable

    - #### Serialized Fields

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

      - ##### numFails

            int numFails

      - ##### offset

            long offset

      - ##### topicPart

            org.apache.kafka.common.TopicPartition topicPart

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff

    class KafkaSpoutRetryExponentialBackoff extends Object implements Serializable

    - #### Serialized Fields

      - ##### delayPeriod

            KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod

      - ##### initialDelay

            KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay

      - ##### maxDelay

            KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay

      - ##### maxRetries

            int maxRetries

      - ##### retrySchedules

            Set<org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.RetrySchedule> retrySchedules

      - ##### toRetryMsgs

            Set<KafkaSpoutMessageId> toRetryMsgs

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval

    class TimeInterval extends Object implements Serializable

    - #### Serialized Fields

      - ##### length

            long length

      - ##### lengthNanos

            long lengthNanos

      - ##### timeUnit

            TimeUnit timeUnit

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt

    class KafkaSpoutTestBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.kafka.spout.KafkaTuple

    class KafkaTuple extends Values implements Serializable
    serialVersionUID:
      4803794470450587992L

    - #### Serialized Fields

      - ##### stream

            String stream

  - ### Class org.apache.storm.kafka.spout.SimpleRecordTranslator

    class SimpleRecordTranslator extends Object implements Serializable
    serialVersionUID:
      4678369144122009596L

    - #### Serialized Fields

      - ##### fields

            Fields fields

      - ##### func

            Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func

      - ##### stream

            String stream

- ## Package org.apache.storm.kafka.spout.internal

  - ### Class org.apache.storm.kafka.spout.internal.ClientFactoryDefault

    class ClientFactoryDefault extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig

    class CommonKafkaSpoutConfig extends Object implements Serializable

    - #### Serialized Fields

      - ##### firstPollOffsetStrategy

            FirstPollOffsetStrategy firstPollOffsetStrategy

      - ##### kafkaProps

            Map<String,Object> kafkaProps

      - ##### partitionRefreshPeriodMs

            long partitionRefreshPeriodMs

      - ##### pollTimeoutMs

            long pollTimeoutMs

      - ##### startTimeStamp

            long startTimeStamp

      - ##### topicFilter

            TopicFilter topicFilter

      - ##### topicPartitioner

            ManualPartitioner topicPartitioner

      - ##### translator

            RecordTranslator<K,V> translator

- ## Package org.apache.storm.kafka.spout.subscription

  - ### Class org.apache.storm.kafka.spout.subscription.NamedTopicFilter

    class NamedTopicFilter extends Object implements Serializable

    - #### Serialized Fields

      - ##### topics

            Set<String> topics

  - ### Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter

    class PatternTopicFilter extends Object implements Serializable

    - #### Serialized Fields

      - ##### pattern

            Pattern pattern

      - ##### topics

            Set<String> topics

  - ### Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner

    class RoundRobinManualPartitioner extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.subscription.TopicAssigner

    class TopicAssigner extends Object implements Serializable
    serialVersionUID:
      5423018073527583826L

- ## Package org.apache.storm.kafka.spout.trident

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter

    class KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### emitter

            KafkaTridentSpoutEmitter<K,V> emitter

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata

    class KafkaTridentSpoutBatchMetadata extends Object implements Serializable

    - #### Serialized Fields

      - ##### firstOffset

            long firstOffset

      - ##### lastOffset

            long lastOffset

      - ##### topologyId

            String topologyId

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig

    class KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
    serialVersionUID:
      1L

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator

    class KafkaTridentSpoutCoordinator extends Object implements Serializable

    - #### Serialized Fields

      - ##### consumer

            org.apache.kafka.clients.consumer.Consumer<K,V> consumer

      - ##### kafkaSpoutConfig

            KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

      - ##### partitionsForBatch

            Set<org.apache.kafka.common.TopicPartition> partitionsForBatch

      - ##### refreshAssignmentTimer

            Timer refreshAssignmentTimer

      - ##### tpSerializer

            TopicPartitionSerializer tpSerializer

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter

    class KafkaTridentSpoutEmitter extends Object implements Serializable
    serialVersionUID:
      -7343927794834130435L

    - #### Serialized Fields

      - ##### consumer

            org.apache.kafka.clients.consumer.Consumer<K,V> consumer

      - ##### firstPollOffsetStrategy

            FirstPollOffsetStrategy firstPollOffsetStrategy

      - ##### kafkaSpoutConfig

            KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

      - ##### pollTimeoutMs

            long pollTimeoutMs

      - ##### startTimeStamp

            long startTimeStamp

      - ##### topicAssigner

            TopicAssigner topicAssigner

      - ##### topologyContext

            TopologyContext topologyContext

      - ##### tpSerializer

            TopicPartitionSerializer tpSerializer

      - ##### tpToFirstSeekOffset

            Map<org.apache.kafka.common.TopicPartition,Long> tpToFirstSeekOffset

      - ##### translator

            RecordTranslator<K,V> translator

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaque

    class 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

    class KafkaTridentSpoutTopicPartition extends Object implements Serializable

    - #### Serialized Fields

      - ##### topicPartition

            org.apache.kafka.common.TopicPartition topicPartition

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional

    class 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

    class 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

    class OutputFieldsExtractor extends Object implements Serializable
    serialVersionUID:
      1L

- ## Package org.apache.storm.kafka.trident

  - ### Class org.apache.storm.kafka.trident.TridentKafkaStateFactory

    class TridentKafkaStateFactory extends Object implements Serializable
    serialVersionUID:
      -3613240970062343385L

    - #### Serialized Fields

      - ##### mapper

            TridentTupleToKafkaMapper<K,V> mapper

      - ##### producerProperties

            Properties producerProperties

      - ##### topicSelector

            KafkaTopicSelector topicSelector

  - ### Class org.apache.storm.kafka.trident.TridentKafkaStateUpdater

    class 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

    class 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

    class DefaultTopicSelector extends Object implements Serializable
    serialVersionUID:
      -1172454882072591493L

    - #### Serialized Fields

      - ##### topicName

            String topicName

- ## Package org.apache.storm.lambda

  - ### Class org.apache.storm.lambda.LambdaBiConsumerBolt

    class LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### biConsumer

            SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer

      - ##### fields

            String[] fields

  - ### Class org.apache.storm.lambda.LambdaConsumerBolt

    class LambdaConsumerBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### consumer

            SerializableConsumer<Tuple> consumer

  - ### Class org.apache.storm.lambda.LambdaSpout

    class LambdaSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### supplier

            SerializableSupplier<?> supplier

- ## Package org.apache.storm.loadgen

  - ### Class org.apache.storm.loadgen.ExecAndProcessLatencyEngine

    class ExecAndProcessLatencyEngine extends Object implements Serializable

    - #### Serialized Fields

      - ##### parkOffset

            AtomicLong parkOffset

      - ##### rand

            Random rand

      - ##### skewedPattern

            SlowExecutorPattern skewedPattern

      - ##### timer

            ScheduledExecutorService timer

  - ### Class org.apache.storm.loadgen.InputStream

    class InputStream extends Object implements Serializable

    - #### Serialized Fields

      - ##### execTime

            NormalDistStats execTime

      - ##### fromComponent

            String fromComponent

      - ##### groupingType

            GroupingType groupingType

      - ##### gsid

            GlobalStreamId gsid

      - ##### id

            String id

      - ##### processTime

            NormalDistStats processTime

      - ##### toComponent

            String toComponent

  - ### Class org.apache.storm.loadgen.LoadBolt

    class LoadBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### executorIndex

            int executorIndex

      - ##### inputStreams

            Map<GlobalStreamId,InputStream> inputStreams

      - ##### outputStreams

            List<OutputStreamEngine> outputStreams

      - ##### outputStreamStats

            List<OutputStream> outputStreamStats

      - ##### sleep

            ExecAndProcessLatencyEngine sleep

  - ### Class org.apache.storm.loadgen.LoadSpout

    class LoadSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### nextStreamCounter

            long nextStreamCounter

      - ##### numStreams

            int numStreams

      - ##### replays

            Queue<org.apache.storm.loadgen.LoadSpout.SentWithTime> replays

      - ##### streams

            List<org.apache.storm.loadgen.LoadSpout.OutputStreamEngineWithHisto> streams

      - ##### streamStats

            List<OutputStream> streamStats

  - ### Class org.apache.storm.loadgen.NormalDistStats

    class NormalDistStats extends Object implements Serializable

    - #### Serialized Fields

      - ##### max

            double max

      - ##### mean

            double mean

      - ##### min

            double min

      - ##### stddev

            double stddev

  - ### Class org.apache.storm.loadgen.OutputStream

    class OutputStream extends Object implements Serializable

    - #### Serialized Fields

      - ##### areKeysSkewed

            boolean areKeysSkewed

      - ##### id

            String id

      - ##### rate

            NormalDistStats rate

  - ### Class org.apache.storm.loadgen.ScopedTopologySet

    class ScopedTopologySet extends HashSet<String> implements Serializable

    - #### Serialized Fields

      - ##### client

            Nimbus.Iface client

      - ##### closed

            boolean closed

  - ### Class org.apache.storm.loadgen.SlowExecutorPattern

    class SlowExecutorPattern extends Object implements Serializable

    - #### Serialized Fields

      - ##### count

            int count

      - ##### maxSlownessMs

            double maxSlownessMs

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout

    class FastRandomSentenceSpout extends LoadSpout implements Serializable

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence

    class SplitSentence extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### executorIndex

            int executorIndex

      - ##### sleep

            ExecAndProcessLatencyEngine sleep

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount

    class WordCount extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

- ## Package org.apache.storm.metric

  - ### Class org.apache.storm.metric.EventLoggerBolt

    class EventLoggerBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### eventLoggers

            List<IEventLogger> eventLoggers

  - ### Class org.apache.storm.metric.MetricsConsumerBolt

    class MetricsConsumerBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### consumerClassName

            String consumerClassName

      - ##### expander

            DataPointExpander expander

      - ##### filterPredicate

            org.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate

      - ##### maxRetainMetricTuples

            int maxRetainMetricTuples

      - ##### metricsConsumer

            IMetricsConsumer metricsConsumer

      - ##### registrationArgument

            Object registrationArgument

      - ##### running

            boolean running

      - ##### taskExecuteThread

            Thread taskExecuteThread

      - ##### taskQueue

            BlockingQueue<org.apache.storm.metric.MetricsConsumerBolt.MetricsTask> taskQueue

  - ### Class org.apache.storm.metric.SystemBolt

    class SystemBolt extends Object implements Serializable

- ## Package org.apache.storm.metric.filter

  - ### Class org.apache.storm.metric.filter.FilterByMetricName

    class FilterByMetricName extends Object implements Serializable

    - #### Serialized Fields

      - ##### blacklistPattern

            List<Pattern> blacklistPattern

      - ##### filterCache

            org.apache.storm.shade.com.google.common.cache.Cache<String,Boolean> filterCache

      - ##### noneSpecified

            boolean noneSpecified

      - ##### whitelistPattern

            List<Pattern> whitelistPattern

- ## Package org.apache.storm.metric.util

  - ### Class org.apache.storm.metric.util.DataPointExpander

    class DataPointExpander extends Object implements Serializable

    - #### Serialized Fields

      - ##### expandMapType

            boolean expandMapType

      - ##### metricNameSeparator

            String metricNameSeparator

- ## Package org.apache.storm.metricstore

  - ### Exception org.apache.storm.metricstore.MetricException

    class MetricException extends Exception implements Serializable

- ## Package org.apache.storm.multilang

  - ### Class org.apache.storm.multilang.JsonSerializer

    class JsonSerializer extends Object implements Serializable
    serialVersionUID:
      2548814660410474022L

  - ### Exception org.apache.storm.multilang.NoOutputException

    class NoOutputException extends Exception implements Serializable

- ## Package org.apache.storm.nimbus

  - ### Class org.apache.storm.nimbus.NimbusInfo

    class NimbusInfo extends Object implements Serializable
    serialVersionUID:
      2161446155116099333L

    - #### Serialized Fields

      - ##### host

            String host

      - ##### isLeader

            boolean isLeader

      - ##### port

            int port

      - ##### tlsPort

            int tlsPort

- ## Package org.apache.storm.pacemaker

  - ### Exception org.apache.storm.pacemaker.PacemakerConnectionException

    class PacemakerConnectionException extends Exception implements Serializable

- ## Package org.apache.storm.perf

  - ### Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter

    class LineWriter extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldName

            String fieldName

      - ##### lineDelimiter

            String lineDelimiter

  - ### Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.LineWriter

    class LineWriter extends Object implements Serializable
    serialVersionUID:
      7524288317405514146L

    - #### Serialized Fields

      - ##### fieldName

            String fieldName

      - ##### lineDelimiter

            String lineDelimiter

- ## Package org.apache.storm.perf.bolt

  - ### Class org.apache.storm.perf.bolt.CountBolt

    class CountBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

  - ### Class org.apache.storm.perf.bolt.DevNullBolt

    class DevNullBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### count

            int count

      - ##### sleepNanos

            Long sleepNanos

  - ### Class org.apache.storm.perf.bolt.IdBolt

    class IdBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.perf.bolt.SplitSentenceBolt

    class SplitSentenceBolt extends BaseBasicBolt implements Serializable

- ## Package org.apache.storm.perf.spout

  - ### Class org.apache.storm.perf.spout.ConstSpout

    class ConstSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### ackCount

            int ackCount

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            int count

      - ##### fieldName

            String fieldName

      - ##### sleep

            Long sleep

      - ##### value

            String value

  - ### Class org.apache.storm.perf.spout.FileReadSpout

    class FileReadSpout extends BaseRichSpout implements Serializable
    serialVersionUID:
      -2582705611472467172L

    - #### Serialized Fields

      - ##### ackEnabled

            boolean ackEnabled

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            long count

      - ##### file

            String file

  - ### Class org.apache.storm.perf.spout.FileReadSpout.FileReader

    class FileReader extends Object implements Serializable
    serialVersionUID:
      -7012334600647556267L

    - #### Serialized Fields

      - ##### contents

            List<String> contents

      - ##### file

            String file

      - ##### index

            int index

      - ##### limit

            int limit

  - ### Class org.apache.storm.perf.spout.StringGenSpout

    class StringGenSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            int count

      - ##### curr

            int curr

      - ##### fieldName

            String fieldName

      - ##### records

            ArrayList<String> records

      - ##### strCount

            int strCount

      - ##### strLen

            int strLen

  - ### Class org.apache.storm.perf.spout.WordGenSpout

    class WordGenSpout extends BaseRichSpout implements Serializable
    serialVersionUID:
      -2582705611472467172L

    - #### Serialized Fields

      - ##### ackEnabled

            boolean ackEnabled

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            long count

      - ##### emitMeter

            ThroughputMeter emitMeter

      - ##### file

            String file

      - ##### index

            int index

      - ##### words

            ArrayList<String> words

- ## Package org.apache.storm.perf.utils

  - ### Class org.apache.storm.perf.utils.IdentityBolt

    class IdentityBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

- ## Package org.apache.storm.planner

  - ### Class org.apache.storm.planner.TaskBundle

    class TaskBundle extends Object implements Serializable

    - #### Serialized Fields

      - ##### componentId

            int componentId

      - ##### task

            IBolt task

- ## Package org.apache.storm.redis.bolt

  - ### Class org.apache.storm.redis.bolt.AbstractRedisBolt

    class AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### jedisClusterConfig

            JedisClusterConfig jedisClusterConfig

      - ##### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

  - ### Class org.apache.storm.redis.bolt.RedisFilterBolt

    class RedisFilterBolt extends AbstractRedisBolt implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - ##### filterMapper

            RedisFilterMapper filterMapper

  - ### Class org.apache.storm.redis.bolt.RedisLookupBolt

    class RedisLookupBolt extends AbstractRedisBolt implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - ##### lookupMapper

            RedisLookupMapper lookupMapper

  - ### Class org.apache.storm.redis.bolt.RedisStoreBolt

    class RedisStoreBolt extends AbstractRedisBolt implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - ##### storeMapper

            RedisStoreMapper storeMapper

- ## Package org.apache.storm.redis.common.config

  - ### Class org.apache.storm.redis.common.config.JedisClusterConfig

    class JedisClusterConfig extends Object implements Serializable

    - #### Serialized Fields

      - ##### maxRedirections

            int maxRedirections

      - ##### nodes

            Set<InetSocketAddress> nodes

      - ##### password

            String password

      - ##### timeout

            int timeout

  - ### Class org.apache.storm.redis.common.config.JedisPoolConfig

    class JedisPoolConfig extends Object implements Serializable

    - #### Serialized Fields

      - ##### database

            int database

      - ##### host

            String host

      - ##### password

            String password

      - ##### port

            int port

      - ##### timeout

            int timeout

- ## Package org.apache.storm.redis.common.mapper

  - ### Class org.apache.storm.redis.common.mapper.RedisDataTypeDescription

    class RedisDataTypeDescription extends Object implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

- ## Package org.apache.storm.redis.topology

  - ### Class org.apache.storm.redis.topology.LookupWordCount.PrintWordTotalCountBolt

    class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt

    class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.redis.topology.WordCounter

    class WordCounter extends Object implements Serializable

    - #### Serialized Fields

      - ##### wordCounter

            Map<String,Integer> wordCounter

  - ### Class org.apache.storm.redis.topology.WordSpout

    class WordSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### isDistributed

            boolean isDistributed

- ## Package org.apache.storm.redis.trident

  - ### Class org.apache.storm.redis.trident.PrintFunction

    class PrintFunction extends BaseFunction implements Serializable

  - ### Class org.apache.storm.redis.trident.WordCountLookupMapper

    class WordCountLookupMapper extends Object implements Serializable

  - ### Class org.apache.storm.redis.trident.WordCountStoreMapper

    class WordCountStoreMapper extends Object implements Serializable

- ## Package org.apache.storm.redis.trident.state

  - ### Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier

    class AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,List<Values>> implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - ##### lookupMapper

            RedisLookupMapper lookupMapper

  - ### Class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

    class AbstractRedisStateUpdater extends BaseStateUpdater<T extends State> implements Serializable

    - #### Serialized Fields

      - ##### additionalKey

            String additionalKey

      - ##### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - ##### expireIntervalSec

            int expireIntervalSec

      - ##### storeMapper

            RedisStoreMapper storeMapper

  - ### Class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory

    class DefaultKeyFactory extends Object implements Serializable

  - ### Class org.apache.storm.redis.trident.state.Options

    class Options extends Object implements Serializable

    - #### Serialized Fields

      - ##### dataTypeDescription

            RedisDataTypeDescription dataTypeDescription

      - ##### expireIntervalSec

            int expireIntervalSec

      - ##### globalKey

            String globalKey

      - ##### keyFactory

            KeyFactory keyFactory

      - ##### localCacheSize

            int localCacheSize

      - ##### serializer

            Serializer<T> serializer

  - ### Class org.apache.storm.redis.trident.state.RedisClusterMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### jedisClusterConfig

            JedisClusterConfig jedisClusterConfig

      - ##### keyFactory

            KeyFactory keyFactory

      - ##### options

            Options options

      - ##### serializer

            Serializer serializer

      - ##### type

            StateType type

  - ### Class org.apache.storm.redis.trident.state.RedisClusterState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### jedisClusterConfig

            JedisClusterConfig jedisClusterConfig

  - ### Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier

    class RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater

    class RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

      - ##### keyFactory

            KeyFactory keyFactory

      - ##### options

            Options options

      - ##### serializer

            Serializer serializer

      - ##### type

            StateType type

  - ### Class org.apache.storm.redis.trident.state.RedisState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

  - ### Class org.apache.storm.redis.trident.state.RedisStateQuerier

    class RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisStateUpdater

    class RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable

- ## Package org.apache.storm.security.auth.plain

  - ### Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider

    class SecurityProvider extends Provider implements Serializable

- ## Package org.apache.storm.shade.org.apache.zookeeper

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException

    class KeeperException extends Exception implements Serializable

    - #### Serialized Fields

      - ##### code

            org.apache.storm.shade.org.apache.zookeeper.KeeperException.Code code

      - ##### path

            String path

      - ##### results

            List<org.apache.storm.shade.org.apache.zookeeper.OpResult> results

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorException

    class APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedException

    class AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsException

    class BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionException

    class BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossException

    class ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyException

    class DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.EphemeralOnLocalSessionException

    class EphemeralOnLocalSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLException

    class InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackException

    class InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorException

    class MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NewConfigNoQuorum

    class NewConfigNoQuorum extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthException

    class NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsException

    class NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsException

    class NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeException

    class NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyException

    class NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyException

    class NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoWatcherException

    class NoWatcherException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutException

    class OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.QuotaExceededException

    class QuotaExceededException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigDisabledException

    class ReconfigDisabledException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigInProgress

    class ReconfigInProgress extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RequestTimeoutException

    class RequestTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyException

    class RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionClosedRequireAuthException

    class SessionClosedRequireAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredException

    class SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedException

    class SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorException

    class SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ThrottledOpException

    class ThrottledOpException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedException

    class UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnknownSessionException

    class UnknownSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Exception org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException

    class ExitCodeException extends IOException implements Serializable

    - #### Serialized Fields

      - ##### exitCode

            int exitCode

- ## Package org.apache.storm.spout

  - ### Class org.apache.storm.spout.CheckpointSpout

    class CheckpointSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### checkpointInterval

            int checkpointInterval

      - ##### checkpointState

            KeyValueState<String,CheckPointState> checkpointState

      - ##### checkpointStepInProgress

            boolean checkpointStepInProgress

      - ##### collector

            SpoutOutputCollector collector

      - ##### context

            TopologyContext context

      - ##### curTxState

            CheckPointState curTxState

      - ##### lastCheckpointTs

            long lastCheckpointTs

      - ##### recovering

            boolean recovering

      - ##### recoveryStepInProgress

            boolean recoveryStepInProgress

      - ##### sleepInterval

            int sleepInterval

  - ### Class org.apache.storm.spout.RawMultiScheme

    class RawMultiScheme extends Object implements Serializable

  - ### Class org.apache.storm.spout.RawScheme

    class RawScheme extends Object implements Serializable

  - ### Class org.apache.storm.spout.SchemeAsMultiScheme

    class SchemeAsMultiScheme extends Object implements Serializable

    - #### Serialized Fields

      - ##### scheme

            Scheme scheme

  - ### Class org.apache.storm.spout.ShellSpout

    class ShellSpout extends Object implements Serializable
    serialVersionUID:
      5982357019665454L

    - #### Serialized Fields

      - ##### changeDirectory

            boolean changeDirectory

      - ##### collector

            SpoutOutputCollector collector

      - ##### command

            String[] command

      - ##### context

            TopologyContext context

      - ##### env

            Map<String,String> env

      - ##### exception

            RuntimeException exception

      - ##### heartBeatExecutorService

            ScheduledExecutorService heartBeatExecutorService

      - ##### lastHeartbeatTimestamp

            AtomicLong lastHeartbeatTimestamp

      - ##### logHandler

            ShellLogHandler logHandler

      - ##### process

            ShellProcess process

      - ##### running

            boolean running

      - ##### spoutMsg

            SpoutMsg spoutMsg

      - ##### waitingOnSubprocess

            AtomicBoolean waitingOnSubprocess

      - ##### workerTimeoutMills

            int workerTimeoutMills

- ## Package org.apache.storm.sql.javac

  - ### Exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerException

    class CompilerException extends Exception implements Serializable
    serialVersionUID:
      -2936958840023603270L

- ## Package org.apache.storm.sql.kafka

  - ### Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter

    class RecordTranslatorSchemeAdapter extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### delegate

            Scheme delegate

- ## Package org.apache.storm.sql.parser.impl

  - ### Exception org.apache.storm.sql.parser.impl.ParseException

    class ParseException extends Exception implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

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

  - ### Class org.apache.storm.sql.parser.impl.Token

    class Token extends Object implements Serializable
    serialVersionUID:
      1L

    - #### Serialized Fields

      - ##### beginColumn

            int beginColumn

        The column number of the first character of this Token.

      - ##### beginLine

            int beginLine

        The line number of the first character of this Token.

      - ##### endColumn

            int endColumn

        The column number of the last character of this Token.

      - ##### endLine

            int endLine

        The line number of the last character of this Token.

      - ##### image

            String image

        The string image of the token.

      - ##### kind

            int kind

        An integer that describes the kind of this token. This numbering system is determined by JavaCCParser, and a table of these numbers is stored in the file ...Constants.java.

      - ##### next

            Token next

        A reference to the next regular (non-special) token from the input stream. If this is the last token from the input stream, or if the token manager has not read tokens beyond this one, this field is set to null. This is true only if this token is also a regular token. Otherwise, see below for a description of the contents of this field.

      - ##### specialToken

            Token specialToken

        This field is used to access special tokens that occur prior to this token, but after the immediately preceding regular (non-special) token. If there are no such special tokens, this field is set to null. When there are more than one such special token, this field refers to the last of these special tokens, which in turn refers to the next previous special token through its specialToken field, and so on until the first special token (whose specialToken field is null). The next fields of special tokens refer to other special tokens that immediately follow it (without an intervening regular token). If there is no such token, this field is null.

  - ### Error org.apache.storm.sql.parser.impl.TokenMgrError

    class TokenMgrError extends Error implements Serializable
    serialVersionUID:
      1L

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

    class FieldInfo extends Object implements Serializable

    - #### Serialized Fields

      - ##### isPrimary

            boolean isPrimary

      - ##### name

            String name

      - ##### type

            Class<?> type

- ## Package org.apache.storm.sql.runtime.calcite

  - ### Class org.apache.storm.sql.runtime.calcite.DebuggableExecutableExpression

    class DebuggableExecutableExpression extends Object implements Serializable

    - #### Serialized Fields

      - ##### delegate

            ExecutableExpression delegate

      - ##### delegateCode

            String delegateCode

  - ### Class org.apache.storm.sql.runtime.calcite.StormDataContext

    class StormDataContext extends Object implements Serializable

    - #### Serialized Fields

      - ##### map

            com.google.common.collect.ImmutableMap<Object,Object> map

- ## Package org.apache.storm.sql.runtime.datasource.socket.bolt

  - ### Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt

    class SocketBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### host

            String host

      - ##### port

            int port

      - ##### serializer

            IOutputSerializer serializer

- ## Package org.apache.storm.sql.runtime.datasource.socket.spout

  - ### Class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout

    class SocketSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### emitted

            Map<String,List<Object>> emitted

      - ##### host

            String host

      - ##### in

            BufferedReader in

      - ##### objectMapper

            com.fasterxml.jackson.databind.ObjectMapper objectMapper

      - ##### port

            int port

      - ##### queue

            BlockingDeque<List<Object>> queue

      - ##### readerThread

            Thread readerThread

      - ##### running

            boolean running

      - ##### scheme

            Scheme scheme

      - ##### socket

            Socket socket

- ## Package org.apache.storm.sql.runtime.serde.avro

  - ### Class org.apache.storm.sql.runtime.serde.avro.AvroScheme

    class AvroScheme extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldNames

            List<String> fieldNames

      - ##### schemas

            CachedSchemas schemas

      - ##### schemaString

            String schemaString

  - ### Class org.apache.storm.sql.runtime.serde.avro.AvroSerializer

    class AvroSerializer extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldNames

            List<String> fieldNames

      - ##### schemas

            CachedSchemas schemas

      - ##### schemaString

            String schemaString

  - ### Class org.apache.storm.sql.runtime.serde.avro.CachedSchemas

    class CachedSchemas extends Object implements Serializable

    - #### Serialized Fields

      - ##### cache

            Map<String,org.apache.avro.Schema> cache

- ## Package org.apache.storm.sql.runtime.serde.csv

  - ### Class org.apache.storm.sql.runtime.serde.csv.CsvScheme

    class CsvScheme extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldNames

            List<String> fieldNames

  - ### Class org.apache.storm.sql.runtime.serde.csv.CsvSerializer

    class CsvSerializer extends Object implements Serializable

    - #### Serialized Fields

      - ##### fields

            List<String> fields

- ## Package org.apache.storm.sql.runtime.serde.json

  - ### Class org.apache.storm.sql.runtime.serde.json.JsonScheme

    class JsonScheme extends Object implements Serializable

    - #### Serialized Fields

      - ##### fields

            List<String> fields

  - ### Class org.apache.storm.sql.runtime.serde.json.JsonSerializer

    class JsonSerializer extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldNames

            List<String> 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

    class TsvScheme extends Object implements Serializable

    - #### Serialized Fields

      - ##### delimiter

            char delimiter

      - ##### fieldNames

            List<String> fieldNames

  - ### Class org.apache.storm.sql.runtime.serde.tsv.TsvSerializer

    class TsvSerializer extends Object implements Serializable

    - #### Serialized Fields

      - ##### delimiter

            char delimiter

      - ##### fields

            List<String> fields

- ## Package org.apache.storm.sql.runtime.streams.functions

  - ### Class org.apache.storm.sql.runtime.streams.functions.EvaluationCalc

    class EvaluationCalc extends Object implements Serializable

    - #### Serialized Fields

      - ##### dataContext

            org.apache.calcite.DataContext dataContext

      - ##### filterInstance

            ExecutableExpression filterInstance

      - ##### outputValues

            Object[] outputValues

      - ##### projectionInstance

            ExecutableExpression projectionInstance

  - ### Class org.apache.storm.sql.runtime.streams.functions.EvaluationFilter

    class EvaluationFilter extends Object implements Serializable

    - #### Serialized Fields

      - ##### dataContext

            org.apache.calcite.DataContext dataContext

      - ##### filterInstance

            ExecutableExpression filterInstance

      - ##### outputValues

            Object[] outputValues

  - ### Class org.apache.storm.sql.runtime.streams.functions.EvaluationFunction

    class EvaluationFunction extends Object implements Serializable

    - #### Serialized Fields

      - ##### dataContext

            org.apache.calcite.DataContext dataContext

      - ##### outputValues

            Object[] outputValues

      - ##### projectionInstance

            ExecutableExpression projectionInstance

  - ### Class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction

    class StreamInsertMapToPairFunction extends Object implements Serializable

    - #### Serialized Fields

      - ##### primaryKeyIndex

            int primaryKeyIndex

  - ### Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper

    class StreamsScanTupleValueMapper extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldNames

            List<String> fieldNames

- ## Package org.apache.storm.st.topology.window

  - ### Class org.apache.storm.st.topology.window.IncrementingSpout

    class IncrementingSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### componentId

            String componentId

      - ##### currentNum

            int currentNum

  - ### Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout

    class TimeDataIncrementingSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### componentId

            String componentId

      - ##### currentNum

            int currentNum

  - ### Class org.apache.storm.st.topology.window.TimeDataVerificationBolt

    class TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### componentId

            String componentId

  - ### Class org.apache.storm.st.topology.window.VerificationBolt

    class 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

    class RandomSentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### random

            Random random

  - ### Class org.apache.storm.starter.AnchoredWordCount.SplitSentence

    class SplitSentence extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.AnchoredWordCount.WordCount

    class WordCount extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

  - ### Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt

    class ExclaimBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords

    class FilterWords extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### poll

            boolean poll

      - ##### pollTime

            long pollTime

      - ##### wordSet

            Set<String> wordSet

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout

    class RandomSentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence

    class SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt

    class ExclamationBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout

    class FastRandomSentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### rand

            Random rand

  - ### Class org.apache.storm.starter.FastWordCountTopology.SplitSentence

    class SplitSentence extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.FastWordCountTopology.WordCount

    class WordCount extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

  - ### Class org.apache.storm.starter.InOrderDeliveryTest.Check

    class Check extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### expected

            Map<Integer,Integer> expected

  - ### Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout

    class InOrderSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### base

            int base

      - ##### collector

            SpoutOutputCollector collector

      - ##### count

            int count

  - ### Class org.apache.storm.starter.ManualDRPC.ExclamationBolt

    class ExclamationBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt

    class ExclamationLoggingBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### logger

            org.slf4j.Logger logger

      - ##### rootLogger

            org.slf4j.Logger rootLogger

      - ##### subLogger

            org.slf4j.Logger subLogger

  - ### Class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentence

    class MultiThreadedSplitSentence extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### executor

            ExecutorService executor

  - ### Class org.apache.storm.starter.ReachTopology.CountAggregator

    class CountAggregator extends BaseBatchBolt<Object> implements Serializable

    - #### Serialized Fields

      - ##### collector

            BatchOutputCollector collector

      - ##### count

            int count

      - ##### id

            Object id

  - ### Class org.apache.storm.starter.ReachTopology.GetFollowers

    class GetFollowers extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.ReachTopology.GetTweeters

    class GetTweeters extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.ReachTopology.PartialUniquer

    class PartialUniquer extends BaseBatchBolt<Object> implements Serializable

    - #### Serialized Fields

      - ##### collector

            BatchOutputCollector collector

      - ##### followers

            Set<String> followers

      - ##### id

            Object id

  - ### Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt

    class ExclamationBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

  - ### Class org.apache.storm.starter.StatefulTopology.PrinterBolt

    class PrinterBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopology.SplitSentence

    class SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence

    class RandomSentence extends ShellSpout implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence

    class SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.WordCount

    class WordCount extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

- ## Package org.apache.storm.starter.bolt

  - ### Class org.apache.storm.starter.bolt.AbstractRankerBolt

    class AbstractRankerBolt extends BaseBasicBolt implements Serializable
    serialVersionUID:
      4931640198501530202L

    - #### Serialized Fields

      - ##### count

            int count

      - ##### emitFrequencyInSeconds

            int emitFrequencyInSeconds

      - ##### rankings

            Rankings rankings

  - ### Class org.apache.storm.starter.bolt.IntermediateRankingsBolt

    class IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable
    serialVersionUID:
      -1369800530256637409L

  - ### Class org.apache.storm.starter.bolt.PrinterBolt

    class PrinterBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.bolt.RollingCountAggBolt

    class RollingCountAggBolt extends BaseRichBolt implements Serializable
    serialVersionUID:
      5537727428628598519L

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### counts

            Map<Object,Map<Integer,Long>> counts

  - ### Class org.apache.storm.starter.bolt.RollingCountBolt

    class RollingCountBolt extends BaseRichBolt implements Serializable
    serialVersionUID:
      5537727428628598519L

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### counter

            SlidingWindowCounter<Object> counter

      - ##### emitFrequencyInSeconds

            int emitFrequencyInSeconds

      - ##### lastModifiedTracker

            NthLastModifiedTimeTracker lastModifiedTracker

      - ##### windowLengthInSeconds

            int windowLengthInSeconds

  - ### Class org.apache.storm.starter.bolt.SingleJoinBolt

    class SingleJoinBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### fieldLocations

            Map<String,GlobalStreamId> fieldLocations

      - ##### idFields

            Fields idFields

      - ##### numSources

            int numSources

      - ##### outFields

            Fields outFields

      - ##### pending

            TimeCacheMap<List<Object>,Map<GlobalStreamId,Tuple>> pending

  - ### Class org.apache.storm.starter.bolt.SlidingWindowSumBolt

    class SlidingWindowSumBolt extends BaseWindowedBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### sum

            int sum

  - ### Class org.apache.storm.starter.bolt.TotalRankingsBolt

    class TotalRankingsBolt extends AbstractRankerBolt implements Serializable
    serialVersionUID:
      -8447525895532302198L

  - ### Class org.apache.storm.starter.bolt.WordCountBolt

    class WordCountBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

- ## Package org.apache.storm.starter.spout

  - ### Class org.apache.storm.starter.spout.RandomIntegerSpout

    class RandomIntegerSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### msgId

            long msgId

      - ##### rand

            Random rand

  - ### Class org.apache.storm.starter.spout.RandomNumberGeneratorSpout

    class RandomNumberGeneratorSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### batches

            Map<Long,List<List<Object>>> batches

      - ##### batchSize

            int batchSize

      - ##### fields

            Fields fields

      - ##### maxNumber

            int maxNumber

  - ### Class org.apache.storm.starter.spout.RandomSentenceSpout

    class RandomSentenceSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### rand

            Random rand

  - ### Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped

    class TimeStamped extends RandomSentenceSpout implements Serializable

    - #### Serialized Fields

      - ##### prefix

            String prefix

- ## Package org.apache.storm.starter.tools

  - ### Class org.apache.storm.starter.tools.RankableObjectWithFields

    class RankableObjectWithFields extends Object implements Serializable
    serialVersionUID:
      -9102878650001058090L

    - #### Serialized Fields

      - ##### count

            long count

      - ##### fields

            com.google.common.collect.ImmutableList<Object> fields

      - ##### obj

            Object obj

  - ### Class org.apache.storm.starter.tools.Rankings

    class Rankings extends Object implements Serializable
    serialVersionUID:
      -1549827195410578903L

    - #### Serialized Fields

      - ##### maxSize

            int maxSize

      - ##### rankedItems

            List<Rankable> rankedItems

  - ### Class org.apache.storm.starter.tools.SlidingWindowCounter

    class SlidingWindowCounter extends Object implements Serializable
    serialVersionUID:
      -2645063988768785810L

    - #### Serialized Fields

      - ##### headSlot

            int headSlot

      - ##### objCounter

            SlotBasedCounter<T> objCounter

      - ##### tailSlot

            int tailSlot

      - ##### windowLengthInSlots

            int windowLengthInSlots

  - ### Class org.apache.storm.starter.tools.SlotBasedCounter

    class SlotBasedCounter extends Object implements Serializable
    serialVersionUID:
      4858185737378394432L

    - #### Serialized Fields

      - ##### numSlots

            int numSlots

      - ##### objToCounts

            Map<T,long[]> objToCounts

- ## Package org.apache.storm.starter.trident

  - ### Class org.apache.storm.starter.trident.DebugMemoryMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

  - ### Class org.apache.storm.starter.trident.TridentReach.ExpandList

    class ExpandList extends BaseFunction implements Serializable

  - ### Class org.apache.storm.starter.trident.TridentReach.One

    class One extends Object implements Serializable

  - ### Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### map

            Map map

  - ### Class org.apache.storm.starter.trident.TridentWordCount.Split

    class Split extends BaseFunction implements Serializable

- ## Package org.apache.storm.state

  - ### Class org.apache.storm.state.DefaultStateSerializer

    class DefaultStateSerializer extends Object implements Serializable

    - #### Serialized Fields

      - ##### context

            TopologyContext context

      - ##### kryo

            ThreadLocal<com.esotericsoftware.kryo.Kryo> kryo

      - ##### output

            ThreadLocal<com.esotericsoftware.kryo.io.Output> output

      - ##### registrations

            List<String> registrations

      - ##### topoConf

            Map<String,Object> topoConf

- ## Package org.apache.storm.streams

  - ### Class org.apache.storm.streams.Pair

    class Pair extends Object implements Serializable

    - #### Serialized Fields

      - ##### value1

            T1 value1

        The first value.

      - ##### value2

            T2 value2

        The second value.

  - ### Class org.apache.storm.streams.ProcessorNode

    class ProcessorNode extends org.apache.storm.streams.Node implements Serializable

    - #### Serialized Fields

      - ##### isBatch

            boolean isBatch

      - ##### preservesKey

            boolean preservesKey

      - ##### processor

            Processor<?> processor

      - ##### windowedParentStreams

            Set<String> windowedParentStreams

  - ### Class org.apache.storm.streams.StreamState

    class StreamState extends Object implements Serializable

  - ### Class org.apache.storm.streams.WindowNode

    class WindowNode extends org.apache.storm.streams.Node implements Serializable

    - #### Serialized Fields

      - ##### windowParams

            Window<?,?> windowParams

- ## Package org.apache.storm.streams.operations

  - ### Class org.apache.storm.streams.operations.IdentityFunction

    class IdentityFunction extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.PairValueJoiner

    class PairValueJoiner extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.PrintConsumer

    class PrintConsumer extends Object implements Serializable

- ## Package org.apache.storm.streams.operations.aggregators

  - ### Class org.apache.storm.streams.operations.aggregators.Count

    class Count extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.aggregators.LongSum

    class LongSum extends Object implements Serializable

- ## Package org.apache.storm.streams.operations.mappers

  - ### Class org.apache.storm.streams.operations.mappers.PairValueMapper

    class PairValueMapper extends Object implements Serializable

    - #### Serialized Fields

      - ##### keyIndex

            int keyIndex

      - ##### valueIndex

            int valueIndex

  - ### Class org.apache.storm.streams.operations.mappers.ValueMapper

    class ValueMapper extends Object implements Serializable

    - #### Serialized Fields

      - ##### index

            int index

  - ### Class org.apache.storm.streams.operations.mappers.ValuesMapper

    class ValuesMapper extends Object implements Serializable

    - #### Serialized Fields

      - ##### indices

            int[] indices

- ## Package org.apache.storm.streams.processors

  - ### Class org.apache.storm.streams.processors.AggregateByKeyProcessor

    class AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

    - #### Serialized Fields

      - ##### aggregator

            CombinerAggregator<V,A,R> aggregator

      - ##### emitAggregate

            boolean emitAggregate

      - ##### state

            Map<K,A> state

  - ### Class org.apache.storm.streams.processors.AggregateProcessor

    class AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### aggregator

            CombinerAggregator<T,A,R> aggregator

      - ##### emitAggregate

            boolean emitAggregate

      - ##### state

            A state

  - ### Class org.apache.storm.streams.processors.BranchProcessor

    class BranchProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### predicateToStream

            Map<Predicate<? super T>,String> predicateToStream

  - ### Class org.apache.storm.streams.processors.ChainedProcessorContext

    class ChainedProcessorContext extends Object implements Serializable

    - #### Serialized Fields

      - ##### contexts

            List<? extends ProcessorContext> contexts

      - ##### processorNode

            ProcessorNode processorNode

  - ### Class org.apache.storm.streams.processors.CoGroupByKeyProcessor

    class CoGroupByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable

    - #### Serialized Fields

      - ##### firstMap

            org.apache.storm.shade.com.google.common.collect.Multimap<K,V1> firstMap

      - ##### firstStream

            String firstStream

      - ##### secondMap

            org.apache.storm.shade.com.google.common.collect.Multimap<K,V2> secondMap

      - ##### secondStream

            String secondStream

  - ### Class org.apache.storm.streams.processors.EmittingProcessorContext

    class EmittingProcessorContext extends Object implements Serializable

    - #### Serialized Fields

      - ##### anchors

            List<RefCountedTuple> anchors

      - ##### collector

            OutputCollector collector

      - ##### eventTimestamp

            long eventTimestamp

      - ##### outputFields

            Fields outputFields

      - ##### outputStreamId

            String outputStreamId

      - ##### processorNode

            ProcessorNode processorNode

      - ##### punctuation

            Values punctuation

      - ##### punctuationStreamId

            String punctuationStreamId

      - ##### timestampField

            String timestampField

  - ### Class org.apache.storm.streams.processors.FilterProcessor

    class FilterProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### predicate

            Predicate<T> predicate

  - ### Class org.apache.storm.streams.processors.FlatMapProcessor

    class 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

    class FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

    - #### Serialized Fields

      - ##### function

            FlatMapFunction<V,R> function

  - ### Class org.apache.storm.streams.processors.ForEachProcessor

    class ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### consumer

            Consumer<T> consumer

  - ### Class org.apache.storm.streams.processors.ForwardingProcessorContext

    class ForwardingProcessorContext extends Object implements Serializable

    - #### Serialized Fields

      - ##### processorNode

            ProcessorNode processorNode

      - ##### streams

            Set<String> streams

      - ##### streamToChildren

            org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren

  - ### Class org.apache.storm.streams.processors.JoinProcessor

    class JoinProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable

    - #### Serialized Fields

      - ##### leftRows

            List<Pair<K,V1>> leftRows

      - ##### leftStream

            String leftStream

      - ##### leftType

            JoinProcessor.JoinType leftType

      - ##### rightRows

            List<Pair<K,V2>> rightRows

      - ##### rightStream

            String rightStream

      - ##### rightType

            JoinProcessor.JoinType rightType

      - ##### valueJoiner

            ValueJoiner<V1,V2,R> valueJoiner

  - ### Class org.apache.storm.streams.processors.MapProcessor

    class 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

    class MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

    - #### Serialized Fields

      - ##### function

            Function<V,R> function

  - ### Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor

    class MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,A>> implements Serializable

    - #### Serialized Fields

      - ##### aggregator

            CombinerAggregator<V,A,R> aggregator

      - ##### state

            Map<K,A> state

  - ### Class org.apache.storm.streams.processors.MergeAggregateProcessor

    class MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable

    - #### Serialized Fields

      - ##### aggregator

            CombinerAggregator<T,A,R> aggregator

      - ##### state

            A state

  - ### Class org.apache.storm.streams.processors.PeekProcessor

    class PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### consumer

            Consumer<T> consumer

  - ### Class org.apache.storm.streams.processors.ReduceByKeyProcessor

    class ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

    - #### Serialized Fields

      - ##### reducer

            Reducer<V> reducer

      - ##### state

            Map<K,V> state

  - ### Class org.apache.storm.streams.processors.ReduceProcessor

    class ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - #### Serialized Fields

      - ##### agg

            T agg

      - ##### reducer

            Reducer<T> reducer

  - ### Class org.apache.storm.streams.processors.StateQueryProcessor

    class StateQueryProcessor extends org.apache.storm.streams.processors.BaseProcessor<K> implements Serializable

    - #### Serialized Fields

      - ##### keyValueState

            KeyValueState<K,V> keyValueState

      - ##### streamState

            StreamState<K,V> streamState

  - ### Class org.apache.storm.streams.processors.UpdateStateByKeyProcessor

    class UpdateStateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

    - #### Serialized Fields

      - ##### keyValueState

            KeyValueState<K,R> keyValueState

      - ##### stateUpdater

            StateUpdater<V,R> stateUpdater

- ## Package org.apache.storm.streams.windowing

  - ### Class org.apache.storm.streams.windowing.BaseWindow

    class BaseWindow extends Object implements Serializable

    - #### Serialized Fields

      - ##### lag

            BaseWindowedBolt.Duration lag

      - ##### lateTupleStream

            String lateTupleStream

      - ##### timestampField

            String timestampField

  - ### Class org.apache.storm.streams.windowing.SlidingWindows

    class SlidingWindows extends BaseWindow<L,I> implements Serializable

    - #### Serialized Fields

      - ##### slidingInterval

            I slidingInterval

      - ##### windowLength

            L windowLength

  - ### Class org.apache.storm.streams.windowing.TumblingWindows

    class TumblingWindows extends BaseWindow<L,L> implements Serializable

    - #### Serialized Fields

      - ##### windowLength

            L windowLength

- ## Package org.apache.storm.task

  - ### Class org.apache.storm.task.ShellBolt

    class ShellBolt extends Object implements Serializable
    serialVersionUID:
      -339575186639193348L

    - #### Serialized Fields

      - ##### changeDirectory

            boolean changeDirectory

      - ##### collector

            OutputCollector collector

      - ##### command

            String[] command

      - ##### context

            TopologyContext context

      - ##### env

            Map<String,String> env

      - ##### exception

            Throwable exception

      - ##### heartBeatExecutorService

            ScheduledExecutorService heartBeatExecutorService

      - ##### inputs

            Map<String,Tuple> inputs

      - ##### isLocalMode

            boolean isLocalMode

      - ##### lastHeartbeatTimestamp

            AtomicLong lastHeartbeatTimestamp

      - ##### logHandler

            ShellLogHandler logHandler

      - ##### pendingWrites

            ShellBoltMessageQueue pendingWrites

      - ##### process

            ShellProcess process

      - ##### rand

            Random rand

      - ##### readerThread

            Thread readerThread

      - ##### running

            boolean running

      - ##### sendHeartbeatFlag

            AtomicBoolean sendHeartbeatFlag

      - ##### workerTimeoutMills

            int workerTimeoutMills

      - ##### writerThread

            Thread writerThread

- ## Package org.apache.storm.testing

  - ### Class org.apache.storm.testing.AckFailMapTracker

    class AckFailMapTracker extends Object implements Serializable

    - #### Serialized Fields

      - ##### acked

            String acked

      - ##### failed

            String failed

  - ### Class org.apache.storm.testing.AckTracker

    class AckTracker extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

  - ### Class org.apache.storm.testing.BoltTracker

    class BoltTracker extends NonRichBoltTracker implements Serializable

    - #### Serialized Fields

      - ##### richDelegate

            IRichBolt richDelegate

  - ### Class org.apache.storm.testing.FeederSpout

    class FeederSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### ackFailDelegate

            AckFailDelegate ackFailDelegate

      - ##### collector

            SpoutOutputCollector collector

      - ##### id

            int id

      - ##### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.FixedTuple

    class FixedTuple extends Object implements Serializable

    - #### Serialized Fields

      - ##### stream

            String stream

      - ##### values

            List<Object> values

  - ### Class org.apache.storm.testing.FixedTupleSpout

    class FixedTupleSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### context

            TopologyContext context

      - ##### fields

            Fields fields

      - ##### id

            String id

      - ##### pending

            Map<String,FixedTuple> pending

      - ##### serveTuples

            List<FixedTuple> serveTuples

      - ##### tuples

            List<FixedTuple> tuples

  - ### Class org.apache.storm.testing.IdentityBolt

    class IdentityBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### fields

            Fields fields

  - ### Class org.apache.storm.testing.NGrouping

    class NGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### number

            int number

      - ##### outTasks

            List<Integer> outTasks

  - ### Class org.apache.storm.testing.NonRichBoltTracker

    class NonRichBoltTracker extends Object implements Serializable

    - #### Serialized Fields

      - ##### delegate

            IBolt delegate

      - ##### trackId

            String trackId

  - ### Class org.apache.storm.testing.PrepareBatchBolt

    class PrepareBatchBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.PythonShellMetricsBolt

    class PythonShellMetricsBolt extends ShellBolt implements Serializable
    serialVersionUID:
      1999209252187463355L

  - ### Class org.apache.storm.testing.PythonShellMetricsSpout

    class PythonShellMetricsSpout extends ShellSpout implements Serializable
    serialVersionUID:
      1999209252187463355L

  - ### Class org.apache.storm.testing.SpoutTracker

    class 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

    class TestAggregatesCounter extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### counts

            Map<String,Integer> counts

  - ### Class org.apache.storm.testing.TestConfBolt

    class TestConfBolt extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### componentConf

            Map<String,Object> componentConf

      - ##### conf

            Map<String,Object> conf

  - ### Class org.apache.storm.testing.TestEventLogSpout

    class TestEventLogSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### eventId

            long eventId

      - ##### myCount

            long myCount

      - ##### source

            int source

      - ##### totalCount

            long totalCount

      - ##### uid

            String uid

  - ### Class org.apache.storm.testing.TestEventOrderCheckBolt

    class TestEventOrderCheckBolt extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### count

            int count

      - ##### recentEventId

            Map<Integer,Long> recentEventId

  - ### Class org.apache.storm.testing.TestGlobalCount

    class TestGlobalCount extends BaseRichBolt implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### count

            int count

  - ### Class org.apache.storm.testing.TestPlannerBolt

    class TestPlannerBolt extends BaseRichBolt implements Serializable

  - ### Class org.apache.storm.testing.TestPlannerSpout

    class TestPlannerSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### isDistributed

            boolean isDistributed

      - ##### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.TestSerObject

    class TestSerObject extends Object implements Serializable

    - #### Serialized Fields

      - ##### f1

            int f1

      - ##### f2

            int f2

  - ### Class org.apache.storm.testing.TestWordBytesCounter

    class TestWordBytesCounter extends TestWordCounter implements Serializable

  - ### Class org.apache.storm.testing.TestWordCounter

    class TestWordCounter extends BaseBasicBolt implements Serializable

    - #### Serialized Fields

      - ##### counts

            Map<String,Integer> counts

  - ### Class org.apache.storm.testing.TestWordSpout

    class TestWordSpout extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### collector

            SpoutOutputCollector collector

      - ##### isDistributed

            boolean isDistributed

  - ### Class org.apache.storm.testing.TupleCaptureBolt

    class TupleCaptureBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            OutputCollector collector

      - ##### name

            String name

- ## Package org.apache.storm.topology

  - ### Class org.apache.storm.topology.BaseStatefulBoltExecutor

    class BaseStatefulBoltExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### checkPointInputTaskCount

            int checkPointInputTaskCount

      - ##### collector

            OutputCollector collector

      - ##### lastTxid

            long lastTxid

      - ##### transactionRequestCount

            Map<org.apache.storm.topology.BaseStatefulBoltExecutor.TransactionRequest,Integer> transactionRequestCount

  - ### Class org.apache.storm.topology.BasicBoltExecutor

    class BasicBoltExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### bolt

            IBasicBolt bolt

  - ### Class org.apache.storm.topology.CheckpointTupleForwarder

    class CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable

    - #### Serialized Fields

      - ##### bolt

            IRichBolt bolt

  - ### Exception org.apache.storm.topology.FailedException

    class FailedException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.topology.PersistentWindowedBoltExecutor

    class PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

    - #### Serialized Fields

      - ##### statefulWindowedBolt

            IStatefulWindowedBolt<T extends State> statefulWindowedBolt

  - ### Exception org.apache.storm.topology.ReportedFailedException

    class ReportedFailedException extends FailedException implements Serializable

  - ### Class org.apache.storm.topology.SharedOffHeapWithinNode

    class SharedOffHeapWithinNode extends SharedMemory implements Serializable
    serialVersionUID:
      1L

  - ### Class org.apache.storm.topology.SharedOffHeapWithinWorker

    class SharedOffHeapWithinWorker extends SharedMemory implements Serializable

  - ### Class org.apache.storm.topology.SharedOnHeap

    class SharedOnHeap extends SharedMemory implements Serializable
    serialVersionUID:
      1L

  - ### Class org.apache.storm.topology.StatefulBoltExecutor

    class StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable

    - #### Serialized Fields

      - ##### bolt

            IStatefulBolt<T extends State> bolt

      - ##### boltInitialized

            boolean boltInitialized

      - ##### collector

            org.apache.storm.topology.StatefulBoltExecutor.AckTrackingOutputCollector collector

      - ##### pendingTuples

            List<Tuple> pendingTuples

      - ##### preparedTuples

            List<Tuple> preparedTuples

      - ##### state

            State state

  - ### Class org.apache.storm.topology.StatefulWindowedBoltExecutor

    class StatefulWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

    - #### Serialized Fields

      - ##### statefulWindowedBolt

            IStatefulWindowedBolt<T extends State> statefulWindowedBolt

  - ### Class org.apache.storm.topology.TupleFieldTimestampExtractor

    class TupleFieldTimestampExtractor extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldName

            String fieldName

  - ### Class org.apache.storm.topology.WindowedBoltExecutor

    class 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

    class BaseBasicBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseBatchBolt

    class BaseBatchBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseComponent

    class BaseComponent extends Object implements Serializable

  - ### Class org.apache.storm.topology.base.BaseRichBolt

    class BaseRichBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseRichSpout

    class BaseRichSpout extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseStatefulBolt

    class BaseStatefulBolt extends Object implements Serializable

  - ### Class org.apache.storm.topology.base.BaseStatefulWindowedBolt

    class BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable

    - #### Serialized Fields

      - ##### maxEventsInMemory

            long maxEventsInMemory

      - ##### persistent

            boolean persistent

  - ### Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt

    class BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt

    class BaseWindowedBolt extends Object implements Serializable

    - #### Serialized Fields

      - ##### timestampExtractor

            TimestampExtractor timestampExtractor

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt.Count

    class Count extends Object implements Serializable

    - #### Serialized Fields

      - ##### value

            int value

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt.Duration

    class Duration extends Object implements Serializable

    - #### Serialized Fields

      - ##### value

            int value

- ## Package org.apache.storm.trident.drpc

  - ### Class org.apache.storm.trident.drpc.ReturnResultsReducer

    class ReturnResultsReducer extends Object implements Serializable

    - #### Serialized Fields

      - ##### clients

            Map<List,DRPCInvocationsClient> clients

      - ##### conf

            Map<String,Object> conf

      - ##### local

            boolean local

- ## Package org.apache.storm.trident.operation

  - ### Class org.apache.storm.trident.operation.BaseAggregator

    class BaseAggregator extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseFilter

    class BaseFilter extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseFunction

    class BaseFunction extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseMultiReducer

    class BaseMultiReducer extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseOperation

    class BaseOperation extends Object implements Serializable

- ## Package org.apache.storm.trident.operation.builtin

  - ### Class org.apache.storm.trident.operation.builtin.ComparisonAggregator

    class ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable

    - #### Serialized Fields

      - ##### batchId

            Object batchId

      - ##### inputFieldName

            String inputFieldName

  - ### Class org.apache.storm.trident.operation.builtin.Count

    class Count extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Debug

    class Debug extends BaseFilter implements Serializable

    - #### Serialized Fields

      - ##### name

            String name

      - ##### useLogger

            boolean useLogger

  - ### Class org.apache.storm.trident.operation.builtin.Equals

    class Equals extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.FilterNull

    class FilterNull extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg

    class 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

    class FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable

    - #### Serialized Fields

      - ##### number

            int number

      - ##### reverse

            boolean reverse

      - ##### sortField

            String sortField

  - ### Class org.apache.storm.trident.operation.builtin.MapGet

    class MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Max

    class Max extends ComparisonAggregator<Comparable<Object>> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.MaxWithComparator

    class MaxWithComparator extends ComparisonAggregator<T> implements Serializable

    - #### Serialized Fields

      - ##### comparator

            Comparator<T> comparator

  - ### Class org.apache.storm.trident.operation.builtin.Min

    class Min extends ComparisonAggregator<Comparable<Object>> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.MinWithComparator

    class MinWithComparator extends ComparisonAggregator<T> implements Serializable

    - #### Serialized Fields

      - ##### comparator

            Comparator<T> comparator

  - ### Class org.apache.storm.trident.operation.builtin.Negate

    class Negate extends Object implements Serializable

    - #### Serialized Fields

      - ##### delegate

            Filter delegate

  - ### Class org.apache.storm.trident.operation.builtin.SnapshotGet

    class SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Sum

    class Sum extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.TupleCollectionGet

    class TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable

- ## Package org.apache.storm.trident.operation.impl

  - ### Class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

    class ChainedAggregatorImpl extends Object implements Serializable

    - #### Serialized Fields

      - ##### aggs

            Aggregator[] aggs

      - ##### fact

            ComboList.Factory fact

      - ##### inputFactories

            TridentTupleView.ProjectionFactory[] inputFactories

      - ##### inputFields

            Fields[] inputFields

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

    class CombinerAggregatorCombineImpl extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl

    class CombinerAggregatorInitImpl extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater

    class CombinerAggStateUpdater extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.ConsumerExecutor

    class ConsumerExecutor extends BaseOperation implements Serializable

    - #### Serialized Fields

      - ##### consumer

            Consumer consumer

  - ### Class org.apache.storm.trident.operation.impl.FilterExecutor

    class FilterExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### filter

            Filter filter

  - ### Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor

    class FlatMapFunctionExecutor extends BaseOperation implements Serializable

    - #### Serialized Fields

      - ##### function

            FlatMapFunction function

  - ### Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition

    class GlobalBatchToPartition extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.impl.GroupedAggregator

    class GroupedAggregator extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            Aggregator agg

      - ##### fact

            ComboList.Factory fact

      - ##### groupFactory

            TridentTupleView.ProjectionFactory groupFactory

      - ##### groupFields

            Fields groupFields

      - ##### inFields

            Fields inFields

      - ##### inputFactory

            TridentTupleView.ProjectionFactory inputFactory

  - ### Class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor

    class GroupedMultiReducerExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### groupFactories

            List<TridentTupleView.ProjectionFactory> groupFactories

      - ##### groupFields

            List<Fields> groupFields

      - ##### inputFactories

            List<TridentTupleView.ProjectionFactory> inputFactories

      - ##### inputFields

            List<Fields> inputFields

      - ##### reducer

            GroupedMultiReducer reducer

  - ### Class org.apache.storm.trident.operation.impl.IdentityMultiReducer

    class IdentityMultiReducer extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition

    class IndexHashBatchToPartition extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.impl.JoinerMultiReducer

    class JoinerMultiReducer extends Object implements Serializable

    - #### Serialized Fields

      - ##### factory

            ComboList.Factory factory

      - ##### numGroupFields

            int numGroupFields

      - ##### sideFields

            List<Fields> sideFields

      - ##### types

            List<JoinType> types

  - ### Class org.apache.storm.trident.operation.impl.MapFunctionExecutor

    class MapFunctionExecutor extends BaseOperation implements Serializable

    - #### Serialized Fields

      - ##### function

            MapFunction function

  - ### Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer

    class PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable

    - #### Serialized Fields

      - ##### factory

            ComboList.Factory factory

      - ##### joiningFields

            List<Fields> joiningFields

      - ##### numGroupFields

            int numGroupFields

      - ##### originFields

            List<Fields> originFields

      - ##### sideFields

            List<Fields> sideFields

      - ##### types

            List<JoinType> types

  - ### Class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl

    class ReducerAggregatorImpl extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            ReducerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater

    class ReducerAggStateUpdater extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            ReducerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.SingleEmitAggregator

    class SingleEmitAggregator extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            Aggregator agg

      - ##### batchToPartition

            SingleEmitAggregator.BatchToPartition batchToPartition

      - ##### myPartitionIndex

            int myPartitionIndex

      - ##### totalPartitions

            int totalPartitions

  - ### Class org.apache.storm.trident.operation.impl.TrueFilter

    class TrueFilter extends Object implements Serializable

- ## Package org.apache.storm.trident.partition

  - ### Class org.apache.storm.trident.partition.GlobalGrouping

    class GlobalGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### target

            List<Integer> target

  - ### Class org.apache.storm.trident.partition.IdentityGrouping

    class IdentityGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### precomputed

            Map<Integer,List<Integer>> precomputed

  - ### Class org.apache.storm.trident.partition.IndexHashGrouping

    class IndexHashGrouping extends Object implements Serializable

    - #### Serialized Fields

      - ##### index

            int index

      - ##### targets

            List<Integer> targets

- ## Package org.apache.storm.trident.planner

  - ### Class org.apache.storm.trident.planner.Node

    class Node extends DefaultResourceDeclarer<Node> implements Serializable

    - #### Serialized Fields

      - ##### allOutputFields

            Fields allOutputFields

      - ##### creationIndex

            int creationIndex

      - ##### name

            String name

      - ##### nodeId

            String nodeId

      - ##### parallelismHint

            Integer parallelismHint

      - ##### stateInfo

            NodeStateInfo stateInfo

      - ##### streamId

            String streamId

  - ### Class org.apache.storm.trident.planner.NodeStateInfo

    class NodeStateInfo extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

      - ##### spec

            StateSpec spec

  - ### Class org.apache.storm.trident.planner.PartitionNode

    class 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

    class ProcessorNode extends Node implements Serializable

    - #### Serialized Fields

      - ##### committer

            boolean committer

      - ##### processor

            TridentProcessor processor

      - ##### selfOutFields

            Fields selfOutFields

  - ### Class org.apache.storm.trident.planner.SpoutNode

    class SpoutNode extends Node implements Serializable

    - #### Serialized Fields

      - ##### spout

            Object spout

      - ##### txId

            String txId

      - ##### type

            SpoutNode.SpoutType type

  - ### Class org.apache.storm.trident.planner.SubtopologyBolt

    class SubtopologyBolt extends Object implements Serializable
    serialVersionUID:
      1475508603138688412L

    - #### Serialized Fields

      - ##### batchGroups

            Map<Node,String> batchGroups

      - ##### graph

            org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph

      - ##### myTopologicallyOrdered

            Map<String,List<TridentProcessor>> myTopologicallyOrdered

      - ##### nodes

            Set<Node> nodes

      - ##### outputFactories

            Map<Node,TridentTuple.Factory> outputFactories

      - ##### roots

            Map<String,SubtopologyBolt.InitialReceiver> roots

- ## Package org.apache.storm.trident.planner.processor

  - ### Class org.apache.storm.trident.planner.processor.AggregateProcessor

    class AggregateProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### agg

            Aggregator agg

      - ##### collector

            FreshCollector collector

      - ##### context

            TridentContext context

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

  - ### Class org.apache.storm.trident.planner.processor.EachProcessor

    class EachProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            AppendCollector collector

      - ##### context

            TridentContext context

      - ##### function

            Function function

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

  - ### Class org.apache.storm.trident.planner.processor.MapProcessor

    class MapProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            FreshCollector collector

      - ##### context

            TridentContext context

      - ##### function

            Function function

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

  - ### Class org.apache.storm.trident.planner.processor.MultiReducerProcessor

    class MultiReducerProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            FreshCollector collector

      - ##### context

            TridentContext context

      - ##### projectFields

            List<Fields> projectFields

      - ##### projectionFactories

            TridentTupleView.ProjectionFactory[] projectionFactories

      - ##### reducer

            MultiReducer reducer

      - ##### streamToIndex

            Map<String,Integer> streamToIndex

  - ### Class org.apache.storm.trident.planner.processor.PartitionPersistProcessor

    class PartitionPersistProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            FreshCollector collector

      - ##### context

            TridentContext context

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

      - ##### state

            State state

      - ##### stateId

            String stateId

      - ##### updater

            StateUpdater updater

  - ### Class org.apache.storm.trident.planner.processor.ProjectedProcessor

    class ProjectedProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### context

            TridentContext context

      - ##### factory

            TridentTupleView.ProjectionFactory factory

      - ##### projectFields

            Fields projectFields

  - ### Class org.apache.storm.trident.planner.processor.StateQueryProcessor

    class StateQueryProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### collector

            AppendCollector collector

      - ##### context

            TridentContext context

      - ##### function

            QueryFunction function

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

      - ##### state

            State state

      - ##### stateId

            String stateId

- ## Package org.apache.storm.trident.spout

  - ### Class org.apache.storm.trident.spout.BatchSpoutExecutor

    class BatchSpoutExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### spout

            IBatchSpout spout

  - ### Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor

    class OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### spout

            IOpaquePartitionedTridentSpout<Object,ISpoutPartition,Object> spout

  - ### Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor

    class PartitionedTridentSpoutExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### spout

            IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout

  - ### Class org.apache.storm.trident.spout.RichSpoutBatchExecutor

    class RichSpoutBatchExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### spout

            IRichSpout spout

  - ### Class org.apache.storm.trident.spout.RichSpoutBatchTriggerer

    class RichSpoutBatchTriggerer extends Object implements Serializable

    - #### Serialized Fields

      - ##### coordStream

            String coordStream

      - ##### delegate

            IRichSpout delegate

      - ##### finishConditions

            Map<Long,org.apache.storm.trident.spout.RichSpoutBatchTriggerer.FinishCondition> finishConditions

      - ##### msgIdToBatchId

            Map<Long,Long> msgIdToBatchId

      - ##### outputTasks

            List<Integer> outputTasks

      - ##### rand

            Random rand

      - ##### stream

            String stream

  - ### Class org.apache.storm.trident.spout.TridentSpoutCoordinator

    class TridentSpoutCoordinator extends Object implements Serializable

    - #### Serialized Fields

      - ##### coord

            ITridentSpout.BatchCoordinator<Object> coord

      - ##### id

            String id

      - ##### spout

            ITridentSpout<Object> spout

      - ##### state

            RotatingTransactionalState state

      - ##### underlyingState

            TransactionalState underlyingState

  - ### Class org.apache.storm.trident.spout.TridentSpoutExecutor

    class TridentSpoutExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### activeBatches

            TreeMap<Long,TransactionAttempt> activeBatches

      - ##### collector

            org.apache.storm.trident.spout.TridentSpoutExecutor.AddIdCollector collector

      - ##### emitter

            ITridentSpout.Emitter<Object> emitter

      - ##### spout

            ITridentSpout<Object> spout

      - ##### streamName

            String streamName

      - ##### txStateId

            String txStateId

- ## Package org.apache.storm.trident.state

  - ### Class org.apache.storm.trident.state.BaseQueryFunction

    class BaseQueryFunction extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.state.BaseStateUpdater

    class BaseStateUpdater extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.state.JSONNonTransactionalSerializer

    class JSONNonTransactionalSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.JSONOpaqueSerializer

    class JSONOpaqueSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.JSONTransactionalSerializer

    class JSONTransactionalSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.StateSpec

    class StateSpec extends Object implements Serializable

    - #### Serialized Fields

      - ##### requiredNumPartitions

            Integer requiredNumPartitions

      - ##### stateFactory

            StateFactory stateFactory

- ## Package org.apache.storm.trident.state.map

  - ### Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater

    class MapCombinerAggStateUpdater extends Object implements Serializable
    serialVersionUID:
      -3960578785572592092L

    - #### Serialized Fields

      - ##### agg

            CombinerAggregator agg

      - ##### factory

            ComboList.Factory factory

      - ##### groupFields

            Fields groupFields

      - ##### inputFields

            Fields inputFields

  - ### Class org.apache.storm.trident.state.map.MapReducerAggStateUpdater

    class MapReducerAggStateUpdater extends Object implements Serializable
    serialVersionUID:
      8667174018978959987L

    - #### Serialized Fields

      - ##### agg

            ReducerAggregator agg

      - ##### factory

            ComboList.Factory factory

      - ##### groupFields

            Fields groupFields

      - ##### inputFields

            Fields inputFields

  - ### Class org.apache.storm.trident.state.map.MicroBatchIBackingMap.Options

    class 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

    class CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable

  - ### Class org.apache.storm.trident.testing.FeederBatchSpout

    class FeederBatchSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

      - ##### outFields

            Fields outFields

      - ##### semaphoreId

            String semaphoreId

      - ##### waitToEmit

            boolean waitToEmit

  - ### Class org.apache.storm.trident.testing.FeederCommitterBatchSpout

    class FeederCommitterBatchSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### spout

            FeederBatchSpout spout

  - ### Class org.apache.storm.trident.testing.FixedBatchSpout

    class FixedBatchSpout extends Object implements Serializable

    - #### Serialized Fields

      - ##### batches

            HashMap<Long,List<List<Object>>> batches

      - ##### cycle

            boolean cycle

      - ##### fields

            Fields fields

      - ##### index

            int index

      - ##### maxBatchSize

            int maxBatchSize

      - ##### outputs

            List<Object>[] outputs

  - ### Class org.apache.storm.trident.testing.LRUMemoryMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

      - ##### maxSize

            int maxSize

  - ### Class org.apache.storm.trident.testing.MemoryMapState.Factory

    class Factory extends Object implements Serializable

    - #### Serialized Fields

      - ##### id

            String id

  - ### Class org.apache.storm.trident.testing.Split

    class Split extends BaseFunction implements Serializable

  - ### Class org.apache.storm.trident.testing.StringLength

    class StringLength extends BaseFunction implements Serializable

  - ### Class org.apache.storm.trident.testing.TrueFilter

    class TrueFilter extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.testing.TuplifyArgs

    class TuplifyArgs extends BaseFunction implements Serializable

- ## Package org.apache.storm.trident.topology

  - ### Class org.apache.storm.trident.topology.MasterBatchCoordinator

    class MasterBatchCoordinator extends BaseRichSpout implements Serializable

    - #### Serialized Fields

      - ##### active

            boolean active

      - ##### activeTx

            TreeMap<Long,org.apache.storm.trident.topology.MasterBatchCoordinator.TransactionStatus> activeTx

      - ##### attemptIds

            TreeMap<Long,Integer> attemptIds

      - ##### collector

            SpoutOutputCollector collector

      - ##### coordinators

            List<ITridentSpout.BatchCoordinator> coordinators

      - ##### currTransaction

            Long currTransaction

      - ##### managedSpoutIds

            List<String> managedSpoutIds

      - ##### maxTransactionActive

            int maxTransactionActive

      - ##### spouts

            List<ITridentSpout> spouts

      - ##### states

            List<TransactionalState> states

      - ##### throttler

            WindowedTimeThrottler throttler

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor

    class TridentBoltExecutor extends Object implements Serializable

    - #### Serialized Fields

      - ##### batches

            RotatingMap<Object,TridentBoltExecutor.TrackedBatch> batches

      - ##### batchGroupIds

            Map<GlobalStreamId,String> batchGroupIds

      - ##### bolt

            ITridentBatchBolt bolt

      - ##### collector

            OutputCollector collector

      - ##### context

            TopologyContext context

      - ##### coordCollector

            org.apache.storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector coordCollector

      - ##### coordConditions

            Map<String,TridentBoltExecutor.CoordCondition> coordConditions

      - ##### coordOutputCollector

            BatchOutputCollector coordOutputCollector

      - ##### coordSpecs

            Map<String,TridentBoltExecutor.CoordSpec> coordSpecs

      - ##### lastRotate

            long lastRotate

      - ##### messageTimeoutMs

            long messageTimeoutMs

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition

    class CoordCondition extends Object implements Serializable

    - #### Serialized Fields

      - ##### commitStream

            GlobalStreamId commitStream

      - ##### expectedTaskReports

            int expectedTaskReports

      - ##### targetTasks

            Set<Integer> targetTasks

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec

    class CoordSpec extends Object implements Serializable

    - #### Serialized Fields

      - ##### commitStream

            GlobalStreamId commitStream

      - ##### coords

            Map<String,TridentBoltExecutor.CoordType> coords

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType

    class CoordType extends Object implements Serializable

    - #### Serialized Fields

      - ##### singleCount

            boolean singleCount

- ## Package org.apache.storm.trident.tuple

  - ### Class org.apache.storm.trident.tuple.ComboList.Factory

    class 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

    class FreshOutputFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldIndex

            Map<String,ValuePointer> fieldIndex

      - ##### index

            ValuePointer[] index

  - ### Class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory

    class OperationOutputFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldIndex

            Map<String,ValuePointer> fieldIndex

      - ##### index

            ValuePointer[] index

      - ##### parent

            TridentTuple.Factory parent

  - ### Class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory

    class ProjectionFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldIndex

            Map<String,ValuePointer> fieldIndex

      - ##### index

            ValuePointer[] index

      - ##### parent

            TridentTuple.Factory parent

  - ### Class org.apache.storm.trident.tuple.TridentTupleView.RootFactory

    class RootFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### fieldIndex

            Map<String,ValuePointer> fieldIndex

      - ##### index

            ValuePointer[] index

- ## Package org.apache.storm.trident.util

  - ### Class org.apache.storm.trident.util.ErrorEdgeFactory

    class ErrorEdgeFactory extends Object implements Serializable

  - ### Class org.apache.storm.trident.util.IndexedEdge

    class IndexedEdge extends Object implements Serializable

    - #### Serialized Fields

      - ##### index

            int index

      - ##### source

            T source

      - ##### target

            T target

  - ### Class org.apache.storm.trident.util.LRUMap

    class 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

    class InMemoryWindowsStore extends Object implements Serializable

    - #### Serialized Fields

      - ##### backingStore

            WindowsStore backingStore

      - ##### currentSize

            AtomicInteger currentSize

      - ##### maxSize

            int maxSize

      - ##### store

            ConcurrentHashMap<String,Object> store

  - ### Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory

    class InMemoryWindowsStoreFactory extends Object implements Serializable

    - #### Serialized Fields

      - ##### inMemoryWindowsStore

            InMemoryWindowsStore inMemoryWindowsStore

  - ### Class org.apache.storm.trident.windowing.WindowsStateFactory

    class WindowsStateFactory extends Object implements Serializable

  - ### Class org.apache.storm.trident.windowing.WindowsStateUpdater

    class WindowsStateUpdater extends Object implements Serializable

    - #### Serialized Fields

      - ##### windowsStore

            WindowsStore windowsStore

      - ##### windowStoreFactory

            WindowsStoreFactory windowStoreFactory

  - ### Class org.apache.storm.trident.windowing.WindowsStore.Entry

    class Entry extends Object implements Serializable

    - #### Serialized Fields

      - ##### key

            String key

      - ##### value

            Object value

  - ### Class org.apache.storm.trident.windowing.WindowTridentProcessor

    class WindowTridentProcessor extends Object implements Serializable

    - #### Serialized Fields

      - ##### aggregator

            Aggregator aggregator

      - ##### collector

            FreshCollector collector

      - ##### inputFields

            Fields inputFields

      - ##### projection

            TridentTupleView.ProjectionFactory projection

      - ##### storeTuplesInStore

            boolean storeTuplesInStore

      - ##### topologyContext

            TopologyContext topologyContext

      - ##### tridentContext

            TridentContext tridentContext

      - ##### tridentWindowManager

            ITridentWindowManager tridentWindowManager

      - ##### windowConfig

            WindowConfig windowConfig

      - ##### windowId

            String windowId

      - ##### windowStore

            WindowsStore windowStore

      - ##### windowStoreFactory

            WindowsStoreFactory windowStoreFactory

      - ##### windowTaskId

            String windowTaskId

      - ##### windowTriggerInprocessId

            String windowTriggerInprocessId

  - ### Class org.apache.storm.trident.windowing.WindowTridentProcessor.TriggerInfo

    class TriggerInfo extends Object implements Serializable

    - #### Serialized Fields

      - ##### triggerId

            int triggerId

      - ##### windowTaskId

            String windowTaskId

- ## Package org.apache.storm.trident.windowing.config

  - ### Class org.apache.storm.trident.windowing.config.BaseWindowConfig

    class BaseWindowConfig extends Object implements Serializable

    - #### Serialized Fields

      - ##### slideLength

            int slideLength

      - ##### windowLength

            int windowLength

  - ### Class org.apache.storm.trident.windowing.config.SlidingCountWindow

    class SlidingCountWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.SlidingDurationWindow

    class SlidingDurationWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.TumblingCountWindow

    class TumblingCountWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.TumblingDurationWindow

    class TumblingDurationWindow extends BaseWindowConfig implements Serializable

- ## Package org.apache.storm.tuple

  - ### Class org.apache.storm.tuple.Fields

    class Fields extends Object implements Serializable
    serialVersionUID:
      -3377931843059975424L

    - #### Serialized Fields

      - ##### fields

            List<String> fields

      - ##### index

            Map<String,Integer> index

  - ### Class org.apache.storm.tuple.Values

    class Values extends ArrayList<Object> implements Serializable

- ## Package org.apache.storm.utils

  - ### Exception org.apache.storm.utils.DisallowedStrategyException

    class DisallowedStrategyException extends RuntimeException implements Serializable

    - #### Serialized Fields

      - ##### allowedStrategies

            List<String> allowedStrategies

      - ##### attemptedClass

            String attemptedClass

  - ### Class org.apache.storm.utils.LruMap

    class LruMap extends LinkedHashMap<A,B> implements Serializable

    - #### Serialized Fields

      - ##### evCb

            LruMap.CacheEvictionCallback evCb

      - ##### maxSize

            int maxSize

  - ### Exception org.apache.storm.utils.NimbusLeaderNotFoundException

    class NimbusLeaderNotFoundException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.utils.ShellBoltMessageQueue

    class ShellBoltMessageQueue extends Object implements Serializable

    - #### Serialized Fields

      - ##### boltMsgQueue

            LinkedBlockingQueue<BoltMsg> boltMsgQueue

      - ##### notEmpty

            Condition notEmpty

      - ##### takeLock

            ReentrantLock takeLock

      - ##### taskIdsQueue

            LinkedList<List<Integer>> taskIdsQueue

  - ### Class org.apache.storm.utils.ShellProcess

    class ShellProcess extends Object implements Serializable

    - #### Serialized Fields

      - ##### command

            String[] command

      - ##### componentName

            String componentName

      - ##### env

            Map<String,String> env

      - ##### pid

            Number pid

      - ##### processErrorStream

            InputStream processErrorStream

      - ##### serializer

            ISerializer serializer

      - ##### subprocess

            Process subprocess

  - ### Exception org.apache.storm.utils.ShellUtils.ExitCodeException

    class ExitCodeException extends IOException implements Serializable

    - #### Serialized Fields

      - ##### exitCode

            int exitCode

  - ### Exception org.apache.storm.utils.WrappedAlreadyAliveException

    class WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedAuthorizationException

    class WrappedAuthorizationException extends AuthorizationException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedDRPCExecutionException

    class WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedHBExecutionException

    class WrappedHBExecutionException extends HBExecutionException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedIllegalStateException

    class WrappedIllegalStateException extends IllegalStateException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedInvalidTopologyException

    class WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedKeyAlreadyExistsException

    class WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedKeyNotFoundException

    class WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable

  - ### Exception org.apache.storm.utils.WrappedNotAliveException

    class WrappedNotAliveException extends NotAliveException implements Serializable

- ## Package org.apache.storm.windowing