Serialized Form (Storm 2.6.2 API)

Package org.apache.calcite.interpreter
- Class org.apache.calcite.interpreter.StormContext
  
  class StormContext extends org.apache.calcite.interpreter.Context implements Serializable
Package org.apache.storm
- Class org.apache.storm.clojure$ack_BANG_
  
  class clojure$ack_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$bolt
  
  class clojure$bolt extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$bolt_execute
  
  class clojure$bolt_execute extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$bolt$fn__704
  
  class clojure$bolt$fn__704 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_bolt
  
  class clojure$clojure_bolt extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_bolt_STAR_
  
  class clojure$clojure_bolt_STAR_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_spout
  
  class clojure$clojure_spout extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$clojure_spout_STAR_
  
  class clojure$clojure_spout_STAR_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$collectify
  
  class clojure$collectify extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$defalias
  
  class clojure$defalias extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$defbolt
  
  class clojure$defbolt extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$defspout
  
  class clojure$defspout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$direct_stream
  
  class clojure$direct_stream extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$emit_bolt_BANG_
  
  class clojure$emit_bolt_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_direct_bolt_BANG_
  
  class clojure$emit_direct_bolt_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_direct_spout_BANG_
  
  class clojure$emit_direct_spout_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$emit_spout_BANG_
  
  class clojure$emit_spout_BANG_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$fail_BANG_
  
  class clojure$fail_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__671
  
  class clojure$fn__671 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__735
  
  class clojure$fn__735 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__738
  
  class clojure$fn__738 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__738$G__733__747
  
  class clojure$fn__738$G__733__747 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    G__734
    
    Object G__734
- Class org.apache.storm.clojure$fn__738$G__734__742
  
  class clojure$fn__738$G__734__742 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__753
  
  class clojure$fn__753 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__753$iter__754__758
  
  class clojure$fn__753$iter__754__758 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__753$iter__754__758$fn__759
  
  class clojure$fn__753$iter__754__758$fn__759 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    iter__754
    
    Object iter__754
    
    s__755
    
    Object s__755
- Class org.apache.storm.clojure$fn__753$iter__754__758$fn__759$fn__760
  
  class clojure$fn__753$iter__754__758$fn__759$fn__760 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    b__757
    
    Object b__757
    
    c__6371__auto__
    
    Object c__6371__auto__
    
    size__6372__auto__
    
    int size__6372__auto__
- Class org.apache.storm.clojure$fn__775
  
  class clojure$fn__775 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__794
  
  class clojure$fn__794 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__796
  
  class clojure$fn__796 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__798
  
  class clojure$fn__798 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__800
  
  class clojure$fn__800 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$fn__802
  
  class clojure$fn__802 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$loading__6789__auto____669
  
  class clojure$loading__6789__auto____669 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$local_cluster
  
  class clojure$local_cluster extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns
  
  class clojure$normalize_fns extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns$iter__679__683
  
  class clojure$normalize_fns$iter__679__683 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$normalize_fns$iter__679__683$fn__684
  
  class clojure$normalize_fns$iter__679__683$fn__684 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    iter__679
    
    Object iter__679
    
    s__680
    
    Object s__680
- Class org.apache.storm.clojure$normalize_fns$iter__679__683$fn__684$fn__685
  
  class clojure$normalize_fns$iter__679__683$fn__684$fn__685 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    b__682
    
    Object b__682
    
    c__6371__auto__
    
    Object c__6371__auto__
    
    size__6372__auto__
    
    int size__6372__auto__
- Class org.apache.storm.clojure$report_error_BANG_
  
  class clojure$report_error_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$reset_timeout_BANG_
  
  class clojure$reset_timeout_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$spout
  
  class clojure$spout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.clojure$spout$fn__712
  
  class clojure$spout$fn__712 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$submit_remote_topology
  
  class clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.clojure$to_spec
  
  class clojure$to_spec extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.Config
  
  class Config extends HashMap<String,Object> implements Serializable
  
  serialVersionUID:
  
  -1550278723792864455L
- Class org.apache.storm.config$clojure_config_name
  
  class config$clojure_config_name extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$fn__536
  
  class config$fn__536 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$fn__543
  
  class config$fn__543 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.config$loading__6789__auto____534
  
  class config$loading__6789__auto____534 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.ExclamationTopology.ExclamationBolt
  
  class ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout
  
  class FixedOrderWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    currentIndex
    
    int currentIndex
    
    numEmitted
    
    int numEmitted
- Class org.apache.storm.LocalCluster.LocalTopology
  
  class LocalTopology extends StormTopology implements Serializable
  
  serialVersionUID:
  
  6145919776650637748L
  - Serialized Fields
    
    topoName
    
    String topoName
- Class org.apache.storm.log$fn__456
  
  class log$fn__456 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.log$loading__6789__auto____273
  
  class log$loading__6789__auto____273 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.log$log_debug
  
  class log$log_debug extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_error
  
  class log$log_error extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_message
  
  class log$log_message extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.log$log_warn
  
  class log$log_warn extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$add_supervisor
  
  class testing$add_supervisor extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$advance_cluster_time
  
  class testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$capture_topology
  
  class testing$capture_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$complete_topology
  
  class testing$complete_topology extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$fn__288
  
  class testing$fn__288 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$get_supervisor
  
  class testing$get_supervisor extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$global_amt
  
  class testing$global_amt extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$increment_global_BANG_
  
  class testing$increment_global_BANG_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$kill_local_storm_cluster
  
  class testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$kill_supervisor
  
  class testing$kill_supervisor extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$loading__6789__auto____271
  
  class testing$loading__6789__auto____271 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$local_cluster_state
  
  class testing$local_cluster_state extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$mk_local_storm_cluster
  
  class testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mk_mocked_nimbus
  
  class testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mk_tracked_topology
  
  class testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$mkClusterParam
  
  class testing$mkClusterParam extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$mock_leader_elector
  
  class testing$mock_leader_elector extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$ms_EQ_
  
  class testing$ms_EQ_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$read_tuples
  
  class testing$read_tuples extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$simulate_wait
  
  class testing$simulate_wait extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects
  
  class testing$spout_objects extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects$iter__337__341
  
  class testing$spout_objects$iter__337__341 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342
  
  class testing$spout_objects$iter__337__341$fn__342 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    iter__337
    
    Object iter__337
    
    s__338
    
    Object s__338
- Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342$fn__343
  
  class testing$spout_objects$iter__337__341$fn__342$fn__343 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    b__340
    
    Object b__340
    
    c__6371__auto__
    
    Object c__6371__auto__
    
    size__6372__auto__
    
    int size__6372__auto__
- Class org.apache.storm.testing$submit_local_topology
  
  class testing$submit_local_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$submit_local_topology_with_opts
  
  class testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$test_tuple
  
  class testing$test_tuple extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$tracked_wait
  
  class testing$tracked_wait extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_for_condition
  
  class testing$wait_for_condition extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_for_condition$fn__309
  
  class testing$wait_for_condition$fn__309 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$wait_until_cluster_waiting
  
  class testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.testing$while_timeout
  
  class testing$while_timeout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_inprocess_zookeeper
  
  class testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_local_cluster
  
  class testing$with_local_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_mocked_nimbus
  
  class testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_simulated_time_local_cluster
  
  class testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_timeout
  
  class testing$with_timeout extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.testing$with_tracked_cluster
  
  class testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$add_inputs
  
  class thrift$add_inputs extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$deserialized_component_object
  
  class thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$direct_output_fields
  
  class thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$field_grouping
  
  class thrift$field_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$fn__547
  
  class thrift$fn__547 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$global_grouping_QMARK_
  
  class thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$grouping_type
  
  class thrift$grouping_type extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$instantiate_java_object
  
  class thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$instantiate_java_object$fn__550
  
  class thrift$instantiate_java_object$fn__550 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$loading__6789__auto____532
  
  class thrift$loading__6789__auto____532 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_all_grouping
  
  class thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_bolt_spec
  
  class thrift$mk_bolt_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_bolt_spec_STAR_
  
  class thrift$mk_bolt_spec_STAR_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_direct_grouping
  
  class thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_fields_grouping
  
  class thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_global_grouping
  
  class thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_grouping
  
  class thrift$mk_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs
  
  class thrift$mk_inputs extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs$iter__591__595
  
  class thrift$mk_inputs$iter__591__595 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_inputs$iter__591__595$fn__596
  
  class thrift$mk_inputs$iter__591__595$fn__596 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    iter__591
    
    Object iter__591
    
    s__592
    
    Object s__592
- Class org.apache.storm.thrift$mk_inputs$iter__591__595$fn__596$fn__597
  
  class thrift$mk_inputs$iter__591__595$fn__596$fn__597 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    b__594
    
    Object b__594
    
    c__6371__auto__
    
    Object c__6371__auto__
    
    size__6372__auto__
    
    int size__6372__auto__
- Class org.apache.storm.thrift$mk_local_or_shuffle_grouping
  
  class thrift$mk_local_or_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_none_grouping
  
  class thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_output_spec
  
  class thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_output_spec$fn__574
  
  class thrift$mk_output_spec$fn__574 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_plain_component_common
  
  class thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shell_bolt_spec
  
  class thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shell_spout_spec
  
  class thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_shuffle_grouping
  
  class thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$mk_spout_spec
  
  class thrift$mk_spout_spec extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_spout_spec_STAR_
  
  class thrift$mk_spout_spec_STAR_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$mk_topology
  
  class thrift$mk_topology extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$nimbus_client_and_conn
  
  class thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$output_fields
  
  class thrift$output_fields extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$parallelism_hint
  
  class thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$serialize_component_object
  
  class thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$shell_component_params
  
  class thrift$shell_component_params extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.thrift$with_configured_nimbus_connection
  
  class thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.thrift$with_nimbus_connection
  
  class thrift$with_nimbus_connection extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$__LT__GT_
  
  class util$__LT__GT_ extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$__LT__GT_$fn__528
  
  class util$__LT__GT_$fn__528 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_error
  
  class util$clojurify_error extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_structure
  
  class util$clojurify_structure extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$clojurify_structure$fn__488
  
  class util$clojurify_structure$fn__488 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$defnk
  
  class util$defnk extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$defnk$fn__482
  
  class util$defnk$fn__482 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$dofor
  
  class util$dofor extends clojure.lang.RestFn implements Serializable
- Class org.apache.storm.util$filter_key
  
  class util$filter_key extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$filter_key$fn__514
  
  class util$filter_key$fn__514 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    afn
    
    Object afn
- Class org.apache.storm.util$fn__462
  
  class util$fn__462 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$hashmap_to_persistent
  
  class util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$loading__6789__auto____271
  
  class util$loading__6789__auto____271 extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$map_val
  
  class util$map_val extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$map_val$iter__492__496
  
  class util$map_val$iter__492__496 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    afn
    
    Object afn
- Class org.apache.storm.util$map_val$iter__492__496$fn__497
  
  class util$map_val$iter__492__496$fn__497 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    afn
    
    Object afn
    
    iter__492
    
    Object iter__492
    
    s__493
    
    Object s__493
- Class org.apache.storm.util$map_val$iter__492__496$fn__497$fn__498
  
  class util$map_val$iter__492__496$fn__497$fn__498 extends clojure.lang.AFunction implements Serializable
  - Serialized Fields
    
    afn
    
    Object afn
    
    b__495
    
    Object b__495
    
    c__6371__auto__
    
    Object c__6371__auto__
    
    size__6372__auto__
    
    int size__6372__auto__
- Class org.apache.storm.util$name_with_attributes
  
  class util$name_with_attributes extends clojure.lang.AFunction implements Serializable
- Class org.apache.storm.util$thrown_cause_QMARK_
  
  class util$thrown_cause_QMARK_ extends clojure.lang.RestFn implements Serializable
Package org.apache.storm.bolt
- Class org.apache.storm.bolt.JoinBolt
  
  class JoinBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    hashedInputs
    
    HashMap<String,HashMap<Object,ArrayList<Tuple>>> hashedInputs
    
    joinCriteria
    
    LinkedHashMap<String,JoinBolt.JoinInfo> joinCriteria
    
    outputFields
    
    JoinBolt.FieldSelector[] outputFields
    
    outputStreamName
    
    String outputStreamName
    
    selectorType
    
    JoinBolt.Selector selectorType
- Class org.apache.storm.bolt.JoinBolt.FieldSelector
  
  class FieldSelector extends Object implements Serializable
  - Serialized Fields
    
    field
    
    String[] field
    
    outputName
    
    String outputName
    
    streamName
    
    String streamName
- Class org.apache.storm.bolt.JoinBolt.JoinInfo
  
  class JoinInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    field
    
    JoinBolt.FieldSelector field
    
    joinType
    
    JoinBolt.JoinType joinType
    
    other
    
    JoinBolt.FieldSelector other
Package org.apache.storm.clojure
- Class org.apache.storm.clojure.ClojureBolt
  
  class ClojureBolt extends Object implements Serializable
  - Serialized Fields
    
    bolt
    
    IBolt bolt
    
    confSpec
    
    List<String> confSpec
    
    fields
    
    Map<String,StreamInfo> fields
    
    fnSpec
    
    List<String> fnSpec
    
    params
    
    List<Object> params
- Class org.apache.storm.clojure.ClojureSpout
  
  class ClojureSpout extends Object implements Serializable
  - Serialized Fields
    
    confSpec
    
    List<String> confSpec
    
    fields
    
    Map<String,StreamInfo> fields
    
    fnSpec
    
    List<String> fnSpec
    
    params
    
    List<Object> params
    
    spout
    
    ISpout spout
- Class org.apache.storm.clojure.RichShellBolt
  
  class RichShellBolt extends ShellBolt implements Serializable
  - Serialized Fields
    
    outputs
    
    Map<String,StreamInfo> outputs
- Class org.apache.storm.clojure.RichShellSpout
  
  class RichShellSpout extends ShellSpout implements Serializable
  - Serialized Fields
    
    outputs
    
    Map<String,StreamInfo> outputs
Package org.apache.storm.coordination
- Class org.apache.storm.coordination.BatchBoltExecutor
  
  class BatchBoltExecutor extends Object implements Serializable
  - Serialized Fields
    
    boltSer
    
    byte[] boltSer
    
    collector
    
    BatchOutputCollectorImpl collector
    
    conf
    
    Map conf
    
    context
    
    TopologyContext context
    
    openTransactions
    
    Map<Object,IBatchBolt> openTransactions
- Class org.apache.storm.coordination.CoordinatedBolt
  
  class CoordinatedBolt extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    countOutTasks
    
    List<Integer> countOutTasks
    
    delegate
    
    IRichBolt delegate
    
    idStreamSpec
    
    CoordinatedBolt.IdStreamSpec idStreamSpec
    
    numSourceReports
    
    Integer numSourceReports
    
    sourceArgs
    
    Map<String,CoordinatedBolt.SourceArgs> sourceArgs
    
    tracked
    
    TimeCacheMap<Object,CoordinatedBolt.TrackingInfo> tracked
- Class org.apache.storm.coordination.CoordinatedBolt.IdStreamSpec
  
  class IdStreamSpec extends Object implements Serializable
  - Serialized Fields
    
    id
    
    GlobalStreamId id
- Class org.apache.storm.coordination.CoordinatedBolt.SourceArgs
  
  class SourceArgs extends Object implements Serializable
  - Serialized Fields
    
    singleCount
    
    boolean singleCount
Package org.apache.storm.daemon
- Class org.apache.storm.daemon.Acker
  
  class Acker extends Object implements Serializable
  
  serialVersionUID:
  
  4430906880683183091L
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    pending
    
    RotatingMap<Object,org.apache.storm.daemon.Acker.AckObject> pending
- Class org.apache.storm.daemon.GrouperFactory.AllGrouper
  
  class AllGrouper extends Object implements Serializable
  - Serialized Fields
    
    targetTasks
    
    List<Integer> targetTasks
- Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping
  
  class BasicLoadAwareCustomStreamGrouping extends Object implements Serializable
  - Serialized Fields
    
    customStreamGrouping
    
    CustomStreamGrouping customStreamGrouping
- Class org.apache.storm.daemon.GrouperFactory.FieldsGrouper
  
  class FieldsGrouper extends Object implements Serializable
  - Serialized Fields
    
    groupFields
    
    Fields groupFields
    
    numTasks
    
    int numTasks
    
    outFields
    
    Fields outFields
    
    targetTasks
    
    List<List<Integer>> targetTasks
- Class org.apache.storm.daemon.GrouperFactory.GlobalGrouper
  
  class GlobalGrouper extends Object implements Serializable
  - Serialized Fields
    
    targetTasks
    
    List<Integer> targetTasks
- Class org.apache.storm.daemon.GrouperFactory.NoneGrouper
  
  class NoneGrouper extends Object implements Serializable
  - Serialized Fields
    
    numTasks
    
    int numTasks
    
    random
    
    Random random
    
    targetTasks
    
    List<Integer> targetTasks
Package org.apache.storm.daemon.supervisor
- Exception org.apache.storm.daemon.supervisor.ContainerRecoveryException
  
  class ContainerRecoveryException extends RuntimeException implements Serializable
- Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignment
  
  class TimerDecoratedAssignment extends LocalAssignment implements Serializable
  - Serialized Fields
    
    timing
    
    com.codahale.metrics.Timer.Context timing
Package org.apache.storm.daemon.ui
- Exception org.apache.storm.daemon.ui.InvalidRequestException
  
  class InvalidRequestException extends Exception implements Serializable
Package org.apache.storm.dependency
- Exception org.apache.storm.dependency.FileNotAvailableException
  
  class FileNotAvailableException extends RuntimeException implements Serializable
Package org.apache.storm.drpc
- Class org.apache.storm.drpc.DRPCSpout
  
  class DRPCSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  2387848310969237877L
  - Serialized Fields
    
    clients
    
    List<DRPCInvocationsClient> clients
    
    collector
    
    SpoutOutputCollector collector
    
    function
    
    String function
    
    localDrpcId
    
    String localDrpcId
- Class org.apache.storm.drpc.JoinResult
  
  class JoinResult extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    results
    
    Map<Object,Tuple> results
    
    returnComponent
    
    String returnComponent
    
    returns
    
    Map<Object,Tuple> returns
- Class org.apache.storm.drpc.KeyedFairBolt
  
  class KeyedFairBolt extends Object implements Serializable
  - Serialized Fields
    
    callback
    
    CoordinatedBolt.FinishedCallback callback
    
    delegate
    
    IRichBolt delegate
    
    executor
    
    Thread executor
    
    rrQueue
    
    KeyedRoundRobinQueue<Tuple> rrQueue
- Class org.apache.storm.drpc.PrepareRequest
  
  class PrepareRequest extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    rand
    
    Random rand
- Class org.apache.storm.drpc.ReturnResults
  
  class ReturnResults extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  -774882142710631591L
  - Serialized Fields
    
    clients
    
    Map<List,DRPCInvocationsClient> clients
    
    collector
    
    OutputCollector collector
    
    conf
    
    Map<String,Object> conf
    
    local
    
    boolean local
Package org.apache.storm.elasticsearch
- Class org.apache.storm.elasticsearch.DefaultEsLookupResultOutput
  
  class DefaultEsLookupResultOutput extends Object implements Serializable
  
  serialVersionUID:
  
  2932278450655703239L
  - Serialized Fields
    
    objectMapper
    
    com.fasterxml.jackson.databind.ObjectMapper objectMapper
Package org.apache.storm.elasticsearch.bolt
- Class org.apache.storm.elasticsearch.bolt.AbstractEsBolt
  
  class AbstractEsBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    esConfig
    
    EsConfig esConfig
- Class org.apache.storm.elasticsearch.bolt.EsIndexBolt
  
  class EsIndexBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    
    tupleMapper
    
    EsTupleMapper tupleMapper
- Class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout
  
  class UserDataSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    The collector passed in EsIndexTopology.UserDataSpout.open(java.util.Map, org.apache.storm.task.TopologyContext, org.apache.storm.spout.SpoutOutputCollector).
    
    count
    
    int count
    
    index
    
    int index
    
    indexName
    
    String indexName
    
    pending
    
    ConcurrentHashMap<UUID,Values> pending
    
    The pending values.
    
    sources
    
    String[] sources
    
    total
    
    long total
    
    typeName
    
    String typeName
- Class org.apache.storm.elasticsearch.bolt.EsLookupBolt
  
  class EsLookupBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    
    output
    
    EsLookupResultOutput output
    
    tupleMapper
    
    EsTupleMapper tupleMapper
- Class org.apache.storm.elasticsearch.bolt.EsPercolateBolt
  
  class EsPercolateBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    
    tupleMapper
    
    EsTupleMapper tupleMapper
Package org.apache.storm.elasticsearch.common
- Class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper
  
  class DefaultEsTupleMapper extends Object implements Serializable
- Class org.apache.storm.elasticsearch.common.EsConfig
  
  class EsConfig extends Object implements Serializable
  - Serialized Fields
    
    compression
    
    boolean compression
    
    defaultHeaders
    
    org.apache.http.Header[] defaultHeaders
    
    failureListener
    
    org.elasticsearch.client.RestClient.FailureListener failureListener
    
    httpClientConfigCallback
    
    org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback
    
    httpHosts
    
    org.apache.http.HttpHost[] httpHosts
    
    pathPrefix
    
    String pathPrefix
    
    requestConfigCallback
    
    org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback
- Class org.apache.storm.elasticsearch.common.StormElasticSearchClient
  
  class StormElasticSearchClient extends Object implements Serializable
  - Serialized Fields
    
    esConfig
    
    EsConfig esConfig
Package org.apache.storm.elasticsearch.trident
- Class org.apache.storm.elasticsearch.trident.EsStateFactory
  
  class EsStateFactory extends Object implements Serializable
  - Serialized Fields
    
    esConfig
    
    EsConfig esConfig
    
    tupleMapper
    
    EsTupleMapper tupleMapper
- Class org.apache.storm.elasticsearch.trident.EsUpdater
  
  class EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState> implements Serializable
- Class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout
  
  class FixedBatchSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    batches
    
    HashMap<Long,List<List<Object>>> batches
    
    The passed batches.
    
    cycle
    
    boolean cycle
    
    A flag indicating whether cycling ought to be performed.
    
    index
    
    int index
    
    The current index.
    
    maxBatchSize
    
    int maxBatchSize
    
    outputs
    
    Values[] outputs
    
    The output values.
Package org.apache.storm.executor
- Class org.apache.storm.executor.TupleInfo
  
  class TupleInfo extends Object implements Serializable
  
  serialVersionUID:
  
  -3348670497595864118L
  - Serialized Fields
    
    messageId
    
    Object messageId
    
    rootId
    
    long rootId
    
    stream
    
    String stream
    
    taskId
    
    int taskId
    
    timestamp
    
    long timestamp
    
    values
    
    List<Object> values
Package org.apache.storm.flux.examples
- Class org.apache.storm.flux.examples.OnlyValueRecordTranslator
  
  class OnlyValueRecordTranslator extends Object implements Serializable
- Class org.apache.storm.flux.examples.StatefulWordCounter
  
  class StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,Long>> implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    wordCounts
    
    KeyValueState<String,Long> wordCounts
