Serialized Form
- 
Package org.apache.calcite.interpreter- 
Class org.apache.calcite.interpreter.StormContextclass 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$boltclass clojure$bolt extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.clojure$bolt_executeclass clojure$bolt_execute extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.clojure$bolt$fn__728class clojure$bolt$fn__728 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$clojure_boltclass 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_spoutclass 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$collectifyclass clojure$collectify extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$defaliasclass clojure$defalias extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$defboltclass clojure$defbolt extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.clojure$defspoutclass clojure$defspout extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.clojure$direct_streamclass 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__695class clojure$fn__695 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__759class clojure$fn__759 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__762class clojure$fn__762 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__762$G__757__771class clojure$fn__762$G__757__771 extends clojure.lang.AFunction implements Serializable- 
Serialized Fields- 
G__758Object G__758 
 
- 
 
- 
- 
Class org.apache.storm.clojure$fn__762$G__758__766class clojure$fn__762$G__758__766 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__777class clojure$fn__777 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__777$iter__778__782class clojure$fn__777$iter__778__782 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783class clojure$fn__777$iter__778__782$fn__783 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783$fn__784class clojure$fn__777$iter__778__782$fn__783$fn__784 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__799class clojure$fn__799 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__818class clojure$fn__818 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__820class clojure$fn__820 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__822class clojure$fn__822 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__824class clojure$fn__824 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$fn__826class clojure$fn__826 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$loading__6812__auto____693class clojure$loading__6812__auto____693 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$local_clusterclass clojure$local_cluster extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$normalize_fnsclass clojure$normalize_fns extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$normalize_fns$iter__703__707class clojure$normalize_fns$iter__703__707 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708class clojure$normalize_fns$iter__703__707$fn__708 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708$fn__709class clojure$normalize_fns$iter__703__707$fn__708$fn__709 extends clojure.lang.AFunction implements Serializable
- 
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$spoutclass clojure$spout extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.clojure$spout$fn__736class clojure$spout$fn__736 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$submit_remote_topologyclass clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.clojure$to_specclass clojure$to_spec extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.Config- serialVersionUID:
- -1550278723792864455L
 
- 
Class org.apache.storm.config$clojure_config_nameclass config$clojure_config_name extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.config$fn__269class config$fn__269 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.config$fn__276class config$fn__276 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.config$loading__6812__auto____267class config$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.ExclamationTopology.ExclamationBoltclass ExclamationBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.ExclamationTopology.FixedOrderWordSpoutclass FixedOrderWordSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
currentIndexint currentIndex 
- 
numEmittedint numEmitted 
 
- 
 
- 
- 
Class org.apache.storm.LocalCluster.LocalTopologyclass LocalTopology extends StormTopology implements Serializable- serialVersionUID:
- 6145919776650637748L
 - 
Serialized Fields- 
topoNameString topoName 
 
- 
 
- 
Class org.apache.storm.log$fn__495class log$fn__495 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.log$loading__6812__auto____284class log$loading__6812__auto____284 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.log$log_debugclass log$log_debug extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.log$log_errorclass log$log_error extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.log$log_messageclass log$log_message extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.log$log_warnclass log$log_warn extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$add_supervisorclass testing$add_supervisor extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$advance_cluster_timeclass testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$capture_topologyclass testing$capture_topology extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$complete_topologyclass testing$complete_topology extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$fn__478class testing$fn__478 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$get_supervisorclass testing$get_supervisor extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$global_amtclass 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_clusterclass testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$kill_supervisorclass testing$kill_supervisor extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$loading__6812__auto____267class testing$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$local_cluster_stateclass testing$local_cluster_state extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$mk_local_storm_clusterclass testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$mk_mocked_nimbusclass testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$mk_tracked_topologyclass testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$mkClusterParamclass testing$mkClusterParam extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$mock_leader_electorclass 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_tuplesclass testing$read_tuples extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$simulate_waitclass testing$simulate_wait extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$spout_objectsclass testing$spout_objects extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$spout_objects$iter__527__531class testing$spout_objects$iter__527__531 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532class testing$spout_objects$iter__527__531$fn__532 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532$fn__533class testing$spout_objects$iter__527__531$fn__532$fn__533 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$submit_local_topologyclass testing$submit_local_topology extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$submit_local_topology_with_optsclass testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$test_tupleclass testing$test_tuple extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$tracked_waitclass testing$tracked_wait extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$wait_for_conditionclass testing$wait_for_condition extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$wait_for_condition$fn__499class testing$wait_for_condition$fn__499 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$wait_until_cluster_waitingclass testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.testing$while_timeoutclass testing$while_timeout extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_inprocess_zookeeperclass testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_local_clusterclass testing$with_local_cluster extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_mocked_nimbusclass testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_simulated_time_local_clusterclass testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_timeoutclass testing$with_timeout extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.testing$with_tracked_clusterclass testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.thrift$add_inputsclass thrift$add_inputs extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$deserialized_component_objectclass thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$direct_output_fieldsclass thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$field_groupingclass thrift$field_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$fn__571class thrift$fn__571 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$global_grouping_QMARK_class thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$grouping_typeclass thrift$grouping_type extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$instantiate_java_objectclass thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$instantiate_java_object$fn__574class thrift$instantiate_java_object$fn__574 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$loading__6812__auto____280class thrift$loading__6812__auto____280 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_all_groupingclass thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_bolt_specclass 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_groupingclass thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_fields_groupingclass thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_global_groupingclass thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_groupingclass thrift$mk_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_inputsclass thrift$mk_inputs extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_inputs$iter__615__619class thrift$mk_inputs$iter__615__619 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620class thrift$mk_inputs$iter__615__619$fn__620 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620$fn__621class thrift$mk_inputs$iter__615__619$fn__620$fn__621 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_local_or_shuffle_groupingclass thrift$mk_local_or_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_none_groupingclass thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_output_specclass thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_output_spec$fn__598class thrift$mk_output_spec$fn__598 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_plain_component_commonclass thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.thrift$mk_shell_bolt_specclass thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.thrift$mk_shell_spout_specclass thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.thrift$mk_shuffle_groupingclass thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$mk_spout_specclass 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_topologyclass thrift$mk_topology extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$nimbus_client_and_connclass thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$output_fieldsclass thrift$output_fields extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$parallelism_hintclass thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$serialize_component_objectclass thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$shell_component_paramsclass thrift$shell_component_params extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.thrift$with_configured_nimbus_connectionclass thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.thrift$with_nimbus_connectionclass 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__567class util$__LT__GT_$fn__567 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$clojurify_errorclass util$clojurify_error extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$clojurify_structureclass util$clojurify_structure extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$clojurify_structure$fn__527class util$clojurify_structure$fn__527 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$defnkclass util$defnk extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.util$defnk$fn__521class util$defnk$fn__521 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$doforclass util$dofor extends clojure.lang.RestFn implements Serializable
- 
Class org.apache.storm.util$filter_keyclass util$filter_key extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$filter_key$fn__553class util$filter_key$fn__553 extends clojure.lang.AFunction implements Serializable- 
Serialized Fields- 
afnObject afn 
 
- 
 
- 
- 
Class org.apache.storm.util$fn__501class util$fn__501 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$hashmap_to_persistentclass util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$loading__6812__auto____282class util$loading__6812__auto____282 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$map_valclass util$map_val extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$map_val$iter__531__535class util$map_val$iter__531__535 extends clojure.lang.AFunction implements Serializable- 
Serialized Fields- 
afnObject afn 
 
- 
 
- 
- 
Class org.apache.storm.util$map_val$iter__531__535$fn__536class util$map_val$iter__531__535$fn__536 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$map_val$iter__531__535$fn__536$fn__537class util$map_val$iter__531__535$fn__536$fn__537 extends clojure.lang.AFunction implements Serializable
- 
Class org.apache.storm.util$name_with_attributesclass 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.JoinBoltclass JoinBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
hashedInputsHashMap<String, HashMap<Object, ArrayList<Tuple>>> hashedInputs 
- 
joinCriteriaLinkedHashMap<String, JoinBolt.JoinInfo> joinCriteria 
- 
outputFieldsJoinBolt.FieldSelector[] outputFields 
- 
outputStreamNameString outputStreamName 
- 
selectorTypeJoinBolt.Selector selectorType 
 
- 
 
- 
- 
Class org.apache.storm.bolt.JoinBolt.FieldSelectorclass FieldSelector extends Object implements Serializable
- 
Class org.apache.storm.bolt.JoinBolt.JoinInfoclass JoinInfo extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
fieldJoinBolt.FieldSelector field 
- 
joinTypeJoinBolt.JoinType joinType 
- 
otherJoinBolt.FieldSelector other 
 
- 
 
 
- 
- 
Package org.apache.storm.clojure- 
Class org.apache.storm.clojure.ClojureBoltclass ClojureBolt extends Object implements Serializable
- 
Class org.apache.storm.clojure.ClojureSpoutclass ClojureSpout extends Object implements Serializable
- 
Class org.apache.storm.clojure.RichShellBoltclass RichShellBolt extends ShellBolt implements Serializable- 
Serialized Fields- 
outputsMap<String, StreamInfo> outputs 
 
- 
 
- 
- 
Class org.apache.storm.clojure.RichShellSpoutclass RichShellSpout extends ShellSpout implements Serializable- 
Serialized Fields- 
outputsMap<String, StreamInfo> outputs 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.coordination- 
Class org.apache.storm.coordination.BatchBoltExecutorclass BatchBoltExecutor extends Object implements Serializable- 
Serialized Fields- 
boltSerbyte[] boltSer 
- 
collectorBatchOutputCollectorImpl collector 
- 
confMap conf 
- 
contextTopologyContext context 
- 
openTransactionsMap<Object, IBatchBolt> openTransactions 
 
- 
 
- 
- 
Class org.apache.storm.coordination.CoordinatedBoltclass CoordinatedBolt extends Object implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countOutTasksList<Integer> countOutTasks 
- 
delegateIRichBolt delegate 
- 
idStreamSpecCoordinatedBolt.IdStreamSpec idStreamSpec 
- 
numSourceReportsInteger numSourceReports 
- 
sourceArgsMap<String, CoordinatedBolt.SourceArgs> sourceArgs 
- 
trackedTimeCacheMap<Object, CoordinatedBolt.TrackingInfo> tracked 
 
- 
 
- 
- 
Class org.apache.storm.coordination.CoordinatedBolt.IdStreamSpecclass IdStreamSpec extends Object implements Serializable- 
Serialized Fields- 
idGlobalStreamId id 
 
- 
 
- 
- 
Class org.apache.storm.coordination.CoordinatedBolt.SourceArgsclass SourceArgs extends Object implements Serializable- 
Serialized Fields- 
singleCountboolean singleCount 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.daemon- 
Class org.apache.storm.daemon.Ackerclass Acker extends Object implements Serializable- serialVersionUID:
- 4430906880683183091L
 - 
Serialized Fields- 
collectorOutputCollector collector 
- 
pendingRotatingMap<Object, org.apache.storm.daemon.Acker.AckObject> pending 
 
- 
 
- 
Class org.apache.storm.daemon.GrouperFactory.AllGrouperclass AllGrouper extends Object implements Serializable
- 
Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGroupingclass BasicLoadAwareCustomStreamGrouping extends Object implements Serializable- 
Serialized Fields- 
customStreamGroupingCustomStreamGrouping customStreamGrouping 
 
- 
 
- 
- 
Class org.apache.storm.daemon.GrouperFactory.FieldsGrouperclass FieldsGrouper extends Object implements Serializable
- 
Class org.apache.storm.daemon.GrouperFactory.GlobalGrouperclass GlobalGrouper extends Object implements Serializable
- 
Class org.apache.storm.daemon.GrouperFactory.NoneGrouperclass NoneGrouper extends Object implements Serializable
 
- 
- 
Package org.apache.storm.daemon.supervisor- 
Exception org.apache.storm.daemon.supervisor.ContainerRecoveryExceptionclass ContainerRecoveryException extends RuntimeException implements Serializable
- 
Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignmentclass TimerDecoratedAssignment extends LocalAssignment implements Serializable- 
Serialized Fields- 
timingcom.codahale.metrics.Timer.Context timing 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.daemon.ui- 
Exception org.apache.storm.daemon.ui.InvalidRequestExceptionclass InvalidRequestException extends Exception implements Serializable
 
- 
- 
Package org.apache.storm.dependency- 
Exception org.apache.storm.dependency.FileNotAvailableExceptionclass FileNotAvailableException extends RuntimeException implements Serializable
 
- 
- 
Package org.apache.storm.drpc- 
Class org.apache.storm.drpc.DRPCSpoutclass DRPCSpout extends BaseRichSpout implements Serializable- serialVersionUID:
- 2387848310969237877L
 - 
Serialized Fields- 
clientsList<DRPCInvocationsClient> clients 
- 
collectorSpoutOutputCollector collector 
- 
functionString function 
- 
localDrpcIdString localDrpcId 
 
- 
 
- 
Class org.apache.storm.drpc.JoinResultclass JoinResult extends BaseRichBolt implements Serializable
- 
Class org.apache.storm.drpc.KeyedFairBoltclass KeyedFairBolt extends Object implements Serializable- 
Serialized Fields- 
callbackCoordinatedBolt.FinishedCallback callback 
- 
delegateIRichBolt delegate 
- 
executorThread executor 
- 
rrQueueKeyedRoundRobinQueue<Tuple> rrQueue 
 
- 
 
- 
- 
Class org.apache.storm.drpc.PrepareRequestclass PrepareRequest extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
randRandom rand 
 
- 
 
- 
- 
Class org.apache.storm.drpc.ReturnResultsclass ReturnResults extends BaseRichBolt implements Serializable- serialVersionUID:
- -774882142710631591L
 - 
Serialized Fields- 
clientsMap<List, DRPCInvocationsClient> clients 
- 
collectorOutputCollector collector 
- 
confMap<String, Object> conf 
- 
localboolean local 
 
- 
 
 
- 
- 
Package org.apache.storm.executor- 
Class org.apache.storm.executor.TupleInfoclass TupleInfo extends Object implements Serializable- serialVersionUID:
- -3348670497595864118L
 
 
- 
- 
Package org.apache.storm.flux.examples- 
Class org.apache.storm.flux.examples.OnlyValueRecordTranslatorclass OnlyValueRecordTranslator extends Object implements Serializable
- 
Class org.apache.storm.flux.examples.StatefulWordCounterclass StatefulWordCounter extends BaseStatefulBolt<KeyValueState<String,Long>> implements Serializable - 
Serialized Fields- 
collectorOutputCollector collector 
- 
wordCountsKeyValueState<String, Long> wordCounts 
 
- 
 
- 
- 
Class org.apache.storm.flux.examples.TestPrintBoltclass TestPrintBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.flux.examples.TestWindowBoltclass TestWindowBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.flux.examples.WordCounterclass WordCounter extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.flux.wrappers.bolts- 
Class org.apache.storm.flux.wrappers.bolts.FluxShellBoltclass FluxShellBolt extends ShellBolt implements Serializable
- 
Class org.apache.storm.flux.wrappers.bolts.LogInfoBoltclass LogInfoBolt extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.flux.wrappers.spouts- 
Class org.apache.storm.flux.wrappers.spouts.FluxShellSpoutclass FluxShellSpout extends ShellSpout implements Serializable
 
- 
- 
Package org.apache.storm.generated- 
Class org.apache.storm.generated.AccessControlclass AccessControl extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
accessint access 
- 
nameString name 
- 
typeAccessControlType type 
 
- 
 
- 
- 
Exception org.apache.storm.generated.AlreadyAliveExceptionclass AlreadyAliveException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.Assignmentclass Assignment extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
executor_node_portMap<List<Long>, NodeInfo> executor_node_port 
- 
executor_start_time_secsMap<List<Long>, Long> executor_start_time_secs 
- 
master_code_dirString master_code_dir 
- 
node_hostMap<String, String> node_host 
- 
ownerString owner 
- 
total_shared_off_heapMap<String, Double> total_shared_off_heap 
- 
worker_resourcesMap<NodeInfo, WorkerResources> worker_resources 
 
- 
 
- 
- 
Exception org.apache.storm.generated.AuthorizationExceptionclass AuthorizationException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.BeginDownloadResultclass BeginDownloadResult extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
data_sizelong data_size 
- 
sessionString session 
- 
versionlong version 
 
- 
 
- 
- 
Class org.apache.storm.generated.Boltclass Bolt extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
bolt_objectComponentObject bolt_object 
- 
commonComponentCommon common 
 
- 
 
- 
- 
Class org.apache.storm.generated.BoltAggregateStatsclass BoltAggregateStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
capacitydouble capacity 
- 
execute_latency_msdouble execute_latency_ms 
- 
executedlong executed 
- 
process_latency_msdouble process_latency_ms 
 
- 
 
- 
- 
Class org.apache.storm.generated.BoltStatsclass BoltStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
ackedMap<String, Map<GlobalStreamId, Long>> acked 
- 
execute_ms_avgMap<String, Map<GlobalStreamId, Double>> execute_ms_avg 
- 
executedMap<String, Map<GlobalStreamId, Long>> executed 
- 
failedMap<String, Map<GlobalStreamId, Long>> failed 
- 
process_ms_avgMap<String, Map<GlobalStreamId, Double>> process_ms_avg 
 
- 
 
- 
- 
Class org.apache.storm.generated.ClusterSummaryclass ClusterSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nimbusesList<NimbusSummary> nimbuses 
- 
supervisorsList<SupervisorSummary> supervisors 
- 
topologiesList<TopologySummary> topologies 
 
- 
 
- 
- 
Class org.apache.storm.generated.ClusterWorkerHeartbeatclass ClusterWorkerHeartbeat extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
executor_statsMap<ExecutorInfo, ExecutorStats> executor_stats 
- 
storm_idString storm_id 
- 
time_secsint time_secs 
- 
uptime_secsint uptime_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.CommonAggregateStatsclass CommonAggregateStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.ComponentAggregateStatsclass ComponentAggregateStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
common_statsCommonAggregateStats common_stats 
- 
last_errorErrorInfo last_error 
- 
specific_statsSpecificAggregateStats specific_stats 
- 
typeComponentType type 
 
