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

Serialized Fields

iter__752

Object iter__752

s__753

Object s__753

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

Serialized Fields

b__755

Object b__755

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

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

Serialized Fields

iter__677

Object iter__677

s__678

Object s__678

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

Serialized Fields

b__680

Object b__680

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

Class org.apache.storm.clojure$report_error_BANG_

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

Class org.apache.storm.clojure$reset_timeout_BANG_

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

Class org.apache.storm.clojure$spout

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

Class org.apache.storm.clojure$spout$fn__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

class Config extends HashMap<String,Object> implements Serializable

serialVersionUID:

-1550278723792864455L

Class org.apache.storm.config$clojure_config_name

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

Class org.apache.storm.config$fn__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

Serialized Fields

iter__337

Object iter__337

s__338

Object s__338

Class org.apache.storm.testing$spout_objects$iter__337__341$fn__342$fn__343

class testing$spout_objects$iter__337__341$fn__342$fn__343 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__340

Object b__340

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

Class org.apache.storm.testing$submit_local_topology

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

Class org.apache.storm.testing$submit_local_topology_with_opts

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

Class org.apache.storm.testing$test_tuple

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

Class org.apache.storm.testing$tracked_wait

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

Class org.apache.storm.testing$wait_for_condition

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

Class org.apache.storm.testing$wait_for_condition$fn__309

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

Class org.apache.storm.testing$wait_until_cluster_waiting

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

Class org.apache.storm.testing$while_timeout

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

Class org.apache.storm.testing$with_inprocess_zookeeper

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

Class org.apache.storm.testing$with_local_cluster

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

Class org.apache.storm.testing$with_mocked_nimbus

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

Class org.apache.storm.testing$with_simulated_time_local_cluster

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

Class org.apache.storm.testing$with_timeout

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

Class org.apache.storm.testing$with_tracked_cluster

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

Class org.apache.storm.thrift$add_inputs

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

Class org.apache.storm.thrift$deserialized_component_object

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

Class org.apache.storm.thrift$direct_output_fields

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

Class org.apache.storm.thrift$field_grouping

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

Class org.apache.storm.thrift$fn__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

Serialized Fields

iter__589

Object iter__589

s__590

Object s__590

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

Serialized Fields

b__592

Object b__592

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

Class org.apache.storm.thrift$mk_local_or_shuffle_grouping

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

Class org.apache.storm.thrift$mk_none_grouping

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

Class org.apache.storm.thrift$mk_output_spec

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

Class org.apache.storm.thrift$mk_output_spec$fn__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

Serialized Fields

afn

Object afn

iter__503

Object iter__503

s__504

Object s__504

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

Serialized Fields

afn

Object afn

b__506

Object b__506

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

Class org.apache.storm.util$name_with_attributes

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

Class org.apache.storm.util$thrown_cause_QMARK_

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

Package org.apache.storm.bolt

Class org.apache.storm.bolt.JoinBolt

class JoinBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

hashedInputs

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

joinCriteria

LinkedHashMap<String,JoinBolt.JoinInfo> joinCriteria

outputFields

JoinBolt.FieldSelector[] outputFields

outputStreamName

String outputStreamName

selectorType

JoinBolt.Selector selectorType

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

class FieldSelector extends Object implements Serializable

Serialized Fields

field

String[] field

outputName

String outputName

streamName

String streamName

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

class JoinInfo extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

field

JoinBolt.FieldSelector field

joinType

JoinBolt.JoinType joinType

other

JoinBolt.FieldSelector other

Package org.apache.storm.clojure

Class org.apache.storm.clojure.ClojureBolt

class ClojureBolt extends Object implements Serializable

Serialized Fields

bolt

IBolt bolt

confSpec

List<String> confSpec

fields

Map<String,StreamInfo> fields

fnSpec

List<String> fnSpec

params

List<Object> params

Class org.apache.storm.clojure.ClojureSpout

class ClojureSpout extends Object implements Serializable

Serialized Fields

confSpec

List<String> confSpec

fields

Map<String,StreamInfo> fields

fnSpec

List<String> fnSpec

params

List<Object> params

spout

ISpout spout

Class org.apache.storm.clojure.RichShellBolt

class RichShellBolt extends ShellBolt implements Serializable

Serialized Fields

outputs

Map<String,StreamInfo> outputs

Class org.apache.storm.clojure.RichShellSpout

class RichShellSpout extends ShellSpout implements Serializable

Serialized Fields

outputs

Map<String,StreamInfo> outputs

Package org.apache.storm.coordination

Class org.apache.storm.coordination.BatchBoltExecutor

class BatchBoltExecutor extends Object implements Serializable

Serialized Fields

boltSer

byte[] boltSer

collector

BatchOutputCollectorImpl collector

conf

Map conf

context

TopologyContext context

openTransactions

Map<Object,IBatchBolt> openTransactions

Class org.apache.storm.coordination.CoordinatedBolt

class CoordinatedBolt extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

countOutTasks

List<Integer> countOutTasks

delegate

IRichBolt delegate

idStreamSpec

CoordinatedBolt.IdStreamSpec idStreamSpec

numSourceReports

Integer numSourceReports

sourceArgs

Map<String,CoordinatedBolt.SourceArgs> sourceArgs

tracked

TimeCacheMap<Object,CoordinatedBolt.TrackingInfo> tracked

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

class IdStreamSpec extends Object implements Serializable

Serialized Fields

id

GlobalStreamId id

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

class SourceArgs extends Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package org.apache.storm.daemon

Class org.apache.storm.daemon.Acker

class Acker extends Object implements Serializable

serialVersionUID:

4430906880683183091L

Serialized Fields

collector

OutputCollector collector

pending

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

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

class AllGrouper extends Object implements Serializable

Serialized Fields

targetTasks

List<Integer> targetTasks

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

class BasicLoadAwareCustomStreamGrouping extends Object implements Serializable

Serialized Fields

customStreamGrouping

CustomStreamGrouping customStreamGrouping

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

class FieldsGrouper extends Object implements Serializable

Serialized Fields

groupFields

Fields groupFields

numTasks

int numTasks

outFields

Fields outFields

targetTasks