- Class org.apache.storm.flux.examples.TestPrintBolt
  
  class TestPrintBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.flux.examples.TestWindowBolt
  
  class TestWindowBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.flux.examples.WordCounter
  
  class WordCounter extends BaseBasicBolt implements Serializable
Package org.apache.storm.flux.wrappers.bolts
- Class org.apache.storm.flux.wrappers.bolts.FluxShellBolt
  
  class FluxShellBolt extends ShellBolt implements Serializable
  - Serialized Fields
    
    componentConfig
    
    Map<String,Object> componentConfig
    
    outputFields
    
    Map<String,String[]> outputFields
- Class org.apache.storm.flux.wrappers.bolts.LogInfoBolt
  
  class LogInfoBolt extends BaseBasicBolt implements Serializable
Package org.apache.storm.flux.wrappers.spouts
- Class org.apache.storm.flux.wrappers.spouts.FluxShellSpout
  
  class FluxShellSpout extends ShellSpout implements Serializable
  - Serialized Fields
    
    componentConfig
    
    Map<String,Object> componentConfig
    
    outputFields
    
    Map<String,String[]> outputFields
Package org.apache.storm.generated
- Class org.apache.storm.generated.AccessControl
  
  class AccessControl extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    access
    
    int access
    
    name
    
    String name
    
    type
    
    AccessControlType type
- Exception org.apache.storm.generated.AlreadyAliveException
  
  class AlreadyAliveException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.Assignment
  
  class Assignment extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    executor_node_port
    
    Map<List<Long>,NodeInfo> executor_node_port
    
    executor_start_time_secs
    
    Map<List<Long>,Long> executor_start_time_secs
    
    master_code_dir
    
    String master_code_dir
    
    node_host
    
    Map<String,String> node_host
    
    owner
    
    String owner
    
    total_shared_off_heap
    
    Map<String,Double> total_shared_off_heap
    
    worker_resources
    
    Map<NodeInfo,WorkerResources> worker_resources
- Exception org.apache.storm.generated.AuthorizationException
  
  class AuthorizationException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.BeginDownloadResult
  
  class BeginDownloadResult extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    data_size
    
    long data_size
    
    session
    
    String session
    
    version
    
    long version
- Class org.apache.storm.generated.Bolt
  
  class Bolt extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    bolt_object
    
    ComponentObject bolt_object
    
    common
    
    ComponentCommon common
- Class org.apache.storm.generated.BoltAggregateStats
  
  class BoltAggregateStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    capacity
    
    double capacity
    
    execute_latency_ms
    
    double execute_latency_ms
    
    executed
    
    long executed
    
    process_latency_ms
    
    double process_latency_ms
- Class org.apache.storm.generated.BoltStats
  
  class BoltStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    acked
    
    Map<String,Map<GlobalStreamId,Long>> acked
    
    execute_ms_avg
    
    Map<String,Map<GlobalStreamId,Double>> execute_ms_avg
    
    executed
    
    Map<String,Map<GlobalStreamId,Long>> executed
    
    failed
    
    Map<String,Map<GlobalStreamId,Long>> failed
    
    process_ms_avg
    
    Map<String,Map<GlobalStreamId,Double>> process_ms_avg
- Class org.apache.storm.generated.ClusterSummary
  
  class ClusterSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    nimbuses
    
    List<NimbusSummary> nimbuses
    
    supervisors
    
    List<SupervisorSummary> supervisors
    
    topologies
    
    List<TopologySummary> topologies
- Class org.apache.storm.generated.ClusterWorkerHeartbeat
  
  class ClusterWorkerHeartbeat extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    executor_stats
    
    Map<ExecutorInfo,ExecutorStats> executor_stats
    
    storm_id
    
    String storm_id
    
    time_secs
    
    int time_secs
    
    uptime_secs
    
    int uptime_secs
- Class org.apache.storm.generated.CommonAggregateStats
  
  class CommonAggregateStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    acked
    
    long acked
    
    emitted
    
    long emitted
    
    failed
    
    long failed
    
    num_executors
    
    int num_executors
    
    num_tasks
    
    int num_tasks
    
    resources_map
    
    Map<String,Double> resources_map
    
    transferred
    
    long transferred
- Class org.apache.storm.generated.ComponentAggregateStats
  
  class ComponentAggregateStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    common_stats
    
    CommonAggregateStats common_stats
    
    last_error
    
    ErrorInfo last_error
    
    specific_stats
    
    SpecificAggregateStats specific_stats
    
    type
    
    ComponentType type
- Class org.apache.storm.generated.ComponentCommon
  
  class ComponentCommon extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    inputs
    
    Map<GlobalStreamId,Grouping> inputs
    
    json_conf
    
    String json_conf
    
    parallelism_hint
    
    int parallelism_hint
    
    streams
    
    Map<String,StreamInfo> streams
- Class org.apache.storm.generated.ComponentObject
  
  class ComponentObject extends org.apache.storm.thrift.TUnion<ComponentObject,ComponentObject._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.ComponentPageInfo
  
  class ComponentPageInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    component_id
    
    String component_id
    
    component_type
    
    ComponentType component_type
    
    debug_options
    
    DebugOptions debug_options
    
    errors
    
    List<ErrorInfo> errors
    
    eventlog_host
    
    String eventlog_host
    
    eventlog_port
    
    int eventlog_port
    
    exec_stats
    
    List<ExecutorAggregateStats> exec_stats
    
    gsid_to_input_stats
    
    Map<GlobalStreamId,ComponentAggregateStats> gsid_to_input_stats
    
    num_executors
    
    int num_executors
    
    num_tasks
    
    int num_tasks
    
    resources_map
    
    Map<String,Double> resources_map
    
    sid_to_output_stats
    
    Map<String,ComponentAggregateStats> sid_to_output_stats
    
    topology_id
    
    String topology_id
    
    topology_name
    
    String topology_name
    
    topology_status
    
    String topology_status
    
    window_to_stats
    
    Map<String,ComponentAggregateStats> window_to_stats
- Class org.apache.storm.generated.Credentials
  
  class Credentials extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    creds
    
    Map<String,String> creds
    
    topoOwner
    
    String topoOwner
- Class org.apache.storm.generated.DebugOptions
  
  class DebugOptions extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    enable
    
    boolean enable
    
    samplingpct
    
    double samplingpct
- Class org.apache.storm.generated.DistributedRPC.execute_args
  
  class execute_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    funcArgs
    
    String funcArgs
    
    functionName
    
    String functionName
- Class org.apache.storm.generated.DistributedRPC.execute_result
  
  class execute_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    DRPCExecutionException e
    
    success
    
    String success
- Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_args
  
  class failRequest_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result
  
  class failRequest_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_args
  
  class failRequestV2_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    e
    
    DRPCExecutionException e
    
    id
    
    String id
- Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_result
  
  class failRequestV2_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args
  
  class fetchRequest_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    functionName
    
    String functionName
- Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result
  
  class fetchRequest_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    DRPCRequest success
- Class org.apache.storm.generated.DistributedRPCInvocations.result_args
  
  class result_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
    
    result
    
    String result
- Class org.apache.storm.generated.DistributedRPCInvocations.result_result
  
  class result_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Exception org.apache.storm.generated.DRPCExecutionException
  
  class DRPCExecutionException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
    
    type
    
    DRPCExceptionType type
- Class org.apache.storm.generated.DRPCRequest
  
  class DRPCRequest extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    func_args
    
    String func_args
    
    request_id
    
    String request_id
- Class org.apache.storm.generated.ErrorInfo
  
  class ErrorInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    error
    
    String error
    
    error_time_secs
    
    int error_time_secs
    
    host
    
    String host
    
    port
    
    int port
- Class org.apache.storm.generated.ExecutorAggregateStats
  
  class ExecutorAggregateStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    exec_summary
    
    ExecutorSummary exec_summary
    
    stats
    
    ComponentAggregateStats stats
- Class org.apache.storm.generated.ExecutorInfo
  
  class ExecutorInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    task_end
    
    int task_end
    
    task_start
    
    int task_start
- Class org.apache.storm.generated.ExecutorSpecificStats
  
  class ExecutorSpecificStats extends org.apache.storm.thrift.TUnion<ExecutorSpecificStats,ExecutorSpecificStats._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.ExecutorStats
  
  class ExecutorStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    emitted
    
    Map<String,Map<String,Long>> emitted
    
    rate
    
    double rate
    
    specific
    
    ExecutorSpecificStats specific
    
    transferred
    
    Map<String,Map<String,Long>> transferred
- Class org.apache.storm.generated.ExecutorSummary
  
  class ExecutorSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    component_id
    
    String component_id
    
    executor_info
    
    ExecutorInfo executor_info
    
    host
    
    String host
    
    port
    
    int port
    
    stats
    
    ExecutorStats stats
    
    uptime_secs
    
    int uptime_secs
- Class org.apache.storm.generated.GetInfoOptions
  
  class GetInfoOptions extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    num_err_choice
    
    NumErrorsChoice num_err_choice
- Class org.apache.storm.generated.GlobalStreamId
  
  class GlobalStreamId extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    componentId
    
    String componentId
    
    streamId
    
    String streamId
- Class org.apache.storm.generated.Grouping
  
  class Grouping extends org.apache.storm.thrift.TUnion<Grouping,Grouping._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Exception org.apache.storm.generated.HBAuthorizationException
  
  class HBAuthorizationException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Exception org.apache.storm.generated.HBExecutionException
  
  class HBExecutionException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.HBMessage
  
  class HBMessage extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    data
    
    HBMessageData data
    
    message_id
    
    int message_id
    
    type
    
    HBServerMessageType type
- Class org.apache.storm.generated.HBMessageData
  
  class HBMessageData extends org.apache.storm.thrift.TUnion<HBMessageData,HBMessageData._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.HBNodes
  
  class HBNodes extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    pulseIds
    
    List<String> pulseIds
- Class org.apache.storm.generated.HBPulse
  
  class HBPulse extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    details
    
    ByteBuffer details
    
    id
    
    String id
- Class org.apache.storm.generated.HBRecords
  
  class HBRecords extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    pulses
    
    List<HBPulse> pulses
- Exception org.apache.storm.generated.IllegalStateException
  
  class IllegalStateException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Exception org.apache.storm.generated.InvalidTopologyException
  
  class InvalidTopologyException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.JavaObject
  
  class JavaObject extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    args_list
    
    List<JavaObjectArg> args_list
    
    full_class_name
    
    String full_class_name
- Class org.apache.storm.generated.JavaObjectArg
  
  class JavaObjectArg extends org.apache.storm.thrift.TUnion<JavaObjectArg,JavaObjectArg._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Exception org.apache.storm.generated.KeyAlreadyExistsException
  
  class KeyAlreadyExistsException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Exception org.apache.storm.generated.KeyNotFoundException
  
  class KeyNotFoundException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.KillOptions
  
  class KillOptions extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    wait_secs
    
    int wait_secs
- Class org.apache.storm.generated.ListBlobsResult
  
  class ListBlobsResult extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    keys
    
    List<String> keys
    
    session
    
    String session
- Class org.apache.storm.generated.LocalAssignment
  
  class LocalAssignment extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    executors
    
    List<ExecutorInfo> executors
    
    owner
    
    String owner
    
    resources
    
    WorkerResources resources
    
    topology_id
    
    String topology_id
    
    total_node_shared
    
    double total_node_shared
- Class org.apache.storm.generated.LocalStateData
  
  class LocalStateData extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    serialized_parts
    
    Map<String,ThriftSerializedObject> serialized_parts
- Class org.apache.storm.generated.LogConfig
  
  class LogConfig extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    named_logger_level
    
    Map<String,LogLevel> named_logger_level
- Class org.apache.storm.generated.LogLevel
  
  class LogLevel extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    action
    
    LogLevelAction action
    
    reset_log_level
    
    String reset_log_level
    
    reset_log_level_timeout_epoch
    
    long reset_log_level_timeout_epoch
    
    reset_log_level_timeout_secs
    
    int reset_log_level_timeout_secs
    
    target_log_level
    
    String target_log_level
- Class org.apache.storm.generated.LSApprovedWorkers
  
  class LSApprovedWorkers extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    approved_workers
    
    Map<String,Integer> approved_workers
- Class org.apache.storm.generated.LSSupervisorAssignments
  
  class LSSupervisorAssignments extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    assignments
    
    Map<Integer,LocalAssignment> assignments
- Class org.apache.storm.generated.LSSupervisorId
  
  class LSSupervisorId extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    supervisor_id
    
    String supervisor_id
- Class org.apache.storm.generated.LSTopoHistory
  
  class LSTopoHistory extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    groups
    
    List<String> groups
    
    time_stamp
    
    long time_stamp
    
    topology_id
    
    String topology_id
    
    users
    
    List<String> users
- Class org.apache.storm.generated.LSTopoHistoryList
  
  class LSTopoHistoryList extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    topo_history
    
    List<LSTopoHistory> topo_history
- Class org.apache.storm.generated.LSWorkerHeartbeat
  
  class LSWorkerHeartbeat extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    executors
    
    List<ExecutorInfo> executors
    
    port
    
    int port
    
    time_secs
    
    int time_secs
    
    topology_id
    
    String topology_id
- Class org.apache.storm.generated.Nimbus.activate_args
  
  class activate_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.activate_result
  
  class activate_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.beginBlobDownload_args
  
  class beginBlobDownload_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.beginBlobDownload_result
  
  class beginBlobDownload_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
    
    success
    
    BeginDownloadResult success
- Class org.apache.storm.generated.Nimbus.beginCreateBlob_args
  
  class beginCreateBlob_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
    
    meta
    
    SettableBlobMeta meta
- Class org.apache.storm.generated.Nimbus.beginCreateBlob_result
  
  class beginCreateBlob_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    kae
    
    KeyAlreadyExistsException kae
    
    success
    
    String success
- Class org.apache.storm.generated.Nimbus.beginFileUpload_args
  
  class beginFileUpload_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.beginFileUpload_result
  
  class beginFileUpload_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    String success
- Class org.apache.storm.generated.Nimbus.beginUpdateBlob_args
  
  class beginUpdateBlob_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.beginUpdateBlob_result
  
  class beginUpdateBlob_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
    
    success
    
    String success
- Class org.apache.storm.generated.Nimbus.cancelBlobUpload_args
  
  class cancelBlobUpload_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    session
    
    String session
- Class org.apache.storm.generated.Nimbus.cancelBlobUpload_result
  
  class cancelBlobUpload_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.createStateInZookeeper_args
  
  class createStateInZookeeper_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.createStateInZookeeper_result
  
  class createStateInZookeeper_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.deactivate_args
  
  class deactivate_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.deactivate_result
  
  class deactivate_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.debug_args
  
  class debug_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    component
    
    String component
    
    enable
    
    boolean enable
    
    name
    
    String name
    
    samplingPercentage
    
    double samplingPercentage
- Class org.apache.storm.generated.Nimbus.debug_result
  
  class debug_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.deleteBlob_args
  
  class deleteBlob_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.deleteBlob_result
  
  class deleteBlob_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    ise
    
    IllegalStateException ise
    
    knf
    
    KeyNotFoundException knf
- Class org.apache.storm.generated.Nimbus.downloadBlobChunk_args
  
  class downloadBlobChunk_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    session
    
    String session
- Class org.apache.storm.generated.Nimbus.downloadBlobChunk_result
  
  class downloadBlobChunk_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    ByteBuffer success
- Class org.apache.storm.generated.Nimbus.downloadChunk_args
  
  class downloadChunk_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.downloadChunk_result
  
  class downloadChunk_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    ByteBuffer success
- Class org.apache.storm.generated.Nimbus.finishBlobUpload_args
  
  class finishBlobUpload_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    session
    
    String session
- Class org.apache.storm.generated.Nimbus.finishBlobUpload_result
  
  class finishBlobUpload_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.finishFileUpload_args
  
  class finishFileUpload_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    location
    
    String location
- Class org.apache.storm.generated.Nimbus.finishFileUpload_result
  
  class finishFileUpload_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.getBlobMeta_args
  
  class getBlobMeta_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.getBlobMeta_result
  
  class getBlobMeta_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
    
    success
    
    ReadableBlobMeta success
- Class org.apache.storm.generated.Nimbus.getBlobReplication_args
  
  class getBlobReplication_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
- Class org.apache.storm.generated.Nimbus.getBlobReplication_result
  
  class getBlobReplication_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
    
    success
    
    int success
- Class org.apache.storm.generated.Nimbus.getClusterInfo_args
  
  class getClusterInfo_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.getClusterInfo_result
  
  class getClusterInfo_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    ClusterSummary success
- Class org.apache.storm.generated.Nimbus.getComponentPageInfo_args
  
  class getComponentPageInfo_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    component_id
    
    String component_id
    
    is_include_sys
    
    boolean is_include_sys
    
    topology_id
    
    String topology_id
    
    window
    
    String window
- Class org.apache.storm.generated.Nimbus.getComponentPageInfo_result
  
  class getComponentPageInfo_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    ComponentPageInfo success
- Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_args
  
  class getComponentPendingProfileActions_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    action
    
    ProfileAction action
    
    component_id
    
    String component_id
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_result
  
  class getComponentPendingProfileActions_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    success
    
    List<ProfileRequest> success
- Class org.apache.storm.generated.Nimbus.getLeader_args
  
  class getLeader_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.getLeader_result
  
  class getLeader_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    NimbusSummary success
- Class org.apache.storm.generated.Nimbus.getLogConfig_args
  
  class getLogConfig_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.getLogConfig_result
  
  class getLogConfig_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    success
    
    LogConfig success
- Class org.apache.storm.generated.Nimbus.getNimbusConf_args
  
  class getNimbusConf_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.getNimbusConf_result
  
  class getNimbusConf_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    String success
- Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_args
  
  class getOwnerResourceSummaries_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    owner
    
    String owner
- Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result
  
  class getOwnerResourceSummaries_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    List<OwnerResourceSummary> success
- Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_args
  
  class getSupervisorAssignments_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    node
    
    String node
- Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_result
  
  class getSupervisorAssignments_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    SupervisorAssignments success
- Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_args
  
  class getSupervisorPageInfo_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    host
    
    String host
    
    id
    
    String id
    
    is_include_sys
    
    boolean is_include_sys
- Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_result
  
  class getSupervisorPageInfo_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    SupervisorPageInfo success
- Class org.apache.storm.generated.Nimbus.getTopology_args
  
  class getTopology_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getTopology_result
  
  class getTopology_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    StormTopology success
- Class org.apache.storm.generated.Nimbus.getTopologyConf_args
  
  class getTopologyConf_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getTopologyConf_result
  
  class getTopologyConf_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    String success
- Class org.apache.storm.generated.Nimbus.getTopologyHistory_args
  
  class getTopologyHistory_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    user
    
    String user
- Class org.apache.storm.generated.Nimbus.getTopologyHistory_result
  
  class getTopologyHistory_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    TopologyHistoryInfo success
- Class org.apache.storm.generated.Nimbus.getTopologyInfo_args
  
  class getTopologyInfo_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getTopologyInfo_result
  
  class getTopologyInfo_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologyInfo success
- Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_args
  
  class getTopologyInfoByName_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_result
  
  class getTopologyInfoByName_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologyInfo success
- Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_args
  
  class getTopologyInfoByNameWithOpts_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
    
    options
    
    GetInfoOptions options
- Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_result
  
  class getTopologyInfoByNameWithOpts_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologyInfo success
- Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_args
  
  class getTopologyInfoWithOpts_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
    
    options
    
    GetInfoOptions options
- Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result
  
  class getTopologyInfoWithOpts_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologyInfo success
- Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_args
  
  class getTopologyPageInfo_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    id
    
    String id
    
    is_include_sys
    
    boolean is_include_sys
    
    window
    
    String window
- Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_result
  
  class getTopologyPageInfo_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologyPageInfo success
- Class org.apache.storm.generated.Nimbus.getTopologySummaries_args
  
  class getTopologySummaries_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.getTopologySummaries_result
  
  class getTopologySummaries_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    success
    
    List<TopologySummary> success
- Class org.apache.storm.generated.Nimbus.getTopologySummary_args
  
  class getTopologySummary_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getTopologySummary_result
  
  class getTopologySummary_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologySummary success
- Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_args
  
  class getTopologySummaryByName_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_result
  
  class getTopologySummaryByName_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    TopologySummary success
- Class org.apache.storm.generated.Nimbus.getUserTopology_args
  
  class getUserTopology_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Nimbus.getUserTopology_result
  
  class getUserTopology_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    StormTopology success
- Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_args
  
  class isRemoteBlobExists_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    blobKey
    
    String blobKey
- Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_result
  
  class isRemoteBlobExists_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    aze
    
    AuthorizationException aze
    
    success
    
    boolean success
- Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_args
  
  class isTopologyNameAllowed_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result
  
  class isTopologyNameAllowed_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    aze
    
    AuthorizationException aze
    
    success
    
    boolean success
- Class org.apache.storm.generated.Nimbus.killTopology_args
  
  class killTopology_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.killTopology_result
  
  class killTopology_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_args
  
  class killTopologyWithOpts_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
    
    options
    
    KillOptions options
- Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result
  
  class killTopologyWithOpts_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.listBlobs_args
  
  class listBlobs_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    session
    
    String session
- Class org.apache.storm.generated.Nimbus.listBlobs_result
  
  class listBlobs_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    success
    
    ListBlobsResult success
- Class org.apache.storm.generated.Nimbus.processWorkerMetrics_args
  
  class processWorkerMetrics_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    metrics
    
    WorkerMetrics metrics
- Class org.apache.storm.generated.Nimbus.processWorkerMetrics_result
  
  class processWorkerMetrics_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.rebalance_args
  
  class rebalance_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    name
    
    String name
    
    options
    
    RebalanceOptions options
- Class org.apache.storm.generated.Nimbus.rebalance_result
  
  class rebalance_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    ite
    
    InvalidTopologyException ite
- Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_args
  
  class sendSupervisorWorkerHeartbeat_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    heatbeat
    
    SupervisorWorkerHeartbeat heatbeat
- Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result
  
  class sendSupervisorWorkerHeartbeat_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
- Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_args
  
  class sendSupervisorWorkerHeartbeats_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    heartbeats
    
    SupervisorWorkerHeartbeats heartbeats
- Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_result
  
  class sendSupervisorWorkerHeartbeats_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.setBlobMeta_args
  
  class setBlobMeta_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    key
    
    String key
    
    meta
    
    SettableBlobMeta meta
- Class org.apache.storm.generated.Nimbus.setBlobMeta_result
  
  class setBlobMeta_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
- Class org.apache.storm.generated.Nimbus.setLogConfig_args
  
  class setLogConfig_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    config
    
    LogConfig config
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.setLogConfig_result
  
  class setLogConfig_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.setWorkerProfiler_args
  
  class setWorkerProfiler_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
    
    profileRequest
    
    ProfileRequest profileRequest
- Class org.apache.storm.generated.Nimbus.setWorkerProfiler_result
  
  class setWorkerProfiler_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.Nimbus.submitTopology_args
  
  class submitTopology_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    jsonConf
    
    String jsonConf
    
    name
    
    String name
    
    topology
    
    StormTopology topology
    
    uploadedJarLocation
    
    String uploadedJarLocation