- 
 
- 
- 
Class org.apache.storm.generated.ComponentCommonclass ComponentCommon extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
inputsMap<GlobalStreamId, Grouping> inputs 
- 
json_confString json_conf 
- 
parallelism_hintint parallelism_hint 
- 
streamsMap<String, StreamInfo> streams 
 
- 
 
- 
- 
Class org.apache.storm.generated.ComponentObjectclass ComponentObject extends org.apache.storm.thrift.TUnion<ComponentObject,ComponentObject._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.ComponentPageInfoclass ComponentPageInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
component_idString component_id 
- 
component_typeComponentType component_type 
- 
debug_optionsDebugOptions debug_options 
- 
errorsList<ErrorInfo> errors 
- 
eventlog_hostString eventlog_host 
- 
eventlog_portint eventlog_port 
- 
exec_statsList<ExecutorAggregateStats> exec_stats 
- 
gsid_to_input_statsMap<GlobalStreamId, ComponentAggregateStats> gsid_to_input_stats 
- 
num_executorsint num_executors 
- 
num_tasksint num_tasks 
- 
resources_mapMap<String, Double> resources_map 
- 
sid_to_output_statsMap<String, ComponentAggregateStats> sid_to_output_stats 
- 
topology_idString topology_id 
- 
topology_nameString topology_name 
- 
topology_statusString topology_status 
- 
window_to_statsMap<String, ComponentAggregateStats> window_to_stats 
 
- 
 
- 
- 
Class org.apache.storm.generated.Credentialsclass Credentials extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.DebugOptionsclass DebugOptions extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
enableboolean enable 
- 
samplingpctdouble samplingpct 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPC.execute_argsclass execute_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.DistributedRPC.execute_resultclass execute_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eDRPCExecutionException e 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_argsclass failRequest_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_resultclass failRequest_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_argsclass failRequestV2_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
eDRPCExecutionException e 
- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_resultclass failRequestV2_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_argsclass fetchRequest_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
functionNameString functionName 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_resultclass fetchRequest_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successDRPCRequest success 
 
- 
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.result_argsclass result_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.DistributedRPCInvocations.result_resultclass result_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Exception org.apache.storm.generated.DRPCExecutionExceptionclass DRPCExecutionException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
- 
typeDRPCExceptionType type 
 
- 
 
- 
- 
Class org.apache.storm.generated.DRPCRequestclass DRPCRequest extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.ErrorInfoclass ErrorInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.ExecutorAggregateStatsclass ExecutorAggregateStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
exec_summaryExecutorSummary exec_summary 
- 
statsComponentAggregateStats stats 
 
- 
 
- 
- 
Class org.apache.storm.generated.ExecutorInfoclass ExecutorInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
task_endint task_end 
- 
task_startint task_start 
 
- 
 
- 
- 
Class org.apache.storm.generated.ExecutorSpecificStatsclass ExecutorSpecificStats extends org.apache.storm.thrift.TUnion<ExecutorSpecificStats,ExecutorSpecificStats._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.ExecutorStatsclass ExecutorStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.ExecutorSummaryclass ExecutorSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
component_idString component_id 
- 
executor_infoExecutorInfo executor_info 
- 
hostString host 
- 
portint port 
- 
statsExecutorStats stats 
- 
uptime_secsint uptime_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.GetInfoOptionsclass GetInfoOptions extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
num_err_choiceNumErrorsChoice num_err_choice 
 
- 
 
- 
- 
Class org.apache.storm.generated.GlobalStreamIdclass GlobalStreamId extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Groupingclass Grouping extends org.apache.storm.thrift.TUnion<Grouping,Grouping._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Exception org.apache.storm.generated.HBAuthorizationExceptionclass HBAuthorizationException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Exception org.apache.storm.generated.HBExecutionExceptionclass HBExecutionException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.HBMessageclass HBMessage extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
dataHBMessageData data 
- 
message_idint message_id 
- 
typeHBServerMessageType type 
 
- 
 
- 
- 
Class org.apache.storm.generated.HBMessageDataclass HBMessageData extends org.apache.storm.thrift.TUnion<HBMessageData,HBMessageData._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.HBNodesclass HBNodes extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.HBPulseclass HBPulse extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
detailsByteBuffer details 
- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.HBRecordsclass HBRecords extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Exception org.apache.storm.generated.IllegalStateExceptionclass IllegalStateException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Exception org.apache.storm.generated.InvalidTopologyExceptionclass InvalidTopologyException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.JavaObjectclass JavaObject extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
args_listList<JavaObjectArg> args_list 
- 
full_class_nameString full_class_name 
 
- 
 
- 
- 
Class org.apache.storm.generated.JavaObjectArgclass JavaObjectArg extends org.apache.storm.thrift.TUnion<JavaObjectArg,JavaObjectArg._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Exception org.apache.storm.generated.KeyAlreadyExistsExceptionclass KeyAlreadyExistsException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Exception org.apache.storm.generated.KeyNotFoundExceptionclass KeyNotFoundException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.KillOptionsclass KillOptions extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
wait_secsint wait_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.ListBlobsResultclass ListBlobsResult extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.LocalAssignmentclass LocalAssignment extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
executorsList<ExecutorInfo> executors 
- 
ownerString owner 
- 
resourcesWorkerResources resources 
- 
topology_idString topology_id 
- 
total_node_shareddouble total_node_shared 
 
- 
 
- 
- 
Class org.apache.storm.generated.LocalStateDataclass LocalStateData extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
serialized_partsMap<String, ThriftSerializedObject> serialized_parts 
 
- 
 
- 
- 
Class org.apache.storm.generated.LogConfigclass LogConfig extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.LogLevelclass LogLevel extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
actionLogLevelAction action 
- 
reset_log_levelString reset_log_level 
- 
reset_log_level_timeout_epochlong reset_log_level_timeout_epoch 
- 
reset_log_level_timeout_secsint reset_log_level_timeout_secs 
- 
target_log_levelString target_log_level 
 
- 
 
- 
- 
Class org.apache.storm.generated.LSApprovedWorkersclass LSApprovedWorkers extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.LSSupervisorAssignmentsclass LSSupervisorAssignments extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
assignmentsMap<Integer, LocalAssignment> assignments 
 
- 
 
- 
- 
Class org.apache.storm.generated.LSSupervisorIdclass LSSupervisorId extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
supervisor_idString supervisor_id 
 
- 
 
- 
- 
Class org.apache.storm.generated.LSTopoHistoryclass LSTopoHistory extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.LSTopoHistoryListclass LSTopoHistoryList extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
topo_historyList<LSTopoHistory> topo_history 
 
- 
 
- 
- 
Class org.apache.storm.generated.LSWorkerHeartbeatclass LSWorkerHeartbeat extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
executorsList<ExecutorInfo> executors 
- 
portint port 
- 
time_secsint time_secs 
- 
topology_idString topology_id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.activate_argsclass activate_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.activate_resultclass activate_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginBlobDownload_argsclass beginBlobDownload_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginBlobDownload_resultclass beginBlobDownload_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
- 
successBeginDownloadResult success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginCreateBlob_argsclass beginCreateBlob_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
- 
metaSettableBlobMeta meta 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginCreateBlob_resultclass beginCreateBlob_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
kaeKeyAlreadyExistsException kae 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginFileUpload_argsclass beginFileUpload_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginFileUpload_resultclass beginFileUpload_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginUpdateBlob_argsclass beginUpdateBlob_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.beginUpdateBlob_resultclass beginUpdateBlob_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.cancelBlobUpload_argsclass cancelBlobUpload_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
sessionString session 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.cancelBlobUpload_resultclass cancelBlobUpload_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.createStateInZookeeper_argsclass createStateInZookeeper_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.createStateInZookeeper_resultclass createStateInZookeeper_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.deactivate_argsclass deactivate_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.deactivate_resultclass deactivate_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.debug_argsclass debug_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Nimbus.debug_resultclass debug_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.deleteBlob_argsclass deleteBlob_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.deleteBlob_resultclass deleteBlob_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
iseIllegalStateException ise 
- 
knfKeyNotFoundException knf 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.downloadBlobChunk_argsclass downloadBlobChunk_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
sessionString session 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.downloadBlobChunk_resultclass downloadBlobChunk_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successByteBuffer success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.downloadChunk_argsclass downloadChunk_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.downloadChunk_resultclass downloadChunk_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successByteBuffer success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.finishBlobUpload_argsclass finishBlobUpload_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
sessionString session 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.finishBlobUpload_resultclass finishBlobUpload_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.finishFileUpload_argsclass finishFileUpload_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
locationString location 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.finishFileUpload_resultclass finishFileUpload_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getBlobMeta_argsclass getBlobMeta_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getBlobMeta_resultclass getBlobMeta_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
- 
successReadableBlobMeta success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getBlobReplication_argsclass getBlobReplication_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getBlobReplication_resultclass getBlobReplication_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
- 
successint success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getClusterInfo_argsclass getClusterInfo_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getClusterInfo_resultclass getClusterInfo_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successClusterSummary success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getComponentPageInfo_argsclass getComponentPageInfo_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Nimbus.getComponentPageInfo_resultclass getComponentPageInfo_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successComponentPageInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_argsclass getComponentPendingProfileActions_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
actionProfileAction action 
- 
component_idString component_id 
- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getComponentPendingProfileActions_resultclass getComponentPendingProfileActions_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
successList<ProfileRequest> success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getLeader_argsclass getLeader_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getLeader_resultclass getLeader_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successNimbusSummary success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getLogConfig_argsclass getLogConfig_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getLogConfig_resultclass getLogConfig_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
successLogConfig success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getNimbusConf_argsclass getNimbusConf_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getNimbusConf_resultclass getNimbusConf_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_argsclass getOwnerResourceSummaries_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
ownerString owner 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_resultclass getOwnerResourceSummaries_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successList<OwnerResourceSummary> success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_argsclass getSupervisorAssignments_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nodeString node 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_resultclass getSupervisorAssignments_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successSupervisorAssignments success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_argsclass getSupervisorPageInfo_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Nimbus.getSupervisorPageInfo_resultclass getSupervisorPageInfo_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successSupervisorPageInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopology_argsclass getTopology_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopology_resultclass getTopology_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successStormTopology success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyConf_argsclass getTopologyConf_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyConf_resultclass getTopologyConf_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successString success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyHistory_argsclass getTopologyHistory_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
userString user 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyHistory_resultclass getTopologyHistory_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successTopologyHistoryInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfo_argsclass getTopologyInfo_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfo_resultclass getTopologyInfo_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologyInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_argsclass getTopologyInfoByName_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_resultclass getTopologyInfoByName_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologyInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_argsclass getTopologyInfoByNameWithOpts_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
- 
optionsGetInfoOptions options 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_resultclass getTopologyInfoByNameWithOpts_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologyInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_argsclass getTopologyInfoWithOpts_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
- 
optionsGetInfoOptions options 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_resultclass getTopologyInfoWithOpts_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologyInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_argsclass getTopologyPageInfo_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologyPageInfo_resultclass getTopologyPageInfo_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologyPageInfo success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummaries_argsclass getTopologySummaries_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummaries_resultclass getTopologySummaries_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
successList<TopologySummary> success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummary_argsclass getTopologySummary_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummary_resultclass getTopologySummary_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologySummary success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_argsclass getTopologySummaryByName_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_resultclass getTopologySummaryByName_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successTopologySummary success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getUserTopology_argsclass getUserTopology_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.getUserTopology_resultclass getUserTopology_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successStormTopology success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_argsclass isRemoteBlobExists_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
blobKeyString blobKey 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_resultclass isRemoteBlobExists_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
azeAuthorizationException aze 
- 
successboolean success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_argsclass isTopologyNameAllowed_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_resultclass isTopologyNameAllowed_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
azeAuthorizationException aze 
- 
successboolean success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.killTopology_argsclass killTopology_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.killTopology_resultclass killTopology_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_argsclass killTopologyWithOpts_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
- 
optionsKillOptions options 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_resultclass killTopologyWithOpts_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.listBlobs_argsclass listBlobs_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
sessionString session 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.listBlobs_resultclass listBlobs_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
successListBlobsResult success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.processWorkerMetrics_argsclass processWorkerMetrics_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
metricsWorkerMetrics metrics 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.processWorkerMetrics_resultclass processWorkerMetrics_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.rebalance_argsclass rebalance_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
nameString name 
- 
optionsRebalanceOptions options 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.rebalance_resultclass rebalance_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
iteInvalidTopologyException ite 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_argsclass sendSupervisorWorkerHeartbeat_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
heatbeatSupervisorWorkerHeartbeat heatbeat 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_resultclass sendSupervisorWorkerHeartbeat_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_argsclass sendSupervisorWorkerHeartbeats_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
heartbeatsSupervisorWorkerHeartbeats heartbeats 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_resultclass sendSupervisorWorkerHeartbeats_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.setBlobMeta_argsclass setBlobMeta_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
keyString key 
- 
metaSettableBlobMeta meta 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.setBlobMeta_resultclass setBlobMeta_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.setLogConfig_argsclass setLogConfig_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.Nimbus.setLogConfig_resultclass setLogConfig_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.setWorkerProfiler_argsclass setWorkerProfiler_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
- 
profileRequestProfileRequest profileRequest 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.setWorkerProfiler_resultclass setWorkerProfiler_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.submitTopology_argsclass submitTopology_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
jsonConfString jsonConf 
- 
nameString name 
- 
topologyStormTopology topology 
- 
uploadedJarLocationString uploadedJarLocation 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.submitTopology_resultclass submitTopology_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eAlreadyAliveException e 
- 
iteInvalidTopologyException ite 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_argsclass submitTopologyWithOpts_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
jsonConfString jsonConf 
- 
nameString name 
- 
optionsSubmitOptions options 
- 
topologyStormTopology topology 
- 
uploadedJarLocationString uploadedJarLocation 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.submitTopologyWithOpts_resultclass submitTopologyWithOpts_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eAlreadyAliveException e 
- 
iteInvalidTopologyException ite 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.updateBlobReplication_argsclass updateBlobReplication_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
keyString key 
- 
replicationint replication 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.updateBlobReplication_resultclass updateBlobReplication_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
azeAuthorizationException aze 
- 
knfKeyNotFoundException knf 
- 
successint success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadBlobChunk_argsclass uploadBlobChunk_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
chunkByteBuffer chunk 
- 
sessionString session 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadBlobChunk_resultclass uploadBlobChunk_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadChunk_argsclass uploadChunk_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
chunkByteBuffer chunk 
- 
locationString location 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadChunk_resultclass uploadChunk_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadNewCredentials_argsclass uploadNewCredentials_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
credsCredentials creds 
- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.Nimbus.uploadNewCredentials_resultclass uploadNewCredentials_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
iteInvalidTopologyException ite 
 
- 
 
- 
- 
Class org.apache.storm.generated.NimbusSummaryclass NimbusSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.NodeInfoclass NodeInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Exception org.apache.storm.generated.NotAliveExceptionclass NotAliveException extends org.apache.storm.thrift.TException implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
msgString msg 
 
- 
 
- 
- 
Class org.apache.storm.generated.NullStructclass NullStruct extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.OwnerResourceSummaryclass OwnerResourceSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldint __isset_bitfield 
- 
assigned_off_heap_memorydouble assigned_off_heap_memory 
- 
assigned_on_heap_memorydouble assigned_on_heap_memory 
- 
cpu_guaranteedouble cpu_guarantee 
- 
cpu_guarantee_remainingdouble cpu_guarantee_remaining 
- 
cpu_usagedouble cpu_usage 
- 
isolated_node_guaranteeint isolated_node_guarantee 
- 
memory_guaranteedouble memory_guarantee 
- 
memory_guarantee_remainingdouble memory_guarantee_remaining 
- 
memory_usagedouble memory_usage 
- 
ownerString owner 
- 
requested_cpudouble requested_cpu 
- 
requested_off_heap_memorydouble requested_off_heap_memory 
- 
requested_on_heap_memorydouble requested_on_heap_memory 
- 
requested_total_memorydouble requested_total_memory 
- 
total_executorsint total_executors 
- 
total_tasksint total_tasks 
- 
total_topologiesint total_topologies 
- 
total_workersint total_workers 
 
- 
 
- 
- 
Class org.apache.storm.generated.PrivateWorkerKeyclass PrivateWorkerKey extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
expirationTimeMillislong expirationTimeMillis 
- 
keyByteBuffer key 
- 
userNameString userName 
 
- 
 
- 
- 
Class org.apache.storm.generated.ProfileRequestclass ProfileRequest extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
actionProfileAction action 
- 
nodeInfoNodeInfo nodeInfo 
- 
time_stamplong time_stamp 
 
- 
 
- 
- 
Class org.apache.storm.generated.ReadableBlobMetaclass ReadableBlobMeta extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
settableSettableBlobMeta settable 
- 
versionlong version 
 
- 
 
- 
- 
Class org.apache.storm.generated.RebalanceOptionsclass RebalanceOptions extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
num_executorsMap<String, Integer> num_executors 
- 
num_workersint num_workers 
- 
principalString principal 
- 
topology_conf_overridesString topology_conf_overrides 
- 
topology_resources_overridesMap<String, Map<String, Double>> topology_resources_overrides 
- 
wait_secsint wait_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.SettableBlobMetaclass SettableBlobMeta extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
aclList<AccessControl> acl 
- 
replication_factorint replication_factor 
 
- 
 
- 
- 
Class org.apache.storm.generated.ShellComponentclass ShellComponent extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.SpecificAggregateStatsclass SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats,SpecificAggregateStats._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.SpoutAggregateStatsclass SpoutAggregateStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
complete_latency_msdouble complete_latency_ms 
 
- 
 