List<List<Integer>> targetTasks

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

class GlobalGrouper extends Object implements Serializable

Serialized Fields

targetTasks

List<Integer> targetTasks

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

class NoneGrouper extends Object implements Serializable

Serialized Fields

numTasks

int numTasks

random

Random random

targetTasks

List<Integer> targetTasks

Package org.apache.storm.daemon.supervisor

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

class ContainerRecoveryException extends RuntimeException implements Serializable

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

class TimerDecoratedAssignment extends LocalAssignment implements Serializable

Serialized Fields

timing

com.codahale.metrics.Timer.Context timing

Package org.apache.storm.daemon.ui

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

class InvalidRequestException extends Exception implements Serializable

Package org.apache.storm.dependency

Exception org.apache.storm.dependency.FileNotAvailableException

class FileNotAvailableException extends RuntimeException implements Serializable

Package org.apache.storm.drpc

Class org.apache.storm.drpc.DRPCSpout

class DRPCSpout extends BaseRichSpout implements Serializable

serialVersionUID:

2387848310969237877L

Serialized Fields

clients

List<DRPCInvocationsClient> clients

collector

SpoutOutputCollector collector

function

String function

localDrpcId

String localDrpcId

Class org.apache.storm.drpc.JoinResult

class JoinResult extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

results

Map<Object,Tuple> results

returnComponent

String returnComponent

returns

Map<Object,Tuple> returns

Class org.apache.storm.drpc.KeyedFairBolt

class KeyedFairBolt extends Object implements Serializable

Serialized Fields

callback

CoordinatedBolt.FinishedCallback callback

delegate

IRichBolt delegate

executor

Thread executor

rrQueue

KeyedRoundRobinQueue<Tuple> rrQueue

Class org.apache.storm.drpc.PrepareRequest

class PrepareRequest extends BaseBasicBolt implements Serializable

Serialized Fields

rand

Random rand

Class org.apache.storm.drpc.ReturnResults

class ReturnResults extends BaseRichBolt implements Serializable

serialVersionUID:

-774882142710631591L

Serialized Fields

clients

Map<List,DRPCInvocationsClient> clients

collector

OutputCollector collector

conf

Map<String,Object> conf

local

boolean local

Package org.apache.storm.elasticsearch

Class org.apache.storm.elasticsearch.DefaultEsLookupResultOutput

class DefaultEsLookupResultOutput extends Object implements Serializable

serialVersionUID:

2932278450655703239L

Serialized Fields

objectMapper

com.fasterxml.jackson.databind.ObjectMapper objectMapper

Package org.apache.storm.elasticsearch.bolt

Class org.apache.storm.elasticsearch.bolt.AbstractEsBolt

class AbstractEsBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

esConfig

EsConfig esConfig

Class org.apache.storm.elasticsearch.bolt.EsIndexBolt

class EsIndexBolt extends AbstractEsBolt implements Serializable

Serialized Fields

tupleMapper

EsTupleMapper tupleMapper

Class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

class UserDataSpout extends BaseRichSpout implements Serializable

serialVersionUID:

1L

Serialized Fields

collector

SpoutOutputCollector collector

The collector passed in EsIndexTopology.UserDataSpout.open(java.util.Map, org.apache.storm.task.TopologyContext, org.apache.storm.spout.SpoutOutputCollector).

count

int count

index

int index

indexName

String indexName

pending

ConcurrentHashMap<UUID,Values> pending

The pending values.

sources

String[] sources

total

long total

typeName

String typeName

Class org.apache.storm.elasticsearch.bolt.EsLookupBolt

class EsLookupBolt extends AbstractEsBolt implements Serializable

Serialized Fields

output

EsLookupResultOutput output

tupleMapper

EsTupleMapper tupleMapper

Class org.apache.storm.elasticsearch.bolt.EsPercolateBolt

class EsPercolateBolt extends AbstractEsBolt implements Serializable

Serialized Fields

tupleMapper

EsTupleMapper tupleMapper

Package org.apache.storm.elasticsearch.common

Class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper

class DefaultEsTupleMapper extends Object implements Serializable

Class org.apache.storm.elasticsearch.common.EsConfig

class EsConfig extends Object implements Serializable

Serialized Fields

compression

boolean compression

defaultHeaders

org.apache.http.Header[] defaultHeaders

failureListener

org.elasticsearch.client.RestClient.FailureListener failureListener

httpClientConfigCallback

org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback

httpHosts

org.apache.http.HttpHost[] httpHosts

pathPrefix

String pathPrefix

requestConfigCallback

org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback

Class org.apache.storm.elasticsearch.common.StormElasticSearchClient

class StormElasticSearchClient extends Object implements Serializable

Serialized Fields

esConfig

EsConfig esConfig

Package org.apache.storm.elasticsearch.trident

Class org.apache.storm.elasticsearch.trident.EsStateFactory

class EsStateFactory extends Object implements Serializable

Serialized Fields

esConfig

EsConfig esConfig

tupleMapper

EsTupleMapper tupleMapper

Class org.apache.storm.elasticsearch.trident.EsUpdater

class EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState> implements Serializable

Class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

class FixedBatchSpout extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

batches

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

The passed batches.

cycle

boolean cycle

A flag indicating whether cycling ought to be performed.

index

int index

The current index.

maxBatchSize

int maxBatchSize

outputs

Values[] outputs

The output values.

Package org.apache.storm.executor

Class org.apache.storm.executor.TupleInfo

class TupleInfo extends Object implements Serializable

serialVersionUID:

-3348670497595864118L

Serialized Fields

messageId

Object messageId

rootId

long rootId

stream

String stream

taskId

int taskId

timestamp

long timestamp

values

List<Object> values

Package org.apache.storm.flux.examples

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

class OnlyValueRecordTranslator extends Object implements Serializable

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

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

Serialized Fields

collector

OutputCollector collector

wordCounts

KeyValueState<String,Long> wordCounts

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

class TestPrintBolt extends BaseBasicBolt implements Serializable

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

class TestWindowBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

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

class WordCounter extends BaseBasicBolt implements Serializable

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

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

class FluxShellBolt extends ShellBolt implements Serializable

Serialized Fields