- Class org.apache.storm.generated.Nimbus.submitTopology_result
  
  class submitTopology_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    AlreadyAliveException e
    
    ite
    
    InvalidTopologyException ite
- Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_args
  
  class submitTopologyWithOpts_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    jsonConf
    
    String jsonConf
    
    name
    
    String name
    
    options
    
    SubmitOptions options
    
    topology
    
    StormTopology topology
    
    uploadedJarLocation
    
    String uploadedJarLocation
- Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_result
  
  class submitTopologyWithOpts_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    AlreadyAliveException e
    
    ite
    
    InvalidTopologyException ite
- Class org.apache.storm.generated.Nimbus.updateBlobReplication_args
  
  class updateBlobReplication_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    key
    
    String key
    
    replication
    
    int replication
- Class org.apache.storm.generated.Nimbus.updateBlobReplication_result
  
  class updateBlobReplication_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    aze
    
    AuthorizationException aze
    
    knf
    
    KeyNotFoundException knf
    
    success
    
    int success
- Class org.apache.storm.generated.Nimbus.uploadBlobChunk_args
  
  class uploadBlobChunk_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    chunk
    
    ByteBuffer chunk
    
    session
    
    String session
- Class org.apache.storm.generated.Nimbus.uploadBlobChunk_result
  
  class uploadBlobChunk_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.uploadChunk_args
  
  class uploadChunk_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    chunk
    
    ByteBuffer chunk
    
    location
    
    String location
- Class org.apache.storm.generated.Nimbus.uploadChunk_result
  
  class uploadChunk_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Nimbus.uploadNewCredentials_args
  
  class uploadNewCredentials_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    creds
    
    Credentials creds
    
    name
    
    String name
- Class org.apache.storm.generated.Nimbus.uploadNewCredentials_result
  
  class uploadNewCredentials_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    ite
    
    InvalidTopologyException ite
- Class org.apache.storm.generated.NimbusSummary
  
  class NimbusSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    host
    
    String host
    
    isLeader
    
    boolean isLeader
    
    port
    
    int port
    
    uptime_secs
    
    int uptime_secs
    
    version
    
    String version
- Class org.apache.storm.generated.NodeInfo
  
  class NodeInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    node
    
    String node
    
    port
    
    Set<Long> port
- Exception org.apache.storm.generated.NotAliveException
  
  class NotAliveException extends org.apache.storm.thrift.TException implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    msg
    
    String msg
- Class org.apache.storm.generated.NullStruct
  
  class NullStruct extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.OwnerResourceSummary
  
  class OwnerResourceSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    int __isset_bitfield
    
    assigned_off_heap_memory
    
    double assigned_off_heap_memory
    
    assigned_on_heap_memory
    
    double assigned_on_heap_memory
    
    cpu_guarantee
    
    double cpu_guarantee
    
    cpu_guarantee_remaining
    
    double cpu_guarantee_remaining
    
    cpu_usage
    
    double cpu_usage
    
    isolated_node_guarantee
    
    int isolated_node_guarantee
    
    memory_guarantee
    
    double memory_guarantee
    
    memory_guarantee_remaining
    
    double memory_guarantee_remaining
    
    memory_usage
    
    double memory_usage
    
    owner
    
    String owner
    
    requested_cpu
    
    double requested_cpu
    
    requested_off_heap_memory
    
    double requested_off_heap_memory
    
    requested_on_heap_memory
    
    double requested_on_heap_memory
    
    requested_total_memory
    
    double requested_total_memory
    
    total_executors
    
    int total_executors
    
    total_tasks
    
    int total_tasks
    
    total_topologies
    
    int total_topologies
    
    total_workers
    
    int total_workers
- Class org.apache.storm.generated.PrivateWorkerKey
  
  class PrivateWorkerKey extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    expirationTimeMillis
    
    long expirationTimeMillis
    
    key
    
    ByteBuffer key
    
    userName
    
    String userName
- Class org.apache.storm.generated.ProfileRequest
  
  class ProfileRequest extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    action
    
    ProfileAction action
    
    nodeInfo
    
    NodeInfo nodeInfo
    
    time_stamp
    
    long time_stamp
- Class org.apache.storm.generated.ReadableBlobMeta
  
  class ReadableBlobMeta extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    settable
    
    SettableBlobMeta settable
    
    version
    
    long version
- Class org.apache.storm.generated.RebalanceOptions
  
  class RebalanceOptions extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    num_executors
    
    Map<String,Integer> num_executors
    
    num_workers
    
    int num_workers
    
    principal
    
    String principal
    
    topology_conf_overrides
    
    String topology_conf_overrides
    
    topology_resources_overrides
    
    Map<String,Map<String,Double>> topology_resources_overrides
    
    wait_secs
    
    int wait_secs
- Class org.apache.storm.generated.SettableBlobMeta
  
  class SettableBlobMeta extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    acl
    
    List<AccessControl> acl
    
    replication_factor
    
    int replication_factor
- Class org.apache.storm.generated.SharedMemory
  
  class SharedMemory extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    name
    
    String name
    
    off_heap_node
    
    double off_heap_node
    
    off_heap_worker
    
    double off_heap_worker
    
    on_heap
    
    double on_heap
- Class org.apache.storm.generated.ShellComponent
  
  class ShellComponent extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    execution_command
    
    String execution_command
    
    script
    
    String script
- Class org.apache.storm.generated.SpecificAggregateStats
  
  class SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats,SpecificAggregateStats._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.SpoutAggregateStats
  
  class SpoutAggregateStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    complete_latency_ms
    
    double complete_latency_ms
- Class org.apache.storm.generated.SpoutSpec
  
  class SpoutSpec extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    common
    
    ComponentCommon common
    
    spout_object
    
    ComponentObject spout_object
- Class org.apache.storm.generated.SpoutStats
  
  class SpoutStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    acked
    
    Map<String,Map<String,Long>> acked
    
    complete_ms_avg
    
    Map<String,Map<String,Double>> complete_ms_avg
    
    failed
    
    Map<String,Map<String,Long>> failed
- Class org.apache.storm.generated.StateSpoutSpec
  
  class StateSpoutSpec extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    common
    
    ComponentCommon common
    
    state_spout_object
    
    ComponentObject state_spout_object
- Class org.apache.storm.generated.StormBase
  
  class StormBase extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    component_debug
    
    Map<String,DebugOptions> component_debug
    
    component_executors
    
    Map<String,Integer> component_executors
    
    launch_time_secs
    
    int launch_time_secs
    
    name
    
    String name
    
    num_workers
    
    int num_workers
    
    owner
    
    String owner
    
    prev_status
    
    TopologyStatus prev_status
    
    principal
    
    String principal
    
    status
    
    TopologyStatus status
    
    topology_action_options
    
    TopologyActionOptions topology_action_options
    
    topology_version
    
    String topology_version
- Class org.apache.storm.generated.StormTopology
  
  class StormTopology extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    bolts
    
    Map<String,Bolt> bolts
    
    component_to_shared_memory
    
    Map<String,Set<String>> component_to_shared_memory
    
    dependency_artifacts
    
    List<String> dependency_artifacts
    
    dependency_jars
    
    List<String> dependency_jars
    
    jdk_version
    
    String jdk_version
    
    shared_memory
    
    Map<String,SharedMemory> shared_memory
    
    spouts
    
    Map<String,SpoutSpec> spouts
    
    state_spouts
    
    Map<String,StateSpoutSpec> state_spouts
    
    storm_version
    
    String storm_version
    
    worker_hooks
    
    List<ByteBuffer> worker_hooks
- Class org.apache.storm.generated.StreamInfo
  
  class StreamInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    direct
    
    boolean direct
    
    output_fields
    
    List<String> output_fields
- Class org.apache.storm.generated.SubmitOptions
  
  class SubmitOptions extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    creds
    
    Credentials creds
    
    initial_status
    
    TopologyInitialStatus initial_status
- Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_args
  
  class getLocalAssignmentForStorm_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result
  
  class getLocalAssignmentForStorm_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
    
    e
    
    NotAliveException e
    
    success
    
    Assignment success
- Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_args
  
  class sendSupervisorAssignments_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    assignments
    
    SupervisorAssignments assignments
- Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result
  
  class sendSupervisorAssignments_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_args
  
  class sendSupervisorWorkerHeartbeat_args extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    heartbeat
    
    SupervisorWorkerHeartbeat heartbeat
- Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result
  
  class sendSupervisorWorkerHeartbeat_result extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    aze
    
    AuthorizationException aze
- Class org.apache.storm.generated.SupervisorAssignments
  
  class SupervisorAssignments extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    storm_assignment
    
    Map<String,Assignment> storm_assignment
- Class org.apache.storm.generated.SupervisorInfo
  
  class SupervisorInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    assignment_id
    
    String assignment_id
    
    hostname
    
    String hostname
    
    meta
    
    List<Long> meta
    
    resources_map
    
    Map<String,Double> resources_map
    
    scheduler_meta
    
    Map<String,String> scheduler_meta
    
    server_port
    
    int server_port
    
    time_secs
    
    long time_secs
    
    uptime_secs
    
    long uptime_secs
    
    used_ports
    
    List<Long> used_ports
    
    version
    
    String version
- Class org.apache.storm.generated.SupervisorPageInfo
  
  class SupervisorPageInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    supervisor_summaries
    
    List<SupervisorSummary> supervisor_summaries
    
    worker_summaries
    
    List<WorkerSummary> worker_summaries
- Class org.apache.storm.generated.SupervisorSummary
  
  class SupervisorSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    blacklisted
    
    boolean blacklisted
    
    fragmented_cpu
    
    double fragmented_cpu
    
    fragmented_mem
    
    double fragmented_mem
    
    host
    
    String host
    
    num_used_workers
    
    int num_used_workers
    
    num_workers
    
    int num_workers
    
    supervisor_id
    
    String supervisor_id
    
    total_resources
    
    Map<String,Double> total_resources
    
    uptime_secs
    
    int uptime_secs
    
    used_cpu
    
    double used_cpu
    
    used_generic_resources
    
    Map<String,Double> used_generic_resources
    
    used_mem
    
    double used_mem
    
    version
    
    String version
- Class org.apache.storm.generated.SupervisorWorkerHeartbeat
  
  class SupervisorWorkerHeartbeat extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    executors
    
    List<ExecutorInfo> executors
    
    storm_id
    
    String storm_id
    
    time_secs
    
    int time_secs
- Class org.apache.storm.generated.SupervisorWorkerHeartbeats
  
  class SupervisorWorkerHeartbeats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    supervisor_id
    
    String supervisor_id
    
    worker_heartbeats
    
    List<SupervisorWorkerHeartbeat> worker_heartbeats
- Class org.apache.storm.generated.ThriftSerializedObject
  
  class ThriftSerializedObject extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    bits
    
    ByteBuffer bits
    
    name
    
    String name
- Class org.apache.storm.generated.TopologyActionOptions
  
  class TopologyActionOptions extends org.apache.storm.thrift.TUnion<TopologyActionOptions,TopologyActionOptions._Fields> implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.generated.TopologyHistoryInfo
  
  class TopologyHistoryInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    topo_ids
    
    List<String> topo_ids
- Class org.apache.storm.generated.TopologyInfo
  
  class TopologyInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    assigned_cpu
    
    double assigned_cpu
    
    assigned_memoffheap
    
    double assigned_memoffheap
    
    assigned_memonheap
    
    double assigned_memonheap
    
    component_debug
    
    Map<String,DebugOptions> component_debug
    
    errors
    
    Map<String,List<ErrorInfo>> errors
    
    executors
    
    List<ExecutorSummary> executors
    
    id
    
    String id
    
    name
    
    String name
    
    owner
    
    String owner
    
    replication_count
    
    int replication_count
    
    requested_cpu
    
    double requested_cpu
    
    requested_memoffheap
    
    double requested_memoffheap
    
    requested_memonheap
    
    double requested_memonheap
    
    sched_status
    
    String sched_status
    
    status
    
    String status
    
    storm_version
    
    String storm_version
    
    uptime_secs
    
    int uptime_secs
- Class org.apache.storm.generated.TopologyPageInfo
  
  class TopologyPageInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    int __isset_bitfield
    
    assigned_cpu
    
    double assigned_cpu
    
    assigned_generic_resources
    
    Map<String,Double> assigned_generic_resources
    
    assigned_memoffheap
    
    double assigned_memoffheap
    
    assigned_memonheap
    
    double assigned_memonheap
    
    assigned_regular_off_heap_memory
    
    double assigned_regular_off_heap_memory
    
    assigned_regular_on_heap_memory
    
    double assigned_regular_on_heap_memory
    
    assigned_shared_off_heap_memory
    
    double assigned_shared_off_heap_memory
    
    assigned_shared_on_heap_memory
    
    double assigned_shared_on_heap_memory
    
    debug_options
    
    DebugOptions debug_options
    
    id
    
    String id
    
    id_to_bolt_agg_stats
    
    Map<String,ComponentAggregateStats> id_to_bolt_agg_stats
    
    id_to_spout_agg_stats
    
    Map<String,ComponentAggregateStats> id_to_spout_agg_stats
    
    name
    
    String name
    
    num_executors
    
    int num_executors
    
    num_tasks
    
    int num_tasks
    
    num_workers
    
    int num_workers
    
    owner
    
    String owner
    
    replication_count
    
    int replication_count
    
    requested_cpu
    
    double requested_cpu
    
    requested_generic_resources
    
    Map<String,Double> requested_generic_resources
    
    requested_memoffheap
    
    double requested_memoffheap
    
    requested_memonheap
    
    double requested_memonheap
    
    requested_regular_off_heap_memory
    
    double requested_regular_off_heap_memory
    
    requested_regular_on_heap_memory
    
    double requested_regular_on_heap_memory
    
    requested_shared_off_heap_memory
    
    double requested_shared_off_heap_memory
    
    requested_shared_on_heap_memory
    
    double requested_shared_on_heap_memory
    
    sched_status
    
    String sched_status
    
    status
    
    String status
    
    storm_version
    
    String storm_version
    
    topology_conf
    
    String topology_conf
    
    topology_stats
    
    TopologyStats topology_stats
    
    topology_version
    
    String topology_version
    
    uptime_secs
    
    int uptime_secs
    
    workers
    
    List<WorkerSummary> workers
- Class org.apache.storm.generated.TopologyStats
  
  class TopologyStats extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    window_to_acked
    
    Map<String,Long> window_to_acked
    
    window_to_complete_latencies_ms
    
    Map<String,Double> window_to_complete_latencies_ms
    
    window_to_emitted
    
    Map<String,Long> window_to_emitted
    
    window_to_failed
    
    Map<String,Long> window_to_failed
    
    window_to_transferred
    
    Map<String,Long> window_to_transferred
- Class org.apache.storm.generated.TopologySummary
  
  class TopologySummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    short __isset_bitfield
    
    assigned_cpu
    
    double assigned_cpu
    
    assigned_generic_resources
    
    Map<String,Double> assigned_generic_resources
    
    assigned_memoffheap
    
    double assigned_memoffheap
    
    assigned_memonheap
    
    double assigned_memonheap
    
    id
    
    String id
    
    name
    
    String name
    
    num_executors
    
    int num_executors
    
    num_tasks
    
    int num_tasks
    
    num_workers
    
    int num_workers
    
    owner
    
    String owner
    
    replication_count
    
    int replication_count
    
    requested_cpu
    
    double requested_cpu
    
    requested_generic_resources
    
    Map<String,Double> requested_generic_resources
    
    requested_memoffheap
    
    double requested_memoffheap
    
    requested_memonheap
    
    double requested_memonheap
    
    sched_status
    
    String sched_status
    
    status
    
    String status
    
    storm_version
    
    String storm_version
    
    topology_version
    
    String topology_version
    
    uptime_secs
    
    int uptime_secs
- Class org.apache.storm.generated.WorkerMetricList
  
  class WorkerMetricList extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    metrics
    
    List<WorkerMetricPoint> metrics
- Class org.apache.storm.generated.WorkerMetricPoint
  
  class WorkerMetricPoint extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    componentId
    
    String componentId
    
    executorId
    
    String executorId
    
    metricName
    
    String metricName
    
    metricValue
    
    double metricValue
    
    streamId
    
    String streamId
    
    timestamp
    
    long timestamp
- Class org.apache.storm.generated.WorkerMetrics
  
  class WorkerMetrics extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    hostname
    
    String hostname
    
    metricList
    
    WorkerMetricList metricList
    
    port
    
    int port
    
    topologyId
    
    String topologyId
- Class org.apache.storm.generated.WorkerResources
  
  class WorkerResources extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    cpu
    
    double cpu
    
    mem_off_heap
    
    double mem_off_heap
    
    mem_on_heap
    
    double mem_on_heap
    
    resources
    
    Map<String,Double> resources
    
    shared_mem_off_heap
    
    double shared_mem_off_heap
    
    shared_mem_on_heap
    
    double shared_mem_on_heap
    
    shared_resources
    
    Map<String,Double> shared_resources
- Class org.apache.storm.generated.WorkerSummary
  
  class WorkerSummary extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    short __isset_bitfield
    
    assigned_cpu
    
    double assigned_cpu
    
    assigned_memoffheap
    
    double assigned_memoffheap
    
    assigned_memonheap
    
    double assigned_memonheap
    
    component_to_num_tasks
    
    Map<String,Long> component_to_num_tasks
    
    host
    
    String host
    
    num_executors
    
    int num_executors
    
    owner
    
    String owner
    
    port
    
    int port
    
    requested_cpu
    
    double requested_cpu
    
    requested_memoffheap
    
    double requested_memoffheap
    
    requested_memonheap
    
    double requested_memonheap
    
    supervisor_id
    
    String supervisor_id
    
    time_secs
    
    int time_secs
    
    topology_id
    
    String topology_id
    
    topology_name
    
    String topology_name
    
    uptime_secs
    
    int uptime_secs
- Class org.apache.storm.generated.WorkerToken
  
  class WorkerToken extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    info
    
    ByteBuffer info
    
    serviceType
    
    WorkerTokenServiceType serviceType
    
    signature
    
    ByteBuffer signature
- Class org.apache.storm.generated.WorkerTokenInfo
  
  class WorkerTokenInfo extends Object implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
    
    Throws:
    
    IOException
    
    ClassNotFoundException
    
    writeObject
    
    private void writeObject(ObjectOutputStream out) throws IOException
    
    Throws:
    
    IOException
  - Serialized Fields
    
    __isset_bitfield
    
    byte __isset_bitfield
    
    expirationTimeMillis
    
    long expirationTimeMillis
    
    secretVersion
    
    long secretVersion
    
    topologyId
    
    String topologyId
    
    userName
    
    String userName
Package org.apache.storm.grouping
- Class org.apache.storm.grouping.LoadAwareShuffleGrouping
  
  class LoadAwareShuffleGrouping extends Object implements Serializable
  - Serialized Fields
    
    capacity
    
    int capacity
    
    choices
    
    int[] choices
    
    conf
    
    Map<String,Object> conf
    
    current
    
    AtomicInteger current
    
    currentScope
    
    org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope currentScope
    
    dnsToSwitchMapping
    
    DNSToSwitchMapping dnsToSwitchMapping
    
    higherBound
    
    double higherBound
    
    localityGroup
    
    Map<org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope,List<Integer>> localityGroup
    
    lowerBound
    
    double lowerBound
    
    nodeToHost
    
    AtomicReference<Map<String,String>> nodeToHost
    
    orig
    
    Map<Integer,org.apache.storm.grouping.LoadAwareShuffleGrouping.IndexAndWeights> orig
    
    prepareChoices
    
    int[] prepareChoices
    
    random
    
    Random random
    
    rets
    
    List<Integer>[] rets
    
    sourceNodeInfo
    
    NodeInfo sourceNodeInfo
    
    targetTasks
    
    List<Integer> targetTasks
    
    taskToNodePort
    
    AtomicReference<Map<Integer,NodeInfo>> taskToNodePort
- Class org.apache.storm.grouping.PartialKeyGrouping
  
  class PartialKeyGrouping extends Object implements Serializable
  
  serialVersionUID:
  
  -1672360572274911808L
  - Serialized Fields
    
    assignmentCreator
    
    PartialKeyGrouping.AssignmentCreator assignmentCreator
    
    fields
    
    Fields fields
    
    outFields
    
    Fields outFields
    
    targetSelector
    
    PartialKeyGrouping.TargetSelector targetSelector
    
    targetTasks
    
    List<Integer> targetTasks
- Class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelector
  
  class BalancedTargetSelector extends Object implements Serializable
  - Serialized Fields
    
    targetTaskStats
    
    Map<Integer,Long> targetTaskStats
- Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator
  
  class RandomTwoTaskAssignmentCreator extends Object implements Serializable
- Class org.apache.storm.grouping.ShuffleGrouping
  
  class ShuffleGrouping extends Object implements Serializable
  - Serialized Fields
    
    choices
    
    ArrayList<List<Integer>> choices
    
    current
    
    AtomicInteger current
Package org.apache.storm.hdfs.avro
- Class org.apache.storm.hdfs.avro.AbstractAvroSerializer
  
  class AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable
- Class org.apache.storm.hdfs.avro.FixedAvroSerializer
  
  class FixedAvroSerializer extends AbstractAvroSerializer implements Serializable
  - Serialized Fields
    
    fingerprint2schemaMap
    
    Map<String,org.apache.avro.Schema> fingerprint2schemaMap
    
    schema2fingerprintMap
    
    Map<org.apache.avro.Schema,String> schema2fingerprintMap
- Class org.apache.storm.hdfs.avro.GenericAvroSerializer
  
  class GenericAvroSerializer extends AbstractAvroSerializer implements Serializable
Package org.apache.storm.hdfs.bolt
- Class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
  
  class AbstractHdfsBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    configKey
    
    String configKey
    
    fileNameFormat
    
    FileNameFormat fileNameFormat
    
    fileRetryCount
    
    Integer fileRetryCount
    
    fsUrl
    
    String fsUrl
    
    maxOpenFiles
    
    Integer maxOpenFiles
    
    offset
    
    long offset
    
    partitioner
    
    Partitioner partitioner
    
    rotationActions
    
    List<RotationAction> rotationActions
    
    rotationCounterMap
    
    Map<String,Integer> rotationCounterMap
    
    rotationPolicy
    
    FileRotationPolicy rotationPolicy
    
    syncPolicy
    
    SyncPolicy syncPolicy
    
    tickTupleInterval
    
    Integer tickTupleInterval
    
    tupleBatch
    
    List<Tuple> tupleBatch
    
    writers
    
    Map<String,Writer> writers
- Class org.apache.storm.hdfs.bolt.AvroGenericRecordBolt
  
  class AvroGenericRecordBolt extends AbstractHdfsBolt implements Serializable
- Class org.apache.storm.hdfs.bolt.HdfsBolt
  
  class HdfsBolt extends AbstractHdfsBolt implements Serializable
  - Serialized Fields
    
    format
    
    RecordFormat format
- Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt
  
  class MyBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    counts
    
    HashMap<String,Long> counts
- Class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpout
  
  class SentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    int count
    
    index
    
    int index
    
    pending
    
    ConcurrentHashMap<UUID,Values> pending
    
    sentences
    
    String[] sentences
    
    total
    
    long total