- 
- 
Class org.apache.storm.generated.SpoutSpecclass SpoutSpec extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
commonComponentCommon common 
- 
spout_objectComponentObject spout_object 
 
- 
 
- 
- 
Class org.apache.storm.generated.SpoutStatsclass SpoutStats extends Object implements Serializable
- 
Class org.apache.storm.generated.StateSpoutSpecclass StateSpoutSpec extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
commonComponentCommon common 
- 
state_spout_objectComponentObject state_spout_object 
 
- 
 
- 
- 
Class org.apache.storm.generated.StormBaseclass StormBase extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
component_debugMap<String, DebugOptions> component_debug 
- 
component_executorsMap<String, Integer> component_executors 
- 
launch_time_secsint launch_time_secs 
- 
nameString name 
- 
num_workersint num_workers 
- 
ownerString owner 
- 
prev_statusTopologyStatus prev_status 
- 
principalString principal 
- 
statusTopologyStatus status 
- 
topology_action_optionsTopologyActionOptions topology_action_options 
- 
topology_versionString topology_version 
 
- 
 
- 
- 
Class org.apache.storm.generated.StormTopologyclass StormTopology extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
boltsMap<String, Bolt> bolts 
- 
component_to_shared_memoryMap<String, Set<String>> component_to_shared_memory 
- 
dependency_artifactsList<String> dependency_artifacts 
- 
dependency_jarsList<String> dependency_jars 
- 
jdk_versionString jdk_version 
- 
shared_memoryMap<String, SharedMemory> shared_memory 
- 
spoutsMap<String, SpoutSpec> spouts 
- 
state_spoutsMap<String, StateSpoutSpec> state_spouts 
- 
storm_versionString storm_version 
- 
worker_hooksList<ByteBuffer> worker_hooks 
 
- 
 
- 
- 
Class org.apache.storm.generated.StreamInfoclass StreamInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.SubmitOptionsclass SubmitOptions extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
credsCredentials creds 
- 
initial_statusTopologyInitialStatus initial_status 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_argsclass getLocalAssignmentForStorm_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_resultclass getLocalAssignmentForStorm_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
- 
eNotAliveException e 
- 
successAssignment success 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_argsclass sendSupervisorAssignments_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
assignmentsSupervisorAssignments assignments 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_resultclass sendSupervisorAssignments_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_argsclass sendSupervisorWorkerHeartbeat_args extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
heartbeatSupervisorWorkerHeartbeat heartbeat 
 
- 
 
- 
- 
Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_resultclass sendSupervisorWorkerHeartbeat_result extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
azeAuthorizationException aze 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorAssignmentsclass SupervisorAssignments extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
storm_assignmentMap<String, Assignment> storm_assignment 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorInfoclass SupervisorInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
assignment_idString assignment_id 
- 
hostnameString hostname 
- 
metaList<Long> meta 
- 
resources_mapMap<String, Double> resources_map 
- 
scheduler_metaMap<String, String> scheduler_meta 
- 
server_portint server_port 
- 
time_secslong time_secs 
- 
uptime_secslong uptime_secs 
- 
used_portsList<Long> used_ports 
- 
versionString version 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorPageInfoclass SupervisorPageInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
supervisor_summariesList<SupervisorSummary> supervisor_summaries 
- 
worker_summariesList<WorkerSummary> worker_summaries 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorSummaryclass SupervisorSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
blacklistedboolean blacklisted 
- 
fragmented_cpudouble fragmented_cpu 
- 
fragmented_memdouble fragmented_mem 
- 
hostString host 
- 
num_used_workersint num_used_workers 
- 
num_workersint num_workers 
- 
supervisor_idString supervisor_id 
- 
total_resourcesMap<String, Double> total_resources 
- 
uptime_secsint uptime_secs 
- 
used_cpudouble used_cpu 
- 
used_generic_resourcesMap<String, Double> used_generic_resources 
- 
used_memdouble used_mem 
- 
versionString version 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorWorkerHeartbeatclass SupervisorWorkerHeartbeat extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
executorsList<ExecutorInfo> executors 
- 
storm_idString storm_id 
- 
time_secsint time_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.SupervisorWorkerHeartbeatsclass SupervisorWorkerHeartbeats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
supervisor_idString supervisor_id 
- 
worker_heartbeatsList<SupervisorWorkerHeartbeat> worker_heartbeats 
 
- 
 
- 
- 
Class org.apache.storm.generated.ThriftSerializedObjectclass ThriftSerializedObject extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
bitsByteBuffer bits 
- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.generated.TopologyActionOptionsclass TopologyActionOptions extends org.apache.storm.thrift.TUnion<TopologyActionOptions,TopologyActionOptions._Fields> implements Serializable - 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.generated.TopologyHistoryInfoclass TopologyHistoryInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.TopologyInfoclass TopologyInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
assigned_cpudouble assigned_cpu 
- 
assigned_memoffheapdouble assigned_memoffheap 
- 
assigned_memonheapdouble assigned_memonheap 
- 
component_debugMap<String, DebugOptions> component_debug 
- 
errorsMap<String, List<ErrorInfo>> errors 
- 
executorsList<ExecutorSummary> executors 
- 
idString id 
- 
nameString name 
- 
ownerString owner 
- 
replication_countint replication_count 
- 
requested_cpudouble requested_cpu 
- 
requested_memoffheapdouble requested_memoffheap 
- 
requested_memonheapdouble requested_memonheap 
- 
sched_statusString sched_status 
- 
statusString status 
- 
storm_versionString storm_version 
- 
uptime_secsint uptime_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.TopologyPageInfoclass TopologyPageInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldint __isset_bitfield 
- 
assigned_cpudouble assigned_cpu 
- 
assigned_generic_resourcesMap<String, Double> assigned_generic_resources 
- 
assigned_memoffheapdouble assigned_memoffheap 
- 
assigned_memonheapdouble assigned_memonheap 
- 
assigned_regular_off_heap_memorydouble assigned_regular_off_heap_memory 
- 
assigned_regular_on_heap_memorydouble assigned_regular_on_heap_memory 
- 
assigned_shared_off_heap_memorydouble assigned_shared_off_heap_memory 
- 
assigned_shared_on_heap_memorydouble assigned_shared_on_heap_memory 
- 
debug_optionsDebugOptions debug_options 
- 
idString id 
- 
id_to_bolt_agg_statsMap<String, ComponentAggregateStats> id_to_bolt_agg_stats 
- 
id_to_spout_agg_statsMap<String, ComponentAggregateStats> id_to_spout_agg_stats 
- 
nameString name 
- 
num_executorsint num_executors 
- 
num_tasksint num_tasks 
- 
num_workersint num_workers 
- 
ownerString owner 
- 
replication_countint replication_count 
- 
requested_cpudouble requested_cpu 
- 
requested_generic_resourcesMap<String, Double> requested_generic_resources 
- 
requested_memoffheapdouble requested_memoffheap 
- 
requested_memonheapdouble requested_memonheap 
- 
requested_regular_off_heap_memorydouble requested_regular_off_heap_memory 
- 
requested_regular_on_heap_memorydouble requested_regular_on_heap_memory 
- 
requested_shared_off_heap_memorydouble requested_shared_off_heap_memory 
- 
requested_shared_on_heap_memorydouble requested_shared_on_heap_memory 
- 
sched_statusString sched_status 
- 
statusString status 
- 
storm_versionString storm_version 
- 
topology_confString topology_conf 
- 
topology_statsTopologyStats topology_stats 
- 
topology_versionString topology_version 
- 
uptime_secsint uptime_secs 
- 
workersList<WorkerSummary> workers 
 
- 
 
- 
- 
Class org.apache.storm.generated.TopologyStatsclass TopologyStats extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.TopologySummaryclass TopologySummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldshort __isset_bitfield 
- 
assigned_cpudouble assigned_cpu 
- 
assigned_generic_resourcesMap<String, Double> assigned_generic_resources 
- 
assigned_memoffheapdouble assigned_memoffheap 
- 
assigned_memonheapdouble assigned_memonheap 
- 
idString id 
- 
nameString name 
- 
num_executorsint num_executors 
- 
num_tasksint num_tasks 
- 
num_workersint num_workers 
- 
ownerString owner 
- 
replication_countint replication_count 
- 
requested_cpudouble requested_cpu 
- 
requested_generic_resourcesMap<String, Double> requested_generic_resources 
- 
requested_memoffheapdouble requested_memoffheap 
- 
requested_memonheapdouble requested_memonheap 
- 
sched_statusString sched_status 
- 
statusString status 
- 
storm_versionString storm_version 
- 
topology_versionString topology_version 
- 
uptime_secsint uptime_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerMetricListclass WorkerMetricList extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
metricsList<WorkerMetricPoint> metrics 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerMetricPointclass WorkerMetricPoint extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
- 
Class org.apache.storm.generated.WorkerMetricsclass WorkerMetrics extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
hostnameString hostname 
- 
metricListWorkerMetricList metricList 
- 
portint port 
- 
topologyIdString topologyId 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerResourcesclass WorkerResources extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldbyte __isset_bitfield 
- 
cpudouble cpu 
- 
mem_off_heapdouble mem_off_heap 
- 
mem_on_heapdouble mem_on_heap 
- 
resourcesMap<String, Double> resources 
- 
shared_mem_off_heapdouble shared_mem_off_heap 
- 
shared_mem_on_heapdouble shared_mem_on_heap 
- 
shared_resourcesMap<String, Double> shared_resources 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerSummaryclass WorkerSummary extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
__isset_bitfieldshort __isset_bitfield 
- 
assigned_cpudouble assigned_cpu 
- 
assigned_memoffheapdouble assigned_memoffheap 
- 
assigned_memonheapdouble assigned_memonheap 
- 
component_to_num_tasksMap<String, Long> component_to_num_tasks 
- 
hostString host 
- 
num_executorsint num_executors 
- 
ownerString owner 
- 
portint port 
- 
requested_cpudouble requested_cpu 
- 
requested_memoffheapdouble requested_memoffheap 
- 
requested_memonheapdouble requested_memonheap 
- 
supervisor_idString supervisor_id 
- 
time_secsint time_secs 
- 
topology_idString topology_id 
- 
topology_nameString topology_name 
- 
uptime_secsint uptime_secs 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerTokenclass WorkerToken extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields- 
infoByteBuffer info 
- 
serviceTypeWorkerTokenServiceType serviceType 
- 
signatureByteBuffer signature 
 
- 
 
- 
- 
Class org.apache.storm.generated.WorkerTokenInfoclass WorkerTokenInfo extends Object implements Serializable- 
Serialization Methods- 
readObject- Throws:
- IOException
- ClassNotFoundException
 
- 
writeObject- Throws:
- IOException
 
 
- 
- 
Serialized Fields
 
- 
 
- 
- 
Package org.apache.storm.grouping- 
Class org.apache.storm.grouping.LoadAwareShuffleGroupingclass LoadAwareShuffleGrouping extends Object implements Serializable- 
Serialized Fields- 
capacityint capacity 
- 
choicesint[] choices 
- 
confMap<String, Object> conf 
- 
currentAtomicInteger current 
- 
currentScopeorg.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope currentScope 
- 
dnsToSwitchMappingDNSToSwitchMapping dnsToSwitchMapping 
- 
higherBounddouble higherBound 
- 
localityGroupMap<org.apache.storm.grouping.LoadAwareShuffleGrouping.LocalityScope, List<Integer>> localityGroup 
- 
lowerBounddouble lowerBound 
- 
nodeToHostAtomicReference<Map<String, String>> nodeToHost 
- 
origMap<Integer, org.apache.storm.grouping.LoadAwareShuffleGrouping.IndexAndWeights> orig 
- 
prepareChoicesint[] prepareChoices 
- 
randomRandom random 
- 
retsList<Integer>[] rets 
- 
sourceNodeInfoNodeInfo sourceNodeInfo 
- 
targetTasksList<Integer> targetTasks 
- 
taskToNodePortAtomicReference<Map<Integer, NodeInfo>> taskToNodePort 
 
- 
 
- 
- 
Class org.apache.storm.grouping.PartialKeyGroupingclass PartialKeyGrouping extends Object implements Serializable- serialVersionUID:
- -1672360572274911808L
 - 
Serialized Fields- 
assignmentCreatorPartialKeyGrouping.AssignmentCreator assignmentCreator 
- 
fieldsFields fields 
- 
outFieldsFields outFields 
- 
targetSelectorPartialKeyGrouping.TargetSelector targetSelector 
- 
targetTasksList<Integer> targetTasks 
 
- 
 
- 
Class org.apache.storm.grouping.PartialKeyGrouping.BalancedTargetSelectorclass BalancedTargetSelector extends Object implements Serializable
- 
Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreatorclass RandomTwoTaskAssignmentCreator extends Object implements Serializable
- 
Class org.apache.storm.grouping.ShuffleGroupingclass ShuffleGrouping extends Object implements Serializable- 
Serialized Fields- 
choicesArrayList<List<Integer>> choices 
- 
currentAtomicInteger current 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.avro- 
Class org.apache.storm.hdfs.avro.AbstractAvroSerializerclass AbstractAvroSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable
- 
Class org.apache.storm.hdfs.avro.FixedAvroSerializerclass FixedAvroSerializer extends AbstractAvroSerializer implements Serializable
- 
Class org.apache.storm.hdfs.avro.GenericAvroSerializerclass GenericAvroSerializer extends AbstractAvroSerializer implements Serializable
 
- 
- 
Package org.apache.storm.hdfs.bolt- 
Class org.apache.storm.hdfs.bolt.AbstractHdfsBoltclass AbstractHdfsBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
configKeyString configKey 
- 
fileNameFormatFileNameFormat fileNameFormat 
- 
fileRetryCountInteger fileRetryCount 
- 
fsUrlString fsUrl 
- 
maxOpenFilesInteger maxOpenFiles 
- 
offsetlong offset 
- 
partitionerPartitioner partitioner 
- 
rotationActionsList<RotationAction> rotationActions 
- 
rotationCounterMapMap<String, Integer> rotationCounterMap 
- 
rotationPolicyFileRotationPolicy rotationPolicy 
- 
syncPolicySyncPolicy syncPolicy 
- 
tickTupleIntervalInteger tickTupleInterval 
- 
tupleBatchList<Tuple> tupleBatch 
- 
writersMap<String, Writer> writers 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.AvroGenericRecordBoltclass AvroGenericRecordBolt extends AbstractHdfsBolt implements Serializable
- 
Class org.apache.storm.hdfs.bolt.HdfsBoltclass HdfsBolt extends AbstractHdfsBolt implements Serializable- 
Serialized Fields- 
formatRecordFormat format 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBoltclass MyBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countsHashMap<String, Long> counts 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.HdfsFileTopology.SentenceSpoutclass SentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
countint count 
- 
indexint index 
- 
pendingConcurrentHashMap<UUID, Values> pending 
- 
sentencesString[] sentences 
- 
totallong total 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.SequenceFileBoltclass SequenceFileBolt extends AbstractHdfsBolt implements Serializable- 
Serialized Fields- 
compressionCodecString compressionCodec 
- 
compressionTypeorg.apache.hadoop.io.SequenceFile.CompressionType compressionType 
- 
formatSequenceFormat format 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBoltclass MyBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countsHashMap<String, Long> counts 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.SequenceFileTopology.SentenceSpoutclass SentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
countint count 
- 
indexint index 
- 
pendingConcurrentHashMap<UUID, Values> pending 
- 
sentencesString[] sentences 
- 
totallong total 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.bolt.format- 
Class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormatclass DefaultFileNameFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormatclass DefaultSequenceFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormatclass DelimitedRecordFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.bolt.format.SimpleFileNameFormatclass SimpleFileNameFormat extends Object implements Serializable- serialVersionUID:
- 1L
 
 
- 
- 
Package org.apache.storm.hdfs.bolt.rotation- 
Class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicyclass FileSizeRotationPolicy extends Object implements Serializable- 
Serialized Fields- 
currentBytesWrittenlong currentBytesWritten 
- 
lastOffsetlong lastOffset 
- 
maxByteslong maxBytes 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicyclass NoRotationPolicy extends Object implements Serializable
- 
Class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicyclass TimedRotationPolicy extends Object implements Serializable- 
Serialized Fields- 
intervallong interval 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.bolt.sync- 
Class org.apache.storm.hdfs.bolt.sync.CountSyncPolicyclass CountSyncPolicy extends Object implements Serializable- 
Serialized Fields- 
countint count 
- 
executeCountint executeCount 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.common- 
Class org.apache.storm.hdfs.common.NullPartitionerclass NullPartitioner extends Object implements Serializable
 
- 
- 
Package org.apache.storm.hdfs.common.rotation- 
Class org.apache.storm.hdfs.common.rotation.MoveFileActionclass MoveFileAction extends Object implements Serializable- 
Serialized Fields- 
destinationString destination 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.spout- 
Class org.apache.storm.hdfs.spout.HdfsSpoutclass HdfsSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
ackEnabledboolean ackEnabled 
- 
acksSinceLastCommitint acksSinceLastCommit 
- 
archiveDirString archiveDir 
- 
archiveDirPathorg.apache.hadoop.fs.Path archiveDirPath 
- 
badFilesDirString badFilesDir 
- 
badFilesDirPathorg.apache.hadoop.fs.Path badFilesDirPath 
- 
clocksInSyncboolean clocksInSync 
- 
collectorSpoutOutputCollector collector 
- 
commitFrequencyCountint commitFrequencyCount 
- 
commitFrequencySecint commitFrequencySec 
- 
commitTimeElapsedAtomicBoolean commitTimeElapsed 
- 
commitTimerTimer commitTimer 
- 
confMap<String, Object> conf 
- 
configKeyString configKey 
- 
fileReadCompletelyboolean fileReadCompletely 
- 
hdfsorg.apache.hadoop.fs.FileSystem hdfs 
- 
hdfsConfigorg.apache.hadoop.conf.Configuration hdfsConfig 
- 
hdfsUriString hdfsUri 
- 
ignoreSuffixString ignoreSuffix 
- 
inflightHashMap<org.apache.storm.hdfs.spout.HdfsSpout.MessageId, List<Object>> inflight 
- 
inprogressSuffixString inprogressSuffix 
- 
lastExpiredLockHdfsUtils.Pair<org.apache.hadoop.fs.Path, FileLock.LogEntry> lastExpiredLock 
- 
lastExpiredLockTimelong lastExpiredLockTime 
- 
lockFileLock lock 
- 
lockDirString lockDir 
- 
lockDirPathorg.apache.hadoop.fs.Path lockDirPath 
- 
lockTimeoutSecint lockTimeoutSec 
- 
maxOutstandingint maxOutstanding 
- 
outputFieldsFields outputFields 
- 
outputStreamNameString outputStreamName 
- 
readerorg.apache.storm.hdfs.spout.FileReader reader 
- 
readerTypeString readerType 
- 
retryListLinkedBlockingQueue<HdfsUtils.Pair<org.apache.storm.hdfs.spout.HdfsSpout.MessageId, List<Object>>> retryList 
- 
sourceDirString sourceDir 
- 
sourceDirPathorg.apache.hadoop.fs.Path sourceDirPath 
- 
spoutIdString spoutId 
- 
trackerProgressTracker tracker 
- 
tupleCounterlong tupleCounter 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.spout.HdfsSpoutTopology.ConstBoltclass ConstBolt extends BaseRichBolt implements Serializable- serialVersionUID:
- -5313598399155365865L
 - 