componentConfig

Map<String,Object> componentConfig

outputFields

Map<String,String[]> outputFields

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

class LogInfoBolt extends BaseBasicBolt implements Serializable

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

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

class FluxShellSpout extends ShellSpout implements Serializable

Serialized Fields

componentConfig

Map<String,Object> componentConfig

outputFields

Map<String,String[]> outputFields

Package org.apache.storm.generated

Class org.apache.storm.generated.AccessControl

class AccessControl extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

access

int access

name

String name

type

AccessControlType type

Exception org.apache.storm.generated.AlreadyAliveException

class AlreadyAliveException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.Assignment

class Assignment extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

executor_node_port

Map<List<Long>,NodeInfo> executor_node_port

executor_start_time_secs

Map<List<Long>,Long> executor_start_time_secs

master_code_dir

String master_code_dir

node_host

Map<String,String> node_host

owner

String owner

total_shared_off_heap

Map<String,Double> total_shared_off_heap

worker_resources

Map<NodeInfo,WorkerResources> worker_resources

Exception org.apache.storm.generated.AuthorizationException

class AuthorizationException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.BeginDownloadResult

class BeginDownloadResult extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

data_size

long data_size

session

String session

version

long version

Class org.apache.storm.generated.Bolt

class Bolt extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

bolt_object

ComponentObject bolt_object

common

ComponentCommon common

Class org.apache.storm.generated.BoltAggregateStats

class BoltAggregateStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

capacity

double capacity

execute_latency_ms

double execute_latency_ms

executed

long executed

process_latency_ms

double process_latency_ms

Class org.apache.storm.generated.BoltStats

class BoltStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

acked

Map<String,Map<GlobalStreamId,Long>> acked

execute_ms_avg

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

executed

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

failed

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

process_ms_avg

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

Class org.apache.storm.generated.ClusterSummary

class ClusterSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

nimbuses

List<NimbusSummary> nimbuses

supervisors

List<SupervisorSummary> supervisors

topologies

List<TopologySummary> topologies

Class org.apache.storm.generated.ClusterWorkerHeartbeat

class ClusterWorkerHeartbeat extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

executor_stats

Map<ExecutorInfo,ExecutorStats> executor_stats

storm_id

String storm_id

time_secs

int time_secs

uptime_secs

int uptime_secs

Class org.apache.storm.generated.CommonAggregateStats

class CommonAggregateStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

acked

long acked

emitted

long emitted

failed

long failed

num_executors

int num_executors

num_tasks

int num_tasks

resources_map

Map<String,Double> resources_map

transferred

long transferred

Class org.apache.storm.generated.ComponentAggregateStats

class ComponentAggregateStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

common_stats

CommonAggregateStats common_stats

last_error

ErrorInfo last_error

specific_stats

SpecificAggregateStats specific_stats

type

ComponentType type

Class org.apache.storm.generated.ComponentCommon

class ComponentCommon extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

inputs

Map<GlobalStreamId,Grouping> inputs

json_conf

String json_conf

parallelism_hint

int parallelism_hint

streams

Map<String,StreamInfo> streams

Class org.apache.storm.generated.ComponentObject

class ComponentObject extends org.apache.storm.thrift.TUnion<ComponentObject,ComponentObject._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.ComponentPageInfo

class ComponentPageInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

component_id

String component_id

component_type

ComponentType component_type

debug_options

DebugOptions debug_options

errors

List<ErrorInfo> errors

eventlog_host

String eventlog_host

eventlog_port

int eventlog_port

exec_stats

List<ExecutorAggregateStats> exec_stats

gsid_to_input_stats

Map<GlobalStreamId,ComponentAggregateStats> gsid_to_input_stats

num_executors

int num_executors

num_tasks

int num_tasks

resources_map

Map<String,Double> resources_map

sid_to_output_stats

Map<String,ComponentAggregateStats> sid_to_output_stats

topology_id

String topology_id

topology_name

String topology_name

topology_status

String topology_status

window_to_stats

Map<String,ComponentAggregateStats> window_to_stats

Class org.apache.storm.generated.Credentials

class Credentials extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

creds

Map<String,String> creds

topoOwner

String topoOwner

Class org.apache.storm.generated.DebugOptions

class DebugOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

enable

boolean enable

samplingpct

double samplingpct

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

class execute_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

funcArgs

String funcArgs

functionName

String functionName

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

class execute_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

DRPCExecutionException e

success

String success

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

class failRequest_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.DistributedRPCInvocations.failRequest_result

class failRequest_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.DistributedRPCInvocations.failRequestV2_args

class failRequestV2_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

e

DRPCExecutionException e

id

String id

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

class failRequestV2_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_args

class fetchRequest_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

functionName

String functionName

Class org.apache.storm.generated.DistributedRPCInvocations.fetchRequest_result

class fetchRequest_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

DRPCRequest success

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

class result_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

result

String result

Class org.apache.storm.generated.DistributedRPCInvocations.result_result

class result_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Exception org.apache.storm.generated.DRPCExecutionException

class DRPCExecutionException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

type

DRPCExceptionType type

Class org.apache.storm.generated.DRPCRequest

class DRPCRequest extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

func_args

String func_args

request_id

String request_id

Class org.apache.storm.generated.ErrorInfo

class ErrorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

error

String error

error_time_secs

int error_time_secs

host

String host

port

int port

Class org.apache.storm.generated.ExecutorAggregateStats

class ExecutorAggregateStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

exec_summary

ExecutorSummary exec_summary

stats

ComponentAggregateStats stats

Class org.apache.storm.generated.ExecutorInfo

class ExecutorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

task_end

int task_end

task_start

int task_start

Class org.apache.storm.generated.ExecutorSpecificStats

class ExecutorSpecificStats extends org.apache.storm.thrift.TUnion<ExecutorSpecificStats,ExecutorSpecificStats._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.ExecutorStats

class ExecutorStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

emitted

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

rate

double rate

specific

ExecutorSpecificStats specific

transferred

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

Class org.apache.storm.generated.ExecutorSummary

class ExecutorSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

component_id

String component_id

executor_info

ExecutorInfo executor_info