- Class org.apache.storm.hdfs.bolt.SequenceFileBolt
  
  class SequenceFileBolt extends AbstractHdfsBolt implements Serializable
  - Serialized Fields
    
    compressionCodec
    
    String compressionCodec
    
    compressionType
    
    org.apache.hadoop.io.SequenceFile.CompressionType compressionType
    
    format
    
    SequenceFormat format
- Class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt
  
  class MyBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    counts
    
    HashMap<String,Long> counts
- Class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpout
  
  class SentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    int count
    
    index
    
    int index
    
    pending
    
    ConcurrentHashMap<UUID,Values> pending
    
    sentences
    
    String[] sentences
    
    total
    
    long total
Package org.apache.storm.hdfs.bolt.format
- Class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
  
  class DefaultFileNameFormat extends Object implements Serializable
  - Serialized Fields
    
    componentId
    
    String componentId
    
    extension
    
    String extension
    
    path
    
    String path
    
    prefix
    
    String prefix
    
    taskId
    
    int taskId
- Class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
  
  class DefaultSequenceFormat extends Object implements Serializable
  - Serialized Fields
    
    keyField
    
    String keyField
    
    valueField
    
    String valueField
- Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
  
  class DelimitedRecordFormat extends Object implements Serializable
  - Serialized Fields
    
    fieldDelimiter
    
    String fieldDelimiter
    
    fields
    
    Fields fields
    
    recordDelimiter
    
    String recordDelimiter
- Class org.apache.storm.hdfs.bolt.format.SimpleFileNameFormat
  
  class SimpleFileNameFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    componentId
    
    String componentId
    
    host
    
    String host
    
    name
    
    String name
    
    path
    
    String path
    
    taskId
    
    int taskId
    
    timeFormat
    
    String timeFormat
Package org.apache.storm.hdfs.bolt.rotation
- Class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy
  
  class FileSizeRotationPolicy extends Object implements Serializable
  - Serialized Fields
    
    currentBytesWritten
    
    long currentBytesWritten
    
    lastOffset
    
    long lastOffset
    
    maxBytes
    
    long maxBytes
- Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
  
  class NoRotationPolicy extends Object implements Serializable
- Class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
  
  class TimedRotationPolicy extends Object implements Serializable
  - Serialized Fields
    
    interval
    
    long interval
Package org.apache.storm.hdfs.bolt.sync
- Class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy
  
  class CountSyncPolicy extends Object implements Serializable
  - Serialized Fields
    
    count
    
    int count
    
    executeCount
    
    int executeCount
Package org.apache.storm.hdfs.common
- Class org.apache.storm.hdfs.common.NullPartitioner
  
  class NullPartitioner extends Object implements Serializable
Package org.apache.storm.hdfs.common.rotation
- Class org.apache.storm.hdfs.common.rotation.MoveFileAction
  
  class MoveFileAction extends Object implements Serializable
  - Serialized Fields
    
    destination
    
    String destination

Package org.apache.storm.hdfs.spout

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

class HdfsSpout extends BaseRichSpout implements Serializable

Serialized Fields

ackEnabled
```
boolean ackEnabled
```
acksSinceLastCommit
```
int acksSinceLastCommit
```
archiveDir
```
String archiveDir
```

archiveDirPath

org.apache.hadoop.fs.Path archiveDirPath

badFilesDir
```
String badFilesDir
```

badFilesDirPath

org.apache.hadoop.fs.Path badFilesDirPath

clocksInSync
```
boolean clocksInSync
```
collector
```
SpoutOutputCollector collector
```
commitFrequencyCount
```
int commitFrequencyCount
```
commitFrequencySec
```
int commitFrequencySec
```
commitTimeElapsed
```
AtomicBoolean commitTimeElapsed
```
commitTimer
```
Timer commitTimer
```
conf
```
Map<String,Object> conf
```
configKey
```
String configKey
```
fileReadCompletely
```
boolean fileReadCompletely
```
hdfs
```
org.apache.hadoop.fs.FileSystem hdfs
```

hdfsConfig

org.apache.hadoop.conf.Configuration hdfsConfig

hdfsUri
```
String hdfsUri
```
ignoreSuffix
```
String ignoreSuffix
```

inflight

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

inprogressSuffix
```
String inprogressSuffix
```

lastExpiredLock

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

lastExpiredLockTime
```
long lastExpiredLockTime
```
lock
```
FileLock lock
```
lockDir
```
String lockDir
```
lockDirPath
```
org.apache.hadoop.fs.Path lockDirPath
```
lockTimeoutSec
```
int lockTimeoutSec
```
maxOutstanding
```
int maxOutstanding
```
outputFields
```
Fields outputFields
```
outputStreamName
```
String outputStreamName
```

reader

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

readerType
```
String readerType
```

retryList

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

sourceDir
```
String sourceDir
```
sourceDirPath
```
org.apache.hadoop.fs.Path sourceDirPath
```
spoutId
```
String spoutId
```
tracker
```
ProgressTracker tracker
```
tupleCounter
```
long tupleCounter
```

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

class ConstBolt extends BaseRichBolt implements Serializable

serialVersionUID:

-5313598399155365865L
- Serialized Fields
  - collector
    
    OutputCollector collector
  - count
    
    int count
Exception org.apache.storm.hdfs.spout.ParseException

class ParseException extends Exception implements Serializable

Package org.apache.storm.hdfs.trident
- Class org.apache.storm.hdfs.trident.FixedBatchSpout
  
  class FixedBatchSpout extends Object implements Serializable
  - Serialized Fields
    
    batches
    
    HashMap<Long,List<List<Object>>> batches
    
    cycle
    
    boolean cycle
    
    fields
    
    Fields fields
    
    index
    
    int index
    
    maxBatchSize
    
    int maxBatchSize
    
    outputs
    
    List<Object>[] outputs
- Class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
  
  class HdfsFileOptions extends HdfsState.Options implements Serializable
  - Serialized Fields
    
    bufferSize
    
    int bufferSize
    
    format
    
    RecordFormat format
    
    offset
    
    long offset
- Class org.apache.storm.hdfs.trident.HdfsState.Options
  
  class Options extends Object implements Serializable
  - Serialized Fields
    
    configKey
    
    String configKey
    
    currentFile
    
    org.apache.hadoop.fs.Path currentFile
    
    fileNameFormat
    
    FileNameFormat fileNameFormat
    
    fsUrl
    
    String fsUrl
    
    rotation
    
    int rotation
    
    rotationActions
    
    ArrayList<RotationAction> rotationActions
    
    rotationPolicy
    
    FileRotationPolicy rotationPolicy
- Class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
  
  class SequenceFileOptions extends HdfsState.Options implements Serializable
  - Serialized Fields
    
    compressionCodec
    
    String compressionCodec
    
    compressionType
    
    org.apache.hadoop.io.SequenceFile.CompressionType compressionType
    
    format
    
    SequenceFormat format
- Class org.apache.storm.hdfs.trident.HdfsStateFactory
  
  class HdfsStateFactory extends Object implements Serializable
  - Serialized Fields
    
    options
    
    HdfsState.Options options
- Class org.apache.storm.hdfs.trident.HdfsUpdater
  
  class HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable
Package org.apache.storm.hdfs.trident.format
- Class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
  
  class DefaultFileNameFormat extends Object implements Serializable
  - Serialized Fields
    
    extension
    
    String extension
    
    partitionIndex
    
    int partitionIndex
    
    path
    
    String path
    
    prefix
    
    String prefix
- Class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
  
  class DefaultSequenceFormat extends Object implements Serializable
  - Serialized Fields
    
    keyField
    
    String keyField
    
    valueField
    
    String valueField
- Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
  
  class DelimitedRecordFormat extends Object implements Serializable
  - Serialized Fields
    
    fieldDelimiter
    
    String fieldDelimiter
    
    fields
    
    Fields fields
    
    recordDelimiter
    
    String recordDelimiter
- Class org.apache.storm.hdfs.trident.format.SimpleFileNameFormat
  
  class SimpleFileNameFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    host
    
    String host
    
    name
    
    String name
    
    partitionIndex
    
    int partitionIndex
    
    path
    
    String path
    
    timeFormat
    
    String timeFormat
Package org.apache.storm.hdfs.trident.rotation
- Class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy
  
  class FileSizeRotationPolicy extends Object implements Serializable
  - Serialized Fields
    
    currentBytesWritten
    
    long currentBytesWritten
    
    lastOffset
    
    long lastOffset
    
    maxBytes
    
    long maxBytes
- Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy
  
  class NoRotationPolicy extends Object implements Serializable
- Class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy
  
  class TimedRotationPolicy extends Object implements Serializable
  - Serialized Fields
    
    interval
    
    long interval
    
    rotationTimer
    
    Timer rotationTimer
    
    rotationTimerTriggered
    
    AtomicBoolean rotationTimerTriggered
Package org.apache.storm.hdfs.trident.sync
- Class org.apache.storm.hdfs.trident.sync.CountSyncPolicy
  
  class CountSyncPolicy extends Object implements Serializable
  - Serialized Fields
    
    count
    
    int count
    
    executeCount
    
    int executeCount
Package org.apache.storm.hive.bolt
- Class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout
  
  class 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
  
  class HiveBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    allWriters
    
    Map<org.apache.hive.hcatalog.streaming.HiveEndPoint,HiveWriter> allWriters
    
    batchHelper
    
    BatchHelper batchHelper
    
    callTimeoutPool
    
    ExecutorService callTimeoutPool
    
    collector
    
    OutputCollector collector
    
    options
    
    HiveOptions options
    
    sendHeartBeat
    
    AtomicBoolean sendHeartBeat
    
    tokenAuthEnabled
    
    boolean tokenAuthEnabled
    
    ugi
    
    org.apache.hadoop.security.UserGroupInformation ugi
- Class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout
  
  class 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
  
  class 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
  
  class DelimitedRecordHiveMapper extends Object implements Serializable
  - Serialized Fields
    
    columnFields
    
    Fields columnFields
    
    columnNames
    
    String[] columnNames
    
    fieldDelimiter
    
    String fieldDelimiter
    
    parseDate
    
    SimpleDateFormat parseDate
    
    partitionFields
    
    Fields partitionFields
    
    timeFormat
    
    String timeFormat
- Class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper
  
  class JsonRecordHiveMapper extends Object implements Serializable
  - Serialized Fields
    
    columnFields
    
    Fields columnFields
    
    parseDate
    
    SimpleDateFormat parseDate
    
    partitionFields
    
    Fields partitionFields
    
    timeFormat
    
    String timeFormat
Package org.apache.storm.hive.common
- Class org.apache.storm.hive.common.HiveOptions
  
  class HiveOptions extends Object implements Serializable
  - Serialized Fields
    
    autoCreatePartitions
    
    Boolean autoCreatePartitions
    
    batchSize
    
    Integer batchSize
    
    callTimeout
    
    Integer callTimeout
    
    databaseName
    
    String databaseName
    
    heartBeatInterval
    
    Integer heartBeatInterval
    
    idleTimeout
    
    Integer idleTimeout
    
    kerberosKeytab
    
    String kerberosKeytab
    
    kerberosPrincipal
    
    String kerberosPrincipal
    
    mapper
    
    HiveMapper mapper
    
    maxOpenConnections
    
    Integer maxOpenConnections
    
    metaStoreURI
    
    String metaStoreURI
    
    tableName
    
    String tableName
    
    tickTupleInterval
    
    Integer tickTupleInterval
    
    txnsPerBatch
    
    Integer txnsPerBatch
- Exception org.apache.storm.hive.common.HiveUtils.AuthenticationFailed
  
  class AuthenticationFailed extends Exception implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.CommitFailure
  
  class CommitFailure extends HiveWriter.Failure implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.ConnectFailure
  
  class ConnectFailure extends HiveWriter.Failure implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.Failure
  
  class Failure extends Exception implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.TxnBatchFailure
  
  class TxnBatchFailure extends HiveWriter.Failure implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.TxnFailure
  
  class TxnFailure extends HiveWriter.Failure implements Serializable
- Exception org.apache.storm.hive.common.HiveWriter.WriteFailure
  
  class WriteFailure extends HiveWriter.Failure implements Serializable
Package org.apache.storm.hive.trident
- Class org.apache.storm.hive.trident.HiveStateFactory
  
  class HiveStateFactory extends Object implements Serializable
  - Serialized Fields
    
    options
    
    HiveOptions options
- Class org.apache.storm.hive.trident.HiveUpdater
  
  class HiveUpdater extends BaseStateUpdater<HiveState> implements Serializable
- Class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout
  
  class 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
  
  class BaseWorkerHook extends Object implements Serializable
  
  serialVersionUID:
  
  2589466485198339529L
- Exception org.apache.storm.hooks.SubmitterHookException
  
  class SubmitterHookException extends RuntimeException implements Serializable
Package org.apache.storm.jdbc.bolt
- Class org.apache.storm.jdbc.bolt.AbstractJdbcBolt
  
  class AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    configKey
    
    String configKey
    
    connectionProvider
    
    ConnectionProvider connectionProvider
    
    queryTimeoutSecs
    
    Integer queryTimeoutSecs
- Class org.apache.storm.jdbc.bolt.JdbcInsertBolt
  
  class JdbcInsertBolt extends AbstractJdbcBolt implements Serializable
  - Serialized Fields
    
    insertQuery
    
    String insertQuery
    
    jdbcMapper
    
    JdbcMapper jdbcMapper
    
    tableName
    
    String tableName
- Class org.apache.storm.jdbc.bolt.JdbcLookupBolt
  
  class JdbcLookupBolt extends AbstractJdbcBolt implements Serializable
  - Serialized Fields
    
    jdbcLookupMapper
    
    JdbcLookupMapper jdbcLookupMapper
    
    selectQuery
    
    String selectQuery
Package org.apache.storm.jdbc.common
- Class org.apache.storm.jdbc.common.Column
  
  class Column extends Object implements Serializable
  - Serialized Fields
    
    columnName
    
    String columnName
    
    sqlType
    
    int sqlType
    
    The sql type(e.g. varchar, date, int) Ideally we would have an enum but java's jdbc API uses integer. See Types
    
    val
    
    T val
- Class org.apache.storm.jdbc.common.HikariCPConnectionProvider
  
  class HikariCPConnectionProvider extends Object implements Serializable
  - Serialized Fields
    
    configMap
    
    Map<String,Object> configMap
Package org.apache.storm.jdbc.mapper
- Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper
  
  class SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable
  - Serialized Fields
    
    outputFields
    
    Fields outputFields
- Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper
  
  class SimpleJdbcMapper extends Object implements Serializable
  - Serialized Fields
    
    schemaColumns
    
    List<Column> schemaColumns
Package org.apache.storm.jdbc.spout
- Class org.apache.storm.jdbc.spout.UserSpout
  
  class UserSpout extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    isDistributed
    
    boolean isDistributed
Package org.apache.storm.jdbc.trident.state
- Class org.apache.storm.jdbc.trident.state.JdbcQuery
  
  class JdbcQuery extends BaseQueryFunction<JdbcState,List<Values>> implements Serializable
- Class org.apache.storm.jdbc.trident.state.JdbcState.Options
  
  class Options extends Object implements Serializable
  - Serialized Fields
    
    connectionProvider
    
    ConnectionProvider connectionProvider
    
    insertQuery
    
    String insertQuery
    
    jdbcLookupMapper
    
    JdbcLookupMapper jdbcLookupMapper
    
    mapper
    
    JdbcMapper mapper
    
    queryTimeoutSecs
    
    Integer queryTimeoutSecs
    
    selectQuery
    
    String selectQuery
    
    tableName
    
    String tableName
- Class org.apache.storm.jdbc.trident.state.JdbcStateFactory
  
  class JdbcStateFactory extends Object implements Serializable
  - Serialized Fields
    
    options
    
    JdbcState.Options options
- Class org.apache.storm.jdbc.trident.state.JdbcUpdater
  
  class JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable
Package org.apache.storm.jms
Package org.apache.storm.jms.bolt
- Class org.apache.storm.jms.bolt.JmsBolt
  
  class JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    
    autoAck
    
    boolean autoAck
    
    collector
    
    OutputCollector collector
    
    connection
    
    javax.jms.Connection connection
    
    jmsAcknowledgeMode
    
    int jmsAcknowledgeMode
    
    jmsProvider
    
    JmsProvider jmsProvider
    
    jmsTransactional
    
    boolean jmsTransactional
    
    messageProducer
    
    javax.jms.MessageProducer messageProducer
    
    producer
    
    JmsMessageProducer producer
    
    session
    
    javax.jms.Session session
Package org.apache.storm.jms.example
- Class org.apache.storm.jms.example.GenericBolt
  
  class GenericBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    autoAck
    
    boolean autoAck
    
    autoAnchor
    
    boolean autoAnchor
    
    collector
    
    OutputCollector collector
    
    declaredFields
    
    Fields declaredFields
    
    name
    
    String name
- Class org.apache.storm.jms.example.JsonTupleProducer
  
  class JsonTupleProducer extends Object implements Serializable
- Class org.apache.storm.jms.example.SpringJmsProvider
  
  class SpringJmsProvider extends Object implements Serializable
  - Serialized Fields
    
    connectionFactory
    
    javax.jms.ConnectionFactory connectionFactory
    
    destination
    
    javax.jms.Destination destination
Package org.apache.storm.jms.spout
- Class org.apache.storm.jms.spout.JmsMessageID
  
  class JmsMessageID extends Object implements Serializable
  - Serialized Fields
    
    jmsId
    
    String jmsId
    
    sequence
    
    Long sequence
- Class org.apache.storm.jms.spout.JmsSpout
  
  class JmsSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    The collector used to emit tuples.
    
    consumer
    
    javax.jms.MessageConsumer consumer
    
    The message consumer.
    
    distributed
    
    boolean distributed
    
    Indicates whether or not this spout should run as a singleton.
    
    individualAcks
    
    boolean individualAcks
    
    If JMS provider supports ack-ing individual messages.
    
    jmsAcknowledgeMode
    
    int jmsAcknowledgeMode
    
    The acknowledgment mode used for this instance.
    
    See Also:
    
    Session
    
    jmsProvider
    
    JmsProvider jmsProvider
    
    Encapsulates jms related classes needed to communicate with the mq.
    
    messageHandler
    
    org.apache.storm.jms.spout.JmsSpout.MessageHandler messageHandler
    
    Sets up the way we want to handle the emit, ack and fails.
    
    messageSequence
    
    long messageSequence
    
    Counter of handled messages.
    
    tupleProducer
    
    JmsTupleProducer tupleProducer
    
    Used to generate tuples from incoming messages.
Package org.apache.storm.jms.trident
- Class org.apache.storm.jms.trident.JmsState.Options
  
  class Options extends Object implements Serializable
  - Serialized Fields
    
    jmsAcknowledgeMode
    
    int jmsAcknowledgeMode
    
    jmsProvider
    
    JmsProvider jmsProvider
    
    jmsTransactional
    
    boolean jmsTransactional
    
    msgProducer
    
    JmsMessageProducer msgProducer
- Class org.apache.storm.jms.trident.JmsStateFactory
  
  class JmsStateFactory extends Object implements Serializable
  - Serialized Fields
    
    options
    
    JmsState.Options options
- Class org.apache.storm.jms.trident.JmsUpdater
  
  class JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable
- Class org.apache.storm.jms.trident.TridentJmsSpout
  
  class TridentJmsSpout extends Object implements Serializable
  
  serialVersionUID:
  
  -3469351154693356655L
  - Serialized Fields
    
    jmsAcknowledgeMode
    
    int jmsAcknowledgeMode
    
    jmsProvider
    
    JmsProvider jmsProvider
    
    name
    
    String name
    
    tupleProducer
    
    JmsTupleProducer tupleProducer
Package org.apache.storm.kafka.bolt
- Class org.apache.storm.kafka.bolt.KafkaBolt
  
  class KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable
  
  serialVersionUID:
  
  -5205886631877033478L
  - Serialized Fields
    
    async
    
    boolean async
    
    KafkaBolt.setAsync(boolean) for more details on this.
    
    boltSpecifiedProperties
    
    Properties boltSpecifiedProperties
    
    collector
    
    OutputCollector collector
    
    fireAndForget
    
    boolean fireAndForget
    
    KafkaBolt.setFireAndForget(boolean) for more details on this.
    
    mapper
    
    TupleToKafkaMapper<K,V> mapper
    
    producer
    
    org.apache.kafka.clients.producer.Producer<K,V> producer
    
    providedCallback
    
    PreparableCallback providedCallback
    
    topicSelector
    
    KafkaTopicSelector topicSelector
Package org.apache.storm.kafka.bolt.mapper
- Class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper
  
  class FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
  
  serialVersionUID:
  
  -8794262989021702349L
  - Serialized Fields
    
    boltKeyField
    
    String boltKeyField
    
    boltMessageField
    
    String boltMessageField
Package org.apache.storm.kafka.bolt.selector
- Class org.apache.storm.kafka.bolt.selector.DefaultTopicSelector
  
  class DefaultTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  4601118062437851265L
  - Serialized Fields
    
    topicName
    
    String topicName
- Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector
  
  class FieldIndexTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3830575380208166367L
  - Serialized Fields
    
    defaultTopicName
    
    String defaultTopicName
    
    fieldIndex
    
    int fieldIndex
- Class org.apache.storm.kafka.bolt.selector.FieldNameTopicSelector
  
  class FieldNameTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -3903708904533396833L
  - Serialized Fields
    
    defaultTopicName
    
    String defaultTopicName
    
    fieldName
    
    String fieldName
Package org.apache.storm.kafka.spout
- Class org.apache.storm.kafka.spout.ByTopicRecordTranslator
  
  class ByTopicRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -121699733778988688L
  - Serialized Fields
    
    defaultTranslator
    
    RecordTranslator<K,V> defaultTranslator
    
    streamToFields
    
    Map<String,Fields> streamToFields
    
    topicToTranslator
    
    Map<String,RecordTranslator<K,V>> topicToTranslator
- Class org.apache.storm.kafka.spout.DefaultRecordTranslator
  
  class DefaultRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  -5782462870112305750L
- Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener
  
  class EmptyKafkaTupleListener extends Object implements Serializable
- Class org.apache.storm.kafka.spout.KafkaSpout
  
  class KafkaSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  4151921085047987154L
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    kafkaConsumerFactory
    
    ConsumerFactory<K,V> kafkaConsumerFactory
    
    kafkaSpoutConfig
    
    KafkaSpoutConfig<K,V> kafkaSpoutConfig
    
    topicAssigner
    
    TopicAssigner topicAssigner
- Class org.apache.storm.kafka.spout.KafkaSpoutConfig
  
  class KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
  
  serialVersionUID:
  
  141902646130682494L
  - Serialized Fields
    
    emitNullTuples
    
    boolean emitNullTuples
    
    maxUncommittedOffsets
    
    int maxUncommittedOffsets
    
    metricsTimeBucketSizeInSecs
    
    int metricsTimeBucketSizeInSecs
    
    offsetCommitPeriodMs
    
    long offsetCommitPeriodMs
    
    processingGuarantee
    
    KafkaSpoutConfig.ProcessingGuarantee processingGuarantee
    
    retryService
    
    KafkaSpoutRetryService retryService
    
    tupleListener
    
    KafkaTupleListener tupleListener
    
    tupleTrackingEnforced
    
    boolean tupleTrackingEnforced