Serialized Fields- 
collectorOutputCollector collector 
- 
countint count 
 
- 
 
- 
Exception org.apache.storm.hdfs.spout.ParseExceptionclass ParseException extends Exception implements Serializable
 
- 
- 
Package org.apache.storm.hdfs.trident- 
Class org.apache.storm.hdfs.trident.FixedBatchSpoutclass FixedBatchSpout extends Object implements Serializable
- 
Class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptionsclass HdfsFileOptions extends HdfsState.Options implements Serializable- 
Serialized Fields- 
bufferSizeint bufferSize 
- 
formatRecordFormat format 
- 
offsetlong offset 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.trident.HdfsState.Optionsclass Options extends Object implements Serializable- 
Serialized Fields- 
configKeyString configKey 
- 
currentFileorg.apache.hadoop.fs.Path currentFile 
- 
fileNameFormatFileNameFormat fileNameFormat 
- 
fsUrlString fsUrl 
- 
rotationint rotation 
- 
rotationActionsArrayList<RotationAction> rotationActions 
- 
rotationPolicyFileRotationPolicy rotationPolicy 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptionsclass SequenceFileOptions extends HdfsState.Options implements Serializable- 
Serialized Fields- 
compressionCodecString compressionCodec 
- 
compressionTypeorg.apache.hadoop.io.SequenceFile.CompressionType compressionType 
- 
formatSequenceFormat format 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.trident.HdfsStateFactoryclass HdfsStateFactory extends Object implements Serializable- 
Serialized Fields- 
optionsHdfsState.Options options 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.trident.HdfsUpdater
 
- 
- 
Package org.apache.storm.hdfs.trident.format- 
Class org.apache.storm.hdfs.trident.format.DefaultFileNameFormatclass DefaultFileNameFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.trident.format.DefaultSequenceFormatclass DefaultSequenceFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormatclass DelimitedRecordFormat extends Object implements Serializable
- 
Class org.apache.storm.hdfs.trident.format.SimpleFileNameFormatclass SimpleFileNameFormat extends Object implements Serializable- serialVersionUID:
- 1L
 
 
- 
- 
Package org.apache.storm.hdfs.trident.rotation- 
Class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicyclass FileSizeRotationPolicy extends Object implements Serializable- 
Serialized Fields- 
currentBytesWrittenlong currentBytesWritten 
- 
lastOffsetlong lastOffset 
- 
maxByteslong maxBytes 
 
- 
 
- 
- 
Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicyclass NoRotationPolicy extends Object implements Serializable
- 
Class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicyclass TimedRotationPolicy extends Object implements Serializable- 
Serialized Fields- 
intervallong interval 
- 
rotationTimerTimer rotationTimer 
- 
rotationTimerTriggeredAtomicBoolean rotationTimerTriggered 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hdfs.trident.sync- 
Class org.apache.storm.hdfs.trident.sync.CountSyncPolicyclass CountSyncPolicy extends Object implements Serializable- 
Serialized Fields- 
countint count 
- 
executeCountint executeCount 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.hooks- 
Class org.apache.storm.hooks.BaseWorkerHookclass BaseWorkerHook extends Object implements Serializable- serialVersionUID:
- 2589466485198339529L
 
- 
Exception org.apache.storm.hooks.SubmitterHookExceptionclass SubmitterHookException extends RuntimeException implements Serializable
 
- 
- 
Package org.apache.storm.jdbc.bolt- 
Class org.apache.storm.jdbc.bolt.AbstractJdbcBoltclass AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
configKeyString configKey 
- 
connectionProviderConnectionProvider connectionProvider 
- 
queryTimeoutSecsInteger queryTimeoutSecs 
 
- 
 
- 
- 
Class org.apache.storm.jdbc.bolt.JdbcInsertBoltclass JdbcInsertBolt extends AbstractJdbcBolt implements Serializable- 
Serialized Fields- 
insertQueryString insertQuery 
- 
jdbcMapperJdbcMapper jdbcMapper 
- 
tableNameString tableName 
 
- 
 
- 
- 
Class org.apache.storm.jdbc.bolt.JdbcLookupBoltclass JdbcLookupBolt extends AbstractJdbcBolt implements Serializable- 
Serialized Fields- 
jdbcLookupMapperJdbcLookupMapper jdbcLookupMapper 
- 
selectQueryString selectQuery 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.jdbc.common- 
Class org.apache.storm.jdbc.common.Columnclass Column extends Object implements Serializable
- 
Class org.apache.storm.jdbc.common.HikariCPConnectionProviderclass HikariCPConnectionProvider extends Object implements Serializable
 
- 
- 
Package org.apache.storm.jdbc.mapper- 
Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapperclass SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable- 
Serialized Fields- 
outputFieldsFields outputFields 
 
- 
 
- 
- 
Class org.apache.storm.jdbc.mapper.SimpleJdbcMapperclass SimpleJdbcMapper extends Object implements Serializable
 
- 
- 
Package org.apache.storm.jdbc.spout- 
Class org.apache.storm.jdbc.spout.UserSpoutclass UserSpout extends Object implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
isDistributedboolean isDistributed 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.jdbc.trident.state- 
Class org.apache.storm.jdbc.trident.state.JdbcQuery
- 
Class org.apache.storm.jdbc.trident.state.JdbcState.Optionsclass Options extends Object implements Serializable- 
Serialized Fields- 
connectionProviderConnectionProvider connectionProvider 
- 
insertQueryString insertQuery 
- 
jdbcLookupMapperJdbcLookupMapper jdbcLookupMapper 
- 
mapperJdbcMapper mapper 
- 
queryTimeoutSecsInteger queryTimeoutSecs 
- 
selectQueryString selectQuery 
- 
tableNameString tableName 
 
- 
 
- 
- 
Class org.apache.storm.jdbc.trident.state.JdbcStateFactoryclass JdbcStateFactory extends Object implements Serializable- 
Serialized Fields- 
optionsJdbcState.Options options 
 
- 
 
- 
- 
Class org.apache.storm.jdbc.trident.state.JdbcUpdater
 
- 
- 
Package org.apache.storm.jms
- 
Package org.apache.storm.jms.bolt- 
Class org.apache.storm.jms.bolt.JmsBoltclass JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable- 
Serialized Fields- 
autoAckboolean autoAck 
- 
collectorOutputCollector collector 
- 
connectionjavax.jms.Connection connection 
- 
jmsAcknowledgeModeint jmsAcknowledgeMode 
- 
jmsProviderJmsProvider jmsProvider 
- 
jmsTransactionalboolean jmsTransactional 
- 
messageProducerjavax.jms.MessageProducer messageProducer 
- 
producerJmsMessageProducer producer 
- 
sessionjavax.jms.Session session 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.jms.example- 
Class org.apache.storm.jms.example.GenericBoltclass GenericBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
autoAckboolean autoAck 
- 
autoAnchorboolean autoAnchor 
- 
collectorOutputCollector collector 
- 
declaredFieldsFields declaredFields 
- 
nameString name 
 
- 
 
- 
- 
Class org.apache.storm.jms.example.JsonTupleProducerclass JsonTupleProducer extends Object implements Serializable
- 
Class org.apache.storm.jms.example.SpringJmsProviderclass SpringJmsProvider extends Object implements Serializable- 
Serialized Fields- 
connectionFactoryjavax.jms.ConnectionFactory connectionFactory 
- 
destinationjavax.jms.Destination destination 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.jms.spout- 
Class org.apache.storm.jms.spout.JmsMessageIDclass JmsMessageID extends Object implements Serializable
- 
Class org.apache.storm.jms.spout.JmsSpoutclass JmsSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector The collector used to emit tuples.
- 
consumerjavax.jms.MessageConsumer consumer The message consumer.
- 
distributedboolean distributed Indicates whether or not this spout should run as a singleton.
- 
individualAcksboolean individualAcks If JMS provider supports ack-ing individual messages.
- 
jmsAcknowledgeModeint jmsAcknowledgeMode The acknowledgment mode used for this instance.- See Also:
- 
- Session
 
 
- 
jmsProviderJmsProvider jmsProvider Encapsulates jms related classes needed to communicate with the mq.
- 
messageHandlerorg.apache.storm.jms.spout.JmsSpout.MessageHandler messageHandler Sets up the way we want to handle the emit, ack and fails.
- 
messageSequencelong messageSequence Counter of handled messages.
- 
tupleProducerJmsTupleProducer tupleProducer Used to generate tuples from incoming messages.
 
- 
 
- 
 
- 
- 
Package org.apache.storm.jms.trident- 
Class org.apache.storm.jms.trident.JmsState.Optionsclass Options extends Object implements Serializable- 
Serialized Fields- 
jmsAcknowledgeModeint jmsAcknowledgeMode 
- 
jmsProviderJmsProvider jmsProvider 
- 
jmsTransactionalboolean jmsTransactional 
- 
msgProducerJmsMessageProducer msgProducer 
 
- 
 
- 
- 
Class org.apache.storm.jms.trident.JmsStateFactoryclass JmsStateFactory extends Object implements Serializable- 
Serialized Fields- 
optionsJmsState.Options options 
 
- 
 
- 
- 
Class org.apache.storm.jms.trident.JmsUpdater
- 
Class org.apache.storm.jms.trident.TridentJmsSpoutclass TridentJmsSpout extends Object implements Serializable- serialVersionUID:
- -3469351154693356655L
 - 
Serialized Fields- 
jmsAcknowledgeModeint jmsAcknowledgeMode 
- 
jmsProviderJmsProvider jmsProvider 
- 
nameString name 
- 
tupleProducerJmsTupleProducer tupleProducer 
 
- 
 
 
- 
- 
Package org.apache.storm.kafka.bolt- 
Class org.apache.storm.kafka.bolt.KafkaBoltclass KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable- serialVersionUID:
- -5205886631877033478L
 - 
Serialized Fields- 
asyncboolean async KafkaBolt.setAsync(boolean)for more details on this.
- 
boltSpecifiedPropertiesProperties boltSpecifiedProperties 
- 
collectorOutputCollector collector 
- 
fireAndForgetboolean fireAndForget KafkaBolt.setFireAndForget(boolean)for more details on this.
- 
mapperTupleToKafkaMapper<K, V> mapper 
- 
producerorg.apache.kafka.clients.producer.Producer<K, V> producer 
- 
providedCallbackPreparableCallback providedCallback 
- 
topicSelectorKafkaTopicSelector topicSelector 
 
- 
 
 
- 
- 
Package org.apache.storm.kafka.bolt.mapper- 
Class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapperclass FieldNameBasedTupleToKafkaMapper extends Object implements Serializable- serialVersionUID:
- -8794262989021702349L
 
 
- 
- 
Package org.apache.storm.kafka.bolt.selector- 
Class org.apache.storm.kafka.bolt.selector.DefaultTopicSelectorclass DefaultTopicSelector extends Object implements Serializable- serialVersionUID:
- 4601118062437851265L
 - 
Serialized Fields- 
topicNameString topicName 
 
- 
 
- 
Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelectorclass FieldIndexTopicSelector extends Object implements Serializable- serialVersionUID:
- -3830575380208166367L
 - 
Serialized Fields- 
defaultTopicNameString defaultTopicName 
- 
fieldIndexint fieldIndex 
 
- 
 
- 
Class org.apache.storm.kafka.bolt.selector.FieldNameTopicSelectorclass FieldNameTopicSelector extends Object implements Serializable- serialVersionUID:
- -3903708904533396833L
 
 
- 
- 
Package org.apache.storm.kafka.spout- 
Class org.apache.storm.kafka.spout.ByTopicRecordTranslatorclass ByTopicRecordTranslator extends Object implements Serializable- serialVersionUID:
- -121699733778988688L
 
- 
Class org.apache.storm.kafka.spout.DefaultRecordTranslatorclass DefaultRecordTranslator extends Object implements Serializable- serialVersionUID:
- -5782462870112305750L
 
- 
Class org.apache.storm.kafka.spout.EmptyKafkaTupleListenerclass EmptyKafkaTupleListener extends Object implements Serializable
- 
Class org.apache.storm.kafka.spout.KafkaSpoutclass KafkaSpout extends BaseRichSpout implements Serializable- serialVersionUID:
- 4151921085047987154L
 - 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
kafkaClientFactoryClientFactory<K, V> kafkaClientFactory 
- 
kafkaSpoutConfigKafkaSpoutConfig<K, V> kafkaSpoutConfig 
- 
topicAssignerTopicAssigner topicAssigner 
 
- 
 
- 
Class org.apache.storm.kafka.spout.KafkaSpoutConfig- serialVersionUID:
- 141902646130682494L
 - 
Serialized Fields- 
emitNullTuplesboolean emitNullTuples 
- 
maxUncommittedOffsetsint maxUncommittedOffsets 
- 
metricsTimeBucketSizeInSecsint metricsTimeBucketSizeInSecs 
- 
offsetCommitPeriodMslong offsetCommitPeriodMs 
- 
processingGuaranteeKafkaSpoutConfig.ProcessingGuarantee processingGuarantee 
- 
retryServiceKafkaSpoutRetryService retryService 
- 
tupleListenerKafkaTupleListener tupleListener 
- 
tupleTrackingEnforcedboolean tupleTrackingEnforced 
 
- 
 
- 
Class org.apache.storm.kafka.spout.KafkaSpoutMessageIdclass KafkaSpoutMessageId extends Object implements Serializable- 
Serialized Fields- 
nullTupleboolean 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
- 
numFailsint numFails 
- 
offsetlong offset 
- 
topicPartorg.apache.kafka.common.TopicPartition topicPart 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoffclass KafkaSpoutRetryExponentialBackoff extends Object implements Serializable- 
Serialized Fields- 
delayPeriodKafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod 
- 
initialDelayKafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay 
- 
maxDelayKafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay 
- 
maxRetriesint maxRetries 
- 
retrySchedulesSet<org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.RetrySchedule> retrySchedules 
- 
toRetryMsgsSet<KafkaSpoutMessageId> toRetryMsgs 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeIntervalclass TimeInterval extends Object implements Serializable- 
Serialized Fields- 
lengthlong length 
- 
lengthNanoslong lengthNanos 
- 
timeUnitTimeUnit timeUnit 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.KafkaSpoutTestBoltclass KafkaSpoutTestBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.KafkaTupleclass KafkaTuple extends Values implements Serializable- serialVersionUID:
- 4803794470450587992L
 - 
Serialized Fields- 
streamString stream 
 
- 
 
- 
Class org.apache.storm.kafka.spout.SimpleRecordTranslatorclass SimpleRecordTranslator extends Object implements Serializable- serialVersionUID:
- 4678369144122009596L
 
 
- 
- 
Package org.apache.storm.kafka.spout.internal- 
Class org.apache.storm.kafka.spout.internal.ClientFactoryDefaultclass ClientFactoryDefault extends Object implements Serializable
- 
Class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfigclass CommonKafkaSpoutConfig extends Object implements Serializable- 
Serialized Fields- 
firstPollOffsetStrategyFirstPollOffsetStrategy firstPollOffsetStrategy 
- 
kafkaPropsMap<String, Object> kafkaProps 
- 
partitionRefreshPeriodMslong partitionRefreshPeriodMs 
- 
pollTimeoutMslong pollTimeoutMs 
- 
startTimeStamplong startTimeStamp 
- 
topicFilterTopicFilter topicFilter 
- 
topicPartitionerManualPartitioner topicPartitioner 
- 
translatorRecordTranslator<K, V> translator 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.kafka.spout.subscription- 
Class org.apache.storm.kafka.spout.subscription.NamedTopicFilterclass NamedTopicFilter extends Object implements Serializable
- 
Class org.apache.storm.kafka.spout.subscription.PatternTopicFilterclass PatternTopicFilter extends Object implements Serializable
- 
Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitionerclass RoundRobinManualPartitioner extends Object implements Serializable
- 
Class org.apache.storm.kafka.spout.subscription.TopicAssignerclass TopicAssigner extends Object implements Serializable- serialVersionUID:
- 5423018073527583826L
 
 
- 
- 
Package org.apache.storm.kafka.spout.trident- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitterclass KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
emitterKafkaTridentSpoutEmitter<K, V> emitter 
 
- 
 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadataclass KafkaTridentSpoutBatchMetadata extends Object implements Serializable- 
Serialized Fields- 
firstOffsetlong firstOffset 
- 
lastOffsetlong lastOffset 
- 
topologyIdString topologyId 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig- serialVersionUID:
- 1L
 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinatorclass KafkaTridentSpoutCoordinator extends Object implements Serializable- 