host

String host

port

int port

stats

ExecutorStats stats

uptime_secs

int uptime_secs

Class org.apache.storm.generated.GetInfoOptions

class GetInfoOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

num_err_choice

NumErrorsChoice num_err_choice

Class org.apache.storm.generated.GlobalStreamId

class GlobalStreamId extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

componentId

String componentId

streamId

String streamId

Class org.apache.storm.generated.Grouping

class Grouping extends org.apache.storm.thrift.TUnion<Grouping,Grouping._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Exception org.apache.storm.generated.HBAuthorizationException

class HBAuthorizationException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Exception org.apache.storm.generated.HBExecutionException

class HBExecutionException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.HBMessage

class HBMessage extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

data

HBMessageData data

message_id

int message_id

type

HBServerMessageType type

Class org.apache.storm.generated.HBMessageData

class HBMessageData extends org.apache.storm.thrift.TUnion<HBMessageData,HBMessageData._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.HBNodes

class HBNodes extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

pulseIds

List<String> pulseIds

Class org.apache.storm.generated.HBPulse

class HBPulse extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

details

ByteBuffer details

id

String id

Class org.apache.storm.generated.HBRecords

class HBRecords extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

pulses

List<HBPulse> pulses

Exception org.apache.storm.generated.IllegalStateException

class IllegalStateException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Exception org.apache.storm.generated.InvalidTopologyException

class InvalidTopologyException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.JavaObject

class JavaObject extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

args_list

List<JavaObjectArg> args_list

full_class_name

String full_class_name

Class org.apache.storm.generated.JavaObjectArg

class JavaObjectArg extends org.apache.storm.thrift.TUnion<JavaObjectArg,JavaObjectArg._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Exception org.apache.storm.generated.KeyAlreadyExistsException

class KeyAlreadyExistsException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Exception org.apache.storm.generated.KeyNotFoundException

class KeyNotFoundException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.KillOptions

class KillOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

wait_secs

int wait_secs

Class org.apache.storm.generated.ListBlobsResult

class ListBlobsResult extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

keys

List<String> keys

session

String session

Class org.apache.storm.generated.LocalAssignment

class LocalAssignment extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

executors

List<ExecutorInfo> executors

owner

String owner

resources

WorkerResources resources

topology_id

String topology_id

total_node_shared

double total_node_shared

Class org.apache.storm.generated.LocalStateData

class LocalStateData extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

serialized_parts

Map<String,ThriftSerializedObject> serialized_parts

Class org.apache.storm.generated.LogConfig

class LogConfig extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

named_logger_level

Map<String,LogLevel> named_logger_level

Class org.apache.storm.generated.LogLevel

class LogLevel extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

action

LogLevelAction action

reset_log_level

String reset_log_level

reset_log_level_timeout_epoch

long reset_log_level_timeout_epoch

reset_log_level_timeout_secs

int reset_log_level_timeout_secs

target_log_level

String target_log_level

Class org.apache.storm.generated.LSApprovedWorkers

class LSApprovedWorkers extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

approved_workers

Map<String,Integer> approved_workers

Class org.apache.storm.generated.LSSupervisorAssignments

class LSSupervisorAssignments extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

assignments

Map<Integer,LocalAssignment> assignments

Class org.apache.storm.generated.LSSupervisorId

class LSSupervisorId extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

supervisor_id

String supervisor_id

Class org.apache.storm.generated.LSTopoHistory

class LSTopoHistory extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

groups

List<String> groups

time_stamp

long time_stamp

topology_id

String topology_id

users

List<String> users

Class org.apache.storm.generated.LSTopoHistoryList

class LSTopoHistoryList extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

topo_history

List<LSTopoHistory> topo_history

Class org.apache.storm.generated.LSWorkerHeartbeat

class LSWorkerHeartbeat extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

executors

List<ExecutorInfo> executors

port

int port

time_secs

int time_secs

topology_id

String topology_id

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

class activate_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.activate_result

class activate_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

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

class beginBlobDownload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.beginBlobDownload_result

class beginBlobDownload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

knf

KeyNotFoundException knf

success

BeginDownloadResult success

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

class beginCreateBlob_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

meta

SettableBlobMeta meta

Class org.apache.storm.generated.Nimbus.beginCreateBlob_result

class beginCreateBlob_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

kae

KeyAlreadyExistsException kae

success

String success

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

class beginFileUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.beginFileUpload_result

class beginFileUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

String success

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

class beginUpdateBlob_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.beginUpdateBlob_result

class beginUpdateBlob_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

knf

KeyNotFoundException knf

success

String success

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

class cancelBlobUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

session

String session

Class org.apache.storm.generated.Nimbus.cancelBlobUpload_result

class cancelBlobUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.createStateInZookeeper_args

class createStateInZookeeper_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.createStateInZookeeper_result

class createStateInZookeeper_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.deactivate_args

class deactivate_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.deactivate_result

class deactivate_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

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

class debug_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

component

String component

enable

boolean enable

name

String name

samplingPercentage

double samplingPercentage

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

class debug_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

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

class deleteBlob_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.deleteBlob_result

class deleteBlob_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

ise

IllegalStateException ise

knf

KeyNotFoundException knf

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

class downloadBlobChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

session

String session

Class org.apache.storm.generated.Nimbus.downloadBlobChunk_result

class downloadBlobChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

ByteBuffer success

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

class downloadChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.downloadChunk_result

class downloadChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

ByteBuffer success

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

class finishBlobUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

session

String session

Class org.apache.storm.generated.Nimbus.finishBlobUpload_result

class finishBlobUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.finishFileUpload_args

class finishFileUpload_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

location

String location

Class org.apache.storm.generated.Nimbus.finishFileUpload_result

class finishFileUpload_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.getBlobMeta_args

class getBlobMeta_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.getBlobMeta_result

class getBlobMeta_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

knf

KeyNotFoundException knf

success

ReadableBlobMeta success

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

class getBlobReplication_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

Class org.apache.storm.generated.Nimbus.getBlobReplication_result

class getBlobReplication_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

aze

AuthorizationException aze

knf

KeyNotFoundException knf