- Class org.apache.storm.kafka.spout.KafkaSpoutMessageId
  
  class KafkaSpoutMessageId extends Object implements Serializable
  - Serialized Fields
    
    nullTuple
    
    boolean nullTuple
    
    false if the record was emitted using a form of collector.emit(...). true when skipping null tuples as configured by the user in KafkaSpoutConfig
    
    numFails
    
    int numFails
    
    offset
    
    long offset
    
    topicPart
    
    org.apache.kafka.common.TopicPartition topicPart
- Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff
  
  class KafkaSpoutRetryExponentialBackoff extends Object implements Serializable
  - Serialized Fields
    
    delayPeriod
    
    KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod
    
    initialDelay
    
    KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay
    
    maxDelay
    
    KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay
    
    maxRetries
    
    int maxRetries
    
    retrySchedules
    
    Set<org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.RetrySchedule> retrySchedules
    
    toRetryMsgs
    
    Set<KafkaSpoutMessageId> toRetryMsgs
- Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval
  
  class TimeInterval extends Object implements Serializable
  - Serialized Fields
    
    length
    
    long length
    
    lengthNanos
    
    long lengthNanos
    
    timeUnit
    
    TimeUnit timeUnit
- Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt
  
  class KafkaSpoutTestBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.kafka.spout.KafkaTuple
  
  class KafkaTuple extends Values implements Serializable
  
  serialVersionUID:
  
  4803794470450587992L
  - Serialized Fields
    
    stream
    
    String stream
- Class org.apache.storm.kafka.spout.SimpleRecordTranslator
  
  class SimpleRecordTranslator extends Object implements Serializable
  
  serialVersionUID:
  
  4678369144122009596L
  - Serialized Fields
    
    fields
    
    Fields fields
    
    func
    
    Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func
    
    stream
    
    String stream
Package org.apache.storm.kafka.spout.internal
- Class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig
  
  class CommonKafkaSpoutConfig extends Object implements Serializable
  - Serialized Fields
    
    firstPollOffsetStrategy
    
    FirstPollOffsetStrategy firstPollOffsetStrategy
    
    kafkaProps
    
    Map<String,Object> kafkaProps
    
    partitionRefreshPeriodMs
    
    long partitionRefreshPeriodMs
    
    pollTimeoutMs
    
    long pollTimeoutMs
    
    startTimeStamp
    
    long startTimeStamp
    
    topicFilter
    
    TopicFilter topicFilter
    
    topicPartitioner
    
    ManualPartitioner topicPartitioner
    
    translator
    
    RecordTranslator<K,V> translator
- Class org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault
  
  class ConsumerFactoryDefault extends Object implements Serializable
Package org.apache.storm.kafka.spout.subscription
- Class org.apache.storm.kafka.spout.subscription.NamedTopicFilter
  
  class NamedTopicFilter extends Object implements Serializable
  - Serialized Fields
    
    topics
    
    Set<String> topics
- Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter
  
  class PatternTopicFilter extends Object implements Serializable
  - Serialized Fields
    
    pattern
    
    Pattern pattern
    
    topics
    
    Set<String> topics
- Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner
  
  class RoundRobinManualPartitioner extends Object implements Serializable
- Class org.apache.storm.kafka.spout.subscription.TopicAssigner
  
  class TopicAssigner extends Object implements Serializable
  
  serialVersionUID:
  
  5423018073527583826L
Package org.apache.storm.kafka.spout.trident
- Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter
  
  class KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    emitter
    
    KafkaTridentSpoutEmitter<K,V> emitter
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata
  
  class KafkaTridentSpoutBatchMetadata extends Object implements Serializable
  - Serialized Fields
    
    firstOffset
    
    long firstOffset
    
    lastOffset
    
    long lastOffset
    
    topologyId
    
    String topologyId
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig
  
  class KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator
  
  class KafkaTridentSpoutCoordinator extends Object implements Serializable
  - Serialized Fields
    
    consumer
    
    org.apache.kafka.clients.consumer.Consumer<K,V> consumer
    
    kafkaSpoutConfig
    
    KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
    
    partitionsForBatch
    
    Set<org.apache.kafka.common.TopicPartition> partitionsForBatch
    
    refreshAssignmentTimer
    
    Timer refreshAssignmentTimer
    
    tpSerializer
    
    TopicPartitionSerializer tpSerializer
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter
  
  class KafkaTridentSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  -7343927794834130435L
  - Serialized Fields
    
    consumer
    
    org.apache.kafka.clients.consumer.Consumer<K,V> consumer
    
    firstPollOffsetStrategy
    
    FirstPollOffsetStrategy firstPollOffsetStrategy
    
    kafkaSpoutConfig
    
    KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
    
    pollTimeoutMs
    
    long pollTimeoutMs
    
    startTimeStamp
    
    long startTimeStamp
    
    topicAssigner
    
    TopicAssigner topicAssigner
    
    topologyContext
    
    TopologyContext topologyContext
    
    tpSerializer
    
    TopicPartitionSerializer tpSerializer
    
    tpToFirstSeekOffset
    
    Map<org.apache.kafka.common.TopicPartition,Long> tpToFirstSeekOffset
    
    translator
    
    RecordTranslator<K,V> translator
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaque
  
  class KafkaTridentSpoutOpaque extends Object implements Serializable
  
  serialVersionUID:
  
  -8003272486566259640L
  - Serialized Fields
    
    kafkaSpoutConfig
    
    KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
    
    outputFieldsExtractor
    
    OutputFieldsExtractor outputFieldsExtractor
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition
  
  class KafkaTridentSpoutTopicPartition extends Object implements Serializable
  - Serialized Fields
    
    topicPartition
    
    org.apache.kafka.common.TopicPartition topicPartition
- Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional
  
  class KafkaTridentSpoutTransactional extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    kafkaSpoutConfig
    
    KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig
    
    outputFieldsExtractor
    
    OutputFieldsExtractor outputFieldsExtractor
- Class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitter
  
  class KafkaTridentTransactionalSpoutEmitter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    emitter
    
    KafkaTridentSpoutEmitter<K,V> emitter
Package org.apache.storm.kafka.spout.trident.internal
- Class org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor
  
  class OutputFieldsExtractor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.storm.kafka.trident
- Class org.apache.storm.kafka.trident.TridentKafkaStateFactory
  
  class TridentKafkaStateFactory extends Object implements Serializable
  
  serialVersionUID:
  
  -3613240970062343385L
  - Serialized Fields
    
    mapper
    
    TridentTupleToKafkaMapper<K,V> mapper
    
    producerProperties
    
    Properties producerProperties
    
    topicSelector
    
    KafkaTopicSelector topicSelector
- Class org.apache.storm.kafka.trident.TridentKafkaStateUpdater
  
  class TridentKafkaStateUpdater extends BaseStateUpdater<TridentKafkaState<K,V>> implements Serializable
  
  serialVersionUID:
  
  3352659585225274402L
Package org.apache.storm.kafka.trident.mapper
- Class org.apache.storm.kafka.trident.mapper.FieldNameBasedTupleToKafkaMapper
  
  class FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
  - Serialized Fields
    
    keyFieldName
    
    String keyFieldName
    
    msgFieldName
    
    String msgFieldName
Package org.apache.storm.kafka.trident.selector
- Class org.apache.storm.kafka.trident.selector.DefaultTopicSelector
  
  class DefaultTopicSelector extends Object implements Serializable
  
  serialVersionUID:
  
  -1172454882072591493L
  - Serialized Fields
    
    topicName
    
    String topicName
Package org.apache.storm.lambda
- Class org.apache.storm.lambda.LambdaBiConsumerBolt
  
  class LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    biConsumer
    
    SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer
    
    fields
    
    String[] fields
- Class org.apache.storm.lambda.LambdaConsumerBolt
  
  class LambdaConsumerBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    consumer
    
    SerializableConsumer<Tuple> consumer
- Class org.apache.storm.lambda.LambdaSpout
  
  class LambdaSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    supplier
    
    SerializableSupplier<?> supplier
Package org.apache.storm.loadgen
- Class org.apache.storm.loadgen.ExecAndProcessLatencyEngine
  
  class ExecAndProcessLatencyEngine extends Object implements Serializable
  - Serialized Fields
    
    parkOffset
    
    AtomicLong parkOffset
    
    rand
    
    Random rand
    
    skewedPattern
    
    SlowExecutorPattern skewedPattern
    
    timer
    
    ScheduledExecutorService timer
- Class org.apache.storm.loadgen.InputStream
  
  class InputStream extends Object implements Serializable
  - Serialized Fields
    
    execTime
    
    NormalDistStats execTime
    
    fromComponent
    
    String fromComponent
    
    groupingType
    
    GroupingType groupingType
    
    gsid
    
    GlobalStreamId gsid
    
    id
    
    String id
    
    processTime
    
    NormalDistStats processTime
    
    toComponent
    
    String toComponent
- Class org.apache.storm.loadgen.LoadBolt
  
  class LoadBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    executorIndex
    
    int executorIndex
    
    inputStreams
    
    Map<GlobalStreamId,InputStream> inputStreams
    
    outputStreams
    
    List<OutputStreamEngine> outputStreams
    
    outputStreamStats
    
    List<OutputStream> outputStreamStats
    
    sleep
    
    ExecAndProcessLatencyEngine sleep
- Class org.apache.storm.loadgen.LoadSpout
  
  class LoadSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    nextStreamCounter
    
    long nextStreamCounter
    
    numStreams
    
    int numStreams
    
    replays
    
    Queue<org.apache.storm.loadgen.LoadSpout.SentWithTime> replays
    
    streams
    
    List<org.apache.storm.loadgen.LoadSpout.OutputStreamEngineWithHisto> streams
    
    streamStats
    
    List<OutputStream> streamStats
- Class org.apache.storm.loadgen.NormalDistStats
  
  class NormalDistStats extends Object implements Serializable
  - Serialized Fields
    
    max
    
    double max
    
    mean
    
    double mean
    
    min
    
    double min
    
    stddev
    
    double stddev
- Class org.apache.storm.loadgen.OutputStream
  
  class OutputStream extends Object implements Serializable
  - Serialized Fields
    
    areKeysSkewed
    
    boolean areKeysSkewed
    
    id
    
    String id
    
    rate
    
    NormalDistStats rate
- Class org.apache.storm.loadgen.ScopedTopologySet
  
  class ScopedTopologySet extends HashSet<String> implements Serializable
  - Serialized Fields
    
    client
    
    Nimbus.Iface client
    
    closed
    
    boolean closed
- Class org.apache.storm.loadgen.SlowExecutorPattern
  
  class SlowExecutorPattern extends Object implements Serializable
  - Serialized Fields
    
    count
    
    int count
    
    maxSlownessMs
    
    double maxSlownessMs
- Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout
  
  class FastRandomSentenceSpout extends LoadSpout implements Serializable
- Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence
  
  class SplitSentence extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    executorIndex
    
    int executorIndex
    
    sleep
    
    ExecAndProcessLatencyEngine sleep
- Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount
  
  class WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
Package org.apache.storm.metric
- Class org.apache.storm.metric.EventLoggerBolt
  
  class EventLoggerBolt extends Object implements Serializable
  - Serialized Fields
    
    eventLoggers
    
    List<IEventLogger> eventLoggers
- Class org.apache.storm.metric.MetricsConsumerBolt
  
  class MetricsConsumerBolt extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    consumerClassName
    
    String consumerClassName
    
    expander
    
    DataPointExpander expander
    
    filterPredicate
    
    org.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate
    
    maxRetainMetricTuples
    
    int maxRetainMetricTuples
    
    metricsConsumer
    
    IMetricsConsumer metricsConsumer
    
    registrationArgument
    
    Object registrationArgument
    
    running
    
    boolean running
    
    taskExecuteThread
    
    Thread taskExecuteThread
    
    taskQueue
    
    BlockingQueue<org.apache.storm.metric.MetricsConsumerBolt.MetricsTask> taskQueue
- Class org.apache.storm.metric.SystemBolt
  
  class SystemBolt extends Object implements Serializable
Package org.apache.storm.metric.filter
- Class org.apache.storm.metric.filter.FilterByMetricName
  
  class FilterByMetricName extends Object implements Serializable
  - Serialized Fields
    
    blacklistPattern
    
    List<Pattern> blacklistPattern
    
    filterCache
    
    org.apache.storm.shade.com.google.common.cache.Cache<String,Boolean> filterCache
    
    noneSpecified
    
    boolean noneSpecified
    
    whitelistPattern
    
    List<Pattern> whitelistPattern
Package org.apache.storm.metric.util
- Class org.apache.storm.metric.util.DataPointExpander
  
  class DataPointExpander extends Object implements Serializable
  - Serialized Fields
    
    expandMapType
    
    boolean expandMapType
    
    metricNameSeparator
    
    String metricNameSeparator
Package org.apache.storm.metricstore
- Exception org.apache.storm.metricstore.MetricException
  
  class MetricException extends Exception implements Serializable
Package org.apache.storm.multilang
- Class org.apache.storm.multilang.JsonSerializer
  
  class JsonSerializer extends Object implements Serializable
  
  serialVersionUID:
  
  2548814660410474022L
- Exception org.apache.storm.multilang.NoOutputException
  
  class NoOutputException extends Exception implements Serializable
Package org.apache.storm.nimbus
- Class org.apache.storm.nimbus.NimbusInfo
  
  class NimbusInfo extends Object implements Serializable
  
  serialVersionUID:
  
  2161446155116099333L
  - Serialized Fields
    
    host
    
    String host
    
    isLeader
    
    boolean isLeader
    
    port
    
    int port
Package org.apache.storm.pacemaker
- Exception org.apache.storm.pacemaker.PacemakerConnectionException
  
  class PacemakerConnectionException extends Exception implements Serializable
Package org.apache.storm.perf
- Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter
  
  class LineWriter extends Object implements Serializable
  - Serialized Fields
    
    fieldName
    
    String fieldName
    
    lineDelimiter
    
    String lineDelimiter
- Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.LineWriter
  
  class LineWriter extends Object implements Serializable
  
  serialVersionUID:
  
  7524288317405514146L
  - Serialized Fields
    
    fieldName
    
    String fieldName
    
    lineDelimiter
    
    String lineDelimiter
Package org.apache.storm.perf.bolt
- Class org.apache.storm.perf.bolt.CountBolt
  
  class CountBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
- Class org.apache.storm.perf.bolt.DevNullBolt
  
  class DevNullBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    count
    
    int count
    
    sleepNanos
    
    Long sleepNanos
- Class org.apache.storm.perf.bolt.IdBolt
  
  class IdBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.perf.bolt.SplitSentenceBolt
  
  class SplitSentenceBolt extends BaseBasicBolt implements Serializable
Package org.apache.storm.perf.spout
- Class org.apache.storm.perf.spout.ConstSpout
  
  class ConstSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    ackCount
    
    int ackCount
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    int count
    
    fieldName
    
    String fieldName
    
    sleep
    
    Long sleep
    
    value
    
    String value
- Class org.apache.storm.perf.spout.FileReadSpout
  
  class FileReadSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  -2582705611472467172L
  - Serialized Fields
    
    ackEnabled
    
    boolean ackEnabled
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    long count
    
    file
    
    String file
- Class org.apache.storm.perf.spout.FileReadSpout.FileReader
  
  class FileReader extends Object implements Serializable
  
  serialVersionUID:
  
  -7012334600647556267L
  - Serialized Fields
    
    contents
    
    List<String> contents
    
    file
    
    String file
    
    index
    
    int index
    
    limit
    
    int limit
- Class org.apache.storm.perf.spout.StringGenSpout
  
  class StringGenSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    int count
    
    curr
    
    int curr
    
    fieldName
    
    String fieldName
    
    records
    
    ArrayList<String> records
    
    strCount
    
    int strCount
    
    strLen
    
    int strLen
- Class org.apache.storm.perf.spout.WordGenSpout
  
  class WordGenSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  -2582705611472467172L
  - Serialized Fields
    
    ackEnabled
    
    boolean ackEnabled
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    long count
    
    emitMeter
    
    ThroughputMeter emitMeter
    
    file
    
    String file
    
    index
    
    int index
    
    words
    
    ArrayList<String> words
Package org.apache.storm.perf.utils
- Class org.apache.storm.perf.utils.IdentityBolt
  
  class IdentityBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
Package org.apache.storm.planner
- Class org.apache.storm.planner.TaskBundle
  
  class TaskBundle extends Object implements Serializable
  - Serialized Fields
    
    componentId
    
    int componentId
    
    task
    
    IBolt task
Package org.apache.storm.redis.bolt
- Class org.apache.storm.redis.bolt.AbstractRedisBolt
  
  class AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    jedisClusterConfig
    
    JedisClusterConfig jedisClusterConfig
    
    jedisPoolConfig
    
    JedisPoolConfig jedisPoolConfig
- Class org.apache.storm.redis.bolt.RedisFilterBolt
  
  class RedisFilterBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
    
    filterMapper
    
    RedisFilterMapper filterMapper
- Class org.apache.storm.redis.bolt.RedisLookupBolt
  
  class RedisLookupBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
    
    lookupMapper
    
    RedisLookupMapper lookupMapper
- Class org.apache.storm.redis.bolt.RedisStoreBolt
  
  class RedisStoreBolt extends AbstractRedisBolt implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
    
    storeMapper
    
    RedisStoreMapper storeMapper
Package org.apache.storm.redis.common.config
- Class org.apache.storm.redis.common.config.JedisClusterConfig
  
  class JedisClusterConfig extends Object implements Serializable
  - Serialized Fields
    
    maxRedirections
    
    int maxRedirections
    
    nodes
    
    Set<InetSocketAddress> nodes
    
    password
    
    String password
    
    timeout
    
    int timeout
- Class org.apache.storm.redis.common.config.JedisPoolConfig
  
  class JedisPoolConfig extends Object implements Serializable
  - Serialized Fields
    
    database
    
    int database
    
    host
    
    String host
    
    password
    
    String password
    
    port
    
    int port
    
    timeout
    
    int timeout
Package org.apache.storm.redis.common.mapper
- Class org.apache.storm.redis.common.mapper.RedisDataTypeDescription
  
  class RedisDataTypeDescription extends Object implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
Package org.apache.storm.redis.topology
- Class org.apache.storm.redis.topology.LookupWordCount.PrintWordTotalCountBolt
  
  class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt
  
  class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.redis.topology.WordCounter
  
  class WordCounter extends Object implements Serializable
  - Serialized Fields
    
    wordCounter
    
    Map<String,Integer> wordCounter
- Class org.apache.storm.redis.topology.WordSpout
  
  class WordSpout extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    isDistributed
    
    boolean isDistributed
Package org.apache.storm.redis.trident
- Class org.apache.storm.redis.trident.PrintFunction
  
  class PrintFunction extends BaseFunction implements Serializable
- Class org.apache.storm.redis.trident.WordCountLookupMapper
  
  class WordCountLookupMapper extends Object implements Serializable
- Class org.apache.storm.redis.trident.WordCountStoreMapper
  
  class WordCountStoreMapper extends Object implements Serializable
Package org.apache.storm.redis.trident.state
- Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
  
  class AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,List<Values>> implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
    
    lookupMapper
    
    RedisLookupMapper lookupMapper
- Class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater
  
  class AbstractRedisStateUpdater extends BaseStateUpdater<T extends State> implements Serializable
  - Serialized Fields
    
    additionalKey
    
    String additionalKey
    
    dataType
    
    RedisDataTypeDescription.RedisDataType dataType
    
    expireIntervalSec
    
    int expireIntervalSec
    
    storeMapper
    
    RedisStoreMapper storeMapper
- Class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory
  
  class DefaultKeyFactory extends Object implements Serializable
- Class org.apache.storm.redis.trident.state.Options
  
  class Options extends Object implements Serializable
  - Serialized Fields
    
    dataTypeDescription
    
    RedisDataTypeDescription dataTypeDescription
    
    expireIntervalSec
    
    int expireIntervalSec
    
    globalKey
    
    String globalKey
    
    keyFactory
    
    KeyFactory keyFactory
    
    localCacheSize
    
    int localCacheSize
    
    serializer
    
    Serializer<T> serializer
- Class org.apache.storm.redis.trident.state.RedisClusterMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    jedisClusterConfig
    
    JedisClusterConfig jedisClusterConfig
    
    keyFactory
    
    KeyFactory keyFactory
    
    options
    
    Options options
    
    serializer
    
    Serializer serializer
    
    type
    
    StateType type
- Class org.apache.storm.redis.trident.state.RedisClusterState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    jedisClusterConfig
    
    JedisClusterConfig jedisClusterConfig
- Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier
  
  class RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater
  
  class RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    jedisPoolConfig
    
    JedisPoolConfig jedisPoolConfig
    
    keyFactory
    
    KeyFactory keyFactory
    
    options
    
    Options options
    
    serializer
    
    Serializer serializer
    
    type
    
    StateType type
- Class org.apache.storm.redis.trident.state.RedisState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    jedisPoolConfig
    
    JedisPoolConfig jedisPoolConfig
- Class org.apache.storm.redis.trident.state.RedisStateQuerier
  
  class RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable
- Class org.apache.storm.redis.trident.state.RedisStateUpdater
  
  class RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable
Package org.apache.storm.security.auth.plain
- Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider
  
  class SecurityProvider extends Provider implements Serializable
Package org.apache.storm.shade.org.apache.zookeeper
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException
  
  class KeeperException extends Exception implements Serializable
  - Serialized Fields
    
    code
    
    org.apache.storm.shade.org.apache.zookeeper.KeeperException.Code code
    
    path
    
    String path
    
    results
    
    List<org.apache.storm.shade.org.apache.zookeeper.OpResult> results
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorException
  
  class APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedException
  
  class AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsException
  
  class BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionException
  
  class BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossException
  
  class ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyException
  
  class DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.EphemeralOnLocalSessionException
  
  class EphemeralOnLocalSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLException
  
  class InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackException
  
  class InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorException
  
  class MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NewConfigNoQuorum
  
  class NewConfigNoQuorum extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthException
  
  class NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsException
  
  class NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsException
  
  class NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeException
  
  class NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyException
  
  class NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyException
  
  class NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoWatcherException
  
  class NoWatcherException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutException
  
  class OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.QuotaExceededException
  
  class QuotaExceededException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigDisabledException
  
  class ReconfigDisabledException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigInProgress
  
  class ReconfigInProgress extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RequestTimeoutException
  
  class RequestTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyException
  
  class RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionClosedRequireAuthException
  
  class SessionClosedRequireAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredException
  
  class SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedException
  
  class SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorException
  
  class SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ThrottledOpException
  
  class ThrottledOpException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedException
  
  class UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnknownSessionException
  
  class UnknownSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- Exception org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException
  
  class ExitCodeException extends IOException implements Serializable
  - Serialized Fields
    
    exitCode
    
    int exitCode
Package org.apache.storm.spout
- Class org.apache.storm.spout.CheckpointSpout
  
  class CheckpointSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    checkpointInterval
    
    int checkpointInterval
    
    checkpointState
    
    KeyValueState<String,CheckPointState> checkpointState
    
    checkpointStepInProgress
    
    boolean checkpointStepInProgress
    
    collector
    
    SpoutOutputCollector collector
    
    context
    
    TopologyContext context
    
    curTxState
    
    CheckPointState curTxState
    
    lastCheckpointTs
    
    long lastCheckpointTs
    
    recovering
    
    boolean recovering
    
    recoveryStepInProgress
    
    boolean recoveryStepInProgress
    
    sleepInterval
    
    int sleepInterval