Serialized Fields- 
consumerorg.apache.kafka.clients.consumer.Consumer<K, V> consumer 
- 
kafkaSpoutConfigKafkaTridentSpoutConfig<K, V> kafkaSpoutConfig 
- 
partitionsForBatchSet<org.apache.kafka.common.TopicPartition> partitionsForBatch 
- 
refreshAssignmentTimerTimer refreshAssignmentTimer 
- 
tpSerializerTopicPartitionSerializer tpSerializer 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitterclass KafkaTridentSpoutEmitter extends Object implements Serializable- serialVersionUID:
- -7343927794834130435L
 - 
Serialized Fields- 
consumerorg.apache.kafka.clients.consumer.Consumer<K, V> consumer 
- 
firstPollOffsetStrategyFirstPollOffsetStrategy firstPollOffsetStrategy 
- 
kafkaSpoutConfigKafkaTridentSpoutConfig<K, V> kafkaSpoutConfig 
- 
pollTimeoutMslong pollTimeoutMs 
- 
startTimeStamplong startTimeStamp 
- 
topicAssignerTopicAssigner topicAssigner 
- 
topologyContextTopologyContext topologyContext 
- 
tpSerializerTopicPartitionSerializer tpSerializer 
- 
tpToFirstSeekOffsetMap<org.apache.kafka.common.TopicPartition, Long> tpToFirstSeekOffset 
- 
translatorRecordTranslator<K, V> translator 
 
- 
 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaqueclass KafkaTridentSpoutOpaque extends Object implements Serializable- serialVersionUID:
- -8003272486566259640L
 - 
Serialized Fields- 
kafkaSpoutConfigKafkaTridentSpoutConfig<K, V> kafkaSpoutConfig 
- 
outputFieldsExtractorOutputFieldsExtractor outputFieldsExtractor 
 
- 
 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartitionclass KafkaTridentSpoutTopicPartition extends Object implements Serializable- 
Serialized Fields- 
topicPartitionorg.apache.kafka.common.TopicPartition topicPartition 
 
- 
 
- 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactionalclass KafkaTridentSpoutTransactional extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
kafkaSpoutConfigKafkaTridentSpoutConfig<K, V> kafkaSpoutConfig 
- 
outputFieldsExtractorOutputFieldsExtractor outputFieldsExtractor 
 
- 
 
- 
Class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitterclass KafkaTridentTransactionalSpoutEmitter extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
emitterKafkaTridentSpoutEmitter<K, V> emitter 
 
- 
 
 
- 
- 
Package org.apache.storm.kafka.spout.trident.internal- 
Class org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractorclass OutputFieldsExtractor extends Object implements Serializable- serialVersionUID:
- 1L
 
 
- 
- 
Package org.apache.storm.kafka.trident- 
Class org.apache.storm.kafka.trident.TridentKafkaStateFactoryclass TridentKafkaStateFactory extends Object implements Serializable- serialVersionUID:
- -3613240970062343385L
 - 
Serialized Fields- 
mapperTridentTupleToKafkaMapper<K, V> mapper 
- 
producerPropertiesProperties producerProperties 
- 
topicSelectorKafkaTopicSelector topicSelector 
 
- 
 
- 
Class org.apache.storm.kafka.trident.TridentKafkaStateUpdaterclass TridentKafkaStateUpdater extends BaseStateUpdater<TridentKafkaState<K,V>> implements Serializable - serialVersionUID:
- 3352659585225274402L
 
 
- 
- 
Package org.apache.storm.kafka.trident.mapper- 
Class org.apache.storm.kafka.trident.mapper.FieldNameBasedTupleToKafkaMapperclass FieldNameBasedTupleToKafkaMapper extends Object implements Serializable
 
- 
- 
Package org.apache.storm.kafka.trident.selector- 
Class org.apache.storm.kafka.trident.selector.DefaultTopicSelectorclass DefaultTopicSelector extends Object implements Serializable- serialVersionUID:
- -1172454882072591493L
 - 
Serialized Fields- 
topicNameString topicName 
 
- 
 
 
- 
- 
Package org.apache.storm.lambda- 
Class org.apache.storm.lambda.LambdaBiConsumerBoltclass LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
biConsumerSerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer 
- 
fieldsString[] fields 
 
- 
 
- 
- 
Class org.apache.storm.lambda.LambdaConsumerBoltclass LambdaConsumerBolt extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
consumerSerializableConsumer<Tuple> consumer 
 
- 
 
- 
- 
Class org.apache.storm.lambda.LambdaSpoutclass LambdaSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
supplierSerializableSupplier<?> supplier 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.loadgen- 
Class org.apache.storm.loadgen.ExecAndProcessLatencyEngineclass ExecAndProcessLatencyEngine extends Object implements Serializable- 
Serialized Fields- 
parkOffsetAtomicLong parkOffset 
- 
randRandom rand 
- 
skewedPatternSlowExecutorPattern skewedPattern 
- 
timerScheduledExecutorService timer 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.InputStreamclass InputStream extends Object implements Serializable- 
Serialized Fields- 
execTimeNormalDistStats execTime 
- 
fromComponentString fromComponent 
- 
groupingTypeGroupingType groupingType 
- 
gsidGlobalStreamId gsid 
- 
idString id 
- 
processTimeNormalDistStats processTime 
- 
toComponentString toComponent 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.LoadBoltclass LoadBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
executorIndexint executorIndex 
- 
inputStreamsMap<GlobalStreamId, InputStream> inputStreams 
- 
outputStreamsList<OutputStreamEngine> outputStreams 
- 
outputStreamStatsList<OutputStream> outputStreamStats 
- 
sleepExecAndProcessLatencyEngine sleep 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.LoadSpoutclass LoadSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
nextStreamCounterlong nextStreamCounter 
- 
numStreamsint numStreams 
- 
replaysQueue<org.apache.storm.loadgen.LoadSpout.SentWithTime> replays 
- 
streamsList<org.apache.storm.loadgen.LoadSpout.OutputStreamEngineWithHisto> streams 
- 
streamStatsList<OutputStream> streamStats 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.NormalDistStatsclass NormalDistStats extends Object implements Serializable- 
Serialized Fields- 
maxdouble max 
- 
meandouble mean 
- 
mindouble min 
- 
stddevdouble stddev 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.OutputStreamclass OutputStream extends Object implements Serializable- 
Serialized Fields- 
areKeysSkewedboolean areKeysSkewed 
- 
idString id 
- 
rateNormalDistStats rate 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.ScopedTopologySet- 
Serialized Fields- 
clientNimbus.Iface client 
- 
closedboolean closed 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.SlowExecutorPatternclass SlowExecutorPattern extends Object implements Serializable- 
Serialized Fields- 
countint count 
- 
maxSlownessMsdouble maxSlownessMs 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpoutclass FastRandomSentenceSpout extends LoadSpout implements Serializable
- 
Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentenceclass SplitSentence extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
executorIndexint executorIndex 
- 
sleepExecAndProcessLatencyEngine sleep 
 
- 
 
- 
- 
Class org.apache.storm.loadgen.ThroughputVsLatency.WordCountclass WordCount extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.metric- 
Class org.apache.storm.metric.EventLoggerBoltclass EventLoggerBolt extends Object implements Serializable- 
Serialized Fields- 
eventLoggersList<IEventLogger> eventLoggers 
 
- 
 
- 
- 
Class org.apache.storm.metric.MetricsConsumerBoltclass MetricsConsumerBolt extends Object implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
consumerClassNameString consumerClassName 
- 
expanderDataPointExpander expander 
- 
filterPredicateorg.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate 
- 
maxRetainMetricTuplesint maxRetainMetricTuples 
- 
metricsConsumerIMetricsConsumer metricsConsumer 
- 
registrationArgumentObject registrationArgument 
- 
runningboolean running 
- 
taskExecuteThreadThread taskExecuteThread 
- 
taskQueueBlockingQueue<org.apache.storm.metric.MetricsConsumerBolt.MetricsTask> taskQueue 
 
- 
 
- 
- 
Class org.apache.storm.metric.SystemBoltclass SystemBolt extends Object implements Serializable
 
- 
- 
Package org.apache.storm.metric.filter- 
Class org.apache.storm.metric.filter.FilterByMetricNameclass FilterByMetricName extends Object implements Serializable
 
- 
- 
Package org.apache.storm.metric.util- 
Class org.apache.storm.metric.util.DataPointExpanderclass DataPointExpander extends Object implements Serializable- 
Serialized Fields- 
expandMapTypeboolean expandMapType 
- 
metricNameSeparatorString metricNameSeparator 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.metricstore- 
Exception org.apache.storm.metricstore.MetricExceptionclass MetricException extends Exception implements Serializable
 
- 
- 
Package org.apache.storm.multilang- 
Class org.apache.storm.multilang.JsonSerializerclass JsonSerializer extends Object implements Serializable- serialVersionUID:
- 2548814660410474022L
 
- 
Exception org.apache.storm.multilang.NoOutputExceptionclass NoOutputException extends Exception implements Serializable
 
- 
- 
Package org.apache.storm.nimbus- 
Class org.apache.storm.nimbus.NimbusInfoclass NimbusInfo extends Object implements Serializable- serialVersionUID:
- 2161446155116099333L
 - 
Serialized Fields- 
hostString host 
- 
isLeaderboolean isLeader 
- 
portint port 
- 
tlsPortint tlsPort 
 
- 
 
 
- 
- 
Package org.apache.storm.pacemaker- 
Exception org.apache.storm.pacemaker.PacemakerConnectionExceptionclass PacemakerConnectionException extends Exception implements Serializable
 
- 
- 
Package org.apache.storm.perf- 
Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriterclass LineWriter extends Object implements Serializable
- 
Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.LineWriterclass LineWriter extends Object implements Serializable- serialVersionUID:
- 7524288317405514146L
 
 
- 
- 
Package org.apache.storm.perf.bolt- 
Class org.apache.storm.perf.bolt.CountBoltclass CountBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.perf.bolt.DevNullBoltclass DevNullBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countint count 
- 
sleepNanosLong sleepNanos 
 
- 
 
- 
- 
Class org.apache.storm.perf.bolt.IdBoltclass IdBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.perf.bolt.SplitSentenceBoltclass SplitSentenceBolt extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.perf.spout- 
Class org.apache.storm.perf.spout.ConstSpoutclass ConstSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
ackCountint ackCount 
- 
collectorSpoutOutputCollector collector 
- 
countint count 
- 
fieldNameString fieldName 
- 
sleepLong sleep 
- 
valueString value 
 
- 
 
- 
- 
Class org.apache.storm.perf.spout.FileReadSpoutclass FileReadSpout extends BaseRichSpout implements Serializable- serialVersionUID:
- -2582705611472467172L
 - 
Serialized Fields- 
ackEnabledboolean ackEnabled 
- 
collectorSpoutOutputCollector collector 
- 
countlong count 
- 
fileString file 
 
- 
 
- 
Class org.apache.storm.perf.spout.FileReadSpout.FileReaderclass FileReader extends Object implements Serializable- serialVersionUID:
- -7012334600647556267L
 
- 
Class org.apache.storm.perf.spout.StringGenSpoutclass StringGenSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
countint count 
- 
currint curr 
- 
fieldNameString fieldName 
- 
recordsArrayList<String> records 
- 
strCountint strCount 
- 
strLenint strLen 
 
- 
 
- 
- 
Class org.apache.storm.perf.spout.WordGenSpoutclass WordGenSpout extends BaseRichSpout implements Serializable- serialVersionUID:
- -2582705611472467172L
 - 
Serialized Fields- 
ackEnabledboolean ackEnabled 
- 
collectorSpoutOutputCollector collector 
- 
countlong count 
- 
emitMeterThroughputMeter emitMeter 
- 
fileString file 
- 
indexint index 
- 
wordsArrayList<String> words 
 
- 
 
 
- 
- 
Package org.apache.storm.perf.utils- 
Class org.apache.storm.perf.utils.IdentityBoltclass IdentityBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.planner- 
Class org.apache.storm.planner.TaskBundleclass TaskBundle extends Object implements Serializable- 
Serialized Fields- 
componentIdint componentId 
- 
taskIBolt task 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.redis.bolt- 
Class org.apache.storm.redis.bolt.AbstractRedisBoltclass AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
jedisClusterConfigJedisClusterConfig jedisClusterConfig 
- 
jedisPoolConfigJedisPoolConfig jedisPoolConfig 
 
- 
 
- 
- 
Class org.apache.storm.redis.bolt.RedisFilterBoltclass RedisFilterBolt extends AbstractRedisBolt implements Serializable- 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
- 
filterMapperRedisFilterMapper filterMapper 
 
- 
 
- 
- 
Class org.apache.storm.redis.bolt.RedisLookupBoltclass RedisLookupBolt extends AbstractRedisBolt implements Serializable- 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
- 
lookupMapperRedisLookupMapper lookupMapper 
 
- 
 
- 
- 
Class org.apache.storm.redis.bolt.RedisStoreBoltclass RedisStoreBolt extends AbstractRedisBolt implements Serializable- 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
- 
storeMapperRedisStoreMapper storeMapper 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.redis.common.config- 
Class org.apache.storm.redis.common.config.JedisClusterConfigclass JedisClusterConfig extends Object implements Serializable- 
Serialized Fields- 
maxRedirectionsint maxRedirections 
- 
nodesSet<InetSocketAddress> nodes 
- 
passwordString password 
- 
timeoutint timeout 
 
- 
 
- 
- 
Class org.apache.storm.redis.common.config.JedisPoolConfigclass JedisPoolConfig extends Object implements Serializable
 
- 
- 
Package org.apache.storm.redis.common.mapper- 
Class org.apache.storm.redis.common.mapper.RedisDataTypeDescriptionclass RedisDataTypeDescription extends Object implements Serializable- 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.redis.topology- 
Class org.apache.storm.redis.topology.LookupWordCount.PrintWordTotalCountBoltclass PrintWordTotalCountBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBoltclass PrintWordTotalCountBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.redis.topology.WordCounterclass WordCounter extends Object implements Serializable
- 
Class org.apache.storm.redis.topology.WordSpoutclass WordSpout extends Object implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
isDistributedboolean isDistributed 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.redis.trident- 
Class org.apache.storm.redis.trident.PrintFunctionclass PrintFunction extends BaseFunction implements Serializable
- 
Class org.apache.storm.redis.trident.WordCountLookupMapperclass WordCountLookupMapper extends Object implements Serializable
- 
Class org.apache.storm.redis.trident.WordCountStoreMapperclass WordCountStoreMapper extends Object implements Serializable
 
- 
- 
Package org.apache.storm.redis.trident.state- 
Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerierclass AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,List<Values>> implements Serializable - 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
- 
lookupMapperRedisLookupMapper lookupMapper 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater- 
Serialized Fields- 
additionalKeyString additionalKey 
- 
dataTypeRedisDataTypeDescription.RedisDataType dataType 
- 
expireIntervalSecint expireIntervalSec 
- 
storeMapperRedisStoreMapper storeMapper 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactoryclass DefaultKeyFactory extends Object implements Serializable
- 
Class org.apache.storm.redis.trident.state.Optionsclass Options extends Object implements Serializable- 
Serialized Fields- 
dataTypeDescriptionRedisDataTypeDescription dataTypeDescription 
- 
expireIntervalSecint expireIntervalSec 
- 
globalKeyString globalKey 
- 
keyFactoryKeyFactory keyFactory 
- 
localCacheSizeint localCacheSize 
- 
serializerSerializer<T> serializer 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.RedisClusterMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
jedisClusterConfigJedisClusterConfig jedisClusterConfig 
- 
keyFactoryKeyFactory keyFactory 
- 
optionsOptions options 
- 
serializerSerializer serializer 
- 
typeStateType type 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.RedisClusterState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
jedisClusterConfigJedisClusterConfig jedisClusterConfig 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.RedisClusterStateQuerierclass RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable
- 
Class org.apache.storm.redis.trident.state.RedisClusterStateUpdaterclass RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable
- 
Class org.apache.storm.redis.trident.state.RedisMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
jedisPoolConfigJedisPoolConfig jedisPoolConfig 
- 
keyFactoryKeyFactory keyFactory 
- 
optionsOptions options 
- 
serializerSerializer serializer 
- 
typeStateType type 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.RedisState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
jedisPoolConfigJedisPoolConfig jedisPoolConfig 
 
- 
 
- 
- 
Class org.apache.storm.redis.trident.state.RedisStateQuerier
- 
Class org.apache.storm.redis.trident.state.RedisStateUpdater
 
- 
- 
Package org.apache.storm.security.auth.plain- 
Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProviderclass SecurityProvider extends Provider implements Serializable
 
- 
- 
Package org.apache.storm.shade.org.apache.zookeeper- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperExceptionclass KeeperException extends Exception implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorExceptionclass APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedExceptionclass AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsExceptionclass BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionExceptionclass BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossExceptionclass ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyExceptionclass DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.EphemeralOnLocalSessionExceptionclass EphemeralOnLocalSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLExceptionclass InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackExceptionclass InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorExceptionclass MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NewConfigNoQuorumclass NewConfigNoQuorum extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthExceptionclass NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsExceptionclass NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsExceptionclass NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeExceptionclass NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyExceptionclass NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyExceptionclass NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoWatcherExceptionclass NoWatcherException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutExceptionclass OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.QuotaExceededExceptionclass QuotaExceededException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigDisabledExceptionclass ReconfigDisabledException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigInProgressclass ReconfigInProgress extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RequestTimeoutExceptionclass RequestTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyExceptionclass RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionClosedRequireAuthExceptionclass SessionClosedRequireAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredExceptionclass SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedExceptionclass SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorExceptionclass SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ThrottledOpExceptionclass ThrottledOpException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedExceptionclass UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnknownSessionExceptionclass UnknownSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable
- 
Exception org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeExceptionclass ExitCodeException extends IOException implements Serializable- 
Serialized Fields- 
exitCodeint exitCode 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.spout- 
Class org.apache.storm.spout.CheckpointSpoutclass CheckpointSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
checkpointIntervalint checkpointInterval 
- 
checkpointStateKeyValueState<String, CheckPointState> checkpointState 
- 
checkpointStepInProgressboolean checkpointStepInProgress 
- 
collectorSpoutOutputCollector collector 
- 
contextTopologyContext context 
- 
curTxStateCheckPointState curTxState 
- 
lastCheckpointTslong lastCheckpointTs 
- 
recoveringboolean recovering 
- 
recoveryStepInProgressboolean recoveryStepInProgress 
- 
sleepIntervalint sleepInterval 
 
