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