- Class org.apache.storm.spout.RawMultiScheme
  
  class RawMultiScheme extends Object implements Serializable
- Class org.apache.storm.spout.RawScheme
  
  class RawScheme extends Object implements Serializable
- Class org.apache.storm.spout.SchemeAsMultiScheme
  
  class SchemeAsMultiScheme extends Object implements Serializable
  - Serialized Fields
    
    scheme
    
    Scheme scheme
- Class org.apache.storm.spout.ShellSpout
  
  class ShellSpout extends Object implements Serializable
  
  serialVersionUID:
  
  5982357019665454L
  - Serialized Fields
    
    changeDirectory
    
    boolean changeDirectory
    
    collector
    
    SpoutOutputCollector collector
    
    command
    
    String[] command
    
    context
    
    TopologyContext context
    
    env
    
    Map<String,String> env
    
    exception
    
    RuntimeException exception
    
    heartBeatExecutorService
    
    ScheduledExecutorService heartBeatExecutorService
    
    lastHeartbeatTimestamp
    
    AtomicLong lastHeartbeatTimestamp
    
    logHandler
    
    ShellLogHandler logHandler
    
    process
    
    ShellProcess process
    
    running
    
    boolean running
    
    spoutMsg
    
    SpoutMsg spoutMsg
    
    waitingOnSubprocess
    
    AtomicBoolean waitingOnSubprocess
    
    workerTimeoutMills
    
    int workerTimeoutMills
Package org.apache.storm.sql.javac
- Exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerException
  
  class CompilerException extends Exception implements Serializable
  
  serialVersionUID:
  
  -2936958840023603270L
Package org.apache.storm.sql.kafka
- Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter
  
  class RecordTranslatorSchemeAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    delegate
    
    Scheme delegate
Package org.apache.storm.sql.parser.impl
- Exception org.apache.storm.sql.parser.impl.ParseException
  
  class ParseException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    currentToken
    
    Token currentToken
    
    This is the last token that has been consumed successfully. If this object has been created due to a parse error, the token following this token will (therefore) be the first error token.
    
    expectedTokenSequences
    
    int[][] expectedTokenSequences
    
    Each entry in this array is an array of integers. Each array of integers represents a sequence of tokens (by their ordinal values) that is expected at this point of the parse.
    
    tokenImage
    
    String[] tokenImage
    
    This is a reference to the "tokenImage" array of the generated parser within which the parse error occurred. This array is defined in the generated ...Constants interface.
- Class org.apache.storm.sql.parser.impl.Token
  
  class Token extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    beginColumn
    
    int beginColumn
    
    The column number of the first character of this Token.
    
    beginLine
    
    int beginLine
    
    The line number of the first character of this Token.
    
    endColumn
    
    int endColumn
    
    The column number of the last character of this Token.
    
    endLine
    
    int endLine
    
    The line number of the last character of this Token.
    
    image
    
    String image
    
    The string image of the token.
    
    kind
    
    int kind
    
    An integer that describes the kind of this token. This numbering system is determined by JavaCCParser, and a table of these numbers is stored in the file ...Constants.java.
    
    next
    
    Token next
    
    A reference to the next regular (non-special) token from the input stream. If this is the last token from the input stream, or if the token manager has not read tokens beyond this one, this field is set to null. This is true only if this token is also a regular token. Otherwise, see below for a description of the contents of this field.
    
    specialToken
    
    Token specialToken
    
    This field is used to access special tokens that occur prior to this token, but after the immediately preceding regular (non-special) token. If there are no such special tokens, this field is set to null. When there are more than one such special token, this field refers to the last of these special tokens, which in turn refers to the next previous special token through its specialToken field, and so on until the first special token (whose specialToken field is null). The next fields of special tokens refer to other special tokens that immediately follow it (without an intervening regular token). If there is no such token, this field is null.
- Error org.apache.storm.sql.parser.impl.TokenMgrError
  
  class TokenMgrError extends Error implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    
    errorCode
    
    int errorCode
    
    Indicates the reason why the exception is thrown. It will have one of the above 4 values.
Package org.apache.storm.sql.runtime
- Class org.apache.storm.sql.runtime.FieldInfo
  
  class FieldInfo extends Object implements Serializable
  - Serialized Fields
    
    isPrimary
    
    boolean isPrimary
    
    name
    
    String name
    
    type
    
    Class<?> type
Package org.apache.storm.sql.runtime.calcite
- Class org.apache.storm.sql.runtime.calcite.DebuggableExecutableExpression
  
  class DebuggableExecutableExpression extends Object implements Serializable
  - Serialized Fields
    
    delegate
    
    ExecutableExpression delegate
    
    delegateCode
    
    String delegateCode
- Class org.apache.storm.sql.runtime.calcite.StormDataContext
  
  class StormDataContext extends Object implements Serializable
  - Serialized Fields
    
    map
    
    com.google.common.collect.ImmutableMap<Object,Object> map
Package org.apache.storm.sql.runtime.datasource.socket.bolt
- Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt
  
  class SocketBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    host
    
    String host
    
    port
    
    int port
    
    serializer
    
    IOutputSerializer serializer
Package org.apache.storm.sql.runtime.datasource.socket.spout
- Class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout
  
  class SocketSpout extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    emitted
    
    Map<String,List<Object>> emitted
    
    host
    
    String host
    
    in
    
    BufferedReader in
    
    objectMapper
    
    com.fasterxml.jackson.databind.ObjectMapper objectMapper
    
    port
    
    int port
    
    queue
    
    BlockingDeque<List<Object>> queue
    
    readerThread
    
    Thread readerThread
    
    running
    
    boolean running
    
    scheme
    
    Scheme scheme
    
    socket
    
    Socket socket
Package org.apache.storm.sql.runtime.serde.avro
- Class org.apache.storm.sql.runtime.serde.avro.AvroScheme
  
  class AvroScheme extends Object implements Serializable
  - Serialized Fields
    
    fieldNames
    
    List<String> fieldNames
    
    schemas
    
    CachedSchemas schemas
    
    schemaString
    
    String schemaString
- Class org.apache.storm.sql.runtime.serde.avro.AvroSerializer
  
  class AvroSerializer extends Object implements Serializable
  - Serialized Fields
    
    fieldNames
    
    List<String> fieldNames
    
    schemas
    
    CachedSchemas schemas
    
    schemaString
    
    String schemaString
- Class org.apache.storm.sql.runtime.serde.avro.CachedSchemas
  
  class CachedSchemas extends Object implements Serializable
  - Serialized Fields
    
    cache
    
    Map<String,org.apache.avro.Schema> cache
Package org.apache.storm.sql.runtime.serde.csv
- Class org.apache.storm.sql.runtime.serde.csv.CsvScheme
  
  class CsvScheme extends Object implements Serializable
  - Serialized Fields
    
    fieldNames
    
    List<String> fieldNames
- Class org.apache.storm.sql.runtime.serde.csv.CsvSerializer
  
  class CsvSerializer extends Object implements Serializable
  - Serialized Fields
    
    fields
    
    List<String> fields
Package org.apache.storm.sql.runtime.serde.json
- Class org.apache.storm.sql.runtime.serde.json.JsonScheme
  
  class JsonScheme extends Object implements Serializable
  - Serialized Fields
    
    fields
    
    List<String> fields
- Class org.apache.storm.sql.runtime.serde.json.JsonSerializer
  
  class JsonSerializer extends Object implements Serializable
  - Serialized Fields
    
    fieldNames
    
    List<String> fieldNames
    
    jsonFactory
    
    com.fasterxml.jackson.core.JsonFactory jsonFactory
Package org.apache.storm.sql.runtime.serde.tsv
- Class org.apache.storm.sql.runtime.serde.tsv.TsvScheme
  
  class TsvScheme extends Object implements Serializable
  - Serialized Fields
    
    delimiter
    
    char delimiter
    
    fieldNames
    
    List<String> fieldNames
- Class org.apache.storm.sql.runtime.serde.tsv.TsvSerializer
  
  class TsvSerializer extends Object implements Serializable
  - Serialized Fields
    
    delimiter
    
    char delimiter
    
    fields
    
    List<String> fields
Package org.apache.storm.sql.runtime.streams.functions
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationCalc
  
  class EvaluationCalc extends Object implements Serializable
  - Serialized Fields
    
    dataContext
    
    org.apache.calcite.DataContext dataContext
    
    filterInstance
    
    ExecutableExpression filterInstance
    
    outputValues
    
    Object[] outputValues
    
    projectionInstance
    
    ExecutableExpression projectionInstance
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationFilter
  
  class EvaluationFilter extends Object implements Serializable
  - Serialized Fields
    
    dataContext
    
    org.apache.calcite.DataContext dataContext
    
    filterInstance
    
    ExecutableExpression filterInstance
    
    outputValues
    
    Object[] outputValues
- Class org.apache.storm.sql.runtime.streams.functions.EvaluationFunction
  
  class EvaluationFunction extends Object implements Serializable
  - Serialized Fields
    
    dataContext
    
    org.apache.calcite.DataContext dataContext
    
    outputValues
    
    Object[] outputValues
    
    projectionInstance
    
    ExecutableExpression projectionInstance
- Class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction
  
  class StreamInsertMapToPairFunction extends Object implements Serializable
  - Serialized Fields
    
    primaryKeyIndex
    
    int primaryKeyIndex
- Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper
  
  class StreamsScanTupleValueMapper extends Object implements Serializable
  - Serialized Fields
    
    fieldNames
    
    List<String> fieldNames
Package org.apache.storm.st.topology.window
- Class org.apache.storm.st.topology.window.IncrementingSpout
  
  class IncrementingSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    componentId
    
    String componentId
    
    currentNum
    
    int currentNum
- Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout
  
  class TimeDataIncrementingSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    componentId
    
    String componentId
    
    currentNum
    
    int currentNum
- Class org.apache.storm.st.topology.window.TimeDataVerificationBolt
  
  class TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    componentId
    
    String componentId
- Class org.apache.storm.st.topology.window.VerificationBolt
  
  class VerificationBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    componentId
    
    String componentId
Package org.apache.storm.starter
- Class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpout
  
  class RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    random
    
    Random random
- Class org.apache.storm.starter.AnchoredWordCount.SplitSentence
  
  class SplitSentence extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.AnchoredWordCount.WordCount
  
  class WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
- Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt
  
  class ExclaimBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords
  
  class FilterWords extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    poll
    
    boolean poll
    
    pollTime
    
    long pollTime
    
    wordSet
    
    Set<String> wordSet
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout
  
  class RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
- Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence
  
  class SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt
  
  class ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout
  
  class FastRandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    rand
    
    Random rand
- Class org.apache.storm.starter.FastWordCountTopology.SplitSentence
  
  class SplitSentence extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.FastWordCountTopology.WordCount
  
  class WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
- Class org.apache.storm.starter.InOrderDeliveryTest.Check
  
  class Check extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    expected
    
    Map<Integer,Integer> expected
- Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout
  
  class InOrderSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    base
    
    int base
    
    collector
    
    SpoutOutputCollector collector
    
    count
    
    int count
- Class org.apache.storm.starter.ManualDRPC.ExclamationBolt
  
  class ExclamationBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt
  
  class ExclamationLoggingBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    logger
    
    org.slf4j.Logger logger
    
    rootLogger
    
    org.slf4j.Logger rootLogger
    
    subLogger
    
    org.slf4j.Logger subLogger
- Class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentence
  
  class MultiThreadedSplitSentence extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    executor
    
    ExecutorService executor
- Class org.apache.storm.starter.ReachTopology.CountAggregator
  
  class CountAggregator extends BaseBatchBolt<Object> implements Serializable
  - Serialized Fields
    
    collector
    
    BatchOutputCollector collector
    
    count
    
    int count
    
    id
    
    Object id
- Class org.apache.storm.starter.ReachTopology.GetFollowers
  
  class GetFollowers extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.ReachTopology.GetTweeters
  
  class GetTweeters extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.ReachTopology.PartialUniquer
  
  class PartialUniquer extends BaseBatchBolt<Object> implements Serializable
  - Serialized Fields
    
    collector
    
    BatchOutputCollector collector
    
    followers
    
    Set<String> followers
    
    id
    
    Object id
- Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt
  
  class ExclamationBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
- Class org.apache.storm.starter.StatefulTopology.PrinterBolt
  
  class PrinterBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopology.SplitSentence
  
  class SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence
  
  class RandomSentence extends ShellSpout implements Serializable
- Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence
  
  class SplitSentence extends ShellBolt implements Serializable
- Class org.apache.storm.starter.WordCountTopologyNode.WordCount
  
  class WordCount extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
Package org.apache.storm.starter.bolt
- Class org.apache.storm.starter.bolt.AbstractRankerBolt
  
  class AbstractRankerBolt extends BaseBasicBolt implements Serializable
  
  serialVersionUID:
  
  4931640198501530202L
  - Serialized Fields
    
    count
    
    int count
    
    emitFrequencyInSeconds
    
    int emitFrequencyInSeconds
    
    rankings
    
    Rankings rankings
- Class org.apache.storm.starter.bolt.IntermediateRankingsBolt
  
  class IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable
  
  serialVersionUID:
  
  -1369800530256637409L
- Class org.apache.storm.starter.bolt.PrinterBolt
  
  class PrinterBolt extends BaseBasicBolt implements Serializable
- Class org.apache.storm.starter.bolt.RollingCountAggBolt
  
  class RollingCountAggBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  5537727428628598519L
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    counts
    
    Map<Object,Map<Integer,Long>> counts
- Class org.apache.storm.starter.bolt.RollingCountBolt
  
  class RollingCountBolt extends BaseRichBolt implements Serializable
  
  serialVersionUID:
  
  5537727428628598519L
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    counter
    
    SlidingWindowCounter<Object> counter
    
    emitFrequencyInSeconds
    
    int emitFrequencyInSeconds
    
    lastModifiedTracker
    
    NthLastModifiedTimeTracker lastModifiedTracker
    
    windowLengthInSeconds
    
    int windowLengthInSeconds
- Class org.apache.storm.starter.bolt.SingleJoinBolt
  
  class SingleJoinBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    fieldLocations
    
    Map<String,GlobalStreamId> fieldLocations
    
    idFields
    
    Fields idFields
    
    numSources
    
    int numSources
    
    outFields
    
    Fields outFields
    
    pending
    
    TimeCacheMap<List<Object>,Map<GlobalStreamId,Tuple>> pending
- Class org.apache.storm.starter.bolt.SlidingWindowSumBolt
  
  class SlidingWindowSumBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    sum
    
    int sum
- Class org.apache.storm.starter.bolt.TotalRankingsBolt
  
  class TotalRankingsBolt extends AbstractRankerBolt implements Serializable
  
  serialVersionUID:
  
  -8447525895532302198L
- Class org.apache.storm.starter.bolt.WordCountBolt
  
  class WordCountBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
Package org.apache.storm.starter.spout
- Class org.apache.storm.starter.spout.RandomIntegerSpout
  
  class RandomIntegerSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    msgId
    
    long msgId
    
    rand
    
    Random rand
- Class org.apache.storm.starter.spout.RandomNumberGeneratorSpout
  
  class RandomNumberGeneratorSpout extends Object implements Serializable
  - Serialized Fields
    
    batches
    
    Map<Long,List<List<Object>>> batches
    
    batchSize
    
    int batchSize
    
    fields
    
    Fields fields
    
    maxNumber
    
    int maxNumber
- Class org.apache.storm.starter.spout.RandomSentenceSpout
  
  class RandomSentenceSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    rand
    
    Random rand
- Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped
  
  class TimeStamped extends RandomSentenceSpout implements Serializable
  - Serialized Fields
    
    prefix
    
    String prefix
Package org.apache.storm.starter.tools
- Class org.apache.storm.starter.tools.RankableObjectWithFields
  
  class RankableObjectWithFields extends Object implements Serializable
  
  serialVersionUID:
  
  -9102878650001058090L
  - Serialized Fields
    
    count
    
    long count
    
    fields
    
    com.google.common.collect.ImmutableList<Object> fields
    
    obj
    
    Object obj
- Class org.apache.storm.starter.tools.Rankings
  
  class Rankings extends Object implements Serializable
  
  serialVersionUID:
  
  -1549827195410578903L
  - Serialized Fields
    
    maxSize
    
    int maxSize
    
    rankedItems
    
    List<Rankable> rankedItems
- Class org.apache.storm.starter.tools.SlidingWindowCounter
  
  class SlidingWindowCounter extends Object implements Serializable
  
  serialVersionUID:
  
  -2645063988768785810L
  - Serialized Fields
    
    headSlot
    
    int headSlot
    
    objCounter
    
    SlotBasedCounter<T> objCounter
    
    tailSlot
    
    int tailSlot
    
    windowLengthInSlots
    
    int windowLengthInSlots
- Class org.apache.storm.starter.tools.SlotBasedCounter
  
  class SlotBasedCounter extends Object implements Serializable
  
  serialVersionUID:
  
  4858185737378394432L
  - Serialized Fields
    
    numSlots
    
    int numSlots
    
    objToCounts
    
    Map<T,long[]> objToCounts
Package org.apache.storm.starter.trident
- Class org.apache.storm.starter.trident.DebugMemoryMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.starter.trident.TridentReach.ExpandList
  
  class ExpandList extends BaseFunction implements Serializable
- Class org.apache.storm.starter.trident.TridentReach.One
  
  class One extends Object implements Serializable
- Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    map
    
    Map map
- Class org.apache.storm.starter.trident.TridentWordCount.Split
  
  class Split extends BaseFunction implements Serializable
Package org.apache.storm.state
- Class org.apache.storm.state.DefaultStateSerializer
  
  class DefaultStateSerializer extends Object implements Serializable
  - Serialized Fields
    
    context
    
    TopologyContext context
    
    kryo
    
    ThreadLocal<com.esotericsoftware.kryo.Kryo> kryo
    
    output
    
    ThreadLocal<com.esotericsoftware.kryo.io.Output> output
    
    registrations
    
    List<String> registrations
    
    topoConf
    
    Map<String,Object> topoConf
Package org.apache.storm.streams
- Class org.apache.storm.streams.Pair
  
  class Pair extends Object implements Serializable
  - Serialized Fields
    
    value1
    
    T1 value1
    
    The first value.
    
    value2
    
    T2 value2
    
    The second value.
- Class org.apache.storm.streams.ProcessorNode
  
  class ProcessorNode extends org.apache.storm.streams.Node implements Serializable
  - Serialized Fields
    
    isBatch
    
    boolean isBatch
    
    preservesKey
    
    boolean preservesKey
    
    processor
    
    Processor<?> processor
    
    windowedParentStreams
    
    Set<String> windowedParentStreams
- Class org.apache.storm.streams.StreamState
  
  class StreamState extends Object implements Serializable
- Class org.apache.storm.streams.WindowNode
  
  class WindowNode extends org.apache.storm.streams.Node implements Serializable
  - Serialized Fields
    
    windowParams
    
    Window<?,?> windowParams
Package org.apache.storm.streams.operations
- Class org.apache.storm.streams.operations.IdentityFunction
  
  class IdentityFunction extends Object implements Serializable
- Class org.apache.storm.streams.operations.PairValueJoiner
  
  class PairValueJoiner extends Object implements Serializable
- Class org.apache.storm.streams.operations.PrintConsumer
  
  class PrintConsumer extends Object implements Serializable
Package org.apache.storm.streams.operations.aggregators
- Class org.apache.storm.streams.operations.aggregators.Count
  
  class Count extends Object implements Serializable
- Class org.apache.storm.streams.operations.aggregators.LongSum
  
  class LongSum extends Object implements Serializable
Package org.apache.storm.streams.operations.mappers
- Class org.apache.storm.streams.operations.mappers.PairValueMapper
  
  class PairValueMapper extends Object implements Serializable
  - Serialized Fields
    
    keyIndex
    
    int keyIndex
    
    valueIndex
    
    int valueIndex
- Class org.apache.storm.streams.operations.mappers.ValueMapper
  
  class ValueMapper extends Object implements Serializable
  - Serialized Fields
    
    index
    
    int index
- Class org.apache.storm.streams.operations.mappers.ValuesMapper
  
  class ValuesMapper extends Object implements Serializable
  - Serialized Fields
    
    indices
    
    int[] indices
Package org.apache.storm.streams.processors
- Class org.apache.storm.streams.processors.AggregateByKeyProcessor
  
  class AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    
    aggregator
    
    CombinerAggregator<V,A,R> aggregator
    
    emitAggregate
    
    boolean emitAggregate
    
    state
    
    Map<K,A> state
- Class org.apache.storm.streams.processors.AggregateProcessor
  
  class AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    aggregator
    
    CombinerAggregator<T,A,R> aggregator
    
    emitAggregate
    
    boolean emitAggregate
    
    state
    
    A state
- Class org.apache.storm.streams.processors.BranchProcessor
  
  class BranchProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    predicateToStream
    
    Map<Predicate<? super T>,String> predicateToStream
- Class org.apache.storm.streams.processors.ChainedProcessorContext
  
  class ChainedProcessorContext extends Object implements Serializable
  - Serialized Fields
    
    contexts
    
    List<? extends ProcessorContext> contexts
    
    processorNode
    
    ProcessorNode processorNode
- Class org.apache.storm.streams.processors.CoGroupByKeyProcessor
  
  class CoGroupByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable
  - Serialized Fields
    
    firstMap
    
    org.apache.storm.shade.com.google.common.collect.Multimap<K,V1> firstMap
    
    firstStream
    
    String firstStream
    
    secondMap
    
    org.apache.storm.shade.com.google.common.collect.Multimap<K,V2> secondMap
    
    secondStream
    
    String secondStream
- Class org.apache.storm.streams.processors.EmittingProcessorContext
  
  class EmittingProcessorContext extends Object implements Serializable
  - Serialized Fields
    
    anchors
    
    List<RefCountedTuple> anchors
    
    collector
    
    OutputCollector collector
    
    eventTimestamp
    
    long eventTimestamp
    
    outputFields
    
    Fields outputFields
    
    outputStreamId
    
    String outputStreamId
    
    processorNode
    
    ProcessorNode processorNode
    
    punctuation
    
    Values punctuation
    
    punctuationStreamId
    
    String punctuationStreamId
    
    timestampField
    
    String timestampField
- Class org.apache.storm.streams.processors.FilterProcessor
  
  class FilterProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    predicate
    
    Predicate<T> predicate
- Class org.apache.storm.streams.processors.FlatMapProcessor
  
  class FlatMapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    function
    
    FlatMapFunction<T,R> function
- Class org.apache.storm.streams.processors.FlatMapValuesProcessor
  
  class FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    
    function
    
    FlatMapFunction<V,R> function
- Class org.apache.storm.streams.processors.ForEachProcessor
  
  class ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    consumer
    
    Consumer<T> consumer