- 
 
- 
- 
Class org.apache.storm.spout.RawMultiSchemeclass RawMultiScheme extends Object implements Serializable
- 
Class org.apache.storm.spout.RawSchemeclass RawScheme extends Object implements Serializable
- 
Class org.apache.storm.spout.SchemeAsMultiSchemeclass SchemeAsMultiScheme extends Object implements Serializable- 
Serialized Fields- 
schemeScheme scheme 
 
- 
 
- 
- 
Class org.apache.storm.spout.ShellSpoutclass ShellSpout extends Object implements Serializable- serialVersionUID:
- 5982357019665454L
 - 
Serialized Fields- 
changeDirectoryboolean changeDirectory 
- 
collectorSpoutOutputCollector collector 
- 
commandString[] command 
- 
contextTopologyContext context 
- 
envMap<String, String> env 
- 
exceptionRuntimeException exception 
- 
heartBeatExecutorServiceScheduledExecutorService heartBeatExecutorService 
- 
lastHeartbeatTimestampAtomicLong lastHeartbeatTimestamp 
- 
logHandlerShellLogHandler logHandler 
- 
processShellProcess process 
- 
runningboolean running 
- 
spoutMsgSpoutMsg spoutMsg 
- 
waitingOnSubprocessAtomicBoolean waitingOnSubprocess 
- 
workerTimeoutMillsint workerTimeoutMills 
 
- 
 
 
- 
- 
Package org.apache.storm.sql.javac- 
Exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerExceptionclass CompilerException extends Exception implements Serializable- serialVersionUID:
- -2936958840023603270L
 
 
- 
- 
Package org.apache.storm.sql.kafka- 
Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapterclass RecordTranslatorSchemeAdapter extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
delegateScheme delegate 
 
- 
 
 
- 
- 
Package org.apache.storm.sql.parser.impl- 
Exception org.apache.storm.sql.parser.impl.ParseExceptionclass ParseException extends Exception implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
currentTokenToken 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.
- 
expectedTokenSequencesint[][] 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.
- 
tokenImageString[] 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.Tokenclass Token extends Object implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
beginColumnint beginColumn The column number of the first character of this Token.
- 
beginLineint beginLine The line number of the first character of this Token.
- 
endColumnint endColumn The column number of the last character of this Token.
- 
endLineint endLine The line number of the last character of this Token.
- 
imageString image The string image of the token.
- 
kindint 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.
- 
nextToken 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.
- 
specialTokenToken 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.TokenMgrErrorclass TokenMgrError extends Error implements Serializable- serialVersionUID:
- 1L
 - 
Serialized Fields- 
errorCodeint 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.FieldInfoclass FieldInfo extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.calcite- 
Class org.apache.storm.sql.runtime.calcite.DebuggableExecutableExpressionclass DebuggableExecutableExpression extends Object implements Serializable- 
Serialized Fields- 
delegateExecutableExpression delegate 
- 
delegateCodeString delegateCode 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.calcite.StormDataContextclass StormDataContext extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.datasource.socket.bolt- 
Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBoltclass SocketBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
hostString host 
- 
portint port 
- 
serializerIOutputSerializer serializer 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.sql.runtime.datasource.socket.spout- 
Class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpoutclass SocketSpout extends Object implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
emittedMap<String, List<Object>> emitted 
- 
hostString host 
- 
inBufferedReader in 
- 
objectMappercom.fasterxml.jackson.databind.ObjectMapper objectMapper 
- 
portint port 
- 
queueBlockingDeque<List<Object>> queue 
- 
readerThreadThread readerThread 
- 
runningboolean running 
- 
schemeScheme scheme 
- 
socketSocket socket 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.sql.runtime.serde.avro- 
Class org.apache.storm.sql.runtime.serde.avro.AvroSchemeclass AvroScheme extends Object implements Serializable- 
Serialized Fields- 
fieldNamesList<String> fieldNames 
- 
schemasCachedSchemas schemas 
- 
schemaStringString schemaString 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.serde.avro.AvroSerializerclass AvroSerializer extends Object implements Serializable- 
Serialized Fields- 
fieldNamesList<String> fieldNames 
- 
schemasCachedSchemas schemas 
- 
schemaStringString schemaString 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.serde.avro.CachedSchemasclass CachedSchemas extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.serde.csv- 
Class org.apache.storm.sql.runtime.serde.csv.CsvSchemeclass CsvScheme extends Object implements Serializable
- 
Class org.apache.storm.sql.runtime.serde.csv.CsvSerializerclass CsvSerializer extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.serde.json- 
Class org.apache.storm.sql.runtime.serde.json.JsonSchemeclass JsonScheme extends Object implements Serializable
- 
Class org.apache.storm.sql.runtime.serde.json.JsonSerializerclass JsonSerializer extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.serde.tsv- 
Class org.apache.storm.sql.runtime.serde.tsv.TsvSchemeclass TsvScheme extends Object implements Serializable
- 
Class org.apache.storm.sql.runtime.serde.tsv.TsvSerializerclass TsvSerializer extends Object implements Serializable
 
- 
- 
Package org.apache.storm.sql.runtime.streams.functions- 
Class org.apache.storm.sql.runtime.streams.functions.EvaluationCalcclass EvaluationCalc extends Object implements Serializable- 
Serialized Fields- 
dataContextorg.apache.calcite.DataContext dataContext 
- 
filterInstanceExecutableExpression filterInstance 
- 
outputValuesObject[] outputValues 
- 
projectionInstanceExecutableExpression projectionInstance 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.streams.functions.EvaluationFilterclass EvaluationFilter extends Object implements Serializable- 
Serialized Fields- 
dataContextorg.apache.calcite.DataContext dataContext 
- 
filterInstanceExecutableExpression filterInstance 
- 
outputValuesObject[] outputValues 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.streams.functions.EvaluationFunctionclass EvaluationFunction extends Object implements Serializable- 
Serialized Fields- 
dataContextorg.apache.calcite.DataContext dataContext 
- 
outputValuesObject[] outputValues 
- 
projectionInstanceExecutableExpression projectionInstance 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunctionclass StreamInsertMapToPairFunction extends Object implements Serializable- 
Serialized Fields- 
primaryKeyIndexint primaryKeyIndex 
 
- 
 
- 
- 
Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapperclass StreamsScanTupleValueMapper extends Object implements Serializable
 
- 
- 
Package org.apache.storm.st.topology.window- 
Class org.apache.storm.st.topology.window.IncrementingSpoutclass IncrementingSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
componentIdString componentId 
- 
currentNumint currentNum 
 
- 
 
- 
- 
Class org.apache.storm.st.topology.window.TimeDataIncrementingSpoutclass TimeDataIncrementingSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
componentIdString componentId 
- 
currentNumint currentNum 
 
- 
 
- 
- 
Class org.apache.storm.st.topology.window.TimeDataVerificationBoltclass TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
componentIdString componentId 
 
- 
 
- 
- 
Class org.apache.storm.st.topology.window.VerificationBoltclass VerificationBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
componentIdString componentId 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.starter- 
Class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpoutclass RandomSentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
randomRandom random 
 
- 
 
- 
- 
Class org.apache.storm.starter.AnchoredWordCount.SplitSentenceclass SplitSentence extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.AnchoredWordCount.WordCountclass WordCount extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBoltclass ExclaimBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWordsclass FilterWords extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpoutclass RandomSentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentenceclass SplitSentence extends ShellBolt implements Serializable
- 
Class org.apache.storm.starter.ExclamationTopology.ExclamationBoltclass ExclamationBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpoutclass FastRandomSentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
randRandom rand 
 
- 
 
- 
- 
Class org.apache.storm.starter.FastWordCountTopology.SplitSentenceclass SplitSentence extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.FastWordCountTopology.WordCountclass WordCount extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.InOrderDeliveryTest.Checkclass Check extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpoutclass InOrderSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
baseint base 
- 
collectorSpoutOutputCollector collector 
- 
countint count 
 
- 
 
- 
- 
Class org.apache.storm.starter.ManualDRPC.ExclamationBoltclass ExclamationBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBoltclass ExclamationLoggingBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
loggerorg.slf4j.Logger logger 
- 
rootLoggerorg.slf4j.Logger rootLogger 
- 
subLoggerorg.slf4j.Logger subLogger 
 
- 
 
- 
- 
Class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentenceclass MultiThreadedSplitSentence extends Object implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
executorExecutorService executor 
 
- 
 
- 
- 
Class org.apache.storm.starter.ReachTopology.CountAggregator- 
Serialized Fields- 
collectorBatchOutputCollector collector 
- 
countint count 
- 
idObject id 
 
- 
 
- 
- 
Class org.apache.storm.starter.ReachTopology.GetFollowersclass GetFollowers extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.ReachTopology.GetTweetersclass GetTweeters extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.ReachTopology.PartialUniquer- 
Serialized Fields- 
collectorBatchOutputCollector collector 
- 
followersSet<String> followers 
- 
idObject id 
 
- 
 
- 
- 
Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBoltclass ExclamationBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
 
- 
 
- 
- 
Class org.apache.storm.starter.StatefulTopology.PrinterBoltclass PrinterBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.WordCountTopology.SplitSentenceclass SplitSentence extends ShellBolt implements Serializable
- 
Class org.apache.storm.starter.WordCountTopologyNode.RandomSentenceclass RandomSentence extends ShellSpout implements Serializable
- 
Class org.apache.storm.starter.WordCountTopologyNode.SplitSentenceclass SplitSentence extends ShellBolt implements Serializable
- 
Class org.apache.storm.starter.WordCountTopologyNode.WordCountclass WordCount extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.starter.bolt- 
Class org.apache.storm.starter.bolt.AbstractRankerBoltclass AbstractRankerBolt extends BaseBasicBolt implements Serializable- serialVersionUID:
- 4931640198501530202L
 - 
Serialized Fields- 
countint count 
- 
emitFrequencyInSecondsint emitFrequencyInSeconds 
- 
rankingsRankings rankings 
 
- 
 
- 
Class org.apache.storm.starter.bolt.IntermediateRankingsBoltclass IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable- serialVersionUID:
- -1369800530256637409L
 
- 
Class org.apache.storm.starter.bolt.PrinterBoltclass PrinterBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.starter.bolt.RollingCountAggBoltclass RollingCountAggBolt extends BaseRichBolt implements Serializable- serialVersionUID:
- 5537727428628598519L
 
- 
Class org.apache.storm.starter.bolt.RollingCountBoltclass RollingCountBolt extends BaseRichBolt implements Serializable- serialVersionUID:
- 5537727428628598519L
 - 
Serialized Fields- 
collectorOutputCollector collector 
- 
counterSlidingWindowCounter<Object> counter 
- 
emitFrequencyInSecondsint emitFrequencyInSeconds 
- 
lastModifiedTrackerNthLastModifiedTimeTracker lastModifiedTracker 
- 
windowLengthInSecondsint windowLengthInSeconds 
 
- 
 
- 
Class org.apache.storm.starter.bolt.SingleJoinBoltclass SingleJoinBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
fieldLocationsMap<String, GlobalStreamId> fieldLocations 
- 
idFieldsFields idFields 
- 
numSourcesint numSources 
- 
outFieldsFields outFields 
- 
pendingTimeCacheMap<List<Object>, Map<GlobalStreamId, Tuple>> pending 
 
- 
 
- 
- 
Class org.apache.storm.starter.bolt.SlidingWindowSumBoltclass SlidingWindowSumBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
sumint sum 
 
- 
 
- 
- 
Class org.apache.storm.starter.bolt.TotalRankingsBoltclass TotalRankingsBolt extends AbstractRankerBolt implements Serializable- serialVersionUID:
- -8447525895532302198L
 
- 
Class org.apache.storm.starter.bolt.WordCountBoltclass WordCountBolt extends BaseBasicBolt implements Serializable
 
- 
- 
Package org.apache.storm.starter.spout- 
Class org.apache.storm.starter.spout.RandomIntegerSpoutclass RandomIntegerSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
msgIdlong msgId 
- 
randRandom rand 
 
- 
 
- 
- 
Class org.apache.storm.starter.spout.RandomNumberGeneratorSpoutclass RandomNumberGeneratorSpout extends Object implements Serializable
- 
Class org.apache.storm.starter.spout.RandomSentenceSpoutclass RandomSentenceSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
randRandom rand 
 
- 
 
- 
- 
Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStampedclass TimeStamped extends RandomSentenceSpout implements Serializable- 
Serialized Fields- 
prefixString prefix 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.starter.tools- 
Class org.apache.storm.starter.tools.RankableObjectWithFieldsclass RankableObjectWithFields extends Object implements Serializable- serialVersionUID:
- -9102878650001058090L
 
- 
Class org.apache.storm.starter.tools.Rankingsclass Rankings extends Object implements Serializable- serialVersionUID:
- -1549827195410578903L
 
- 
Class org.apache.storm.starter.tools.SlidingWindowCounterclass SlidingWindowCounter extends Object implements Serializable- serialVersionUID:
- -2645063988768785810L
 - 
Serialized Fields- 
headSlotint headSlot 
- 
objCounterSlotBasedCounter<T> objCounter 
- 
tailSlotint tailSlot 
- 
windowLengthInSlotsint windowLengthInSlots 
 
- 
 
- 
Class org.apache.storm.starter.tools.SlotBasedCounterclass SlotBasedCounter extends Object implements Serializable- serialVersionUID:
- 4858185737378394432L
 
 
- 
- 
Package org.apache.storm.starter.trident- 
Class org.apache.storm.starter.trident.DebugMemoryMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.starter.trident.TridentReach.ExpandListclass ExpandList extends BaseFunction implements Serializable
- 
Class org.apache.storm.starter.trident.TridentReach.Oneclass One extends Object implements Serializable
- 
Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
mapMap map 
 
- 
 
- 
- 
Class org.apache.storm.starter.trident.TridentWordCount.Splitclass Split extends BaseFunction implements Serializable
 
- 
- 
Package org.apache.storm.state- 
Class org.apache.storm.state.DefaultStateSerializerclass DefaultStateSerializer extends Object implements Serializable- 
Serialized Fields- 
contextTopologyContext context 
- 
kryoThreadLocal<com.esotericsoftware.kryo.Kryo> kryo 
- 
outputThreadLocal<com.esotericsoftware.kryo.io.Output> output 
- 
registrationsList<String> registrations 
- 
topoConfMap<String, Object> topoConf 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.streams- 
Class org.apache.storm.streams.Pairclass Pair extends Object implements Serializable
- 
Class org.apache.storm.streams.ProcessorNodeclass ProcessorNode extends org.apache.storm.streams.Node implements Serializable
- 
Class org.apache.storm.streams.StreamStateclass StreamState extends Object implements Serializable
- 
Class org.apache.storm.streams.WindowNodeclass WindowNode extends org.apache.storm.streams.Node implements Serializable- 
Serialized Fields- 
windowParamsWindow<?, ?> windowParams 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.streams.operations- 
Class org.apache.storm.streams.operations.IdentityFunctionclass IdentityFunction extends Object implements Serializable
- 
Class org.apache.storm.streams.operations.PairValueJoinerclass PairValueJoiner extends Object implements Serializable
- 
Class org.apache.storm.streams.operations.PrintConsumerclass PrintConsumer extends Object implements Serializable
 
- 
- 
Package org.apache.storm.streams.operations.aggregators- 
Class org.apache.storm.streams.operations.aggregators.Countclass Count extends Object implements Serializable
- 
Class org.apache.storm.streams.operations.aggregators.LongSumclass LongSum extends Object implements Serializable
 
- 
- 
Package org.apache.storm.streams.operations.mappers- 
Class org.apache.storm.streams.operations.mappers.PairValueMapperclass PairValueMapper extends Object implements Serializable- 
Serialized Fields- 
keyIndexint keyIndex 
- 
valueIndexint valueIndex 
 
- 
 
- 
- 
Class org.apache.storm.streams.operations.mappers.ValueMapperclass ValueMapper extends Object implements Serializable- 
Serialized Fields- 
indexint index 
 
- 
 
- 
- 
Class org.apache.storm.streams.operations.mappers.ValuesMapperclass ValuesMapper extends Object implements Serializable- 
Serialized Fields- 
indicesint[] indices 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.streams.processors- 
Class org.apache.storm.streams.processors.AggregateByKeyProcessorclass AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable 
- 
Class org.apache.storm.streams.processors.AggregateProcessorclass AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable- 
Serialized Fields- 
aggregatorCombinerAggregator<T, A, R> aggregator 
- 
emitAggregateboolean emitAggregate 
- 
stateA state 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.BranchProcessorclass BranchProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.ChainedProcessorContextclass ChainedProcessorContext extends Object implements Serializable- 
Serialized Fields- 
contextsList<? extends ProcessorContext> contexts 
- 
processorNodeProcessorNode processorNode 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.CoGroupByKeyProcessorclass CoGroupByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable 
- 
Class org.apache.storm.streams.processors.EmittingProcessorContextclass EmittingProcessorContext extends Object implements Serializable- 
Serialized Fields- 
anchorsList<RefCountedTuple> anchors 
- 
collectorOutputCollector collector 
- 
eventTimestamplong eventTimestamp 
- 
outputFieldsFields outputFields 
- 
outputStreamIdString outputStreamId 
- 
processorNodeProcessorNode processorNode 
- 
punctuationValues punctuation 
- 
punctuationStreamIdString punctuationStreamId 
- 
timestampFieldString timestampField 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.FilterProcessorclass FilterProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.FlatMapProcessorclass FlatMapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable- 
Serialized Fields- 
functionFlatMapFunction<T, R> function 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.FlatMapValuesProcessorclass FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable - 
Serialized Fields- 
functionFlatMapFunction<V, R> function 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.ForEachProcessorclass ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.ForwardingProcessorContextclass ForwardingProcessorContext extends Object implements Serializable- 
Serialized Fields- 
processorNodeProcessorNode processorNode 
- 
streamsSet<String> streams 
- 
streamToChildrenorg.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.JoinProcessorclass JoinProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable 
- 
Class org.apache.storm.streams.processors.MapProcessorclass MapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.MapValuesProcessorclass MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable 
- 
Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessorclass MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,A>> implements Serializable 
- 
Class org.apache.storm.streams.processors.MergeAggregateProcessorclass MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable- 
Serialized Fields- 
aggregatorCombinerAggregator<T, A, R> aggregator 
- 
stateA state 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.PeekProcessorclass PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.ReduceByKeyProcessorclass ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable 
- 
Class org.apache.storm.streams.processors.ReduceProcessorclass ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable
- 
Class org.apache.storm.streams.processors.StateQueryProcessorclass StateQueryProcessor extends org.apache.storm.streams.processors.BaseProcessor<K> implements Serializable- 
Serialized Fields- 
keyValueStateKeyValueState<K, V> keyValueState 
- 
streamStateStreamState<K, V> streamState 
 