success

int success

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

class getClusterInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.getClusterInfo_result

class getClusterInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

ClusterSummary success

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

class getComponentPageInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

component_id

String component_id

is_include_sys

boolean is_include_sys

topology_id

String topology_id

window

String window

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

class getComponentPageInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

ComponentPageInfo success

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

class getComponentPendingProfileActions_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

action

ProfileAction action

component_id

String component_id

id

String id

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

class getComponentPendingProfileActions_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

success

List<ProfileRequest> success

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

class getLeader_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.getLeader_result

class getLeader_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

NimbusSummary success

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

class getLogConfig_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.getLogConfig_result

class getLogConfig_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

success

LogConfig success

Class org.apache.storm.generated.Nimbus.getNimbusConf_args

class getNimbusConf_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.getNimbusConf_result

class getNimbusConf_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

String success

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

class getOwnerResourceSummaries_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

owner

String owner

Class org.apache.storm.generated.Nimbus.getOwnerResourceSummaries_result

class getOwnerResourceSummaries_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

List<OwnerResourceSummary> success

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

class getSupervisorAssignments_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

node

String node

Class org.apache.storm.generated.Nimbus.getSupervisorAssignments_result

class getSupervisorAssignments_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

SupervisorAssignments success

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

class getSupervisorPageInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

host

String host

id

String id

is_include_sys

boolean is_include_sys

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

class getSupervisorPageInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

SupervisorPageInfo success

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

class getTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.getTopology_result

class getTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

StormTopology success

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

class getTopologyConf_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.getTopologyConf_result

class getTopologyConf_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

String success

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

class getTopologyHistory_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

user

String user

Class org.apache.storm.generated.Nimbus.getTopologyHistory_result

class getTopologyHistory_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

TopologyHistoryInfo success

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

class getTopologyInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.getTopologyInfo_result

class getTopologyInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologyInfo success

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

class getTopologyInfoByName_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.getTopologyInfoByName_result

class getTopologyInfoByName_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologyInfo success

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

class getTopologyInfoByNameWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

options

GetInfoOptions options

Class org.apache.storm.generated.Nimbus.getTopologyInfoByNameWithOpts_result

class getTopologyInfoByNameWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologyInfo success

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

class getTopologyInfoWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

options

GetInfoOptions options

Class org.apache.storm.generated.Nimbus.getTopologyInfoWithOpts_result

class getTopologyInfoWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologyInfo success

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

class getTopologyPageInfo_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

id

String id

is_include_sys

boolean is_include_sys

window

String window

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

class getTopologyPageInfo_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologyPageInfo success

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

class getTopologySummaries_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.getTopologySummaries_result

class getTopologySummaries_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

success

List<TopologySummary> success

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

class getTopologySummary_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.getTopologySummary_result

class getTopologySummary_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologySummary success

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

class getTopologySummaryByName_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.getTopologySummaryByName_result

class getTopologySummaryByName_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

TopologySummary success

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

class getUserTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Nimbus.getUserTopology_result

class getUserTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

StormTopology success

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

class isRemoteBlobExists_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

blobKey

String blobKey

Class org.apache.storm.generated.Nimbus.isRemoteBlobExists_result

class isRemoteBlobExists_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

aze

AuthorizationException aze

success

boolean success

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

class isTopologyNameAllowed_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.isTopologyNameAllowed_result

class isTopologyNameAllowed_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

aze

AuthorizationException aze

success

boolean success

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

class killTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

Class org.apache.storm.generated.Nimbus.killTopology_result

class killTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

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

class killTopologyWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

options

KillOptions options

Class org.apache.storm.generated.Nimbus.killTopologyWithOpts_result

class killTopologyWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

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

class listBlobs_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

session

String session

Class org.apache.storm.generated.Nimbus.listBlobs_result

class listBlobs_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

success

ListBlobsResult success

Class org.apache.storm.generated.Nimbus.processWorkerMetrics_args

class processWorkerMetrics_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

metrics

WorkerMetrics metrics

Class org.apache.storm.generated.Nimbus.processWorkerMetrics_result

class processWorkerMetrics_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.rebalance_args

class rebalance_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

name

String name

options

RebalanceOptions options

Class org.apache.storm.generated.Nimbus.rebalance_result

class rebalance_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

ite

InvalidTopologyException ite

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

class sendSupervisorWorkerHeartbeat_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

heatbeat

SupervisorWorkerHeartbeat heatbeat

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeat_result

class sendSupervisorWorkerHeartbeat_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_args

class sendSupervisorWorkerHeartbeats_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

heartbeats

SupervisorWorkerHeartbeats heartbeats

Class org.apache.storm.generated.Nimbus.sendSupervisorWorkerHeartbeats_result

class sendSupervisorWorkerHeartbeats_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.setBlobMeta_args

class setBlobMeta_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

key

String key

meta

SettableBlobMeta meta

Class org.apache.storm.generated.Nimbus.setBlobMeta_result

class setBlobMeta_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

knf

KeyNotFoundException knf

Class org.apache.storm.generated.Nimbus.setLogConfig_args

class setLogConfig_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

config

LogConfig config

name

String name

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

class setLogConfig_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.setWorkerProfiler_args

class setWorkerProfiler_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

profileRequest

ProfileRequest profileRequest

Class org.apache.storm.generated.Nimbus.setWorkerProfiler_result

class setWorkerProfiler_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.Nimbus.submitTopology_args

class submitTopology_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

jsonConf

String jsonConf

name

String name

topology

StormTopology topology

uploadedJarLocation

String uploadedJarLocation

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

class submitTopology_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

AlreadyAliveException e

ite

InvalidTopologyException ite

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

class submitTopologyWithOpts_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

jsonConf

String jsonConf

name

String name

options

SubmitOptions options

topology

StormTopology topology

uploadedJarLocation

String uploadedJarLocation

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

class submitTopologyWithOpts_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

AlreadyAliveException e

ite

InvalidTopologyException ite

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

class updateBlobReplication_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

key

String key

replication

int replication

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

class updateBlobReplication_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

aze

AuthorizationException aze

knf

KeyNotFoundException knf

success