- Class org.apache.storm.streams.processors.ForwardingProcessorContext
  
  class ForwardingProcessorContext extends Object implements Serializable
  - Serialized Fields
    
    processorNode
    
    ProcessorNode processorNode
    
    streams
    
    Set<String> streams
    
    streamToChildren
    
    org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren
- Class org.apache.storm.streams.processors.JoinProcessor
  
  class JoinProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable
  - Serialized Fields
    
    leftRows
    
    List<Pair<K,V1>> leftRows
    
    leftStream
    
    String leftStream
    
    leftType
    
    JoinProcessor.JoinType leftType
    
    rightRows
    
    List<Pair<K,V2>> rightRows
    
    rightStream
    
    String rightStream
    
    rightType
    
    JoinProcessor.JoinType rightType
    
    valueJoiner
    
    ValueJoiner<V1,V2,R> valueJoiner
- Class org.apache.storm.streams.processors.MapProcessor
  
  class MapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    function
    
    Function<T,R> function
- Class org.apache.storm.streams.processors.MapValuesProcessor
  
  class MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    
    function
    
    Function<V,R> function
- Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor
  
  class MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,A>> implements Serializable
  - Serialized Fields
    
    aggregator
    
    CombinerAggregator<V,A,R> aggregator
    
    state
    
    Map<K,A> state
- Class org.apache.storm.streams.processors.MergeAggregateProcessor
  
  class MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable
  - Serialized Fields
    
    aggregator
    
    CombinerAggregator<T,A,R> aggregator
    
    state
    
    A state
- Class org.apache.storm.streams.processors.PeekProcessor
  
  class PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    consumer
    
    Consumer<T> consumer
- Class org.apache.storm.streams.processors.ReduceByKeyProcessor
  
  class ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    
    reducer
    
    Reducer<V> reducer
    
    state
    
    Map<K,V> state
- Class org.apache.storm.streams.processors.ReduceProcessor
  
  class ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
  - Serialized Fields
    
    agg
    
    T agg
    
    reducer
    
    Reducer<T> reducer
- Class org.apache.storm.streams.processors.StateQueryProcessor
  
  class StateQueryProcessor extends org.apache.storm.streams.processors.BaseProcessor<K> implements Serializable
  - Serialized Fields
    
    keyValueState
    
    KeyValueState<K,V> keyValueState
    
    streamState
    
    StreamState<K,V> streamState
- Class org.apache.storm.streams.processors.UpdateStateByKeyProcessor
  
  class UpdateStateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable
  - Serialized Fields
    
    keyValueState
    
    KeyValueState<K,R> keyValueState
    
    stateUpdater
    
    StateUpdater<V,R> stateUpdater
Package org.apache.storm.streams.windowing
- Class org.apache.storm.streams.windowing.BaseWindow
  
  class BaseWindow extends Object implements Serializable
  - Serialized Fields
    
    lag
    
    BaseWindowedBolt.Duration lag
    
    lateTupleStream
    
    String lateTupleStream
    
    timestampField
    
    String timestampField
- Class org.apache.storm.streams.windowing.SlidingWindows
  
  class SlidingWindows extends BaseWindow<L,I> implements Serializable
  - Serialized Fields
    
    slidingInterval
    
    I slidingInterval
    
    windowLength
    
    L windowLength
- Class org.apache.storm.streams.windowing.TumblingWindows
  
  class TumblingWindows extends BaseWindow<L,L> implements Serializable
  - Serialized Fields
    
    windowLength
    
    L windowLength

Package org.apache.storm.task

Class org.apache.storm.task.ShellBolt

class ShellBolt extends Object implements Serializable

serialVersionUID:: -339575186639193348L

Serialized Fields

changeDirectory
```
boolean changeDirectory
```
collector
```
OutputCollector collector
```
command
```
String[] command
```
context
```
TopologyContext context
```
env
```
Map<String,String> env
```
exception
```
Throwable exception
```

heartBeatExecutorService

ScheduledExecutorService heartBeatExecutorService

inputs
```
Map<String,Tuple> inputs
```
isLocalMode
```
boolean isLocalMode
```
lastHeartbeatTimestamp
```
AtomicLong lastHeartbeatTimestamp
```
logHandler
```
ShellLogHandler logHandler
```
pendingWrites
```
ShellBoltMessageQueue pendingWrites
```
process
```
ShellProcess process
```
rand
```
Random rand
```
readerThread
```
Thread readerThread
```
running
```
boolean running
```
sendHeartbeatFlag
```
AtomicBoolean sendHeartbeatFlag
```
workerTimeoutMills
```
int workerTimeoutMills
```
writerThread
```
Thread writerThread
```

Package org.apache.storm.testing
- Class org.apache.storm.testing.AckFailMapTracker
  
  class AckFailMapTracker extends Object implements Serializable
  - Serialized Fields
    
    acked
    
    String acked
    
    failed
    
    String failed
- Class org.apache.storm.testing.AckTracker
  
  class AckTracker extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.testing.BoltTracker
  
  class BoltTracker extends NonRichBoltTracker implements Serializable
  - Serialized Fields
    
    richDelegate
    
    IRichBolt richDelegate
- Class org.apache.storm.testing.FeederSpout
  
  class FeederSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    ackFailDelegate
    
    AckFailDelegate ackFailDelegate
    
    collector
    
    SpoutOutputCollector collector
    
    id
    
    int id
    
    outFields
    
    Fields outFields
- Class org.apache.storm.testing.FixedTuple
  
  class FixedTuple extends Object implements Serializable
  - Serialized Fields
    
    stream
    
    String stream
    
    values
    
    List<Object> values
- Class org.apache.storm.testing.FixedTupleSpout
  
  class FixedTupleSpout extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    context
    
    TopologyContext context
    
    fields
    
    Fields fields
    
    id
    
    String id
    
    pending
    
    Map<String,FixedTuple> pending
    
    serveTuples
    
    List<FixedTuple> serveTuples
    
    tuples
    
    List<FixedTuple> tuples
- Class org.apache.storm.testing.IdentityBolt
  
  class IdentityBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    fields
    
    Fields fields
- Class org.apache.storm.testing.NGrouping
  
  class NGrouping extends Object implements Serializable
  - Serialized Fields
    
    number
    
    int number
    
    outTasks
    
    List<Integer> outTasks
- Class org.apache.storm.testing.NonRichBoltTracker
  
  class NonRichBoltTracker extends Object implements Serializable
  - Serialized Fields
    
    delegate
    
    IBolt delegate
    
    trackId
    
    String trackId
- Class org.apache.storm.testing.PrepareBatchBolt
  
  class PrepareBatchBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    outFields
    
    Fields outFields
- Class org.apache.storm.testing.PythonShellMetricsBolt
  
  class PythonShellMetricsBolt extends ShellBolt implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class org.apache.storm.testing.PythonShellMetricsSpout
  
  class PythonShellMetricsSpout extends ShellSpout implements Serializable
  
  serialVersionUID:
  
  1999209252187463355L
- Class org.apache.storm.testing.SpoutTracker
  
  class SpoutTracker extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    delegate
    
    IRichSpout delegate
    
    tracker
    
    org.apache.storm.testing.SpoutTracker.SpoutTrackOutputCollector tracker
    
    trackId
    
    String trackId
- Class org.apache.storm.testing.TestAggregatesCounter
  
  class TestAggregatesCounter extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    counts
    
    Map<String,Integer> counts
- Class org.apache.storm.testing.TestConfBolt
  
  class TestConfBolt extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    componentConf
    
    Map<String,Object> componentConf
    
    conf
    
    Map<String,Object> conf
- Class org.apache.storm.testing.TestEventLogSpout
  
  class TestEventLogSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    eventId
    
    long eventId
    
    myCount
    
    long myCount
    
    source
    
    int source
    
    totalCount
    
    long totalCount
    
    uid
    
    String uid
- Class org.apache.storm.testing.TestEventOrderCheckBolt
  
  class TestEventOrderCheckBolt extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    count
    
    int count
    
    recentEventId
    
    Map<Integer,Long> recentEventId
- Class org.apache.storm.testing.TestGlobalCount
  
  class TestGlobalCount extends BaseRichBolt implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    count
    
    int count
- Class org.apache.storm.testing.TestPlannerBolt
  
  class TestPlannerBolt extends BaseRichBolt implements Serializable
- Class org.apache.storm.testing.TestPlannerSpout
  
  class TestPlannerSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    isDistributed
    
    boolean isDistributed
    
    outFields
    
    Fields outFields
- Class org.apache.storm.testing.TestSerObject
  
  class TestSerObject extends Object implements Serializable
  - Serialized Fields
    
    f1
    
    int f1
    
    f2
    
    int f2
- Class org.apache.storm.testing.TestWordBytesCounter
  
  class TestWordBytesCounter extends TestWordCounter implements Serializable
- Class org.apache.storm.testing.TestWordCounter
  
  class TestWordCounter extends BaseBasicBolt implements Serializable
  - Serialized Fields
    
    counts
    
    Map<String,Integer> counts
- Class org.apache.storm.testing.TestWordSpout
  
  class TestWordSpout extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    collector
    
    SpoutOutputCollector collector
    
    isDistributed
    
    boolean isDistributed
- Class org.apache.storm.testing.TupleCaptureBolt
  
  class TupleCaptureBolt extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    OutputCollector collector
    
    name
    
    String name
Package org.apache.storm.topology
- Class org.apache.storm.topology.BaseStatefulBoltExecutor
  
  class BaseStatefulBoltExecutor extends Object implements Serializable
  - Serialized Fields
    
    checkPointInputTaskCount
    
    int checkPointInputTaskCount
    
    collector
    
    OutputCollector collector
    
    lastTxid
    
    long lastTxid
    
    transactionRequestCount
    
    Map<org.apache.storm.topology.BaseStatefulBoltExecutor.TransactionRequest,Integer> transactionRequestCount
- Class org.apache.storm.topology.BasicBoltExecutor
  
  class BasicBoltExecutor extends Object implements Serializable
  - Serialized Fields
    
    bolt
    
    IBasicBolt bolt
- Class org.apache.storm.topology.CheckpointTupleForwarder
  
  class CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable
  - Serialized Fields
    
    bolt
    
    IRichBolt bolt
- Exception org.apache.storm.topology.FailedException
  
  class FailedException extends RuntimeException implements Serializable
- Class org.apache.storm.topology.PersistentWindowedBoltExecutor
  
  class PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable
  - Serialized Fields
    
    statefulWindowedBolt
    
    IStatefulWindowedBolt<T extends State> statefulWindowedBolt
- Exception org.apache.storm.topology.ReportedFailedException
  
  class ReportedFailedException extends FailedException implements Serializable
- Class org.apache.storm.topology.SharedOffHeapWithinNode
  
  class SharedOffHeapWithinNode extends SharedMemory implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.topology.SharedOffHeapWithinWorker
  
  class SharedOffHeapWithinWorker extends SharedMemory implements Serializable
- Class org.apache.storm.topology.SharedOnHeap
  
  class SharedOnHeap extends SharedMemory implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.storm.topology.StatefulBoltExecutor
  
  class StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable
  - Serialized Fields
    
    bolt
    
    IStatefulBolt<T extends State> bolt
    
    boltInitialized
    
    boolean boltInitialized
    
    collector
    
    org.apache.storm.topology.StatefulBoltExecutor.AckTrackingOutputCollector collector
    
    pendingTuples
    
    List<Tuple> pendingTuples
    
    preparedTuples
    
    List<Tuple> preparedTuples
    
    state
    
    State state
- Class org.apache.storm.topology.StatefulWindowedBoltExecutor
  
  class StatefulWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable
  - Serialized Fields
    
    statefulWindowedBolt
    
    IStatefulWindowedBolt<T extends State> statefulWindowedBolt
- Class org.apache.storm.topology.TupleFieldTimestampExtractor
  
  class TupleFieldTimestampExtractor extends Object implements Serializable
  - Serialized Fields
    
    fieldName
    
    String fieldName
- Class org.apache.storm.topology.WindowedBoltExecutor
  
  class WindowedBoltExecutor extends Object implements Serializable
  - Serialized Fields
    
    bolt
    
    IWindowedBolt bolt
    
    timestampExtractor
    
    TimestampExtractor timestampExtractor
Package org.apache.storm.topology.base
- Class org.apache.storm.topology.base.BaseBasicBolt
  
  class BaseBasicBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseBatchBolt
  
  class BaseBatchBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseComponent
  
  class BaseComponent extends Object implements Serializable
- Class org.apache.storm.topology.base.BaseRichBolt
  
  class BaseRichBolt extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseRichSpout
  
  class BaseRichSpout extends BaseComponent implements Serializable
- Class org.apache.storm.topology.base.BaseStatefulBolt
  
  class BaseStatefulBolt extends Object implements Serializable
- Class org.apache.storm.topology.base.BaseStatefulWindowedBolt
  
  class BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable
  - Serialized Fields
    
    maxEventsInMemory
    
    long maxEventsInMemory
    
    persistent
    
    boolean persistent
- Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt
  
  class BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable
- Class org.apache.storm.topology.base.BaseWindowedBolt
  
  class BaseWindowedBolt extends Object implements Serializable
  - Serialized Fields
    
    timestampExtractor
    
    TimestampExtractor timestampExtractor
- Class org.apache.storm.topology.base.BaseWindowedBolt.Count
  
  class Count extends Object implements Serializable
  - Serialized Fields
    
    value
    
    int value
- Class org.apache.storm.topology.base.BaseWindowedBolt.Duration
  
  class Duration extends Object implements Serializable
  - Serialized Fields
    
    value
    
    int value
Package org.apache.storm.trident.drpc
- Class org.apache.storm.trident.drpc.ReturnResultsReducer
  
  class ReturnResultsReducer extends Object implements Serializable
  - Serialized Fields
    
    clients
    
    Map<List,DRPCInvocationsClient> clients
    
    conf
    
    Map<String,Object> conf
    
    local
    
    boolean local
Package org.apache.storm.trident.operation
- Class org.apache.storm.trident.operation.BaseAggregator
  
  class BaseAggregator extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseFilter
  
  class BaseFilter extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseFunction
  
  class BaseFunction extends BaseOperation implements Serializable
- Class org.apache.storm.trident.operation.BaseMultiReducer
  
  class BaseMultiReducer extends Object implements Serializable
- Class org.apache.storm.trident.operation.BaseOperation
  
  class BaseOperation extends Object implements Serializable
Package org.apache.storm.trident.operation.builtin
- Class org.apache.storm.trident.operation.builtin.ComparisonAggregator
  
  class ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable
  - Serialized Fields
    
    batchId
    
    Object batchId
    
    inputFieldName
    
    String inputFieldName
- Class org.apache.storm.trident.operation.builtin.Count
  
  class Count extends Object implements Serializable
- Class org.apache.storm.trident.operation.builtin.Debug
  
  class Debug extends BaseFilter implements Serializable
  - Serialized Fields
    
    name
    
    String name
    
    useLogger
    
    boolean useLogger
- Class org.apache.storm.trident.operation.builtin.Equals
  
  class Equals extends BaseFilter implements Serializable
- Class org.apache.storm.trident.operation.builtin.FilterNull
  
  class FilterNull extends BaseFilter implements Serializable
- Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg
  
  class FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable
  - Serialized Fields
    
    number
    
    int number
- Class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg
  
  class FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable
  - Serialized Fields
    
    number
    
    int number
    
    reverse
    
    boolean reverse
    
    sortField
    
    String sortField
- Class org.apache.storm.trident.operation.builtin.MapGet
  
  class MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable
- Class org.apache.storm.trident.operation.builtin.Max
  
  class Max extends ComparisonAggregator<Comparable<Object>> implements Serializable
- Class org.apache.storm.trident.operation.builtin.MaxWithComparator
  
  class MaxWithComparator extends ComparisonAggregator<T> implements Serializable
  - Serialized Fields
    
    comparator
    
    Comparator<T> comparator
- Class org.apache.storm.trident.operation.builtin.Min
  
  class Min extends ComparisonAggregator<Comparable<Object>> implements Serializable
- Class org.apache.storm.trident.operation.builtin.MinWithComparator
  
  class MinWithComparator extends ComparisonAggregator<T> implements Serializable
  - Serialized Fields
    
    comparator
    
    Comparator<T> comparator
- Class org.apache.storm.trident.operation.builtin.Negate
  
  class Negate extends Object implements Serializable
  - Serialized Fields
    
    delegate
    
    Filter delegate
- Class org.apache.storm.trident.operation.builtin.SnapshotGet
  
  class SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable
- Class org.apache.storm.trident.operation.builtin.Sum
  
  class Sum extends Object implements Serializable
- Class org.apache.storm.trident.operation.builtin.TupleCollectionGet
  
  class TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable
Package org.apache.storm.trident.operation.impl
- Class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl
  
  class ChainedAggregatorImpl extends Object implements Serializable
  - Serialized Fields
    
    aggs
    
    Aggregator[] aggs
    
    fact
    
    ComboList.Factory fact
    
    inputFactories
    
    TridentTupleView.ProjectionFactory[] inputFactories
    
    inputFields
    
    Fields[] inputFields
- Class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl
  
  class CombinerAggregatorCombineImpl extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    CombinerAggregator agg
- Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl
  
  class CombinerAggregatorInitImpl extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    CombinerAggregator agg
- Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater
  
  class CombinerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    CombinerAggregator agg
- Class org.apache.storm.trident.operation.impl.ConsumerExecutor
  
  class ConsumerExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    
    consumer
    
    Consumer consumer
- Class org.apache.storm.trident.operation.impl.FilterExecutor
  
  class FilterExecutor extends Object implements Serializable
  - Serialized Fields
    
    filter
    
    Filter filter
- Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor
  
  class FlatMapFunctionExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    
    function
    
    FlatMapFunction function
- Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition
  
  class GlobalBatchToPartition extends Object implements Serializable
- Class org.apache.storm.trident.operation.impl.GroupedAggregator
  
  class GroupedAggregator extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    Aggregator agg
    
    fact
    
    ComboList.Factory fact
    
    groupFactory
    
    TridentTupleView.ProjectionFactory groupFactory
    
    groupFields
    
    Fields groupFields
    
    inFields
    
    Fields inFields
    
    inputFactory
    
    TridentTupleView.ProjectionFactory inputFactory
- Class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor
  
  class GroupedMultiReducerExecutor extends Object implements Serializable
  - Serialized Fields
    
    groupFactories
    
    List<TridentTupleView.ProjectionFactory> groupFactories
    
    groupFields
    
    List<Fields> groupFields
    
    inputFactories
    
    List<TridentTupleView.ProjectionFactory> inputFactories
    
    inputFields
    
    List<Fields> inputFields
    
    reducer
    
    GroupedMultiReducer reducer
- Class org.apache.storm.trident.operation.impl.IdentityMultiReducer
  
  class IdentityMultiReducer extends Object implements Serializable
- Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition
  
  class IndexHashBatchToPartition extends Object implements Serializable
- Class org.apache.storm.trident.operation.impl.JoinerMultiReducer
  
  class JoinerMultiReducer extends Object implements Serializable
  - Serialized Fields
    
    factory
    
    ComboList.Factory factory
    
    numGroupFields
    
    int numGroupFields
    
    sideFields
    
    List<Fields> sideFields
    
    types
    
    List<JoinType> types
- Class org.apache.storm.trident.operation.impl.MapFunctionExecutor
  
  class MapFunctionExecutor extends BaseOperation implements Serializable
  - Serialized Fields
    
    function
    
    MapFunction function
- Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer
  
  class PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable
  - Serialized Fields
    
    factory
    
    ComboList.Factory factory
    
    joiningFields
    
    List<Fields> joiningFields
    
    numGroupFields
    
    int numGroupFields
    
    originFields
    
    List<Fields> originFields
    
    sideFields
    
    List<Fields> sideFields
    
    types
    
    List<JoinType> types
- Class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl
  
  class ReducerAggregatorImpl extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    ReducerAggregator agg
- Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater
  
  class ReducerAggStateUpdater extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    ReducerAggregator agg
- Class org.apache.storm.trident.operation.impl.SingleEmitAggregator
  
  class SingleEmitAggregator extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    Aggregator agg
    
    batchToPartition
    
    SingleEmitAggregator.BatchToPartition batchToPartition
    
    myPartitionIndex
    
    int myPartitionIndex
    
    totalPartitions
    
    int totalPartitions
- Class org.apache.storm.trident.operation.impl.TrueFilter
  
  class TrueFilter extends Object implements Serializable
Package org.apache.storm.trident.partition
- Class org.apache.storm.trident.partition.GlobalGrouping
  
  class GlobalGrouping extends Object implements Serializable
  - Serialized Fields
    
    target
    
    List<Integer> target
- Class org.apache.storm.trident.partition.IdentityGrouping
  
  class IdentityGrouping extends Object implements Serializable
  - Serialized Fields
    
    precomputed
    
    Map<Integer,List<Integer>> precomputed
- Class org.apache.storm.trident.partition.IndexHashGrouping
  
  class IndexHashGrouping extends Object implements Serializable
  - Serialized Fields
    
    index
    
    int index
    
    targets
    
    List<Integer> targets
Package org.apache.storm.trident.planner
- Class org.apache.storm.trident.planner.Node
  
  class Node extends DefaultResourceDeclarer<Node> implements Serializable
  - Serialized Fields
    
    allOutputFields
    
    Fields allOutputFields
    
    creationIndex
    
    int creationIndex
    
    name
    
    String name
    
    nodeId
    
    String nodeId
    
    parallelismHint
    
    Integer parallelismHint
    
    stateInfo
    
    NodeStateInfo stateInfo
    
    streamId
    
    String streamId
- Class org.apache.storm.trident.planner.NodeStateInfo
  
  class NodeStateInfo extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
    
    spec
    
    StateSpec spec
- Class org.apache.storm.trident.planner.PartitionNode
  
  class PartitionNode extends Node implements Serializable
  - Serialization Methods
    
    readObject
    
    private void readObject(ObjectInputStream ois) throws ClassNotFoundException, IOException
    
    Throws:
    
    ClassNotFoundException
    
    IOException
    
    writeObject
    
    private void writeObject(ObjectOutputStream oos) throws IOException
    
    Throws:
    
    IOException
- Class org.apache.storm.trident.planner.ProcessorNode
  
  class ProcessorNode extends Node implements Serializable
  - Serialized Fields
    
    committer
    
    boolean committer
    
    processor
    
    TridentProcessor processor
    
    selfOutFields
    
    Fields selfOutFields
- Class org.apache.storm.trident.planner.SpoutNode
  
  class SpoutNode extends Node implements Serializable
  - Serialized Fields
    
    spout
    
    Object spout
    
    txId
    
    String txId
    
    type
    
    SpoutNode.SpoutType type
- Class org.apache.storm.trident.planner.SubtopologyBolt
  
  class SubtopologyBolt extends Object implements Serializable
  
  serialVersionUID:
  
  1475508603138688412L
  - Serialized Fields
    
    batchGroups
    
    Map<Node,String> batchGroups
    
    graph
    
    org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph
    
    myTopologicallyOrdered
    
    Map<String,List<TridentProcessor>> myTopologicallyOrdered
    
    nodes
    
    Set<Node> nodes
    
    outputFactories
    
    Map<Node,TridentTuple.Factory> outputFactories
    
    roots
    
    Map<String,SubtopologyBolt.InitialReceiver> roots