- 
 
- 
- 
Class org.apache.storm.streams.processors.UpdateStateByKeyProcessorclass UpdateStateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable - 
Serialized Fields- 
keyValueStateKeyValueState<K, R> keyValueState 
- 
stateUpdaterStateUpdater<V, R> stateUpdater 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.streams.windowing- 
Class org.apache.storm.streams.windowing.BaseWindowclass BaseWindow extends Object implements Serializable- 
Serialized Fields- 
lagBaseWindowedBolt.Duration lag 
- 
lateTupleStreamString lateTupleStream 
- 
timestampFieldString timestampField 
 
- 
 
- 
- 
Class org.apache.storm.streams.windowing.SlidingWindows
- 
Class org.apache.storm.streams.windowing.TumblingWindows- 
Serialized Fields- 
windowLengthL windowLength 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.task- 
Class org.apache.storm.task.ShellBoltclass ShellBolt extends Object implements Serializable- serialVersionUID:
- -339575186639193348L
 - 
Serialized Fields- 
changeDirectoryboolean changeDirectory 
- 
collectorOutputCollector collector 
- 
commandString[] command 
- 
contextTopologyContext context 
- 
envMap<String, String> env 
- 
exceptionThrowable exception 
- 
heartBeatExecutorServiceScheduledExecutorService heartBeatExecutorService 
- 
inputsMap<String, Tuple> inputs 
- 
isLocalModeboolean isLocalMode 
- 
lastHeartbeatTimestampAtomicLong lastHeartbeatTimestamp 
- 
logHandlerShellLogHandler logHandler 
- 
pendingWritesShellBoltMessageQueue pendingWrites 
- 
processShellProcess process 
- 
randRandom rand 
- 
readerThreadThread readerThread 
- 
runningboolean running 
- 
sendHeartbeatFlagAtomicBoolean sendHeartbeatFlag 
- 
workerTimeoutMillsint workerTimeoutMills 
- 
writerThreadThread writerThread 
 
- 
 
 
- 
- 
Package org.apache.storm.testing- 
Class org.apache.storm.testing.AckFailMapTrackerclass AckFailMapTracker extends Object implements Serializable
- 
Class org.apache.storm.testing.AckTrackerclass AckTracker extends Object implements Serializable- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.testing.BoltTrackerclass BoltTracker extends NonRichBoltTracker implements Serializable- 
Serialized Fields- 
richDelegateIRichBolt richDelegate 
 
- 
 
- 
- 
Class org.apache.storm.testing.FeederSpoutclass FeederSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
ackFailDelegateAckFailDelegate ackFailDelegate 
- 
collectorSpoutOutputCollector collector 
- 
idint id 
- 
outFieldsFields outFields 
 
- 
 
- 
- 
Class org.apache.storm.testing.FixedTupleclass FixedTuple extends Object implements Serializable
- 
Class org.apache.storm.testing.FixedTupleSpoutclass FixedTupleSpout extends Object implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
contextTopologyContext context 
- 
fieldsFields fields 
- 
idString id 
- 
pendingMap<String, FixedTuple> pending 
- 
serveTuplesList<FixedTuple> serveTuples 
- 
tuplesList<FixedTuple> tuples 
 
- 
 
- 
- 
Class org.apache.storm.testing.IdentityBoltclass IdentityBolt extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
fieldsFields fields 
 
- 
 
- 
- 
Class org.apache.storm.testing.NGroupingclass NGrouping extends Object implements Serializable
- 
Class org.apache.storm.testing.NonRichBoltTrackerclass NonRichBoltTracker extends Object implements Serializable
- 
Class org.apache.storm.testing.PrepareBatchBoltclass PrepareBatchBolt extends BaseBasicBolt implements Serializable- 
Serialized Fields- 
outFieldsFields outFields 
 
- 
 
- 
- 
Class org.apache.storm.testing.PythonShellMetricsBoltclass PythonShellMetricsBolt extends ShellBolt implements Serializable- serialVersionUID:
- 1999209252187463355L
 
- 
Class org.apache.storm.testing.PythonShellMetricsSpoutclass PythonShellMetricsSpout extends ShellSpout implements Serializable- serialVersionUID:
- 1999209252187463355L
 
- 
Class org.apache.storm.testing.SpoutTrackerclass SpoutTracker extends BaseRichSpout implements Serializable- 
Serialized Fields- 
delegateIRichSpout delegate 
- 
trackerorg.apache.storm.testing.SpoutTracker.SpoutTrackOutputCollector tracker 
- 
trackIdString trackId 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestAggregatesCounterclass TestAggregatesCounter extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countsMap<String, Integer> counts 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestConfBoltclass TestConfBolt extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.testing.TestEventLogSpoutclass TestEventLogSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
eventIdlong eventId 
- 
myCountlong myCount 
- 
sourceint source 
- 
totalCountlong totalCount 
- 
uidString uid 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestEventOrderCheckBoltclass TestEventOrderCheckBolt extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countint count 
- 
recentEventIdMap<Integer, Long> recentEventId 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestGlobalCountclass TestGlobalCount extends BaseRichBolt implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
countint count 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestPlannerBoltclass TestPlannerBolt extends BaseRichBolt implements Serializable
- 
Class org.apache.storm.testing.TestPlannerSpoutclass TestPlannerSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
isDistributedboolean isDistributed 
- 
outFieldsFields outFields 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestSerObjectclass TestSerObject extends Object implements Serializable- 
Serialized Fields- 
f1int f1 
- 
f2int f2 
 
- 
 
- 
- 
Class org.apache.storm.testing.TestWordBytesCounterclass TestWordBytesCounter extends TestWordCounter implements Serializable
- 
Class org.apache.storm.testing.TestWordCounterclass TestWordCounter extends BaseBasicBolt implements Serializable
- 
Class org.apache.storm.testing.TestWordSpoutclass TestWordSpout extends BaseRichSpout implements Serializable- 
Serialized Fields- 
collectorSpoutOutputCollector collector 
- 
isDistributedboolean isDistributed 
 
- 
 
- 
- 
Class org.apache.storm.testing.TupleCaptureBoltclass TupleCaptureBolt extends Object implements Serializable- 
Serialized Fields- 
collectorOutputCollector collector 
- 
nameString name 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.topology- 
Class org.apache.storm.topology.BaseStatefulBoltExecutorclass BaseStatefulBoltExecutor extends Object implements Serializable- 
Serialized Fields- 
checkPointInputTaskCountint checkPointInputTaskCount 
- 
collectorOutputCollector collector 
- 
lastTxidlong lastTxid 
- 
transactionRequestCountMap<org.apache.storm.topology.BaseStatefulBoltExecutor.TransactionRequest, Integer> transactionRequestCount 
 
- 
 
- 
- 
Class org.apache.storm.topology.BasicBoltExecutorclass BasicBoltExecutor extends Object implements Serializable- 
Serialized Fields- 
boltIBasicBolt bolt 
 
- 
 
- 
- 
Class org.apache.storm.topology.CheckpointTupleForwarderclass CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable- 
Serialized Fields- 
boltIRichBolt bolt 
 
- 
 
- 
- 
Exception org.apache.storm.topology.FailedExceptionclass FailedException extends RuntimeException implements Serializable
- 
Class org.apache.storm.topology.PersistentWindowedBoltExecutorclass PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable- 
Serialized Fields- 
statefulWindowedBoltIStatefulWindowedBolt<T extends State> statefulWindowedBolt 
 
- 
 
- 
- 
Exception org.apache.storm.topology.ReportedFailedExceptionclass ReportedFailedException extends FailedException implements Serializable
- 
Class org.apache.storm.topology.StatefulBoltExecutorclass StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable
- 
Class org.apache.storm.topology.StatefulWindowedBoltExecutorclass StatefulWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable- 
Serialized Fields- 
statefulWindowedBoltIStatefulWindowedBolt<T extends State> statefulWindowedBolt 
 
- 
 
- 
- 
Class org.apache.storm.topology.TupleFieldTimestampExtractorclass TupleFieldTimestampExtractor extends Object implements Serializable- 
Serialized Fields- 
fieldNameString fieldName 
 
- 
 
- 
- 
Class org.apache.storm.topology.WindowedBoltExecutorclass WindowedBoltExecutor extends Object implements Serializable- 
Serialized Fields- 
boltIWindowedBolt bolt 
- 
timestampExtractorTimestampExtractor timestampExtractor 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.topology.base- 
Class org.apache.storm.topology.base.BaseBasicBoltclass BaseBasicBolt extends BaseComponent implements Serializable
- 
Class org.apache.storm.topology.base.BaseBatchBoltclass BaseBatchBolt extends BaseComponent implements Serializable
- 
Class org.apache.storm.topology.base.BaseComponentclass BaseComponent extends Object implements Serializable
- 
Class org.apache.storm.topology.base.BaseRichBoltclass BaseRichBolt extends BaseComponent implements Serializable
- 
Class org.apache.storm.topology.base.BaseRichSpoutclass BaseRichSpout extends BaseComponent implements Serializable
- 
Class org.apache.storm.topology.base.BaseStatefulBoltclass BaseStatefulBolt extends Object implements Serializable
- 
Class org.apache.storm.topology.base.BaseStatefulWindowedBoltclass BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable- 
Serialized Fields- 
maxEventsInMemorylong maxEventsInMemory 
- 
persistentboolean persistent 
 
- 
 
- 
- 
Class org.apache.storm.topology.base.BaseTickTupleAwareRichBoltclass BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable
- 
Class org.apache.storm.topology.base.BaseWindowedBoltclass BaseWindowedBolt extends Object implements Serializable- 
Serialized Fields- 
timestampExtractorTimestampExtractor timestampExtractor 
 
- 
 
- 
- 
Class org.apache.storm.topology.base.BaseWindowedBolt.Countclass Count extends Object implements Serializable- 
Serialized Fields- 
valueint value 
 
- 
 
- 
- 
Class org.apache.storm.topology.base.BaseWindowedBolt.Durationclass Duration extends Object implements Serializable- 
Serialized Fields- 
valueint value 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.drpc- 
Class org.apache.storm.trident.drpc.ReturnResultsReducerclass ReturnResultsReducer extends Object implements Serializable
 
- 
- 
Package org.apache.storm.trident.operation- 
Class org.apache.storm.trident.operation.BaseAggregatorclass BaseAggregator extends BaseOperation implements Serializable
- 
Class org.apache.storm.trident.operation.BaseFilterclass BaseFilter extends BaseOperation implements Serializable
- 
Class org.apache.storm.trident.operation.BaseFunctionclass BaseFunction extends BaseOperation implements Serializable
- 
Class org.apache.storm.trident.operation.BaseMultiReducerclass BaseMultiReducer extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.BaseOperationclass BaseOperation extends Object implements Serializable
 
- 
- 
Package org.apache.storm.trident.operation.builtin- 
Class org.apache.storm.trident.operation.builtin.ComparisonAggregatorclass ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable
- 
Class org.apache.storm.trident.operation.builtin.Countclass Count extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.builtin.Debugclass Debug extends BaseFilter implements Serializable- 
Serialized Fields- 
nameString name 
- 
useLoggerboolean useLogger 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.Equalsclass Equals extends BaseFilter implements Serializable
- 
Class org.apache.storm.trident.operation.builtin.FilterNullclass FilterNull extends BaseFilter implements Serializable
- 
Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAggclass FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable- 
Serialized Fields- 
numberint number 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg- 
Serialized Fields- 
numberint number 
- 
reverseboolean reverse 
- 
sortFieldString sortField 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.MapGet
- 
Class org.apache.storm.trident.operation.builtin.Max
- 
Class org.apache.storm.trident.operation.builtin.MaxWithComparator- 
Serialized Fields- 
comparatorComparator<T> comparator 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.Min
- 
Class org.apache.storm.trident.operation.builtin.MinWithComparator- 
Serialized Fields- 
comparatorComparator<T> comparator 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.Negateclass Negate extends Object implements Serializable- 
Serialized Fields- 
delegateFilter delegate 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.builtin.SnapshotGet
- 
Class org.apache.storm.trident.operation.builtin.Sumclass Sum extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.builtin.TupleCollectionGetclass TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable 
 
- 
- 
Package org.apache.storm.trident.operation.impl- 
Class org.apache.storm.trident.operation.impl.ChainedAggregatorImplclass ChainedAggregatorImpl extends Object implements Serializable- 
Serialized Fields- 
aggsAggregator[] aggs 
- 
factComboList.Factory fact 
- 
inputFactoriesTridentTupleView.ProjectionFactory[] inputFactories 
- 
inputFieldsFields[] inputFields 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImplclass CombinerAggregatorCombineImpl extends Object implements Serializable- 
Serialized Fields- 
aggCombinerAggregator agg 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImplclass CombinerAggregatorInitImpl extends Object implements Serializable- 
Serialized Fields- 
aggCombinerAggregator agg 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdaterclass CombinerAggStateUpdater extends Object implements Serializable- 
Serialized Fields- 
aggCombinerAggregator agg 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.ConsumerExecutorclass ConsumerExecutor extends BaseOperation implements Serializable- 
Serialized Fields- 
consumerConsumer consumer 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.FilterExecutorclass FilterExecutor extends Object implements Serializable- 
Serialized Fields- 
filterFilter filter 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutorclass FlatMapFunctionExecutor extends BaseOperation implements Serializable- 
Serialized Fields- 
functionFlatMapFunction function 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.GlobalBatchToPartitionclass GlobalBatchToPartition extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.impl.GroupedAggregatorclass GroupedAggregator extends Object implements Serializable- 
Serialized Fields- 
aggAggregator agg 
- 
factComboList.Factory fact 
- 
groupFactoryTridentTupleView.ProjectionFactory groupFactory 
- 
groupFieldsFields groupFields 
- 
inFieldsFields inFields 
- 
inputFactoryTridentTupleView.ProjectionFactory inputFactory 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutorclass GroupedMultiReducerExecutor extends Object implements Serializable- 
Serialized Fields- 
groupFactoriesList<TridentTupleView.ProjectionFactory> groupFactories 
- 
groupFieldsList<Fields> groupFields 
- 
inputFactoriesList<TridentTupleView.ProjectionFactory> inputFactories 
- 
inputFieldsList<Fields> inputFields 
- 
reducerGroupedMultiReducer reducer 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.IdentityMultiReducerclass IdentityMultiReducer extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartitionclass IndexHashBatchToPartition extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.impl.JoinerMultiReducerclass JoinerMultiReducer extends Object implements Serializable- 
Serialized Fields- 
factoryComboList.Factory factory 
- 
numGroupFieldsint numGroupFields 
- 
sideFieldsList<Fields> sideFields 
- 
typesList<JoinType> types 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.MapFunctionExecutorclass MapFunctionExecutor extends BaseOperation implements Serializable- 
Serialized Fields- 
functionMapFunction function 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducerclass PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable
- 
Class org.apache.storm.trident.operation.impl.ReducerAggregatorImplclass ReducerAggregatorImpl extends Object implements Serializable- 
Serialized Fields- 
aggReducerAggregator agg 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdaterclass ReducerAggStateUpdater extends Object implements Serializable- 
Serialized Fields- 
aggReducerAggregator agg 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.SingleEmitAggregatorclass SingleEmitAggregator extends Object implements Serializable- 
Serialized Fields- 
aggAggregator agg 
- 
batchToPartitionSingleEmitAggregator.BatchToPartition batchToPartition 
- 
myPartitionIndexint myPartitionIndex 
- 
totalPartitionsint totalPartitions 
 
- 
 
- 
- 
Class org.apache.storm.trident.operation.impl.TrueFilterclass TrueFilter extends Object implements Serializable
 
- 
- 
Package org.apache.storm.trident.partition- 
Class org.apache.storm.trident.partition.GlobalGroupingclass GlobalGrouping extends Object implements Serializable
- 
Class org.apache.storm.trident.partition.IdentityGroupingclass IdentityGrouping extends Object implements Serializable
- 
Class org.apache.storm.trident.partition.IndexHashGroupingclass IndexHashGrouping extends Object implements Serializable
 
- 
- 
Package org.apache.storm.trident.planner- 
Class org.apache.storm.trident.planner.Node
- 
Class org.apache.storm.trident.planner.NodeStateInfoclass NodeStateInfo extends Object implements Serializable
- 
Class org.apache.storm.trident.planner.PartitionNodeclass PartitionNode extends Node implements Serializable- 
Serialization Methods- 
readObject- Throws:
- ClassNotFoundException
- IOException
 
- 
writeObject- Throws:
- IOException
 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.ProcessorNodeclass ProcessorNode extends Node implements Serializable- 
Serialized Fields- 
committerboolean committer 
- 
processorTridentProcessor processor 
- 
selfOutFieldsFields selfOutFields 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.SpoutNodeclass SpoutNode extends Node implements Serializable- 
Serialized Fields- 
spoutObject spout 
- 
txIdString txId 
- 
typeSpoutNode.SpoutType type 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.SubtopologyBoltclass SubtopologyBolt extends Object implements Serializable- serialVersionUID:
- 1475508603138688412L
 - 