int success

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

class uploadBlobChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

chunk

ByteBuffer chunk

session

String session

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

class uploadBlobChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.uploadChunk_args

class uploadChunk_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

chunk

ByteBuffer chunk

location

String location

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

class uploadChunk_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Nimbus.uploadNewCredentials_args

class uploadNewCredentials_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

creds

Credentials creds

name

String name

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

class uploadNewCredentials_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

ite

InvalidTopologyException ite

Class org.apache.storm.generated.NimbusSummary

class NimbusSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

host

String host

isLeader

boolean isLeader

port

int port

uptime_secs

int uptime_secs

version

String version

Class org.apache.storm.generated.NodeInfo

class NodeInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

node

String node

port

Set<Long> port

Exception org.apache.storm.generated.NotAliveException

class NotAliveException extends org.apache.storm.thrift.TException implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

msg

String msg

Class org.apache.storm.generated.NullStruct

class NullStruct extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.OwnerResourceSummary

class OwnerResourceSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

int __isset_bitfield

assigned_off_heap_memory

double assigned_off_heap_memory

assigned_on_heap_memory

double assigned_on_heap_memory

cpu_guarantee

double cpu_guarantee

cpu_guarantee_remaining

double cpu_guarantee_remaining

cpu_usage

double cpu_usage

isolated_node_guarantee

int isolated_node_guarantee

memory_guarantee

double memory_guarantee

memory_guarantee_remaining

double memory_guarantee_remaining

memory_usage

double memory_usage

owner

String owner

requested_cpu

double requested_cpu

requested_off_heap_memory

double requested_off_heap_memory

requested_on_heap_memory

double requested_on_heap_memory

requested_total_memory

double requested_total_memory

total_executors

int total_executors

total_tasks

int total_tasks

total_topologies

int total_topologies

total_workers

int total_workers

Class org.apache.storm.generated.PrivateWorkerKey

class PrivateWorkerKey extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

expirationTimeMillis

long expirationTimeMillis

key

ByteBuffer key

userName

String userName

Class org.apache.storm.generated.ProfileRequest

class ProfileRequest extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

action

ProfileAction action

nodeInfo

NodeInfo nodeInfo

time_stamp

long time_stamp

Class org.apache.storm.generated.ReadableBlobMeta

class ReadableBlobMeta extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

settable

SettableBlobMeta settable

version

long version

Class org.apache.storm.generated.RebalanceOptions

class RebalanceOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

num_executors

Map<String,Integer> num_executors

num_workers

int num_workers

principal

String principal

topology_conf_overrides

String topology_conf_overrides

topology_resources_overrides

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

wait_secs

int wait_secs

Class org.apache.storm.generated.SettableBlobMeta

class SettableBlobMeta extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

acl

List<AccessControl> acl

replication_factor

int replication_factor

Class org.apache.storm.generated.SharedMemory

class SharedMemory extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

name

String name

off_heap_node

double off_heap_node

off_heap_worker

double off_heap_worker

on_heap

double on_heap

Class org.apache.storm.generated.ShellComponent

class ShellComponent extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

execution_command

String execution_command

script

String script

Class org.apache.storm.generated.SpecificAggregateStats

class SpecificAggregateStats extends org.apache.storm.thrift.TUnion<SpecificAggregateStats,SpecificAggregateStats._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.SpoutAggregateStats

class SpoutAggregateStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

complete_latency_ms

double complete_latency_ms

Class org.apache.storm.generated.SpoutSpec

class SpoutSpec extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

common

ComponentCommon common

spout_object

ComponentObject spout_object

Class org.apache.storm.generated.SpoutStats

class SpoutStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

acked

Map<String,Map<String,Long>> acked

complete_ms_avg

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

failed

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

Class org.apache.storm.generated.StateSpoutSpec

class StateSpoutSpec extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

common

ComponentCommon common

state_spout_object

ComponentObject state_spout_object

Class org.apache.storm.generated.StormBase

class StormBase extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

component_debug

Map<String,DebugOptions> component_debug

component_executors

Map<String,Integer> component_executors

launch_time_secs

int launch_time_secs

name

String name

num_workers

int num_workers

owner

String owner

prev_status

TopologyStatus prev_status

principal

String principal

status

TopologyStatus status

topology_action_options

TopologyActionOptions topology_action_options

topology_version

String topology_version

Class org.apache.storm.generated.StormTopology

class StormTopology extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

bolts

Map<String,Bolt> bolts

component_to_shared_memory

Map<String,Set<String>> component_to_shared_memory

dependency_artifacts

List<String> dependency_artifacts

dependency_jars

List<String> dependency_jars

jdk_version

String jdk_version

shared_memory

Map<String,SharedMemory> shared_memory

spouts

Map<String,SpoutSpec> spouts

state_spouts

Map<String,StateSpoutSpec> state_spouts

storm_version

String storm_version

worker_hooks

List<ByteBuffer> worker_hooks

Class org.apache.storm.generated.StreamInfo

class StreamInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

direct

boolean direct

output_fields

List<String> output_fields

Class org.apache.storm.generated.SubmitOptions

class SubmitOptions extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

creds

Credentials creds

initial_status

TopologyInitialStatus initial_status

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

class getLocalAssignmentForStorm_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

id

String id

Class org.apache.storm.generated.Supervisor.getLocalAssignmentForStorm_result

class getLocalAssignmentForStorm_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

e

NotAliveException e

success

Assignment success

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

class sendSupervisorAssignments_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

assignments

SupervisorAssignments assignments

Class org.apache.storm.generated.Supervisor.sendSupervisorAssignments_result

class sendSupervisorAssignments_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_args

class sendSupervisorWorkerHeartbeat_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

heartbeat

SupervisorWorkerHeartbeat heartbeat

Class org.apache.storm.generated.Supervisor.sendSupervisorWorkerHeartbeat_result

class sendSupervisorWorkerHeartbeat_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

aze

AuthorizationException aze

Class org.apache.storm.generated.SupervisorAssignments

class SupervisorAssignments extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

storm_assignment

Map<String,Assignment> storm_assignment

Class org.apache.storm.generated.SupervisorInfo

class SupervisorInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

assignment_id

String assignment_id

hostname

String hostname

meta

List<Long> meta

resources_map

Map<String,Double> resources_map

scheduler_meta

Map<String,String> scheduler_meta

server_port

int server_port

time_secs

long time_secs

uptime_secs

long uptime_secs

used_ports

List<Long> used_ports

version

String version

Class org.apache.storm.generated.SupervisorPageInfo

class SupervisorPageInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

supervisor_summaries

List<SupervisorSummary> supervisor_summaries

worker_summaries

List<WorkerSummary> worker_summaries

Class org.apache.storm.generated.SupervisorSummary

class SupervisorSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

blacklisted

boolean blacklisted

fragmented_cpu

double fragmented_cpu

fragmented_mem

double fragmented_mem

host

String host

num_used_workers

int num_used_workers

num_workers

int num_workers

supervisor_id

String supervisor_id

total_resources

Map<String,Double> total_resources

uptime_secs

int uptime_secs

used_cpu

double used_cpu

used_generic_resources

Map<String,Double> used_generic_resources

used_mem

double used_mem

version

String version

Class org.apache.storm.generated.SupervisorWorkerHeartbeat

class SupervisorWorkerHeartbeat extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

executors

List<ExecutorInfo> executors

storm_id

String storm_id

time_secs

int time_secs

Class org.apache.storm.generated.SupervisorWorkerHeartbeats

class SupervisorWorkerHeartbeats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

supervisor_id

String supervisor_id

worker_heartbeats

List<SupervisorWorkerHeartbeat> worker_heartbeats

Class org.apache.storm.generated.ThriftSerializedObject

class ThriftSerializedObject extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

bits

ByteBuffer bits

name

String name

Class org.apache.storm.generated.TopologyActionOptions

class TopologyActionOptions extends org.apache.storm.thrift.TUnion<TopologyActionOptions,TopologyActionOptions._Fields> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class org.apache.storm.generated.TopologyHistoryInfo

class TopologyHistoryInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

topo_ids

List<String> topo_ids

Class org.apache.storm.generated.TopologyInfo

class TopologyInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

assigned_cpu

double assigned_cpu

assigned_memoffheap

double assigned_memoffheap

assigned_memonheap

double assigned_memonheap

component_debug

Map<String,DebugOptions> component_debug

errors

Map<String,List<ErrorInfo>> errors

executors

List<ExecutorSummary> executors

id

String id

name

String name

owner

String owner

replication_count

int replication_count

requested_cpu

double requested_cpu

requested_memoffheap

double requested_memoffheap

requested_memonheap

double requested_memonheap

sched_status

String sched_status

status

String status

storm_version

String storm_version

uptime_secs

int uptime_secs

Class org.apache.storm.generated.TopologyPageInfo

class TopologyPageInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

int __isset_bitfield

assigned_cpu

double assigned_cpu

assigned_generic_resources

Map<String,Double> assigned_generic_resources

assigned_memoffheap

double assigned_memoffheap

assigned_memonheap

double assigned_memonheap

assigned_regular_off_heap_memory

double assigned_regular_off_heap_memory

assigned_regular_on_heap_memory

double assigned_regular_on_heap_memory

assigned_shared_off_heap_memory

double assigned_shared_off_heap_memory

assigned_shared_on_heap_memory

double assigned_shared_on_heap_memory

debug_options

DebugOptions debug_options

id

String id

id_to_bolt_agg_stats

Map<String,ComponentAggregateStats> id_to_bolt_agg_stats

id_to_spout_agg_stats

Map<String,ComponentAggregateStats> id_to_spout_agg_stats

name

String name

num_executors

int num_executors

num_tasks

int num_tasks

num_workers

int num_workers

owner

String owner

replication_count

int replication_count

requested_cpu

double requested_cpu

requested_generic_resources

Map<String,Double> requested_generic_resources

requested_memoffheap

double requested_memoffheap

requested_memonheap

double requested_memonheap

requested_regular_off_heap_memory

double requested_regular_off_heap_memory

requested_regular_on_heap_memory

double requested_regular_on_heap_memory

requested_shared_off_heap_memory

double requested_shared_off_heap_memory

requested_shared_on_heap_memory

double requested_shared_on_heap_memory

sched_status

String sched_status

status

String status

storm_version

String storm_version

topology_conf

String topology_conf

topology_stats

TopologyStats topology_stats

topology_version

String topology_version

uptime_secs

int uptime_secs

workers

List<WorkerSummary> workers

Class org.apache.storm.generated.TopologyStats

class TopologyStats extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

window_to_acked

Map<String,Long> window_to_acked

window_to_complete_latencies_ms

Map<String,Double> window_to_complete_latencies_ms

window_to_emitted

Map<String,Long> window_to_emitted

window_to_failed

Map<String,Long> window_to_failed

window_to_transferred

Map<String,Long> window_to_transferred

Class org.apache.storm.generated.TopologySummary

class TopologySummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

short __isset_bitfield

assigned_cpu

double assigned_cpu

assigned_generic_resources

Map<String,Double> assigned_generic_resources

assigned_memoffheap

double assigned_memoffheap

assigned_memonheap

double assigned_memonheap

id

String id

name

String name

num_executors

int num_executors

num_tasks

int num_tasks

num_workers

int num_workers

owner

String owner

replication_count

int replication_count

requested_cpu

double requested_cpu

requested_generic_resources

Map<String,Double> requested_generic_resources

requested_memoffheap

double requested_memoffheap

requested_memonheap

double requested_memonheap

sched_status

String sched_status

status

String status

storm_version

String storm_version

topology_version

String topology_version

uptime_secs

int uptime_secs

Class org.apache.storm.generated.WorkerMetricList

class WorkerMetricList extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

metrics

List<WorkerMetricPoint> metrics

Class org.apache.storm.generated.WorkerMetricPoint

class WorkerMetricPoint extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

componentId

String componentId

executorId

String executorId

metricName

String metricName

metricValue

double metricValue

streamId

String streamId

timestamp

long timestamp

Class org.apache.storm.generated.WorkerMetrics