Package org.apache.storm.trident.planner.processor
- Class org.apache.storm.trident.planner.processor.AggregateProcessor
  
  class AggregateProcessor extends Object implements Serializable
  - Serialized Fields
    
    agg
    
    Aggregator agg
    
    collector
    
    FreshCollector collector
    
    context
    
    TridentContext context
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
- Class org.apache.storm.trident.planner.processor.EachProcessor
  
  class EachProcessor extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    AppendCollector collector
    
    context
    
    TridentContext context
    
    function
    
    Function function
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
- Class org.apache.storm.trident.planner.processor.MapProcessor
  
  class MapProcessor extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    FreshCollector collector
    
    context
    
    TridentContext context
    
    function
    
    Function function
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
- Class org.apache.storm.trident.planner.processor.MultiReducerProcessor
  
  class MultiReducerProcessor extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    FreshCollector collector
    
    context
    
    TridentContext context
    
    projectFields
    
    List<Fields> projectFields
    
    projectionFactories
    
    TridentTupleView.ProjectionFactory[] projectionFactories
    
    reducer
    
    MultiReducer reducer
    
    streamToIndex
    
    Map<String,Integer> streamToIndex
- Class org.apache.storm.trident.planner.processor.PartitionPersistProcessor
  
  class PartitionPersistProcessor extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    FreshCollector collector
    
    context
    
    TridentContext context
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
    
    state
    
    State state
    
    stateId
    
    String stateId
    
    updater
    
    StateUpdater updater
- Class org.apache.storm.trident.planner.processor.ProjectedProcessor
  
  class ProjectedProcessor extends Object implements Serializable
  - Serialized Fields
    
    context
    
    TridentContext context
    
    factory
    
    TridentTupleView.ProjectionFactory factory
    
    projectFields
    
    Fields projectFields
- Class org.apache.storm.trident.planner.processor.StateQueryProcessor
  
  class StateQueryProcessor extends Object implements Serializable
  - Serialized Fields
    
    collector
    
    AppendCollector collector
    
    context
    
    TridentContext context
    
    function
    
    QueryFunction function
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
    
    state
    
    State state
    
    stateId
    
    String stateId
Package org.apache.storm.trident.spout
- Class org.apache.storm.trident.spout.BatchSpoutExecutor
  
  class BatchSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    
    spout
    
    IBatchSpout spout
- Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor
  
  class OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    
    spout
    
    IOpaquePartitionedTridentSpout<Object,ISpoutPartition,Object> spout
- Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor
  
  class PartitionedTridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    
    spout
    
    IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout
- Class org.apache.storm.trident.spout.RichSpoutBatchExecutor
  
  class RichSpoutBatchExecutor extends Object implements Serializable
  - Serialized Fields
    
    spout
    
    IRichSpout spout
- Class org.apache.storm.trident.spout.RichSpoutBatchTriggerer
  
  class RichSpoutBatchTriggerer extends Object implements Serializable
  - Serialized Fields
    
    coordStream
    
    String coordStream
    
    delegate
    
    IRichSpout delegate
    
    finishConditions
    
    Map<Long,org.apache.storm.trident.spout.RichSpoutBatchTriggerer.FinishCondition> finishConditions
    
    msgIdToBatchId
    
    Map<Long,Long> msgIdToBatchId
    
    outputTasks
    
    List<Integer> outputTasks
    
    rand
    
    Random rand
    
    stream
    
    String stream
- Class org.apache.storm.trident.spout.TridentSpoutCoordinator
  
  class TridentSpoutCoordinator extends Object implements Serializable
  - Serialized Fields
    
    coord
    
    ITridentSpout.BatchCoordinator<Object> coord
    
    id
    
    String id
    
    spout
    
    ITridentSpout<Object> spout
    
    state
    
    RotatingTransactionalState state
    
    underlyingState
    
    TransactionalState underlyingState
- Class org.apache.storm.trident.spout.TridentSpoutExecutor
  
  class TridentSpoutExecutor extends Object implements Serializable
  - Serialized Fields
    
    activeBatches
    
    TreeMap<Long,TransactionAttempt> activeBatches
    
    collector
    
    org.apache.storm.trident.spout.TridentSpoutExecutor.AddIdCollector collector
    
    emitter
    
    ITridentSpout.Emitter<Object> emitter
    
    spout
    
    ITridentSpout<Object> spout
    
    streamName
    
    String streamName
    
    txStateId
    
    String txStateId
Package org.apache.storm.trident.state
- Class org.apache.storm.trident.state.BaseQueryFunction
  
  class BaseQueryFunction extends BaseOperation implements Serializable
- Class org.apache.storm.trident.state.BaseStateUpdater
  
  class BaseStateUpdater extends BaseOperation implements Serializable
- Class org.apache.storm.trident.state.JSONNonTransactionalSerializer
  
  class JSONNonTransactionalSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.JSONOpaqueSerializer
  
  class JSONOpaqueSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.JSONTransactionalSerializer
  
  class JSONTransactionalSerializer extends Object implements Serializable
- Class org.apache.storm.trident.state.StateSpec
  
  class StateSpec extends Object implements Serializable
  - Serialized Fields
    
    requiredNumPartitions
    
    Integer requiredNumPartitions
    
    stateFactory
    
    StateFactory stateFactory
Package org.apache.storm.trident.state.map
- Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater
  
  class MapCombinerAggStateUpdater extends Object implements Serializable
  
  serialVersionUID:
  
  -3960578785572592092L
  - Serialized Fields
    
    agg
    
    CombinerAggregator agg
    
    factory
    
    ComboList.Factory factory
    
    groupFields
    
    Fields groupFields
    
    inputFields
    
    Fields inputFields
- Class org.apache.storm.trident.state.map.MapReducerAggStateUpdater
  
  class MapReducerAggStateUpdater extends Object implements Serializable
  
  serialVersionUID:
  
  8667174018978959987L
  - Serialized Fields
    
    agg
    
    ReducerAggregator agg
    
    factory
    
    ComboList.Factory factory
    
    groupFields
    
    Fields groupFields
    
    inputFields
    
    Fields inputFields
- Class org.apache.storm.trident.state.map.MicroBatchIBackingMap.Options
  
  class Options extends Object implements Serializable
  - Serialized Fields
    
    maxMultiGetBatchSize
    
    int maxMultiGetBatchSize
    
    maxMultiPutBatchSize
    
    int maxMultiPutBatchSize
Package org.apache.storm.trident.testing
- Class org.apache.storm.trident.testing.CountAsAggregator
  
  class CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable
- Class org.apache.storm.trident.testing.FeederBatchSpout
  
  class FeederBatchSpout extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
    
    outFields
    
    Fields outFields
    
    semaphoreId
    
    String semaphoreId
    
    waitToEmit
    
    boolean waitToEmit
- Class org.apache.storm.trident.testing.FeederCommitterBatchSpout
  
  class FeederCommitterBatchSpout extends Object implements Serializable
  - Serialized Fields
    
    spout
    
    FeederBatchSpout spout
- Class org.apache.storm.trident.testing.FixedBatchSpout
  
  class FixedBatchSpout extends Object implements Serializable
  - Serialized Fields
    
    batches
    
    HashMap<Long,List<List<Object>>> batches
    
    cycle
    
    boolean cycle
    
    fields
    
    Fields fields
    
    index
    
    int index
    
    maxBatchSize
    
    int maxBatchSize
    
    outputs
    
    List<Object>[] outputs
- Class org.apache.storm.trident.testing.LRUMemoryMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
    
    maxSize
    
    int maxSize
- Class org.apache.storm.trident.testing.MemoryMapState.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    id
    
    String id
- Class org.apache.storm.trident.testing.Split
  
  class Split extends BaseFunction implements Serializable
- Class org.apache.storm.trident.testing.StringLength
  
  class StringLength extends BaseFunction implements Serializable
- Class org.apache.storm.trident.testing.TrueFilter
  
  class TrueFilter extends BaseFilter implements Serializable
- Class org.apache.storm.trident.testing.TuplifyArgs
  
  class TuplifyArgs extends BaseFunction implements Serializable
Package org.apache.storm.trident.topology
- Class org.apache.storm.trident.topology.MasterBatchCoordinator
  
  class MasterBatchCoordinator extends BaseRichSpout implements Serializable
  - Serialized Fields
    
    active
    
    boolean active
    
    activeTx
    
    TreeMap<Long,org.apache.storm.trident.topology.MasterBatchCoordinator.TransactionStatus> activeTx
    
    attemptIds
    
    TreeMap<Long,Integer> attemptIds
    
    collector
    
    SpoutOutputCollector collector
    
    coordinators
    
    List<ITridentSpout.BatchCoordinator> coordinators
    
    currTransaction
    
    Long currTransaction
    
    managedSpoutIds
    
    List<String> managedSpoutIds
    
    maxTransactionActive
    
    int maxTransactionActive
    
    spouts
    
    List<ITridentSpout> spouts
    
    states
    
    List<TransactionalState> states
    
    throttler
    
    WindowedTimeThrottler throttler
- Class org.apache.storm.trident.topology.TridentBoltExecutor
  
  class TridentBoltExecutor extends Object implements Serializable
  - Serialized Fields
    
    batches
    
    RotatingMap<Object,TridentBoltExecutor.TrackedBatch> batches
    
    batchGroupIds
    
    Map<GlobalStreamId,String> batchGroupIds
    
    bolt
    
    ITridentBatchBolt bolt
    
    collector
    
    OutputCollector collector
    
    context
    
    TopologyContext context
    
    coordCollector
    
    org.apache.storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector coordCollector
    
    coordConditions
    
    Map<String,TridentBoltExecutor.CoordCondition> coordConditions
    
    coordOutputCollector
    
    BatchOutputCollector coordOutputCollector
    
    coordSpecs
    
    Map<String,TridentBoltExecutor.CoordSpec> coordSpecs
    
    lastRotate
    
    long lastRotate
    
    messageTimeoutMs
    
    long messageTimeoutMs
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition
  
  class CoordCondition extends Object implements Serializable
  - Serialized Fields
    
    commitStream
    
    GlobalStreamId commitStream
    
    expectedTaskReports
    
    int expectedTaskReports
    
    targetTasks
    
    Set<Integer> targetTasks
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec
  
  class CoordSpec extends Object implements Serializable
  - Serialized Fields
    
    commitStream
    
    GlobalStreamId commitStream
    
    coords
    
    Map<String,TridentBoltExecutor.CoordType> coords
- Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType
  
  class CoordType extends Object implements Serializable
  - Serialized Fields
    
    singleCount
    
    boolean singleCount
Package org.apache.storm.trident.tuple
- Class org.apache.storm.trident.tuple.ComboList.Factory
  
  class Factory extends Object implements Serializable
  - Serialized Fields
    
    index
    
    org.apache.storm.trident.tuple.ComboList.Pointer[] index
    
    sizes
    
    int[] sizes
- Class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory
  
  class FreshOutputFactory extends Object implements Serializable
  - Serialized Fields
    
    fieldIndex
    
    Map<String,ValuePointer> fieldIndex
    
    index
    
    ValuePointer[] index
- Class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory
  
  class OperationOutputFactory extends Object implements Serializable
  - Serialized Fields
    
    fieldIndex
    
    Map<String,ValuePointer> fieldIndex
    
    index
    
    ValuePointer[] index
    
    parent
    
    TridentTuple.Factory parent
- Class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory
  
  class ProjectionFactory extends Object implements Serializable
  - Serialized Fields
    
    fieldIndex
    
    Map<String,ValuePointer> fieldIndex
    
    index
    
    ValuePointer[] index
    
    parent
    
    TridentTuple.Factory parent
- Class org.apache.storm.trident.tuple.TridentTupleView.RootFactory
  
  class RootFactory extends Object implements Serializable
  - Serialized Fields
    
    fieldIndex
    
    Map<String,ValuePointer> fieldIndex
    
    index
    
    ValuePointer[] index
Package org.apache.storm.trident.util
- Class org.apache.storm.trident.util.ErrorEdgeFactory
  
  class ErrorEdgeFactory extends Object implements Serializable
- Class org.apache.storm.trident.util.IndexedEdge
  
  class IndexedEdge extends Object implements Serializable
  - Serialized Fields
    
    index
    
    int index
    
    source
    
    T source
    
    target
    
    T target
- Class org.apache.storm.trident.util.LRUMap
  
  class LRUMap extends LinkedHashMap<A,B> implements Serializable
  - Serialized Fields
    
    maxSize
    
    int maxSize
Package org.apache.storm.trident.windowing
- Class org.apache.storm.trident.windowing.InMemoryWindowsStore
  
  class InMemoryWindowsStore extends Object implements Serializable
  - Serialized Fields
    
    backingStore
    
    WindowsStore backingStore
    
    currentSize
    
    AtomicInteger currentSize
    
    maxSize
    
    int maxSize
    
    store
    
    ConcurrentHashMap<String,Object> store
- Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory
  
  class InMemoryWindowsStoreFactory extends Object implements Serializable
  - Serialized Fields
    
    inMemoryWindowsStore
    
    InMemoryWindowsStore inMemoryWindowsStore
- Class org.apache.storm.trident.windowing.WindowsStateFactory
  
  class WindowsStateFactory extends Object implements Serializable
- Class org.apache.storm.trident.windowing.WindowsStateUpdater
  
  class WindowsStateUpdater extends Object implements Serializable
  - Serialized Fields
    
    windowsStore
    
    WindowsStore windowsStore
    
    windowStoreFactory
    
    WindowsStoreFactory windowStoreFactory
- Class org.apache.storm.trident.windowing.WindowsStore.Entry
  
  class Entry extends Object implements Serializable
  - Serialized Fields
    
    key
    
    String key
    
    value
    
    Object value
- Class org.apache.storm.trident.windowing.WindowTridentProcessor
  
  class WindowTridentProcessor extends Object implements Serializable
  - Serialized Fields
    
    aggregator
    
    Aggregator aggregator
    
    collector
    
    FreshCollector collector
    
    inputFields
    
    Fields inputFields
    
    projection
    
    TridentTupleView.ProjectionFactory projection
    
    storeTuplesInStore
    
    boolean storeTuplesInStore
    
    topologyContext
    
    TopologyContext topologyContext
    
    tridentContext
    
    TridentContext tridentContext
    
    tridentWindowManager
    
    ITridentWindowManager tridentWindowManager
    
    windowConfig
    
    WindowConfig windowConfig
    
    windowId
    
    String windowId
    
    windowStore
    
    WindowsStore windowStore
    
    windowStoreFactory
    
    WindowsStoreFactory windowStoreFactory
    
    windowTaskId
    
    String windowTaskId
    
    windowTriggerInprocessId
    
    String windowTriggerInprocessId
- Class org.apache.storm.trident.windowing.WindowTridentProcessor.TriggerInfo
  
  class TriggerInfo extends Object implements Serializable
  - Serialized Fields
    
    triggerId
    
    int triggerId
    
    windowTaskId
    
    String windowTaskId
Package org.apache.storm.trident.windowing.config
- Class org.apache.storm.trident.windowing.config.BaseWindowConfig
  
  class BaseWindowConfig extends Object implements Serializable
  - Serialized Fields
    
    slideLength
    
    int slideLength
    
    windowLength
    
    int windowLength
- Class org.apache.storm.trident.windowing.config.SlidingCountWindow
  
  class SlidingCountWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.SlidingDurationWindow
  
  class SlidingDurationWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.TumblingCountWindow
  
  class TumblingCountWindow extends BaseWindowConfig implements Serializable
- Class org.apache.storm.trident.windowing.config.TumblingDurationWindow
  
  class TumblingDurationWindow extends BaseWindowConfig implements Serializable
Package org.apache.storm.tuple
- Class org.apache.storm.tuple.Fields
  
  class Fields extends Object implements Serializable
  
  serialVersionUID:
  
  -3377931843059975424L
  - Serialized Fields
    
    fields
    
    List<String> fields
    
    index
    
    Map<String,Integer> index
- Class org.apache.storm.tuple.Values
  
  class Values extends ArrayList<Object> implements Serializable
Package org.apache.storm.utils
- Exception org.apache.storm.utils.DisallowedStrategyException
  
  class DisallowedStrategyException extends RuntimeException implements Serializable
  - Serialized Fields
    
    allowedStrategies
    
    List<String> allowedStrategies
    
    attemptedClass
    
    String attemptedClass
- Class org.apache.storm.utils.LruMap
  
  class LruMap extends LinkedHashMap<A,B> implements Serializable
  - Serialized Fields
    
    evCb
    
    LruMap.CacheEvictionCallback evCb
    
    maxSize
    
    int maxSize
- Exception org.apache.storm.utils.NimbusLeaderNotFoundException
  
  class NimbusLeaderNotFoundException extends RuntimeException implements Serializable
- Class org.apache.storm.utils.ShellBoltMessageQueue
  
  class ShellBoltMessageQueue extends Object implements Serializable
  - Serialized Fields
    
    boltMsgQueue
    
    LinkedBlockingQueue<BoltMsg> boltMsgQueue
    
    notEmpty
    
    Condition notEmpty
    
    takeLock
    
    ReentrantLock takeLock
    
    taskIdsQueue
    
    LinkedList<List<Integer>> taskIdsQueue
- Class org.apache.storm.utils.ShellProcess
  
  class ShellProcess extends Object implements Serializable
  - Serialized Fields
    
    command
    
    String[] command
    
    componentName
    
    String componentName
    
    env
    
    Map<String,String> env
    
    pid
    
    Number pid
    
    processErrorStream
    
    InputStream processErrorStream
    
    serializer
    
    ISerializer serializer
    
    subprocess
    
    Process subprocess
- Exception org.apache.storm.utils.ShellUtils.ExitCodeException
  
  class ExitCodeException extends IOException implements Serializable
  - Serialized Fields
    
    exitCode
    
    int exitCode
- Exception org.apache.storm.utils.WrappedAlreadyAliveException
  
  class WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable
- Exception org.apache.storm.utils.WrappedAuthorizationException
  
  class WrappedAuthorizationException extends AuthorizationException implements Serializable
- Exception org.apache.storm.utils.WrappedDRPCExecutionException
  
  class WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable
- Exception org.apache.storm.utils.WrappedHBExecutionException
  
  class WrappedHBExecutionException extends HBExecutionException implements Serializable
- Exception org.apache.storm.utils.WrappedIllegalStateException
  
  class WrappedIllegalStateException extends IllegalStateException implements Serializable
- Exception org.apache.storm.utils.WrappedInvalidTopologyException
  
  class WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable
- Exception org.apache.storm.utils.WrappedKeyAlreadyExistsException
  
  class WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable
- Exception org.apache.storm.utils.WrappedKeyNotFoundException
  
  class WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable
- Exception org.apache.storm.utils.WrappedNotAliveException
  
  class WrappedNotAliveException extends NotAliveException implements Serializable
Package org.apache.storm.windowing

Serialized Form

Package org.apache.calcite.interpreter

Class org.apache.calcite.interpreter.StormContext

Package org.apache.storm

Class org.apache.storm.clojure$ack_BANG_

Class org.apache.storm.clojure$bolt

Class org.apache.storm.clojure$bolt_execute

Class org.apache.storm.clojure$bolt$fn__704

Class org.apache.storm.clojure$clojure_bolt

Class org.apache.storm.clojure$clojure_bolt_STAR_

Class org.apache.storm.clojure$clojure_spout

Class org.apache.storm.clojure$clojure_spout_STAR_

Class org.apache.storm.clojure$collectify

Class org.apache.storm.clojure$defalias

Class org.apache.storm.clojure$defbolt

Class org.apache.storm.clojure$defspout

Class org.apache.storm.clojure$direct_stream

Class org.apache.storm.clojure$emit_bolt_BANG_

Class org.apache.storm.clojure$emit_direct_bolt_BANG_

Class org.apache.storm.clojure$emit_direct_spout_BANG_

Class org.apache.storm.clojure$emit_spout_BANG_

Class org.apache.storm.clojure$fail_BANG_

Class org.apache.storm.clojure$fn__671

Class org.apache.storm.clojure$fn__735

Class org.apache.storm.clojure$fn__738

Class org.apache.storm.clojure$fn__738$G__733__747

Serialized Fields

G__734

Class org.apache.storm.clojure$fn__738$G__734__742

Class org.apache.storm.clojure$fn__753

Class org.apache.storm.clojure$fn__753$iter__754__758

Class org.apache.storm.clojure$fn__753$iter__754__758$fn__759

Serialized Fields

iter__754

s__755

Class org.apache.storm.clojure$fn__753$iter__754__758$fn__759$fn__760

Serialized Fields

b__757

c__6371__auto__

size__6372__auto__

Class org.apache.storm.clojure$fn__775

Class org.apache.storm.clojure$fn__794

Class org.apache.storm.clojure$fn__796

Class org.apache.storm.clojure$fn__798

Class org.apache.storm.clojure$fn__800

Class org.apache.storm.clojure$fn__802

Class org.apache.storm.clojure$loading__6789__auto____669

Class org.apache.storm.clojure$local_cluster

Class org.apache.storm.clojure$normalize_fns

Class org.apache.storm.clojure$normalize_fns$iter__679__683

Class org.apache.storm.clojure$normalize_fns$iter__679__683$fn__684

Serialized Fields

iter__679

s__680

Class org.apache.storm.clojure$normalize_fns$iter__679__683$fn__684$fn__685

Serialized Fields

b__682

c__6371__auto__

size__6372__auto__

Class org.apache.storm.clojure$report_error_BANG_

Class org.apache.storm.clojure$reset_timeout_BANG_

Class org.apache.storm.clojure$spout

Class org.apache.storm.clojure$spout$fn__712

Class org.apache.storm.clojure$submit_remote_topology

Class org.apache.storm.clojure$to_spec

Class org.apache.storm.Config

Class org.apache.storm.config$clojure_config_name

Class org.apache.storm.config$fn__536

Class org.apache.storm.config$fn__543

Class org.apache.storm.config$loading__6789__auto____534

Class org.apache.storm.ExclamationTopology.ExclamationBolt

Serialized Fields

collector

Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout

Serialized Fields

collector

currentIndex

numEmitted

Class org.apache.storm.LocalCluster.LocalTopology

Serialized Fields

Class org.apache.storm.clojure$fn738$G733__747

Class org.apache.storm.clojure$fn738$G734__742

Class org.apache.storm.clojure$fn753$iter754__758

Class org.apache.storm.clojure$fn753$iter754758$fn759

Class org.apache.storm.clojure$fn753$iter754758$fn759$fn__760

c6371auto__

size6372auto__

Class org.apache.storm.clojure$loading6789auto____669

Class org.apache.storm.clojure$normalize_fns$iter679683

Class org.apache.storm.clojure$normalize_fns$iter679683$fn__684

Class org.apache.storm.clojure$normalize_fns$iter679683$fn684$fn685

c6371auto__

size6372auto__

Class org.apache.storm.config$loading6789auto____534

Class org.apache.storm.log$loading6789auto____273

Class org.apache.storm.testing$loading6789auto____271

Class org.apache.storm.testing$spout_objects$iter337341

Class org.apache.storm.testing$spout_objects$iter337341$fn__342

Class org.apache.storm.testing$spout_objects$iter337341$fn342$fn343

c6371auto__

size6372auto__

Class org.apache.storm.thrift$loading6789auto____532