# Serialized Form

- ## Package org.apache.calcite.interpreter

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

- ## Package org.apache.storm

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

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

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

  - ### Class org.apache.storm.clojure$bolt$fn__728 extends clojure.lang.AFunction implements Serializable

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  - ### Class org.apache.storm.clojure$fn__695 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__759 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__762 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.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 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__777 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__777$iter__778__782 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.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 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 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__818 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__820 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__822 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__824 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$fn__826 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.clojure$loading__6812__auto____693 extends clojure.lang.AFunction implements Serializable

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

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

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

  - ### Class org.apache.storm.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 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_ extends clojure.lang.AFunction implements Serializable

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

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

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

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

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

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

    serialVersionUID:
      -1550278723792864455L

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

  - ### Class org.apache.storm.config$fn__269 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.config$fn__276 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.config$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

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

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

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

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### currentIndex

            int currentIndex

      - #### numEmitted

            int numEmitted

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

    serialVersionUID:
      6145919776650637748L

    - ### Serialized Fields

      - #### topoName

            String topoName

  - ### Class org.apache.storm.log$fn__495 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.log$loading__6812__auto____284 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.log$log_debug extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_error extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_message extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.log$log_warn extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$add_supervisor extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$capture_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$complete_topology extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$fn__478 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$get_supervisor extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$global_amt extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$increment_global_BANG_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$kill_supervisor extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$local_cluster_state extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$mkClusterParam extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$mock_leader_elector extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$ms_EQ_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$read_tuples extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$simulate_wait extends clojure.lang.AFunction implements Serializable

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

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

  - ### Class org.apache.storm.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 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 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$test_tuple extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$tracked_wait extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_for_condition extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_for_condition$fn__499 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.testing$while_timeout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_local_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_timeout extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$add_inputs extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$field_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$fn__571 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$grouping_type extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$instantiate_java_object$fn__574 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$loading__6812__auto____280 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_bolt_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_bolt_spec_STAR_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_grouping extends clojure.lang.AFunction implements Serializable

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

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

  - ### Class org.apache.storm.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 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 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_output_spec$fn__598 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$mk_spout_spec extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_spout_spec_STAR_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$mk_topology extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$output_fields extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$shell_component_params extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.thrift$with_nimbus_connection extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$__LT__GT_ extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$__LT__GT_$fn__567 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_error extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_structure extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$clojurify_structure$fn__527 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$defnk extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$defnk$fn__521 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$dofor extends clojure.lang.RestFn implements Serializable

  - ### Class org.apache.storm.util$filter_key extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$filter_key$fn__553 extends clojure.lang.AFunction implements Serializable

    - ### Serialized Fields

      - #### afn

            Object afn

  - ### Class org.apache.storm.util$fn__501 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$loading__6812__auto____282 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$map_val extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$map_val$iter__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 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 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 extends clojure.lang.AFunction implements Serializable

  - ### Class org.apache.storm.util$thrown_cause_QMARK_ extends clojure.lang.RestFn implements Serializable

- ## Package org.apache.storm.bolt

  - ### Class org.apache.storm.bolt.JoinBolt extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### field

            String[] field

      - #### outputName

            String outputName

      - #### streamName

            String streamName

  - ### Class org.apache.storm.bolt.JoinBolt.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 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 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 extends ShellBolt implements Serializable

    - ### Serialized Fields

      - #### outputs

            Map<String,​StreamInfo> outputs

  - ### Class org.apache.storm.clojure.RichShellSpout extends ShellSpout implements Serializable

    - ### Serialized Fields

      - #### outputs

            Map<String,​StreamInfo> outputs

- ## Package org.apache.storm.coordination

  - ### Class org.apache.storm.coordination.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            GlobalStreamId id

  - ### Class org.apache.storm.coordination.CoordinatedBolt.SourceArgs extends Object implements Serializable

    - ### Serialized Fields

      - #### singleCount

            boolean singleCount

- ## Package org.apache.storm.daemon

  - ### Class org.apache.storm.daemon.Acker extends Object implements Serializable

    serialVersionUID:
      4430906880683183091L

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### pending

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

  - ### Class org.apache.storm.daemon.GrouperFactory.AllGrouper extends Object implements Serializable

    - ### Serialized Fields

      - #### targetTasks

            List<Integer> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping extends Object implements Serializable

    - ### Serialized Fields

      - #### customStreamGrouping

            CustomStreamGrouping customStreamGrouping

  - ### Class org.apache.storm.daemon.GrouperFactory.FieldsGrouper extends Object implements Serializable

    - ### Serialized Fields

      - #### groupFields

            Fields groupFields

      - #### numTasks

            int numTasks

      - #### outFields

            Fields outFields

      - #### targetTasks

            List<List<Integer>> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.GlobalGrouper extends Object implements Serializable

    - ### Serialized Fields

      - #### targetTasks

            List<Integer> targetTasks

  - ### Class org.apache.storm.daemon.GrouperFactory.NoneGrouper extends Object implements Serializable

    - ### Serialized Fields

      - #### numTasks

            int numTasks

      - #### random

            Random random

      - #### targetTasks

            List<Integer> targetTasks

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

  - ### Class org.apache.storm.daemon.supervisor.ContainerRecoveryException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignment extends LocalAssignment implements Serializable

    - ### Serialized Fields

      - #### timing

            com.codahale.metrics.Timer.Context timing

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

  - ### Class org.apache.storm.daemon.ui.InvalidRequestException extends Exception implements Serializable

- ## Package org.apache.storm.dependency

  - ### Class org.apache.storm.dependency.FileNotAvailableException extends RuntimeException implements Serializable

- ## Package org.apache.storm.drpc

  - ### Class org.apache.storm.drpc.DRPCSpout extends BaseRichSpout implements Serializable

    serialVersionUID:
      2387848310969237877L

    - ### Serialized Fields

      - #### clients

            List<DRPCInvocationsClient> clients

      - #### collector

            SpoutOutputCollector collector

      - #### function

            String function

      - #### localDrpcId

            String localDrpcId

  - ### Class org.apache.storm.drpc.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 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 extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### rand

            Random rand

  - ### Class org.apache.storm.drpc.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 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 extends Object implements Serializable

  - ### Class org.apache.storm.flux.examples.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 extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.flux.examples.TestWindowBolt extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.flux.examples.WordCounter extends BaseBasicBolt implements Serializable

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

  - ### Class org.apache.storm.flux.wrappers.bolts.FluxShellBolt extends ShellBolt implements Serializable

    - ### Serialized Fields

      - #### componentConfig

            Map<String,​Object> componentConfig

      - #### outputFields

            Map<String,​String[]> outputFields

  - ### Class org.apache.storm.flux.wrappers.bolts.LogInfoBolt extends BaseBasicBolt implements Serializable

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

  - ### Class org.apache.storm.flux.wrappers.spouts.FluxShellSpout extends ShellSpout implements Serializable

    - ### Serialized Fields

      - #### componentConfig

            Map<String,​Object> componentConfig

      - #### outputFields

            Map<String,​String[]> outputFields