class WorkerMetrics extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

hostname

String hostname

metricList

WorkerMetricList metricList

port

int port

topologyId

String topologyId

Class org.apache.storm.generated.WorkerResources

class WorkerResources extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

cpu

double cpu

mem_off_heap

double mem_off_heap

mem_on_heap

double mem_on_heap

resources

Map<String,Double> resources

shared_mem_off_heap

double shared_mem_off_heap

shared_mem_on_heap

double shared_mem_on_heap

shared_resources

Map<String,Double> shared_resources

Class org.apache.storm.generated.WorkerSummary

class WorkerSummary extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

short __isset_bitfield

assigned_cpu

double assigned_cpu

assigned_memoffheap

double assigned_memoffheap

assigned_memonheap

double assigned_memonheap

component_to_num_tasks

Map<String,Long> component_to_num_tasks

host

String host

num_executors

int num_executors

owner

String owner

port

int port

requested_cpu

double requested_cpu

requested_memoffheap

double requested_memoffheap

requested_memonheap

double requested_memonheap

supervisor_id

String supervisor_id

time_secs

int time_secs

topology_id

String topology_id

topology_name

String topology_name

uptime_secs

int uptime_secs

Class org.apache.storm.generated.WorkerToken

class WorkerToken extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

info

ByteBuffer info

serviceType

WorkerTokenServiceType serviceType

signature

ByteBuffer signature

Class org.apache.storm.generated.WorkerTokenInfo

class WorkerTokenInfo extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

__isset_bitfield

byte __isset_bitfield

expirationTimeMillis

long expirationTimeMillis

secretVersion

long secretVersion

topologyId

String topologyId

userName

String userName

Package org.apache.storm.grouping

Class org.apache.storm.grouping.LoadAwareShuffleGrouping

class LoadAwareShuffleGrouping extends Object implements Serializable

Serialized Fields

capacity

int capacity

choices

int[] choices

conf

Map<String,Object> conf

current

AtomicInteger current

currentScope

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

dnsToSwitchMapping

DNSToSwitchMapping dnsToSwitchMapping

higherBound

double higherBound

localityGroup

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

lowerBound

double lowerBound

nodeToHost

AtomicReference<Map<String,String>> nodeToHost

orig

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

prepareChoices

int[] prepareChoices

random

Random random

rets

List<Integer>[] rets

sourceNodeInfo

NodeInfo sourceNodeInfo

targetTasks

List<Integer> targetTasks

taskToNodePort

AtomicReference<Map<Integer,NodeInfo>> taskToNodePort

Class org.apache.storm.grouping.PartialKeyGrouping

class PartialKeyGrouping extends Object implements Serializable

serialVersionUID:

-1672360572274911808L

Serialized Fields

assignmentCreator

PartialKeyGrouping.AssignmentCreator assignmentCreator

fields

Fields fields

outFields

Fields outFields

targetSelector

PartialKeyGrouping.TargetSelector targetSelector

targetTasks

List<Integer> targetTasks

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

class BalancedTargetSelector extends Object implements Serializable

Serialized Fields

targetTaskStats

Map<Integer,Long> targetTaskStats

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

class RandomTwoTaskAssignmentCreator extends Object implements Serializable

Class org.apache.storm.grouping.ShuffleGrouping

class ShuffleGrouping extends Object implements Serializable

Serialized Fields

choices

ArrayList<List<Integer>> choices

current

AtomicInteger current

Package org.apache.storm.hdfs.avro

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

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

Class org.apache.storm.hdfs.avro.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

Serialized Fields

fingerprint2schemaMap

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

schema2fingerprintMap

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

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

class GenericAvroSerializer extends AbstractAvroSerializer implements Serializable

Package org.apache.storm.hdfs.bolt

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

class AbstractHdfsBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

configKey

String configKey

fileNameFormat

FileNameFormat fileNameFormat

fileRetryCount

Integer fileRetryCount

fsUrl

String fsUrl

maxOpenFiles

Integer maxOpenFiles

offset

long offset

partitioner

Partitioner partitioner

rotationActions

List<RotationAction> rotationActions

rotationCounterMap

Map<String,Integer> rotationCounterMap

rotationPolicy

FileRotationPolicy rotationPolicy

syncPolicy

SyncPolicy syncPolicy

tickTupleInterval

Integer tickTupleInterval

tupleBatch

List<Tuple> tupleBatch

writers

Map<String,Writer> writers

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

class AvroGenericRecordBolt extends AbstractHdfsBolt implements Serializable

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

class HdfsBolt extends AbstractHdfsBolt implements Serializable

Serialized Fields

format

RecordFormat format

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

class MyBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

HashMap<String,Long> counts

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

class SentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

count

int count

index

int index

pending

ConcurrentHashMap<UUID,Values> pending

sentences

String[] sentences

total

long total

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

class SequenceFileBolt extends AbstractHdfsBolt implements Serializable

Serialized Fields

compressionCodec

String compressionCodec

compressionType

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

format

SequenceFormat format

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

class MyBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

HashMap<String,Long> counts

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

class SentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

count

int count

index

int index

pending

ConcurrentHashMap<UUID,Values> pending

sentences

String[] sentences

total

long total

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

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

class DefaultFileNameFormat extends Object implements Serializable

Serialized Fields

componentId

String componentId

extension

String extension

path

String path

prefix

String prefix

taskId

int taskId

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

class DefaultSequenceFormat extends Object implements Serializable

Serialized Fields

keyField

String keyField

valueField

String valueField

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

class DelimitedRecordFormat extends Object implements Serializable

Serialized Fields

fieldDelimiter

String fieldDelimiter

fields

Fields fields

recordDelimiter

String recordDelimiter

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

class SimpleFileNameFormat extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

componentId

String componentId

host

String host

name

String name

path

String path

taskId

int taskId

timeFormat

String timeFormat

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

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

class FileSizeRotationPolicy extends Object implements Serializable

Serialized Fields

currentBytesWritten

long currentBytesWritten

lastOffset

long lastOffset

maxBytes

long maxBytes

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

class NoRotationPolicy extends Object implements Serializable

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

class TimedRotationPolicy extends Object implements Se