Serialized Fields- 
batchGroupsMap<Node, String> batchGroups 
- 
graphorg.apache.storm.shade.org.jgrapht.DirectedGraph<Node, IndexedEdge> graph 
- 
myTopologicallyOrderedMap<String, List<TridentProcessor>> myTopologicallyOrdered 
- 
nodesSet<Node> nodes 
- 
outputFactoriesMap<Node, TridentTuple.Factory> outputFactories 
- 
rootsMap<String, SubtopologyBolt.InitialReceiver> roots 
 
- 
 
 
- 
- 
Package org.apache.storm.trident.planner.processor- 
Class org.apache.storm.trident.planner.processor.AggregateProcessorclass AggregateProcessor extends Object implements Serializable- 
Serialized Fields- 
aggAggregator agg 
- 
collectorFreshCollector collector 
- 
contextTridentContext context 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.EachProcessorclass EachProcessor extends Object implements Serializable- 
Serialized Fields- 
collectorAppendCollector collector 
- 
contextTridentContext context 
- 
functionFunction function 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.MapProcessorclass MapProcessor extends Object implements Serializable- 
Serialized Fields- 
collectorFreshCollector collector 
- 
contextTridentContext context 
- 
functionFunction function 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.MultiReducerProcessorclass MultiReducerProcessor extends Object implements Serializable- 
Serialized Fields- 
collectorFreshCollector collector 
- 
contextTridentContext context 
- 
projectFieldsList<Fields> projectFields 
- 
projectionFactoriesTridentTupleView.ProjectionFactory[] projectionFactories 
- 
reducerMultiReducer reducer 
- 
streamToIndexMap<String, Integer> streamToIndex 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.PartitionPersistProcessorclass PartitionPersistProcessor extends Object implements Serializable- 
Serialized Fields- 
collectorFreshCollector collector 
- 
contextTridentContext context 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
- 
stateState state 
- 
stateIdString stateId 
- 
updaterStateUpdater updater 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.ProjectedProcessorclass ProjectedProcessor extends Object implements Serializable- 
Serialized Fields- 
contextTridentContext context 
- 
factoryTridentTupleView.ProjectionFactory factory 
- 
projectFieldsFields projectFields 
 
- 
 
- 
- 
Class org.apache.storm.trident.planner.processor.StateQueryProcessorclass StateQueryProcessor extends Object implements Serializable- 
Serialized Fields- 
collectorAppendCollector collector 
- 
contextTridentContext context 
- 
functionQueryFunction function 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
- 
stateState state 
- 
stateIdString stateId 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.spout- 
Class org.apache.storm.trident.spout.BatchSpoutExecutorclass BatchSpoutExecutor extends Object implements Serializable- 
Serialized Fields- 
spoutIBatchSpout spout 
 
- 
 
- 
- 
Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutorclass OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable- 
Serialized Fields- 
spoutIOpaquePartitionedTridentSpout<Object, ISpoutPartition, Object> spout 
 
- 
 
- 
- 
Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutorclass PartitionedTridentSpoutExecutor extends Object implements Serializable- 
Serialized Fields- 
spoutIPartitionedTridentSpout<Object, ISpoutPartition, Object> spout 
 
- 
 
- 
- 
Class org.apache.storm.trident.spout.RichSpoutBatchExecutorclass RichSpoutBatchExecutor extends Object implements Serializable- 
Serialized Fields- 
spoutIRichSpout spout 
 
- 
 
- 
- 
Class org.apache.storm.trident.spout.RichSpoutBatchTriggererclass RichSpoutBatchTriggerer extends Object implements Serializable- 
Serialized Fields
 
- 
- 
Class org.apache.storm.trident.spout.TridentSpoutCoordinatorclass TridentSpoutCoordinator extends Object implements Serializable- 
Serialized Fields- 
coordITridentSpout.BatchCoordinator<Object> coord 
- 
idString id 
- 
spoutITridentSpout<Object> spout 
- 
stateRotatingTransactionalState state 
- 
underlyingStateTransactionalState underlyingState 
 
- 
 
- 
- 
Class org.apache.storm.trident.spout.TridentSpoutExecutorclass TridentSpoutExecutor extends Object implements Serializable- 
Serialized Fields- 
activeBatchesTreeMap<Long, TransactionAttempt> activeBatches 
- 
collectororg.apache.storm.trident.spout.TridentSpoutExecutor.AddIdCollector collector 
- 
emitterITridentSpout.Emitter<Object> emitter 
- 
spoutITridentSpout<Object> spout 
- 
streamNameString streamName 
- 
txStateIdString txStateId 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.state- 
Class org.apache.storm.trident.state.BaseQueryFunctionclass BaseQueryFunction extends BaseOperation implements Serializable
- 
Class org.apache.storm.trident.state.BaseStateUpdaterclass BaseStateUpdater extends BaseOperation implements Serializable
- 
Class org.apache.storm.trident.state.JSONNonTransactionalSerializerclass JSONNonTransactionalSerializer extends Object implements Serializable
- 
Class org.apache.storm.trident.state.JSONOpaqueSerializerclass JSONOpaqueSerializer extends Object implements Serializable
- 
Class org.apache.storm.trident.state.JSONTransactionalSerializerclass JSONTransactionalSerializer extends Object implements Serializable
- 
Class org.apache.storm.trident.state.StateSpecclass StateSpec extends Object implements Serializable- 
Serialized Fields- 
requiredNumPartitionsInteger requiredNumPartitions 
- 
stateFactoryStateFactory stateFactory 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.state.map- 
Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdaterclass MapCombinerAggStateUpdater extends Object implements Serializable- serialVersionUID:
- -3960578785572592092L
 - 
Serialized Fields- 
aggCombinerAggregator agg 
- 
factoryComboList.Factory factory 
- 
groupFieldsFields groupFields 
- 
inputFieldsFields inputFields 
 
- 
 
- 
Class org.apache.storm.trident.state.map.MapReducerAggStateUpdaterclass MapReducerAggStateUpdater extends Object implements Serializable- serialVersionUID:
- 8667174018978959987L
 - 
Serialized Fields- 
aggReducerAggregator agg 
- 
factoryComboList.Factory factory 
- 
groupFieldsFields groupFields 
- 
inputFieldsFields inputFields 
 
- 
 
- 
Class org.apache.storm.trident.state.map.MicroBatchIBackingMap.Optionsclass Options extends Object implements Serializable- 
Serialized Fields- 
maxMultiGetBatchSizeint maxMultiGetBatchSize 
- 
maxMultiPutBatchSizeint maxMultiPutBatchSize 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.testing- 
Class org.apache.storm.trident.testing.CountAsAggregatorclass CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable
- 
Class org.apache.storm.trident.testing.FeederBatchSpoutclass FeederBatchSpout extends Object implements Serializable
- 
Class org.apache.storm.trident.testing.FeederCommitterBatchSpoutclass FeederCommitterBatchSpout extends Object implements Serializable- 
Serialized Fields- 
spoutFeederBatchSpout spout 
 
- 
 
- 
- 
Class org.apache.storm.trident.testing.FixedBatchSpoutclass FixedBatchSpout extends Object implements Serializable
- 
Class org.apache.storm.trident.testing.LRUMemoryMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
idString id 
- 
maxSizeint maxSize 
 
- 
 
- 
- 
Class org.apache.storm.trident.testing.MemoryMapState.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
idString id 
 
- 
 
- 
- 
Class org.apache.storm.trident.testing.Splitclass Split extends BaseFunction implements Serializable
- 
Class org.apache.storm.trident.testing.StringLengthclass StringLength extends BaseFunction implements Serializable
- 
Class org.apache.storm.trident.testing.TrueFilterclass TrueFilter extends BaseFilter implements Serializable
- 
Class org.apache.storm.trident.testing.TuplifyArgsclass TuplifyArgs extends BaseFunction implements Serializable
 
- 
- 
Package org.apache.storm.trident.topology- 
Class org.apache.storm.trident.topology.MasterBatchCoordinatorclass MasterBatchCoordinator extends BaseRichSpout implements Serializable- 
Serialized Fields- 
activeboolean active 
- 
activeTxTreeMap<Long, org.apache.storm.trident.topology.MasterBatchCoordinator.TransactionStatus> activeTx 
- 
attemptIdsTreeMap<Long, Integer> attemptIds 
- 
collectorSpoutOutputCollector collector 
- 
coordinatorsList<ITridentSpout.BatchCoordinator> coordinators 
- 
currTransactionLong currTransaction 
- 
managedSpoutIdsList<String> managedSpoutIds 
- 
maxTransactionActiveint maxTransactionActive 
- 
spoutsList<ITridentSpout> spouts 
- 
statesList<TransactionalState> states 
- 
throttlerWindowedTimeThrottler throttler 
 
- 
 
- 
- 
Class org.apache.storm.trident.topology.TridentBoltExecutorclass TridentBoltExecutor extends Object implements Serializable- 
Serialized Fields- 
batchesRotatingMap<Object, TridentBoltExecutor.TrackedBatch> batches 
- 
batchGroupIdsMap<GlobalStreamId, String> batchGroupIds 
- 
boltITridentBatchBolt bolt 
- 
collectorOutputCollector collector 
- 
contextTopologyContext context 
- 
coordCollectororg.apache.storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector coordCollector 
- 
coordConditionsMap<String, TridentBoltExecutor.CoordCondition> coordConditions 
- 
coordOutputCollectorBatchOutputCollector coordOutputCollector 
- 
coordSpecsMap<String, TridentBoltExecutor.CoordSpec> coordSpecs 
- 
lastRotatelong lastRotate 
- 
messageTimeoutMslong messageTimeoutMs 
 
- 
 
- 
- 
Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordConditionclass CoordCondition extends Object implements Serializable- 
Serialized Fields- 
commitStreamGlobalStreamId commitStream 
- 
expectedTaskReportsint expectedTaskReports 
- 
targetTasksSet<Integer> targetTasks 
 
- 
 
- 
- 
Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpecclass CoordSpec extends Object implements Serializable- 
Serialized Fields- 
commitStreamGlobalStreamId commitStream 
- 
coordsMap<String, TridentBoltExecutor.CoordType> coords 
 
- 
 
- 
- 
Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordTypeclass CoordType extends Object implements Serializable- 
Serialized Fields- 
singleCountboolean singleCount 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.tuple- 
Class org.apache.storm.trident.tuple.ComboList.Factoryclass Factory extends Object implements Serializable- 
Serialized Fields- 
indexorg.apache.storm.trident.tuple.ComboList.Pointer[] index 
- 
sizesint[] sizes 
 
- 
 
- 
- 
Class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactoryclass FreshOutputFactory extends Object implements Serializable- 
Serialized Fields- 
fieldIndexMap<String, ValuePointer> fieldIndex 
- 
indexValuePointer[] index 
 
- 
 
- 
- 
Class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactoryclass OperationOutputFactory extends Object implements Serializable- 
Serialized Fields- 
fieldIndexMap<String, ValuePointer> fieldIndex 
- 
indexValuePointer[] index 
- 
parentTridentTuple.Factory parent 
 
- 
 
- 
- 
Class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactoryclass ProjectionFactory extends Object implements Serializable- 
Serialized Fields- 
fieldIndexMap<String, ValuePointer> fieldIndex 
- 
indexValuePointer[] index 
- 
parentTridentTuple.Factory parent 
 
- 
 
- 
- 
Class org.apache.storm.trident.tuple.TridentTupleView.RootFactoryclass RootFactory extends Object implements Serializable- 
Serialized Fields- 
fieldIndexMap<String, ValuePointer> fieldIndex 
- 
indexValuePointer[] index 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.util- 
Class org.apache.storm.trident.util.ErrorEdgeFactoryclass ErrorEdgeFactory extends Object implements Serializable
- 
Class org.apache.storm.trident.util.IndexedEdgeclass IndexedEdge extends Object implements Serializable
- 
Class org.apache.storm.trident.util.LRUMap- 
Serialized Fields- 
maxSizeint maxSize 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.windowing- 
Class org.apache.storm.trident.windowing.InMemoryWindowsStoreclass InMemoryWindowsStore extends Object implements Serializable- 
Serialized Fields- 
backingStoreWindowsStore backingStore 
- 
currentSizeAtomicInteger currentSize 
- 
maxSizeint maxSize 
- 
storeConcurrentHashMap<String, Object> store 
 
- 
 
- 
- 
Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactoryclass InMemoryWindowsStoreFactory extends Object implements Serializable- 
Serialized Fields- 
inMemoryWindowsStoreInMemoryWindowsStore inMemoryWindowsStore 
 
- 
 
- 
- 
Class org.apache.storm.trident.windowing.WindowsStateFactoryclass WindowsStateFactory extends Object implements Serializable
- 
Class org.apache.storm.trident.windowing.WindowsStateUpdaterclass WindowsStateUpdater extends Object implements Serializable- 
Serialized Fields- 
windowsStoreWindowsStore windowsStore 
- 
windowStoreFactoryWindowsStoreFactory windowStoreFactory 
 
- 
 
- 
- 
Class org.apache.storm.trident.windowing.WindowsStore.Entryclass Entry extends Object implements Serializable
- 
Class org.apache.storm.trident.windowing.WindowTridentProcessorclass WindowTridentProcessor extends Object implements Serializable- 
Serialized Fields- 
aggregatorAggregator aggregator 
- 
collectorFreshCollector collector 
- 
inputFieldsFields inputFields 
- 
projectionTridentTupleView.ProjectionFactory projection 
- 
storeTuplesInStoreboolean storeTuplesInStore 
- 
topologyContextTopologyContext topologyContext 
- 
tridentContextTridentContext tridentContext 
- 
tridentWindowManagerITridentWindowManager tridentWindowManager 
- 
windowConfigWindowConfig windowConfig 
- 
windowIdString windowId 
- 
windowStoreWindowsStore windowStore 
- 
windowStoreFactoryWindowsStoreFactory windowStoreFactory 
- 
windowTaskIdString windowTaskId 
- 
windowTriggerInprocessIdString windowTriggerInprocessId 
 
- 
 
- 
- 
Class org.apache.storm.trident.windowing.WindowTridentProcessor.TriggerInfoclass TriggerInfo extends Object implements Serializable- 
Serialized Fields- 
triggerIdint triggerId 
- 
windowTaskIdString windowTaskId 
 
- 
 
- 
 
- 
- 
Package org.apache.storm.trident.windowing.config- 
Class org.apache.storm.trident.windowing.config.BaseWindowConfigclass BaseWindowConfig extends Object implements Serializable- 
Serialized Fields- 
slideLengthint slideLength 
- 
windowLengthint windowLength 
 
- 
 
- 
- 
Class org.apache.storm.trident.windowing.config.SlidingCountWindowclass SlidingCountWindow extends BaseWindowConfig implements Serializable
- 
Class org.apache.storm.trident.windowing.config.SlidingDurationWindowclass SlidingDurationWindow extends BaseWindowConfig implements Serializable
- 
Class org.apache.storm.trident.windowing.config.TumblingCountWindowclass TumblingCountWindow extends BaseWindowConfig implements Serializable
- 
Class org.apache.storm.trident.windowing.config.TumblingDurationWindowclass TumblingDurationWindow extends BaseWindowConfig implements Serializable
 
- 
- 
Package org.apache.storm.tuple- 
Class org.apache.storm.tuple.Fieldsclass Fields extends Object implements Serializable- serialVersionUID:
- -3377931843059975424L
 
- 
Class org.apache.storm.tuple.Values
 
- 
- 
Package org.apache.storm.utils- 
Exception org.apache.storm.utils.DisallowedStrategyExceptionclass DisallowedStrategyException extends RuntimeException implements Serializable
- 
Class org.apache.storm.utils.LruMap- 
Serialized Fields- 
evCbLruMap.CacheEvictionCallback evCb 
- 
maxSizeint maxSize 
 
- 
 
- 
- 
Exception org.apache.storm.utils.NimbusLeaderNotFoundExceptionclass NimbusLeaderNotFoundException extends RuntimeException implements Serializable
- 
Class org.apache.storm.utils.ShellBoltMessageQueueclass ShellBoltMessageQueue extends Object implements Serializable- 
Serialized Fields- 
boltMsgQueueLinkedBlockingQueue<BoltMsg> boltMsgQueue 
- 
notEmptyCondition notEmpty 
- 
takeLockReentrantLock takeLock 
- 
taskIdsQueueLinkedList<List<Integer>> taskIdsQueue 
 
- 
 
- 
- 
Class org.apache.storm.utils.ShellProcessclass ShellProcess extends Object implements Serializable- 
Serialized Fields- 
commandString[] command 
- 
componentNameString componentName 
- 
envMap<String, String> env 
- 
pidNumber pid 
- 
processErrorStreamInputStream processErrorStream 
- 
serializerISerializer serializer 
- 
subprocessProcess subprocess 
 
- 
 
- 
- 
Exception org.apache.storm.utils.ShellUtils.ExitCodeExceptionclass ExitCodeException extends IOException implements Serializable- 
Serialized Fields- 
exitCodeint exitCode 
 
- 
 
- 
- 
Exception org.apache.storm.utils.WrappedAlreadyAliveExceptionclass WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable
- 
Exception org.apache.storm.utils.WrappedAuthorizationExceptionclass WrappedAuthorizationException extends AuthorizationException implements Serializable
- 
Exception org.apache.storm.utils.WrappedDRPCExecutionExceptionclass WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable
- 
Exception org.apache.storm.utils.WrappedHBExecutionExceptionclass WrappedHBExecutionException extends HBExecutionException implements Serializable
- 
Exception org.apache.storm.utils.WrappedIllegalStateExceptionclass WrappedIllegalStateException extends IllegalStateException implements Serializable
- 
Exception org.apache.storm.utils.WrappedInvalidTopologyExceptionclass WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable
- 
Exception org.apache.storm.utils.WrappedKeyAlreadyExistsExceptionclass WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable
- 
Exception org.apache.storm.utils.WrappedKeyNotFoundExceptionclass WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable
- 
Exception org.apache.storm.utils.WrappedNotAliveExceptionclass WrappedNotAliveException extends NotAliveException implements Serializable
 
- 
- 
Package org.apache.storm.windowing