- ## Package org.apache.storm.generated

  - ### Class org.apache.storm.generated.AccessControl extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### access

            int access

      - #### name

            String name

      - #### type

            AccessControlType type

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.Assignment extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

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

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.BeginDownloadResult extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### data_size

            long data_size

      - #### session

            String session

      - #### version

            long version

  - ### Class org.apache.storm.generated.Bolt extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### bolt_object

            ComponentObject bolt_object

      - #### common

            ComponentCommon common

  - ### Class org.apache.storm.generated.BoltAggregateStats extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### 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 extends org.apache.storm.thrift.TUnion<ComponentObject,​ComponentObject._Fields> implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.ComponentPageInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### e

            DRPCExecutionException e

      - #### id

            String id

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### functionName

            String functionName

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            DRPCRequest success

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.result_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

      - #### result

            String result

  - ### Class org.apache.storm.generated.DistributedRPCInvocations.result_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

      - #### type

            DRPCExceptionType type

  - ### Class org.apache.storm.generated.DRPCRequest extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### func_args

            String func_args

      - #### request_id

            String request_id

  - ### Class org.apache.storm.generated.ErrorInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### exec_summary

            ExecutorSummary exec_summary

      - #### stats

            ComponentAggregateStats stats

  - ### Class org.apache.storm.generated.ExecutorInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### task_end

            int task_end

      - #### task_start

            int task_start

  - ### Class org.apache.storm.generated.ExecutorSpecificStats extends org.apache.storm.thrift.TUnion<ExecutorSpecificStats,​ExecutorSpecificStats._Fields> implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.ExecutorStats extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### num_err_choice

            NumErrorsChoice num_err_choice

  - ### Class org.apache.storm.generated.GlobalStreamId extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### componentId

            String componentId

      - #### streamId

            String streamId

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.HBAuthorizationException extends org.apache.storm.thrift.TException implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.HBExecutionException extends org.apache.storm.thrift.TException implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.HBMessage extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### data

            HBMessageData data

      - #### message_id

            int message_id

      - #### type

            HBServerMessageType type

  - ### Class org.apache.storm.generated.HBMessageData extends org.apache.storm.thrift.TUnion<HBMessageData,​HBMessageData._Fields> implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.HBNodes extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### pulseIds

            List<String> pulseIds

  - ### Class org.apache.storm.generated.HBPulse extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### details

            ByteBuffer details

      - #### id

            String id

  - ### Class org.apache.storm.generated.HBRecords extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### pulses

            List<HBPulse> pulses

  - ### Class org.apache.storm.generated.IllegalStateException extends org.apache.storm.thrift.TException implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.JavaObject extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### args_list

            List<JavaObjectArg> args_list

      - #### full_class_name

            String full_class_name

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.KeyAlreadyExistsException extends org.apache.storm.thrift.TException implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.KeyNotFoundException extends org.apache.storm.thrift.TException implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.KillOptions extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### wait_secs

            int wait_secs

  - ### Class org.apache.storm.generated.ListBlobsResult extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### keys

            List<String> keys

      - #### session

            String session

  - ### Class org.apache.storm.generated.LocalAssignment extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### supervisor_id

            String supervisor_id

  - ### Class org.apache.storm.generated.LSTopoHistory extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.activate_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.beginBlobDownload_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.beginBlobDownload_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### success

            BeginDownloadResult success

  - ### Class org.apache.storm.generated.Nimbus.beginCreateBlob_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

      - #### meta

            SettableBlobMeta meta

  - ### Class org.apache.storm.generated.Nimbus.beginCreateBlob_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### kae

            KeyAlreadyExistsException kae

      - #### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.beginFileUpload_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.beginFileUpload_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.beginUpdateBlob_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.beginUpdateBlob_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.cancelBlobUpload_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.cancelBlobUpload_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.createStateInZookeeper_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.createStateInZookeeper_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.deactivate_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.deactivate_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.debug_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.deleteBlob_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### ise

            IllegalStateException ise

      - #### knf

            KeyNotFoundException knf

  - ### Class org.apache.storm.generated.Nimbus.downloadBlobChunk_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.downloadBlobChunk_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            ByteBuffer success

  - ### Class org.apache.storm.generated.Nimbus.downloadChunk_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.downloadChunk_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            ByteBuffer success

  - ### Class org.apache.storm.generated.Nimbus.finishBlobUpload_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.finishBlobUpload_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.finishFileUpload_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### location

            String location

  - ### Class org.apache.storm.generated.Nimbus.finishFileUpload_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.getBlobMeta_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.getBlobMeta_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### success

            ReadableBlobMeta success

  - ### Class org.apache.storm.generated.Nimbus.getBlobReplication_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

  - ### Class org.apache.storm.generated.Nimbus.getBlobReplication_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### success

            int success

  - ### Class org.apache.storm.generated.Nimbus.getClusterInfo_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.getClusterInfo_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            ClusterSummary success

  - ### Class org.apache.storm.generated.Nimbus.getComponentPageInfo_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.getLeader_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            NimbusSummary success

  - ### Class org.apache.storm.generated.Nimbus.getLogConfig_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.getLogConfig_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### success

            LogConfig success

  - ### Class org.apache.storm.generated.Nimbus.getNimbusConf_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.getNimbusConf_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### owner

            String owner

  - ### Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            List<OwnerResourceSummary> success

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### node

            String node

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            SupervisorAssignments success

  - ### Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getTopology_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            StormTopology success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyConf_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getTopologyConf_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            String success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyHistory_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### user

            String user

  - ### Class org.apache.storm.generated.Nimbus.getTopologyHistory_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            TopologyHistoryInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfo_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfo_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

      - #### options

            GetInfoOptions options

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

      - #### options

            GetInfoOptions options

  - ### Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologyInfo success

  - ### Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummaries_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### success

            List<TopologySummary> success

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummary_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummary_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologySummary success

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            TopologySummary success

  - ### Class org.apache.storm.generated.Nimbus.getUserTopology_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Nimbus.getUserTopology_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            StormTopology success

  - ### Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### blobKey

            String blobKey

  - ### Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### aze

            AuthorizationException aze

      - #### success

            boolean success

  - ### Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### aze

            AuthorizationException aze

      - #### success

            boolean success

  - ### Class org.apache.storm.generated.Nimbus.killTopology_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.killTopology_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

      - #### options

            KillOptions options

  - ### Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.listBlobs_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.listBlobs_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### success

            ListBlobsResult success

  - ### Class org.apache.storm.generated.Nimbus.processWorkerMetrics_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### metrics

            WorkerMetrics metrics

  - ### Class org.apache.storm.generated.Nimbus.processWorkerMetrics_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.rebalance_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### name

            String name

      - #### options

            RebalanceOptions options

  - ### Class org.apache.storm.generated.Nimbus.rebalance_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### heatbeat

            SupervisorWorkerHeartbeat heatbeat

  - ### Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

  - ### Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### heartbeats

            SupervisorWorkerHeartbeats heartbeats

  - ### Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.setBlobMeta_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### key

            String key

      - #### meta

            SettableBlobMeta meta

  - ### Class org.apache.storm.generated.Nimbus.setBlobMeta_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

  - ### Class org.apache.storm.generated.Nimbus.setLogConfig_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### config

            LogConfig config

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.setLogConfig_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.setWorkerProfiler_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

      - #### profileRequest

            ProfileRequest profileRequest

  - ### Class org.apache.storm.generated.Nimbus.setWorkerProfiler_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.Nimbus.submitTopology_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### jsonConf

            String jsonConf

      - #### name

            String name

      - #### topology

            StormTopology topology

      - #### uploadedJarLocation

            String uploadedJarLocation

  - ### Class org.apache.storm.generated.Nimbus.submitTopology_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            AlreadyAliveException e

      - #### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### jsonConf

            String jsonConf

      - #### name

            String name

      - #### options

            SubmitOptions options

      - #### topology

            StormTopology topology

      - #### uploadedJarLocation

            String uploadedJarLocation

  - ### Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            AlreadyAliveException e

      - #### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.Nimbus.updateBlobReplication_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### key

            String key

      - #### replication

            int replication

  - ### Class org.apache.storm.generated.Nimbus.updateBlobReplication_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### aze

            AuthorizationException aze

      - #### knf

            KeyNotFoundException knf

      - #### success

            int success

  - ### Class org.apache.storm.generated.Nimbus.uploadBlobChunk_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### chunk

            ByteBuffer chunk

      - #### session

            String session

  - ### Class org.apache.storm.generated.Nimbus.uploadBlobChunk_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.uploadChunk_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### chunk

            ByteBuffer chunk

      - #### location

            String location

  - ### Class org.apache.storm.generated.Nimbus.uploadChunk_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Nimbus.uploadNewCredentials_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### creds

            Credentials creds

      - #### name

            String name

  - ### Class org.apache.storm.generated.Nimbus.uploadNewCredentials_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### ite

            InvalidTopologyException ite

  - ### Class org.apache.storm.generated.NimbusSummary extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### msg

            String msg

  - ### Class org.apache.storm.generated.NullStruct extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.OwnerResourceSummary extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### execution_command

            String execution_command

      - #### script

            String script

  - ### Class org.apache.storm.generated.SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats,​SpecificAggregateStats._Fields> implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.SpoutAggregateStats extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __isset_bitfield

            byte __isset_bitfield

      - #### complete_latency_ms

            double complete_latency_ms

  - ### Class org.apache.storm.generated.SpoutSpec extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### common

            ComponentCommon common

      - #### spout_object

            ComponentObject spout_object

  - ### Class org.apache.storm.generated.SpoutStats extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### acked

            Map<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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

      - #### e

            NotAliveException e

      - #### success

            Assignment success

  - ### Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### assignments

            SupervisorAssignments assignments

  - ### Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_args extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### heartbeat

            SupervisorWorkerHeartbeat heartbeat

  - ### Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### aze

            AuthorizationException aze

  - ### Class org.apache.storm.generated.SupervisorAssignments extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### storm_assignment

            Map<String,​Assignment> storm_assignment

  - ### Class org.apache.storm.generated.SupervisorInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

      - #### 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 extends org.apache.storm.thrift.TUnion<TopologyActionOptions,​TopologyActionOptions._Fields> implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.generated.TopologyHistoryInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### topo_ids

            List<String> topo_ids

  - ### Class org.apache.storm.generated.TopologyInfo extends Object implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream in)
                             throws IOException,
                                    ClassNotFoundException

        Throws:
          `IOException`
          `ClassNotFoundException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream out)
                              throws IOException

        Throws:
          `IOException`

    - ### Serialized Fields

      - #### __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 extends Object implements Serializable

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialization Methods

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

    - ### Serialized Fields

      - #### targetTaskStats

            Map<Integer,​Long> targetTaskStats

  - ### Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator extends Object implements Serializable

  - ### Class org.apache.storm.grouping.ShuffleGrouping extends Object implements Serializable

    - ### Serialized Fields

      - #### choices

            ArrayList<List<Integer>> choices

      - #### current

            AtomicInteger current

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

  - ### Class org.apache.storm.hdfs.avro.AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable

  - ### Class org.apache.storm.hdfs.avro.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 extends AbstractAvroSerializer implements Serializable

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

  - ### Class org.apache.storm.hdfs.bolt.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 extends AbstractHdfsBolt implements Serializable

  - ### Class org.apache.storm.hdfs.bolt.HdfsBolt extends AbstractHdfsBolt implements Serializable

    - ### Serialized Fields

      - #### format

            RecordFormat format

  - ### Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### counts

            HashMap<String,​Long> counts

  - ### Class org.apache.storm.hdfs.bolt.HdfsFileTopology.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 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 extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### counts

            HashMap<String,​Long> counts

  - ### Class org.apache.storm.hdfs.bolt.SequenceFileTopology.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### keyField

            String keyField

      - #### valueField

            String valueField

  - ### Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldDelimiter

            String fieldDelimiter

      - #### fields

            Fields fields

      - #### recordDelimiter

            String recordDelimiter

  - ### Class org.apache.storm.hdfs.bolt.format.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### currentBytesWritten

            long currentBytesWritten

      - #### lastOffset

            long lastOffset

      - #### maxBytes

            long maxBytes

  - ### Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy extends Object implements Serializable

  - ### Class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy extends Object implements Serializable

    - ### Serialized Fields

      - #### interval

            long interval

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

  - ### Class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy extends Object implements Serializable

    - ### Serialized Fields

      - #### count

            int count

      - #### executeCount

            int executeCount

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

  - ### Class org.apache.storm.hdfs.common.NullPartitioner extends Object implements Serializable

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

  - ### Class org.apache.storm.hdfs.common.rotation.MoveFileAction extends Object implements Serializable

    - ### Serialized Fields

      - #### destination

            String destination

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

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

    - ### Serialized Fields

      - #### 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 extends BaseRichBolt implements Serializable

    serialVersionUID:
      -5313598399155365865L

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### count

            int count

  - ### Class org.apache.storm.hdfs.spout.ParseException extends Exception implements Serializable

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

  - ### Class org.apache.storm.hdfs.trident.FixedBatchSpout extends Object implements Serializable

    - ### Serialized Fields

      - #### 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 extends HdfsState.Options implements Serializable

    - ### Serialized Fields

      - #### bufferSize

            int bufferSize

      - #### format

            RecordFormat format

      - #### offset

            long offset

  - ### Class org.apache.storm.hdfs.trident.HdfsState.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### options

            HdfsState.Options options

  - ### Class org.apache.storm.hdfs.trident.HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable

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

  - ### Class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat extends Object implements Serializable

    - ### Serialized Fields

      - #### extension

            String extension

      - #### partitionIndex

            int partitionIndex

      - #### path

            String path

      - #### prefix

            String prefix

  - ### Class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat extends Object implements Serializable

    - ### Serialized Fields

      - #### keyField

            String keyField

      - #### valueField

            String valueField

  - ### Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldDelimiter

            String fieldDelimiter

      - #### fields

            Fields fields

      - #### recordDelimiter

            String recordDelimiter

  - ### Class org.apache.storm.hdfs.trident.format.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### currentBytesWritten

            long currentBytesWritten

      - #### lastOffset

            long lastOffset

      - #### maxBytes

            long maxBytes

  - ### Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy extends Object implements Serializable

  - ### Class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy extends Object implements Serializable

    - ### Serialized Fields

      - #### interval

            long interval

      - #### rotationTimer

            Timer rotationTimer

      - #### rotationTimerTriggered

            AtomicBoolean rotationTimerTriggered

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

  - ### Class org.apache.storm.hdfs.trident.sync.CountSyncPolicy extends Object implements Serializable

    - ### Serialized Fields

      - #### count

            int count

      - #### executeCount

            int executeCount

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

  - ### Class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### br

            BufferedReader br

      - #### collector

            SpoutOutputCollector collector

      - #### count

            int count

      - #### filePath

            String filePath

      - #### outputFields

            String[] outputFields

      - #### pending

            ConcurrentHashMap<UUID,​Values> pending

      - #### total

            long total

  - ### Class org.apache.storm.hive.bolt.HiveBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### allWriters

            Map<org.apache.hive.hcatalog.streaming.HiveEndPoint,​HiveWriter> allWriters

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### batchHelper

            BatchHelper batchHelper

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### callTimeoutPool

            ExecutorService callTimeoutPool

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### collector

            OutputCollector collector

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### options

            HiveOptions options

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### sendHeartBeat

            AtomicBoolean sendHeartBeat

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### tokenAuthEnabled

            boolean tokenAuthEnabled

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### ugi

            org.apache.hadoop.security.UserGroupInformation ugi

        Deprecated, for removal: This API element is subject to removal in a future version.

  - ### Class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout 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.hive.bolt.HiveTopologyPartitioned.UserDataSpout 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.hive.bolt.mapper

  - ### Class org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### columnFields

            Fields columnFields

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### columnNames

            String[] columnNames

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### fieldDelimiter

            String fieldDelimiter

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### parseDate

            SimpleDateFormat parseDate

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### partitionFields

            Fields partitionFields

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### timeFormat

            String timeFormat

        Deprecated, for removal: This API element is subject to removal in a future version.

  - ### Class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### columnFields

            Fields columnFields

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### parseDate

            SimpleDateFormat parseDate

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### partitionFields

            Fields partitionFields

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### timeFormat

            String timeFormat

        Deprecated, for removal: This API element is subject to removal in a future version.

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

  - ### Class org.apache.storm.hive.common.HiveOptions extends Object implements Serializable

    - ### Serialized Fields

      - #### autoCreatePartitions

            Boolean autoCreatePartitions

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### batchSize

            Integer batchSize

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### callTimeout

            Integer callTimeout

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### databaseName

            String databaseName

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### heartBeatInterval

            Integer heartBeatInterval

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### idleTimeout

            Integer idleTimeout

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### kerberosKeytab

            String kerberosKeytab

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### kerberosPrincipal

            String kerberosPrincipal

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### mapper

            HiveMapper mapper

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### maxOpenConnections

            Integer maxOpenConnections

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### metaStoreURI

            String metaStoreURI

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### tableName

            String tableName

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### tickTupleInterval

            Integer tickTupleInterval

        Deprecated, for removal: This API element is subject to removal in a future version.

      - #### txnsPerBatch

            Integer txnsPerBatch

        Deprecated, for removal: This API element is subject to removal in a future version.

  - ### Class org.apache.storm.hive.common.HiveUtils.AuthenticationFailed extends Exception implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.CommitFailure extends HiveWriter.Failure implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.ConnectFailure extends HiveWriter.Failure implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.Failure extends Exception implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.TxnBatchFailure extends HiveWriter.Failure implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.TxnFailure extends HiveWriter.Failure implements Serializable

  - ### Class org.apache.storm.hive.common.HiveWriter.WriteFailure extends HiveWriter.Failure implements Serializable

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

  - ### Class org.apache.storm.hive.trident.HiveStateFactory extends Object implements Serializable

    - ### Serialized Fields

      - #### options

            HiveOptions options

        Deprecated, for removal: This API element is subject to removal in a future version.

  - ### Class org.apache.storm.hive.trident.HiveUpdater extends BaseStateUpdater<HiveState> implements Serializable

  - ### Class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout extends Object implements Serializable

    - ### Serialized Fields

      - #### batches

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

      - #### cycle

            boolean cycle

      - #### index

            int index

      - #### maxBatchSize

            int maxBatchSize

      - #### outputs

            Values[] outputs

- ## Package org.apache.storm.hooks

  - ### Class org.apache.storm.hooks.BaseWorkerHook extends Object implements Serializable

    serialVersionUID:
      2589466485198339529L

  - ### Class org.apache.storm.hooks.SubmitterHookException extends RuntimeException implements Serializable

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

  - ### Class org.apache.storm.jdbc.bolt.AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### configKey

            String configKey

      - #### connectionProvider

            ConnectionProvider connectionProvider

      - #### queryTimeoutSecs

            Integer queryTimeoutSecs

  - ### Class org.apache.storm.jdbc.bolt.JdbcInsertBolt extends AbstractJdbcBolt implements Serializable

    - ### Serialized Fields

      - #### insertQuery

            String insertQuery

      - #### jdbcMapper

            JdbcMapper jdbcMapper

      - #### tableName

            String tableName

  - ### Class org.apache.storm.jdbc.bolt.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### configMap

            Map<String,​Object> configMap

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

  - ### Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable

    - ### Serialized Fields

      - #### outputFields

            Fields outputFields

  - ### Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### schemaColumns

            List<Column> schemaColumns

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

  - ### Class org.apache.storm.jdbc.spout.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 extends BaseQueryFunction<JdbcState,​List<Values>> implements Serializable

  - ### Class org.apache.storm.jdbc.trident.state.JdbcState.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### options

            JdbcState.Options options

  - ### Class org.apache.storm.jdbc.trident.state.JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable

- ## Package org.apache.storm.jms

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

  - ### Class org.apache.storm.jms.bolt.JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - ### Serialized Fields

      - #### autoAck

            boolean autoAck

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

  - ### Class org.apache.storm.jms.example.SpringJmsProvider extends Object implements Serializable

    - ### Serialized Fields

      - #### connectionFactory

            javax.jms.ConnectionFactory connectionFactory

      - #### destination

            javax.jms.Destination destination

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

  - ### Class org.apache.storm.jms.spout.JmsMessageID extends Object implements Serializable

    - ### Serialized Fields

      - #### jmsId

            String jmsId

      - #### sequence

            Long sequence

  - ### Class org.apache.storm.jms.spout.JmsSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### options

            JmsState.Options options

  - ### Class org.apache.storm.jms.trident.JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable

  - ### Class org.apache.storm.jms.trident.TridentJmsSpout extends Object implements Serializable

    serialVersionUID:
      -3469351154693356655L

    - ### Serialized Fields

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

    serialVersionUID:
      -8794262989021702349L

    - ### Serialized Fields

      - #### boltKeyField

            String boltKeyField

      - #### boltMessageField

            String boltMessageField

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

  - ### Class org.apache.storm.kafka.bolt.selector.DefaultTopicSelector extends Object implements Serializable

    serialVersionUID:
      4601118062437851265L

    - ### Serialized Fields

      - #### topicName

            String topicName

  - ### Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector extends Object implements Serializable

    serialVersionUID:
      -3830575380208166367L

    - ### Serialized Fields

      - #### defaultTopicName

            String defaultTopicName

      - #### fieldIndex

            int fieldIndex

  - ### Class org.apache.storm.kafka.bolt.selector.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 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 extends Object implements Serializable

    serialVersionUID:
      -5782462870112305750L

  - ### Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.KafkaSpout extends BaseRichSpout implements Serializable

    serialVersionUID:
      4151921085047987154L

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### kafkaClientFactory

            ClientFactory<K,​V> kafkaClientFactory

      - #### kafkaSpoutConfig

            KafkaSpoutConfig<K,​V> kafkaSpoutConfig

      - #### topicAssigner

            TopicAssigner topicAssigner

  - ### Class org.apache.storm.kafka.spout.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 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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### length

            long length

      - #### lengthNanos

            long lengthNanos

      - #### timeUnit

            TimeUnit timeUnit

  - ### Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.kafka.spout.KafkaTuple extends Values implements Serializable

    serialVersionUID:
      4803794470450587992L

    - ### Serialized Fields

      - #### stream

            String stream

  - ### Class org.apache.storm.kafka.spout.SimpleRecordTranslator extends Object implements Serializable

    serialVersionUID:
      4678369144122009596L

    - ### Serialized Fields

      - #### fields

            Fields fields

      - #### func

            Func<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 extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.internal.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### topics

            Set<String> topics

  - ### Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter extends Object implements Serializable

    - ### Serialized Fields

      - #### pattern

            Pattern pattern

      - #### topics

            Set<String> topics

  - ### Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner extends Object implements Serializable

  - ### Class org.apache.storm.kafka.spout.subscription.TopicAssigner extends Object implements Serializable

    serialVersionUID:
      5423018073527583826L

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

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable

    serialVersionUID:
      1L

    - ### Serialized Fields

      - #### emitter

            KafkaTridentSpoutEmitter<K,​V> emitter

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata extends Object implements Serializable

    - ### Serialized Fields

      - #### firstOffset

            long firstOffset

      - #### lastOffset

            long lastOffset

      - #### topologyId

            String topologyId

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,​V> implements Serializable

    serialVersionUID:
      1L

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator extends Object implements Serializable

    - ### Serialized Fields

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

    serialVersionUID:
      -8003272486566259640L

    - ### Serialized Fields

      - #### kafkaSpoutConfig

            KafkaTridentSpoutConfig<K,​V> kafkaSpoutConfig

      - #### outputFieldsExtractor

            OutputFieldsExtractor outputFieldsExtractor

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition extends Object implements Serializable

    - ### Serialized Fields

      - #### topicPartition

            org.apache.kafka.common.TopicPartition topicPartition

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional extends Object implements Serializable

    serialVersionUID:
      1L

    - ### Serialized Fields

      - #### kafkaSpoutConfig

            KafkaTridentSpoutConfig<K,​V> kafkaSpoutConfig

      - #### outputFieldsExtractor

            OutputFieldsExtractor outputFieldsExtractor

  - ### Class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitter extends Object implements Serializable

    serialVersionUID:
      1L

    - ### Serialized Fields

      - #### emitter

            KafkaTridentSpoutEmitter<K,​V> emitter

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

  - ### Class org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor extends Object implements Serializable

    serialVersionUID:
      1L

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

  - ### Class org.apache.storm.kafka.trident.TridentKafkaStateFactory extends Object implements Serializable

    serialVersionUID:
      -3613240970062343385L

    - ### Serialized Fields

      - #### mapper

            TridentTupleToKafkaMapper<K,​V> mapper

      - #### producerProperties

            Properties producerProperties

      - #### topicSelector

            KafkaTopicSelector topicSelector

  - ### Class org.apache.storm.kafka.trident.TridentKafkaStateUpdater extends BaseStateUpdater<TridentKafkaState<K,​V>> implements Serializable

    serialVersionUID:
      3352659585225274402L

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

  - ### Class org.apache.storm.kafka.trident.mapper.FieldNameBasedTupleToKafkaMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### keyFieldName

            String keyFieldName

      - #### msgFieldName

            String msgFieldName

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

  - ### Class org.apache.storm.kafka.trident.selector.DefaultTopicSelector extends Object implements Serializable

    serialVersionUID:
      -1172454882072591493L

    - ### Serialized Fields

      - #### topicName

            String topicName

- ## Package org.apache.storm.lambda

  - ### Class org.apache.storm.lambda.LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### biConsumer

            SerializableBiConsumer<Tuple,​BasicOutputCollector> biConsumer

      - #### fields

            String[] fields

  - ### Class org.apache.storm.lambda.LambdaConsumerBolt extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### consumer

            SerializableConsumer<Tuple> consumer

  - ### Class org.apache.storm.lambda.LambdaSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### supplier

            SerializableSupplier<?> supplier

- ## Package org.apache.storm.loadgen

  - ### Class org.apache.storm.loadgen.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 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 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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### max

            double max

      - #### mean

            double mean

      - #### min

            double min

      - #### stddev

            double stddev

  - ### Class org.apache.storm.loadgen.OutputStream extends Object implements Serializable

    - ### Serialized Fields

      - #### areKeysSkewed

            boolean areKeysSkewed

      - #### id

            String id

      - #### rate

            NormalDistStats rate

  - ### Class org.apache.storm.loadgen.ScopedTopologySet extends HashSet<String> implements Serializable

    - ### Serialized Fields

      - #### client

            Nimbus.Iface client

      - #### closed

            boolean closed

  - ### Class org.apache.storm.loadgen.SlowExecutorPattern extends Object implements Serializable

    - ### Serialized Fields

      - #### count

            int count

      - #### maxSlownessMs

            double maxSlownessMs

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout extends LoadSpout implements Serializable

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### executorIndex

            int executorIndex

      - #### sleep

            ExecAndProcessLatencyEngine sleep

  - ### Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

- ## Package org.apache.storm.metric

  - ### Class org.apache.storm.metric.EventLoggerBolt extends Object implements Serializable

    - ### Serialized Fields

      - #### eventLoggers

            List<IEventLogger> eventLoggers

  - ### Class org.apache.storm.metric.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 extends Object implements Serializable

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

  - ### Class org.apache.storm.metric.filter.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### expandMapType

            boolean expandMapType

      - #### metricNameSeparator

            String metricNameSeparator

- ## Package org.apache.storm.metricstore

  - ### Class org.apache.storm.metricstore.MetricException extends Exception implements Serializable

- ## Package org.apache.storm.multilang

  - ### Class org.apache.storm.multilang.JsonSerializer extends Object implements Serializable

    serialVersionUID:
      2548814660410474022L

  - ### Class org.apache.storm.multilang.NoOutputException extends Exception implements Serializable

- ## Package org.apache.storm.nimbus

  - ### Class org.apache.storm.nimbus.NimbusInfo extends Object implements Serializable

    serialVersionUID:
      2161446155116099333L

    - ### Serialized Fields

      - #### host

            String host

      - #### isLeader

            boolean isLeader

      - #### port

            int port

      - #### tlsPort

            int tlsPort

- ## Package org.apache.storm.pacemaker

  - ### Class org.apache.storm.pacemaker.PacemakerConnectionException extends Exception implements Serializable

- ## Package org.apache.storm.perf

  - ### Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldName

            String fieldName

      - #### lineDelimiter

            String lineDelimiter

  - ### Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.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 extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

  - ### Class org.apache.storm.perf.bolt.DevNullBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### count

            int count

      - #### sleepNanos

            Long sleepNanos

  - ### Class org.apache.storm.perf.bolt.IdBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.perf.bolt.SplitSentenceBolt extends BaseBasicBolt implements Serializable

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

  - ### Class org.apache.storm.perf.spout.ConstSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### 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 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 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 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 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 extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

- ## Package org.apache.storm.planner

  - ### Class org.apache.storm.planner.TaskBundle extends Object implements Serializable

    - ### Serialized Fields

      - #### componentId

            int componentId

      - #### task

            IBolt task

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

  - ### Class org.apache.storm.redis.bolt.AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### jedisClusterConfig

            JedisClusterConfig jedisClusterConfig

      - #### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

  - ### Class org.apache.storm.redis.bolt.RedisFilterBolt extends AbstractRedisBolt implements Serializable

    - ### Serialized Fields

      - #### additionalKey

            String additionalKey

      - #### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - #### filterMapper

            RedisFilterMapper filterMapper

  - ### Class org.apache.storm.redis.bolt.RedisLookupBolt extends AbstractRedisBolt implements Serializable

    - ### Serialized Fields

      - #### additionalKey

            String additionalKey

      - #### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - #### lookupMapper

            RedisLookupMapper lookupMapper

  - ### Class org.apache.storm.redis.bolt.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 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 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 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 extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.redis.topology.WordCounter extends Object implements Serializable

    - ### Serialized Fields

      - #### wordCounter

            Map<String,​Integer> wordCounter

  - ### Class org.apache.storm.redis.topology.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 extends BaseFunction implements Serializable

  - ### Class org.apache.storm.redis.trident.WordCountLookupMapper extends Object implements Serializable

  - ### Class org.apache.storm.redis.trident.WordCountStoreMapper extends Object implements Serializable

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

  - ### Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,​List<Values>> implements Serializable

    - ### Serialized Fields

      - #### additionalKey

            String additionalKey

      - #### dataType

            RedisDataTypeDescription.RedisDataType dataType

      - #### lookupMapper

            RedisLookupMapper lookupMapper

  - ### Class org.apache.storm.redis.trident.state.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 extends Object implements Serializable

  - ### Class org.apache.storm.redis.trident.state.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### jedisClusterConfig

            JedisClusterConfig jedisClusterConfig

  - ### Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisMapState.Factory extends Object implements Serializable

    - ### Serialized Fields

      - #### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

      - #### keyFactory

            KeyFactory keyFactory

      - #### options

            Options options

      - #### serializer

            Serializer serializer

      - #### type

            StateType type

  - ### Class org.apache.storm.redis.trident.state.RedisState.Factory extends Object implements Serializable

    - ### Serialized Fields

      - #### jedisPoolConfig

            JedisPoolConfig jedisPoolConfig

  - ### Class org.apache.storm.redis.trident.state.RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable

  - ### Class org.apache.storm.redis.trident.state.RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable

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

  - ### Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider extends Provider implements Serializable

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

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException extends Exception implements Serializable

    - ### Serialized Fields

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

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.EphemeralOnLocalSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NewConfigNoQuorum extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoWatcherException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.QuotaExceededException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigDisabledException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigInProgress extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.RequestTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionClosedRequireAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.ThrottledOpException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnknownSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

  - ### Class org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException extends IOException implements Serializable

    - ### Serialized Fields

      - #### exitCode

            int exitCode

- ## Package org.apache.storm.spout

  - ### Class org.apache.storm.spout.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 extends Object implements Serializable

  - ### Class org.apache.storm.spout.RawScheme extends Object implements Serializable

  - ### Class org.apache.storm.spout.SchemeAsMultiScheme extends Object implements Serializable

    - ### Serialized Fields

      - #### scheme

            Scheme scheme

  - ### Class org.apache.storm.spout.ShellSpout extends Object implements Serializable

    serialVersionUID:
      5982357019665454L

    - ### Serialized Fields

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

  - ### Class org.apache.storm.sql.javac.CompilingClassLoader.CompilerException extends Exception implements Serializable

    serialVersionUID:
      -2936958840023603270L

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

  - ### Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter extends Object implements Serializable

    serialVersionUID:
      1L

    - ### Serialized Fields

      - #### delegate

            Scheme delegate

- ## Package org.apache.storm.sql.parser.impl

  - ### Class org.apache.storm.sql.parser.impl.ParseException extends Exception implements Serializable

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

  - ### Class org.apache.storm.sql.parser.impl.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### delegate

            ExecutableExpression delegate

      - #### delegateCode

            String delegateCode

  - ### Class org.apache.storm.sql.runtime.calcite.StormDataContext extends Object implements Serializable

    - ### Serialized Fields

      - #### map

            com.google.common.collect.ImmutableMap<Object,​Object> map

- ## Package org.apache.storm.sql.runtime.datasource.socket.bolt

  - ### Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### fieldNames

            List<String> fieldNames

  - ### Class org.apache.storm.sql.runtime.serde.csv.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### fields

            List<String> fields

  - ### Class org.apache.storm.sql.runtime.serde.json.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### delimiter

            char delimiter

      - #### fieldNames

            List<String> fieldNames

  - ### Class org.apache.storm.sql.runtime.serde.tsv.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 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 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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### primaryKeyIndex

            int primaryKeyIndex

  - ### Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldNames

            List<String> fieldNames

- ## Package org.apache.storm.st.topology.window

  - ### Class org.apache.storm.st.topology.window.IncrementingSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### componentId

            String componentId

      - #### currentNum

            int currentNum

  - ### Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### componentId

            String componentId

      - #### currentNum

            int currentNum

  - ### Class org.apache.storm.st.topology.window.TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### componentId

            String componentId

  - ### Class org.apache.storm.st.topology.window.VerificationBolt extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### componentId

            String componentId

- ## Package org.apache.storm.starter

  - ### Class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### random

            Random random

  - ### Class org.apache.storm.starter.AnchoredWordCount.SplitSentence extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.AnchoredWordCount.WordCount extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

  - ### Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### poll

            boolean poll

      - #### pollTime

            long pollTime

      - #### wordSet

            Set<String> wordSet

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

  - ### Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### rand

            Random rand

  - ### Class org.apache.storm.starter.FastWordCountTopology.SplitSentence extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.FastWordCountTopology.WordCount extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

  - ### Class org.apache.storm.starter.InOrderDeliveryTest.Check extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### expected

            Map<Integer,​Integer> expected

  - ### Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### base

            int base

      - #### collector

            SpoutOutputCollector collector

      - #### count

            int count

  - ### Class org.apache.storm.starter.ManualDRPC.ExclamationBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### logger

            org.slf4j.Logger logger

      - #### rootLogger

            org.slf4j.Logger rootLogger

      - #### subLogger

            org.slf4j.Logger subLogger

  - ### Class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentence extends Object implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### executor

            ExecutorService executor

  - ### Class org.apache.storm.starter.ReachTopology.CountAggregator extends BaseBatchBolt<Object> implements Serializable

    - ### Serialized Fields

      - #### collector

            BatchOutputCollector collector

      - #### count

            int count

      - #### id

            Object id

  - ### Class org.apache.storm.starter.ReachTopology.GetFollowers extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.ReachTopology.GetTweeters extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.ReachTopology.PartialUniquer extends BaseBatchBolt<Object> implements Serializable

    - ### Serialized Fields

      - #### collector

            BatchOutputCollector collector

      - #### followers

            Set<String> followers

      - #### id

            Object id

  - ### Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

  - ### Class org.apache.storm.starter.StatefulTopology.PrinterBolt extends BaseBasicBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopology.SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence extends ShellSpout implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence extends ShellBolt implements Serializable

  - ### Class org.apache.storm.starter.WordCountTopologyNode.WordCount extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

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

  - ### Class org.apache.storm.starter.bolt.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 extends AbstractRankerBolt implements Serializable

    serialVersionUID:
      -1369800530256637409L

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

  - ### Class org.apache.storm.starter.bolt.RollingCountAggBolt extends BaseRichBolt implements Serializable

    serialVersionUID:
      5537727428628598519L

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### counts

            Map<Object,​Map<Integer,​Long>> counts

  - ### Class org.apache.storm.starter.bolt.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 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 extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### sum

            int sum

  - ### Class org.apache.storm.starter.bolt.TotalRankingsBolt extends AbstractRankerBolt implements Serializable

    serialVersionUID:
      -8447525895532302198L

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

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

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

  - ### Class org.apache.storm.starter.spout.RandomIntegerSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### msgId

            long msgId

      - #### rand

            Random rand

  - ### Class org.apache.storm.starter.spout.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 extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### rand

            Random rand

  - ### Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped extends RandomSentenceSpout implements Serializable

    - ### Serialized Fields

      - #### prefix

            String prefix

- ## Package org.apache.storm.starter.tools

  - ### Class org.apache.storm.starter.tools.RankableObjectWithFields extends Object implements Serializable

    serialVersionUID:
      -9102878650001058090L

    - ### Serialized Fields

      - #### count

            long count

      - #### fields

            com.google.common.collect.ImmutableList<Object> fields

      - #### obj

            Object obj

  - ### Class org.apache.storm.starter.tools.Rankings extends Object implements Serializable

    serialVersionUID:
      -1549827195410578903L

    - ### Serialized Fields

      - #### maxSize

            int maxSize

      - #### rankedItems

            List<Rankable> rankedItems

  - ### Class org.apache.storm.starter.tools.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.starter.trident.TridentReach.ExpandList extends BaseFunction implements Serializable

  - ### Class org.apache.storm.starter.trident.TridentReach.One extends Object implements Serializable

  - ### Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory extends Object implements Serializable

    - ### Serialized Fields

      - #### map

            Map map

  - ### Class org.apache.storm.starter.trident.TridentWordCount.Split extends BaseFunction implements Serializable

- ## Package org.apache.storm.state

  - ### Class org.apache.storm.state.DefaultStateSerializer extends Object implements Serializable

    - ### Serialized Fields

      - #### context

            TopologyContext context

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

    - ### Serialized Fields

      - #### value1

            T1 value1

        The first value.

      - #### value2

            T2 value2

        The second value.

  - ### Class org.apache.storm.streams.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 extends Object implements Serializable

  - ### Class org.apache.storm.streams.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 extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.PairValueJoiner extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.PrintConsumer extends Object implements Serializable

- ## Package org.apache.storm.streams.operations.aggregators

  - ### Class org.apache.storm.streams.operations.aggregators.Count extends Object implements Serializable

  - ### Class org.apache.storm.streams.operations.aggregators.LongSum extends Object implements Serializable

- ## Package org.apache.storm.streams.operations.mappers

  - ### Class org.apache.storm.streams.operations.mappers.PairValueMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### keyIndex

            int keyIndex

      - #### valueIndex

            int valueIndex

  - ### Class org.apache.storm.streams.operations.mappers.ValueMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### index

            int index

  - ### Class org.apache.storm.streams.operations.mappers.ValuesMapper extends Object implements Serializable

    - ### Serialized Fields

      - #### indices

            int[] indices

- ## Package org.apache.storm.streams.processors

  - ### Class org.apache.storm.streams.processors.AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,​V>> implements Serializable

    - ### Serialized Fields

      - #### aggregator

            CombinerAggregator<V,​A,​R> aggregator

      - #### emitAggregate

            boolean emitAggregate

      - #### state

            Map<K,​A> state

  - ### Class org.apache.storm.streams.processors.AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### aggregator

            CombinerAggregator<T,​A,​R> aggregator

      - #### emitAggregate

            boolean emitAggregate

      - #### state

            A state

  - ### Class org.apache.storm.streams.processors.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### contexts

            List<? extends ProcessorContext> contexts

      - #### processorNode

            ProcessorNode processorNode

  - ### Class org.apache.storm.streams.processors.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 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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### predicate

            Predicate<T> predicate

  - ### Class org.apache.storm.streams.processors.FlatMapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### function

            FlatMapFunction<T,​R> function

  - ### Class org.apache.storm.streams.processors.FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,​V>> implements Serializable

    - ### Serialized Fields

      - #### function

            FlatMapFunction<V,​R> function

  - ### Class org.apache.storm.streams.processors.ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### consumer

            Consumer<T> consumer

  - ### Class org.apache.storm.streams.processors.ForwardingProcessorContext extends Object implements Serializable

    - ### Serialized Fields

      - #### processorNode

            ProcessorNode processorNode

      - #### streams

            Set<String> streams

      - #### streamToChildren

            org.apache.storm.shade.com.google.common.collect.Multimap<String,​ProcessorNode> streamToChildren

  - ### Class org.apache.storm.streams.processors.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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### function

            Function<T,​R> function

  - ### Class org.apache.storm.streams.processors.MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,​V>> implements Serializable

    - ### Serialized Fields

      - #### function

            Function<V,​R> function

  - ### Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,​A>> implements Serializable

    - ### Serialized Fields

      - #### aggregator

            CombinerAggregator<V,​A,​R> aggregator

      - #### state

            Map<K,​A> state

  - ### Class org.apache.storm.streams.processors.MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable

    - ### Serialized Fields

      - #### aggregator

            CombinerAggregator<T,​A,​R> aggregator

      - #### state

            A state

  - ### Class org.apache.storm.streams.processors.PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### consumer

            Consumer<T> consumer

  - ### Class org.apache.storm.streams.processors.ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,​V>> implements Serializable

    - ### Serialized Fields

      - #### reducer

            Reducer<V> reducer

      - #### state

            Map<K,​V> state

  - ### Class org.apache.storm.streams.processors.ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

    - ### Serialized Fields

      - #### agg

            T agg

      - #### reducer

            Reducer<T> reducer

  - ### Class org.apache.storm.streams.processors.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### lag

            BaseWindowedBolt.Duration lag

      - #### lateTupleStream

            String lateTupleStream

      - #### timestampField

            String timestampField

  - ### Class org.apache.storm.streams.windowing.SlidingWindows extends BaseWindow<L,​I> implements Serializable

    - ### Serialized Fields

      - #### slidingInterval

            I slidingInterval

      - #### windowLength

            L windowLength

  - ### Class org.apache.storm.streams.windowing.TumblingWindows extends BaseWindow<L,​L> implements Serializable

    - ### Serialized Fields

      - #### windowLength

            L windowLength

- ## Package org.apache.storm.task

  - ### Class org.apache.storm.task.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### acked

            String acked

      - #### failed

            String failed

  - ### Class org.apache.storm.testing.AckTracker extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable

    - ### Serialized Fields

      - #### richDelegate

            IRichBolt richDelegate

  - ### Class org.apache.storm.testing.FeederSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### ackFailDelegate

            AckFailDelegate ackFailDelegate

      - #### collector

            SpoutOutputCollector collector

      - #### id

            int id

      - #### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.FixedTuple extends Object implements Serializable

    - ### Serialized Fields

      - #### stream

            String stream

      - #### values

            List<Object> values

  - ### Class org.apache.storm.testing.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 extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### fields

            Fields fields

  - ### Class org.apache.storm.testing.NGrouping extends Object implements Serializable

    - ### Serialized Fields

      - #### number

            int number

      - #### outTasks

            List<Integer> outTasks

  - ### Class org.apache.storm.testing.NonRichBoltTracker extends Object implements Serializable

    - ### Serialized Fields

      - #### delegate

            IBolt delegate

      - #### trackId

            String trackId

  - ### Class org.apache.storm.testing.PrepareBatchBolt extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.PythonShellMetricsBolt extends ShellBolt implements Serializable

    serialVersionUID:
      1999209252187463355L

  - ### Class org.apache.storm.testing.PythonShellMetricsSpout extends ShellSpout implements Serializable

    serialVersionUID:
      1999209252187463355L

  - ### Class org.apache.storm.testing.SpoutTracker extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### delegate

            IRichSpout delegate

      - #### tracker

            org.apache.storm.testing.SpoutTracker.SpoutTrackOutputCollector tracker

      - #### trackId

            String trackId

  - ### Class org.apache.storm.testing.TestAggregatesCounter extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### counts

            Map<String,​Integer> counts

  - ### Class org.apache.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### componentConf

            Map<String,​Object> componentConf

      - #### conf

            Map<String,​Object> conf

  - ### Class org.apache.storm.testing.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 extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### count

            int count

      - #### recentEventId

            Map<Integer,​Long> recentEventId

  - ### Class org.apache.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### count

            int count

  - ### Class org.apache.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable

  - ### Class org.apache.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### isDistributed

            boolean isDistributed

      - #### outFields

            Fields outFields

  - ### Class org.apache.storm.testing.TestSerObject extends Object implements Serializable

    - ### Serialized Fields

      - #### f1

            int f1

      - #### f2

            int f2

  - ### Class org.apache.storm.testing.TestWordBytesCounter extends TestWordCounter implements Serializable

  - ### Class org.apache.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable

    - ### Serialized Fields

      - #### counts

            Map<String,​Integer> counts

  - ### Class org.apache.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable

    - ### Serialized Fields

      - #### collector

            SpoutOutputCollector collector

      - #### isDistributed

            boolean isDistributed

  - ### Class org.apache.storm.testing.TupleCaptureBolt extends Object implements Serializable

    - ### Serialized Fields

      - #### collector

            OutputCollector collector

      - #### name

            String name

- ## Package org.apache.storm.topology

  - ### Class org.apache.storm.topology.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### bolt

            IBasicBolt bolt

  - ### Class org.apache.storm.topology.CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable

    - ### Serialized Fields

      - #### bolt

            IRichBolt bolt

  - ### Class org.apache.storm.topology.FailedException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.topology.PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

    - ### Serialized Fields

      - #### statefulWindowedBolt

            IStatefulWindowedBolt<T extends State> statefulWindowedBolt

  - ### Class org.apache.storm.topology.ReportedFailedException extends FailedException implements Serializable

  - ### Class org.apache.storm.topology.SharedOffHeapWithinNode extends SharedMemory implements Serializable

    serialVersionUID:
      1L

  - ### Class org.apache.storm.topology.SharedOffHeapWithinWorker extends SharedMemory implements Serializable

  - ### Class org.apache.storm.topology.SharedOnHeap extends SharedMemory implements Serializable

    serialVersionUID:
      1L

  - ### Class org.apache.storm.topology.StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable

    - ### Serialized Fields

      - #### bolt

            IStatefulBolt<T extends State> bolt

      - #### 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 extends WindowedBoltExecutor implements Serializable

    - ### Serialized Fields

      - #### statefulWindowedBolt

            IStatefulWindowedBolt<T extends State> statefulWindowedBolt

  - ### Class org.apache.storm.topology.TupleFieldTimestampExtractor extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldName

            String fieldName

  - ### Class org.apache.storm.topology.WindowedBoltExecutor extends Object implements Serializable

    - ### Serialized Fields

      - #### bolt

            IWindowedBolt bolt

      - #### timestampExtractor

            TimestampExtractor timestampExtractor

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

  - ### Class org.apache.storm.topology.base.BaseBasicBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseBatchBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseComponent extends Object implements Serializable

  - ### Class org.apache.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable

  - ### Class org.apache.storm.topology.base.BaseStatefulBolt extends Object implements Serializable

  - ### Class org.apache.storm.topology.base.BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable

    - ### Serialized Fields

      - #### maxEventsInMemory

            long maxEventsInMemory

      - #### persistent

            boolean persistent

  - ### Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt extends Object implements Serializable

    - ### Serialized Fields

      - #### timestampExtractor

            TimestampExtractor timestampExtractor

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt.Count extends Object implements Serializable

    - ### Serialized Fields

      - #### value

            int value

  - ### Class org.apache.storm.topology.base.BaseWindowedBolt.Duration extends Object implements Serializable

    - ### Serialized Fields

      - #### value

            int value

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

  - ### Class org.apache.storm.trident.drpc.ReturnResultsReducer extends Object implements Serializable

    - ### Serialized Fields

      - #### 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 extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseFilter extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseFunction extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseMultiReducer extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.BaseOperation extends Object implements Serializable

- ## Package org.apache.storm.trident.operation.builtin

  - ### Class org.apache.storm.trident.operation.builtin.ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable

    - ### Serialized Fields

      - #### batchId

            Object batchId

      - #### inputFieldName

            String inputFieldName

  - ### Class org.apache.storm.trident.operation.builtin.Count extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Debug extends BaseFilter implements Serializable

    - ### Serialized Fields

      - #### name

            String name

      - #### useLogger

            boolean useLogger

  - ### Class org.apache.storm.trident.operation.builtin.Equals extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.FilterNull extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable

    - ### Serialized Fields

      - #### number

            int number

  - ### Class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable

    - ### Serialized Fields

      - #### number

            int number

      - #### reverse

            boolean reverse

      - #### sortField

            String sortField

  - ### Class org.apache.storm.trident.operation.builtin.MapGet extends BaseQueryFunction<ReadOnlyMapState,​Object> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Max extends ComparisonAggregator<Comparable<Object>> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.MaxWithComparator extends ComparisonAggregator<T> implements Serializable

    - ### Serialized Fields

      - #### comparator

            Comparator<T> comparator

  - ### Class org.apache.storm.trident.operation.builtin.Min extends ComparisonAggregator<Comparable<Object>> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.MinWithComparator extends ComparisonAggregator<T> implements Serializable

    - ### Serialized Fields

      - #### comparator

            Comparator<T> comparator

  - ### Class org.apache.storm.trident.operation.builtin.Negate extends Object implements Serializable

    - ### Serialized Fields

      - #### delegate

            Filter delegate

  - ### Class org.apache.storm.trident.operation.builtin.SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,​Object> implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.Sum extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.builtin.TupleCollectionGet extends BaseQueryFunction<State,​Iterator<List<Object>>> implements Serializable

- ## Package org.apache.storm.trident.operation.impl

  - ### Class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl extends Object implements Serializable

    - ### Serialized Fields

      - #### aggs

            Aggregator[] aggs

      - #### fact

            ComboList.Factory fact

      - #### inputFactories

            TridentTupleView.ProjectionFactory[] inputFactories

      - #### inputFields

            Fields[] inputFields

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl extends Object implements Serializable

    - ### Serialized Fields

      - #### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl extends Object implements Serializable

    - ### Serialized Fields

      - #### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater extends Object implements Serializable

    - ### Serialized Fields

      - #### agg

            CombinerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.ConsumerExecutor extends BaseOperation implements Serializable

    - ### Serialized Fields

      - #### consumer

            Consumer consumer

  - ### Class org.apache.storm.trident.operation.impl.FilterExecutor extends Object implements Serializable

    - ### Serialized Fields

      - #### filter

            Filter filter

  - ### Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor extends BaseOperation implements Serializable

    - ### Serialized Fields

      - #### function

            FlatMapFunction function

  - ### Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.impl.GroupedAggregator extends Object implements Serializable

    - ### Serialized Fields

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

  - ### Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition extends Object implements Serializable

  - ### Class org.apache.storm.trident.operation.impl.JoinerMultiReducer extends Object implements Serializable

    - ### Serialized Fields

      - #### factory

            ComboList.Factory factory

      - #### numGroupFields

            int numGroupFields

      - #### sideFields

            List<Fields> sideFields

      - #### types

            List<JoinType> types

  - ### Class org.apache.storm.trident.operation.impl.MapFunctionExecutor extends BaseOperation implements Serializable

    - ### Serialized Fields

      - #### function

            MapFunction function

  - ### Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### agg

            ReducerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater extends Object implements Serializable

    - ### Serialized Fields

      - #### agg

            ReducerAggregator agg

  - ### Class org.apache.storm.trident.operation.impl.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 extends Object implements Serializable

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

  - ### Class org.apache.storm.trident.partition.GlobalGrouping extends Object implements Serializable

    - ### Serialized Fields

      - #### target

            List<Integer> target

  - ### Class org.apache.storm.trident.partition.IdentityGrouping extends Object implements Serializable

    - ### Serialized Fields

      - #### precomputed

            Map<Integer,​List<Integer>> precomputed

  - ### Class org.apache.storm.trident.partition.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 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 extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            String id

      - #### spec

            StateSpec spec

  - ### Class org.apache.storm.trident.planner.PartitionNode extends Node implements Serializable

    - ### Serialization Methods

      - #### readObject

            private void readObject​(ObjectInputStream ois)
                             throws ClassNotFoundException,
                                    IOException

        Throws:
          `ClassNotFoundException`
          `IOException`

      - #### writeObject

            private void writeObject​(ObjectOutputStream oos)
                              throws IOException

        Throws:
          `IOException`

  - ### Class org.apache.storm.trident.planner.ProcessorNode extends Node implements Serializable

    - ### Serialized Fields

      - #### committer

            boolean committer

      - #### processor

            TridentProcessor processor

      - #### selfOutFields

            Fields selfOutFields

  - ### Class org.apache.storm.trident.planner.SpoutNode extends Node implements Serializable

    - ### Serialized Fields

      - #### spout

            Object spout

      - #### txId

            String txId

      - #### type

            SpoutNode.SpoutType type

  - ### Class org.apache.storm.trident.planner.SubtopologyBolt extends Object implements Serializable

    serialVersionUID:
      1475508603138688412L

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### context

            TridentContext context

      - #### factory

            TridentTupleView.ProjectionFactory factory

      - #### projectFields

            Fields projectFields

  - ### Class org.apache.storm.trident.planner.processor.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### spout

            IBatchSpout spout

  - ### Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable

    - ### Serialized Fields

      - #### spout

            IOpaquePartitionedTridentSpout<Object,​ISpoutPartition,​Object> spout

  - ### Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor extends Object implements Serializable

    - ### Serialized Fields

      - #### spout

            IPartitionedTridentSpout<Object,​ISpoutPartition,​Object> spout

  - ### Class org.apache.storm.trident.spout.RichSpoutBatchExecutor extends Object implements Serializable

    - ### Serialized Fields

      - #### spout

            IRichSpout spout

  - ### Class org.apache.storm.trident.spout.RichSpoutBatchTriggerer extends Object implements Serializable

    - ### Serialized Fields

      - #### 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 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 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 extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.state.BaseStateUpdater extends BaseOperation implements Serializable

  - ### Class org.apache.storm.trident.state.JSONNonTransactionalSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.JSONOpaqueSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.JSONTransactionalSerializer extends Object implements Serializable

  - ### Class org.apache.storm.trident.state.StateSpec extends Object implements Serializable

    - ### Serialized Fields

      - #### requiredNumPartitions

            Integer requiredNumPartitions

      - #### stateFactory

            StateFactory stateFactory

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

  - ### Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater extends Object implements Serializable

    serialVersionUID:
      -3960578785572592092L

    - ### Serialized Fields

      - #### agg

            CombinerAggregator agg

      - #### factory

            ComboList.Factory factory

      - #### groupFields

            Fields groupFields

      - #### inputFields

            Fields inputFields

  - ### Class org.apache.storm.trident.state.map.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 extends Object implements Serializable

    - ### Serialized Fields

      - #### maxMultiGetBatchSize

            int maxMultiGetBatchSize

      - #### maxMultiPutBatchSize

            int maxMultiPutBatchSize

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

  - ### Class org.apache.storm.trident.testing.CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable

  - ### Class org.apache.storm.trident.testing.FeederBatchSpout extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            String id

      - #### outFields

            Fields outFields

      - #### semaphoreId

            String semaphoreId

      - #### waitToEmit

            boolean waitToEmit

  - ### Class org.apache.storm.trident.testing.FeederCommitterBatchSpout extends Object implements Serializable

    - ### Serialized Fields

      - #### spout

            FeederBatchSpout spout

  - ### Class org.apache.storm.trident.testing.FixedBatchSpout extends Object implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### id

            String id

      - #### maxSize

            int maxSize

  - ### Class org.apache.storm.trident.testing.MemoryMapState.Factory extends Object implements Serializable

    - ### Serialized Fields

      - #### id

            String id

  - ### Class org.apache.storm.trident.testing.Split extends BaseFunction implements Serializable

  - ### Class org.apache.storm.trident.testing.StringLength extends BaseFunction implements Serializable

  - ### Class org.apache.storm.trident.testing.TrueFilter extends BaseFilter implements Serializable

  - ### Class org.apache.storm.trident.testing.TuplifyArgs extends BaseFunction implements Serializable

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

  - ### Class org.apache.storm.trident.topology.MasterBatchCoordinator extends BaseRichSpout implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### commitStream

            GlobalStreamId commitStream

      - #### expectedTaskReports

            int expectedTaskReports

      - #### targetTasks

            Set<Integer> targetTasks

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec extends Object implements Serializable

    - ### Serialized Fields

      - #### commitStream

            GlobalStreamId commitStream

      - #### coords

            Map<String,​TridentBoltExecutor.CoordType> coords

  - ### Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType extends Object implements Serializable

    - ### Serialized Fields

      - #### singleCount

            boolean singleCount

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

  - ### Class org.apache.storm.trident.tuple.ComboList.Factory extends Object implements Serializable

    - ### Serialized Fields

      - #### index

            org.apache.storm.trident.tuple.ComboList.Pointer[] index

      - #### sizes

            int[] sizes

  - ### Class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory extends Object implements Serializable

    - ### Serialized Fields

      - #### fieldIndex

            Map<String,​ValuePointer> fieldIndex

      - #### index

            ValuePointer[] index

  - ### Class org.apache.storm.trident.tuple.TridentTupleView.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 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 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 extends Object implements Serializable

  - ### Class org.apache.storm.trident.util.IndexedEdge extends Object implements Serializable

    - ### Serialized Fields

      - #### index

            int index

      - #### source

            T source

      - #### target

            T target

  - ### Class org.apache.storm.trident.util.LRUMap extends LinkedHashMap<A,​B> implements Serializable

    - ### Serialized Fields

      - #### maxSize

            int maxSize

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

  - ### Class org.apache.storm.trident.windowing.InMemoryWindowsStore extends Object implements Serializable

    - ### Serialized Fields

      - #### backingStore

            WindowsStore backingStore

      - #### currentSize

            AtomicInteger currentSize

      - #### maxSize

            int maxSize

      - #### store

            ConcurrentHashMap<String,​Object> store

  - ### Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory extends Object implements Serializable

    - ### Serialized Fields

      - #### inMemoryWindowsStore

            InMemoryWindowsStore inMemoryWindowsStore

  - ### Class org.apache.storm.trident.windowing.WindowsStateFactory extends Object implements Serializable

  - ### Class org.apache.storm.trident.windowing.WindowsStateUpdater extends Object implements Serializable

    - ### Serialized Fields

      - #### windowsStore

            WindowsStore windowsStore

      - #### windowStoreFactory

            WindowsStoreFactory windowStoreFactory

  - ### Class org.apache.storm.trident.windowing.WindowsStore.Entry extends Object implements Serializable

    - ### Serialized Fields

      - #### key

            String key

      - #### value

            Object value

  - ### Class org.apache.storm.trident.windowing.WindowTridentProcessor extends Object implements Serializable

    - ### Serialized Fields

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

    - ### Serialized Fields

      - #### slideLength

            int slideLength

      - #### windowLength

            int windowLength

  - ### Class org.apache.storm.trident.windowing.config.SlidingCountWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.SlidingDurationWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.TumblingCountWindow extends BaseWindowConfig implements Serializable

  - ### Class org.apache.storm.trident.windowing.config.TumblingDurationWindow extends BaseWindowConfig implements Serializable

- ## Package org.apache.storm.tuple

  - ### Class org.apache.storm.tuple.Fields extends Object implements Serializable

    serialVersionUID:
      -3377931843059975424L

    - ### Serialized Fields

      - #### fields

            List<String> fields

      - #### index

            Map<String,​Integer> index

  - ### Class org.apache.storm.tuple.Values extends ArrayList<Object> implements Serializable

- ## Package org.apache.storm.utils

  - ### Class org.apache.storm.utils.DisallowedStrategyException extends RuntimeException implements Serializable

    - ### Serialized Fields

      - #### allowedStrategies

            List<String> allowedStrategies

      - #### attemptedClass

            String attemptedClass

  - ### Class org.apache.storm.utils.LruMap extends LinkedHashMap<A,​B> implements Serializable

    - ### Serialized Fields

      - #### evCb

            LruMap.CacheEvictionCallback evCb

      - #### maxSize

            int maxSize

  - ### Class org.apache.storm.utils.NimbusLeaderNotFoundException extends RuntimeException implements Serializable

  - ### Class org.apache.storm.utils.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 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

  - ### Class org.apache.storm.utils.ShellUtils.ExitCodeException extends IOException implements Serializable

    - ### Serialized Fields

      - #### exitCode

            int exitCode

  - ### Class org.apache.storm.utils.WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable

  - ### Class org.apache.storm.utils.WrappedAuthorizationException extends AuthorizationException implements Serializable

  - ### Class org.apache.storm.utils.WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable

  - ### Class org.apache.storm.utils.WrappedHBExecutionException extends HBExecutionException implements Serializable

  - ### Class org.apache.storm.utils.WrappedIllegalStateException extends IllegalStateException implements Serializable

  - ### Class org.apache.storm.utils.WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable

  - ### Class org.apache.storm.utils.WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable

  - ### Class org.apache.storm.utils.WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable

  - ### Class org.apache.storm.utils.WrappedNotAliveException extends NotAliveException implements Serializable

- ## Package org.apache.storm.windowing