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__534

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

Class org.apache.storm.config$fn__541

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

Class org.apache.storm.config$loading__6706__auto____532

class config$loading__6706__auto____532 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__454

class log$fn__454 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.log$loading__6706__auto____273

class log$loading__6706__auto____273 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.log$log_debug

class log$log_debug extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_error

class log$log_error extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_message

class log$log_message extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_warn

class log$log_warn extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$add_supervisor

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

Class org.apache.storm.testing$advance_cluster_time

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

Class org.apache.storm.testing$capture_topology

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

Class org.apache.storm.testing$complete_topology

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

Class org.apache.storm.testing$fn__288

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

Class org.apache.storm.testing$get_supervisor

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

Class org.apache.storm.testing$global_amt

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

Class org.apache.storm.testing$increment_global_BANG_

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

Class org.apache.storm.testing$kill_local_storm_cluster

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

Class org.apache.storm.testing$kill_supervisor

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

Class org.apache.storm.testing$loading__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__288

class thrift$fn__288 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__291

class thrift$instantiate_java_object$fn__291 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____286

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

Class org.apache.storm.thrift$loading__6706__auto____530

class thrift$loading__6706__auto____530 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__332__336

class thrift$mk_inputs$iter__332__336 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_inputs$iter__332__336$fn__337

class thrift$mk_inputs$iter__332__336$fn__337 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__332

Object iter__332

s__333

Object s__333

Class org.apache.storm.thrift$mk_inputs$iter__332__336$fn__337$fn__338

class thrift$mk_inputs$iter__332__336$fn__337$fn__338 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__335

Object b__335

c__6288__auto__

Object c__6288__auto__

size__6289__auto__

int size__6289__auto__

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__315

class thrift$mk_output_spec$fn__315 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__526

class util$__LT__GT_$fn__526 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__486

class util$clojurify_structure$fn__486 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__480

class util$defnk$fn__480 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__512

class util$filter_key$fn__512 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

Class org.apache.storm.util$fn__460

class util$fn__460 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____271

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

Class org.apache.storm.util$map_val

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

Class org.apache.storm.util$map_val$iter__490__494

class util$map_val$iter__490__494 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

Class org.apache.storm.util$map_val$iter__490__494$fn__495

class util$map_val$iter__490__494$fn__495 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

iter__490

Object iter__490

s__491

Object s__491

Class org.apache.storm.util$map_val$iter__490__494$fn__495$fn__496

class util$map_val$iter__490__494$fn__495$fn__496 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

b__493

Object b__493

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

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

maxRetryTimeoutMillis

Integer maxRetryTimeoutMillis

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 Serializable

Serialized Fields

interval

long interval

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

Class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy

class CountSyncPolicy extends Object implements Serializable

Serialized Fields

count

int count

executeCount

int executeCount

Package org.apache.storm.hdfs.common

Class org.apache.storm.hdfs.common.NullPartitioner

class NullPartitioner extends Object implements Serializable

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

Class org.apache.storm.hdfs.common.rotation.MoveFileAction

class MoveFileAction extends Object implements Serializable

Serialized Fields

destination

String destination

Package org.apache.storm.hdfs.spout

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

class HdfsSpout extends BaseRichSpout implements Serializable

Serialized Fields

ackEnabled

boolean ackEnabled

acksSinceLastCommit

int acksSinceLastCommit

archiveDir

String archiveDir

archiveDirPath

org.apache.hadoop.fs.Path archiveDirPath

badFilesDir

String badFilesDir

badFilesDirPath

org.apache.hadoop.fs.Path badFilesDirPath

clocksInSync

boolean clocksInSync

collector

SpoutOutputCollector collector

commitFrequencyCount

int commitFrequencyCount

commitFrequencySec

int commitFrequencySec

commitTimeElapsed

AtomicBoolean commitTimeElapsed

commitTimer

Timer commitTimer

conf

Map<String,Object> conf

configKey

String configKey

fileReadCompletely

boolean fileReadCompletely

hdfs

org.apache.hadoop.fs.FileSystem hdfs

hdfsConfig

org.apache.hadoop.conf.Configuration hdfsConfig

hdfsUri

String hdfsUri

ignoreSuffix

String ignoreSuffix

inflight

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

inprogressSuffix

String inprogressSuffix

lastExpiredLock

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

lastExpiredLockTime

long lastExpiredLockTime

lock

FileLock lock

lockDir

String lockDir

lockDirPath

org.apache.hadoop.fs.Path lockDirPath

lockTimeoutSec

int lockTimeoutSec

maxOutstanding

int maxOutstanding

outputFields

Fields outputFields

outputStreamName

String outputStreamName

reader

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

readerType

String readerType

retryList

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

sourceDir

String sourceDir

sourceDirPath

org.apache.hadoop.fs.Path sourceDirPath

spoutId

String spoutId

tracker

ProgressTracker tracker

tupleCounter

long tupleCounter

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

class ConstBolt extends BaseRichBolt implements Serializable

serialVersionUID:

-5313598399155365865L

Serialized Fields

collector

OutputCollector collector

count

int count

Exception org.apache.storm.hdfs.spout.ParseException

class ParseException extends Exception implements Serializable

Package org.apache.storm.hdfs.trident

Class org.apache.storm.hdfs.trident.FixedBatchSpout

class FixedBatchSpout extends Object implements Serializable

Serialized Fields

batches

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

cycle

boolean cycle

fields

Fields fields

index

int index

maxBatchSize

int maxBatchSize

outputs

List<Object>[] outputs

Class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions

class HdfsFileOptions extends HdfsState.Options implements Serializable

Serialized Fields

bufferSize

int bufferSize

format

RecordFormat format

offset

long offset

Class org.apache.storm.hdfs.trident.HdfsState.Options

class Options extends Object implements Serializable

Serialized Fields

configKey

String configKey

currentFile

org.apache.hadoop.fs.Path currentFile

fileNameFormat

FileNameFormat fileNameFormat

fsUrl

String fsUrl

rotation

int rotation

rotationActions

ArrayList<RotationAction> rotationActions

rotationPolicy

FileRotationPolicy rotationPolicy

Class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions

class SequenceFileOptions extends HdfsState.Options implements Serializable

Serialized Fields

compressionCodec

String compressionCodec

compressionType

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

format

SequenceFormat format

Class org.apache.storm.hdfs.trident.HdfsStateFactory

class HdfsStateFactory extends Object implements Serializable

Serialized Fields

options

HdfsState.Options options

Class org.apache.storm.hdfs.trident.HdfsUpdater

class HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable

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

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

class DefaultFileNameFormat extends Object implements Serializable

Serialized Fields

extension

String extension

partitionIndex

int partitionIndex

path

String path

prefix

String prefix

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

class DefaultSequenceFormat extends Object implements Serializable

Serialized Fields

keyField

String keyField

valueField

String valueField

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

class DelimitedRecordFormat extends Object implements Serializable

Serialized Fields

fieldDelimiter

String fieldDelimiter

fields

Fields fields

recordDelimiter

String recordDelimiter

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

class SimpleFileNameFormat extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

host

String host

name

String name

partitionIndex

int partitionIndex

path

String path

timeFormat

String timeFormat

Package org.apache.storm.hdfs.trident.rotation

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

class FileSizeRotationPolicy extends Object implements Serializable

Serialized Fields

currentBytesWritten

long currentBytesWritten

lastOffset

long lastOffset

maxBytes

long maxBytes

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

class NoRotationPolicy extends Object implements Serializable

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

class TimedRotationPolicy extends Object implements Serializable

Serialized Fields

interval

long interval

rotationTimer

Timer rotationTimer

rotationTimerTriggered

AtomicBoolean rotationTimerTriggered

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

Class org.apache.storm.hdfs.trident.sync.CountSyncPolicy

class CountSyncPolicy extends Object implements Serializable

Serialized Fields

count

int count

executeCount

int executeCount

Package org.apache.storm.hive.bolt

Class org.apache.storm.hive.bolt.BucketTestHiveTopology.UserDataSpout

class UserDataSpout extends BaseRichSpout implements Serializable

Serialized Fields

br

BufferedReader br

collector

SpoutOutputCollector collector

count

int count

filePath

String filePath

outputFields

String[] outputFields

pending

ConcurrentHashMap<UUID,Values> pending

total

long total

Class org.apache.storm.hive.bolt.HiveBolt

class HiveBolt extends BaseRichBolt implements Serializable

Serialized Fields

allWriters

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

batchHelper

BatchHelper batchHelper

callTimeoutPool

ExecutorService callTimeoutPool

collector

OutputCollector collector

options

HiveOptions options

sendHeartBeat

AtomicBoolean sendHeartBeat

tokenAuthEnabled

boolean tokenAuthEnabled

ugi

org.apache.hadoop.security.UserGroupInformation ugi

Class org.apache.storm.hive.bolt.HiveTopology.UserDataSpout

class UserDataSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

count

int count

index

int index

pending

ConcurrentHashMap<UUID,Values> pending

sentences

String[] sentences

total

long total

Class org.apache.storm.hive.bolt.HiveTopologyPartitioned.UserDataSpout

class UserDataSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

count

int count

index

int index

pending

ConcurrentHashMap<UUID,Values> pending

sentences

String[] sentences

total

long total

Package org.apache.storm.hive.bolt.mapper

Class org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper

class DelimitedRecordHiveMapper extends Object implements Serializable

Serialized Fields

columnFields

Fields columnFields

columnNames

String[] columnNames

fieldDelimiter

String fieldDelimiter

parseDate

SimpleDateFormat parseDate

partitionFields

Fields partitionFields

timeFormat

String timeFormat

Class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper

class JsonRecordHiveMapper extends Object implements Serializable

Serialized Fields

columnFields

Fields columnFields

parseDate

SimpleDateFormat parseDate

partitionFields

Fields partitionFields

timeFormat

String timeFormat

Package org.apache.storm.hive.common

Class org.apache.storm.hive.common.HiveOptions

class HiveOptions extends Object implements Serializable

Serialized Fields

autoCreatePartitions

Boolean autoCreatePartitions

batchSize

Integer batchSize

callTimeout

Integer callTimeout

databaseName

String databaseName

heartBeatInterval

Integer heartBeatInterval

idleTimeout

Integer idleTimeout

kerberosKeytab

String kerberosKeytab

kerberosPrincipal

String kerberosPrincipal

mapper

HiveMapper mapper

maxOpenConnections

Integer maxOpenConnections

metaStoreURI

String metaStoreURI

tableName

String tableName

tickTupleInterval

Integer tickTupleInterval

txnsPerBatch

Integer txnsPerBatch

Exception org.apache.storm.hive.common.HiveUtils.AuthenticationFailed

class AuthenticationFailed extends Exception implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.CommitFailure

class CommitFailure extends HiveWriter.Failure implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.ConnectFailure

class ConnectFailure extends HiveWriter.Failure implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.Failure

class Failure extends Exception implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.TxnBatchFailure

class TxnBatchFailure extends HiveWriter.Failure implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.TxnFailure

class TxnFailure extends HiveWriter.Failure implements Serializable

Exception org.apache.storm.hive.common.HiveWriter.WriteFailure

class WriteFailure extends HiveWriter.Failure implements Serializable

Package org.apache.storm.hive.trident

Class org.apache.storm.hive.trident.HiveStateFactory

class HiveStateFactory extends Object implements Serializable

Serialized Fields

options

HiveOptions options

Class org.apache.storm.hive.trident.HiveUpdater

class HiveUpdater extends BaseStateUpdater<HiveState> implements Serializable

Class org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout

class FixedBatchSpout extends Object implements Serializable

Serialized Fields

batches

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

cycle

boolean cycle

index

int index

maxBatchSize

int maxBatchSize

outputs

Values[] outputs

Package org.apache.storm.hooks

Class org.apache.storm.hooks.BaseWorkerHook

class BaseWorkerHook extends Object implements Serializable

serialVersionUID:

2589466485198339529L

Exception org.apache.storm.hooks.SubmitterHookException

class SubmitterHookException extends RuntimeException implements Serializable

Package org.apache.storm.jdbc.bolt

Class org.apache.storm.jdbc.bolt.AbstractJdbcBolt

class AbstractJdbcBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

configKey

String configKey

connectionProvider

ConnectionProvider connectionProvider

queryTimeoutSecs

Integer queryTimeoutSecs

Class org.apache.storm.jdbc.bolt.JdbcInsertBolt

class JdbcInsertBolt extends AbstractJdbcBolt implements Serializable

Serialized Fields

insertQuery

String insertQuery

jdbcMapper

JdbcMapper jdbcMapper

tableName

String tableName

Class org.apache.storm.jdbc.bolt.JdbcLookupBolt

class JdbcLookupBolt extends AbstractJdbcBolt implements Serializable

Serialized Fields

jdbcLookupMapper

JdbcLookupMapper jdbcLookupMapper

selectQuery

String selectQuery

Package org.apache.storm.jdbc.common

Class org.apache.storm.jdbc.common.Column

class Column extends Object implements Serializable

Serialized Fields

columnName

String columnName

sqlType

int sqlType

The sql type(e.g. varchar, date, int) Ideally we would have an enum but java's jdbc API uses integer. See Types

val

T val

Class org.apache.storm.jdbc.common.HikariCPConnectionProvider

class HikariCPConnectionProvider extends Object implements Serializable

Serialized Fields

configMap

Map<String,Object> configMap

Package org.apache.storm.jdbc.mapper

Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper

class SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable

Serialized Fields

outputFields

Fields outputFields

Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper

class SimpleJdbcMapper extends Object implements Serializable

Serialized Fields

schemaColumns

List<Column> schemaColumns

Package org.apache.storm.jdbc.spout

Class org.apache.storm.jdbc.spout.UserSpout

class UserSpout extends Object implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

isDistributed

boolean isDistributed

Package org.apache.storm.jdbc.trident.state

Class org.apache.storm.jdbc.trident.state.JdbcQuery

class JdbcQuery extends BaseQueryFunction<JdbcState,List<Values>> implements Serializable

Class org.apache.storm.jdbc.trident.state.JdbcState.Options

class Options extends Object implements Serializable

Serialized Fields

connectionProvider

ConnectionProvider connectionProvider

insertQuery

String insertQuery

jdbcLookupMapper

JdbcLookupMapper jdbcLookupMapper

mapper

JdbcMapper mapper

queryTimeoutSecs

Integer queryTimeoutSecs

selectQuery

String selectQuery

tableName

String tableName

Class org.apache.storm.jdbc.trident.state.JdbcStateFactory

class JdbcStateFactory extends Object implements Serializable

Serialized Fields

options

JdbcState.Options options

Class org.apache.storm.jdbc.trident.state.JdbcUpdater

class JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable

Package org.apache.storm.jms

Package org.apache.storm.jms.bolt

Class org.apache.storm.jms.bolt.JmsBolt

class JmsBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

autoAck

boolean autoAck

collector

OutputCollector collector

connection

javax.jms.Connection connection

jmsAcknowledgeMode

int jmsAcknowledgeMode

jmsProvider

JmsProvider jmsProvider

jmsTransactional

boolean jmsTransactional

messageProducer

javax.jms.MessageProducer messageProducer

producer

JmsMessageProducer producer

session

javax.jms.Session session

Package org.apache.storm.jms.example

Class org.apache.storm.jms.example.GenericBolt

class GenericBolt extends BaseRichBolt implements Serializable

Serialized Fields

autoAck

boolean autoAck

autoAnchor

boolean autoAnchor

collector

OutputCollector collector

declaredFields

Fields declaredFields

name

String name

Class org.apache.storm.jms.example.JsonTupleProducer

class JsonTupleProducer extends Object implements Serializable

Class org.apache.storm.jms.example.SpringJmsProvider

class SpringJmsProvider extends Object implements Serializable

Serialized Fields

connectionFactory

javax.jms.ConnectionFactory connectionFactory

destination

javax.jms.Destination destination

Package org.apache.storm.jms.spout

Class org.apache.storm.jms.spout.JmsMessageID

class JmsMessageID extends Object implements Serializable

Serialized Fields

jmsId

String jmsId

sequence

Long sequence

Class org.apache.storm.jms.spout.JmsSpout

class JmsSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

The collector used to emit tuples.

consumer

javax.jms.MessageConsumer consumer

The message consumer.

distributed

boolean distributed

Indicates whether or not this spout should run as a singleton.

individualAcks

boolean individualAcks

If JMS provider supports ack-ing individual messages.

jmsAcknowledgeMode

int jmsAcknowledgeMode

The acknowledgment mode used for this instance.

See Also:

• Session

jmsProvider

JmsProvider jmsProvider

Encapsulates jms related classes needed to communicate with the mq.

messageHandler

org.apache.storm.jms.spout.JmsSpout.MessageHandler messageHandler

Sets up the way we want to handle the emit, ack and fails.

messageSequence

long messageSequence

Counter of handled messages.

tupleProducer

JmsTupleProducer tupleProducer

Used to generate tuples from incoming messages.

Package org.apache.storm.jms.trident

Class org.apache.storm.jms.trident.JmsState.Options

class Options extends Object implements Serializable

Serialized Fields

jmsAcknowledgeMode

int jmsAcknowledgeMode

jmsProvider

JmsProvider jmsProvider

jmsTransactional

boolean jmsTransactional

msgProducer

JmsMessageProducer msgProducer

Class org.apache.storm.jms.trident.JmsStateFactory

class JmsStateFactory extends Object implements Serializable

Serialized Fields

options

JmsState.Options options

Class org.apache.storm.jms.trident.JmsUpdater

class JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable

Class org.apache.storm.jms.trident.TridentJmsSpout

class TridentJmsSpout extends Object implements Serializable

serialVersionUID:

-3469351154693356655L

Serialized Fields

jmsAcknowledgeMode

int jmsAcknowledgeMode

jmsProvider

JmsProvider jmsProvider

name

String name

tupleProducer

JmsTupleProducer tupleProducer

Package org.apache.storm.kafka.bolt

Class org.apache.storm.kafka.bolt.KafkaBolt

class KafkaBolt extends BaseTickTupleAwareRichBolt implements Serializable

serialVersionUID:

-5205886631877033478L

Serialized Fields

async

boolean async

KafkaBolt.setAsync(boolean) for more details on this.

boltSpecifiedProperties

Properties boltSpecifiedProperties

collector

OutputCollector collector

fireAndForget

boolean fireAndForget

KafkaBolt.setFireAndForget(boolean) for more details on this.

mapper

TupleToKafkaMapper<K,V> mapper

producer

org.apache.kafka.clients.producer.Producer<K,V> producer

providedCallback

PreparableCallback providedCallback

topicSelector

KafkaTopicSelector topicSelector

Package org.apache.storm.kafka.bolt.mapper

Class org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper

class FieldNameBasedTupleToKafkaMapper extends Object implements Serializable

serialVersionUID:

-8794262989021702349L

Serialized Fields

boltKeyField

String boltKeyField

boltMessageField

String boltMessageField

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

Class org.apache.storm.kafka.bolt.selector.DefaultTopicSelector

class DefaultTopicSelector extends Object implements Serializable

serialVersionUID:

4601118062437851265L

Serialized Fields

topicName

String topicName

Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector

class FieldIndexTopicSelector extends Object implements Serializable

serialVersionUID:

-3830575380208166367L

Serialized Fields

defaultTopicName

String defaultTopicName

fieldIndex

int fieldIndex

Class org.apache.storm.kafka.bolt.selector.FieldNameTopicSelector

class FieldNameTopicSelector extends Object implements Serializable

serialVersionUID:

-3903708904533396833L

Serialized Fields

defaultTopicName

String defaultTopicName

fieldName

String fieldName

Package org.apache.storm.kafka.spout

Class org.apache.storm.kafka.spout.ByTopicRecordTranslator

class ByTopicRecordTranslator extends Object implements Serializable

serialVersionUID:

-121699733778988688L

Serialized Fields

defaultTranslator

RecordTranslator<K,V> defaultTranslator

streamToFields

Map<String,Fields> streamToFields

topicToTranslator

Map<String,RecordTranslator<K,V>> topicToTranslator

Class org.apache.storm.kafka.spout.DefaultRecordTranslator

class DefaultRecordTranslator extends Object implements Serializable

serialVersionUID:

-5782462870112305750L

Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener

class EmptyKafkaTupleListener extends Object implements Serializable

Class org.apache.storm.kafka.spout.KafkaSpout

class KafkaSpout extends BaseRichSpout implements Serializable

serialVersionUID:

4151921085047987154L

Serialized Fields

collector

SpoutOutputCollector collector

kafkaConsumerFactory

ConsumerFactory<K,V> kafkaConsumerFactory

kafkaSpoutConfig

KafkaSpoutConfig<K,V> kafkaSpoutConfig

topicAssigner

TopicAssigner topicAssigner

Class org.apache.storm.kafka.spout.KafkaSpoutConfig

class KafkaSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable

serialVersionUID:

141902646130682494L

Serialized Fields

emitNullTuples

boolean emitNullTuples

maxUncommittedOffsets

int maxUncommittedOffsets

metricsTimeBucketSizeInSecs

int metricsTimeBucketSizeInSecs

offsetCommitPeriodMs

long offsetCommitPeriodMs

processingGuarantee

KafkaSpoutConfig.ProcessingGuarantee processingGuarantee

retryService

KafkaSpoutRetryService retryService

tupleListener

KafkaTupleListener tupleListener

tupleTrackingEnforced

boolean tupleTrackingEnforced

Class org.apache.storm.kafka.spout.KafkaSpoutMessageId

class KafkaSpoutMessageId extends Object implements Serializable

Serialized Fields

nullTuple

boolean nullTuple

false if the record was emitted using a form of collector.emit(...). true when skipping null tuples as configured by the user in KafkaSpoutConfig

numFails

int numFails

offset

long offset

topicPart

org.apache.kafka.common.TopicPartition topicPart

Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff

class KafkaSpoutRetryExponentialBackoff extends Object implements Serializable

Serialized Fields

delayPeriod

KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod

initialDelay

KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay

maxDelay

KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay

maxRetries

int maxRetries

retrySchedules

Set<org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.RetrySchedule> retrySchedules

toRetryMsgs

Set<KafkaSpoutMessageId> toRetryMsgs

Class org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval

class TimeInterval extends Object implements Serializable

Serialized Fields

length

long length

lengthNanos

long lengthNanos

timeUnit

TimeUnit timeUnit

Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt

class KafkaSpoutTestBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.kafka.spout.KafkaTuple

class KafkaTuple extends Values implements Serializable

serialVersionUID:

4803794470450587992L

Serialized Fields

stream

String stream

Class org.apache.storm.kafka.spout.SimpleRecordTranslator

class SimpleRecordTranslator extends Object implements Serializable

serialVersionUID:

4678369144122009596L

Serialized Fields

fields

Fields fields

func

Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func

stream

String stream

Package org.apache.storm.kafka.spout.internal

Class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig

class CommonKafkaSpoutConfig extends Object implements Serializable

Serialized Fields

firstPollOffsetStrategy

FirstPollOffsetStrategy firstPollOffsetStrategy

kafkaProps

Map<String,Object> kafkaProps

partitionRefreshPeriodMs

long partitionRefreshPeriodMs

pollTimeoutMs

long pollTimeoutMs

startTimeStamp

long startTimeStamp

topicFilter

TopicFilter topicFilter

topicPartitioner

ManualPartitioner topicPartitioner

translator

RecordTranslator<K,V> translator

Class org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault

class ConsumerFactoryDefault extends Object implements Serializable

Package org.apache.storm.kafka.spout.subscription

Class org.apache.storm.kafka.spout.subscription.NamedTopicFilter

class NamedTopicFilter extends Object implements Serializable

Serialized Fields

topics

Set<String> topics

Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter

class PatternTopicFilter extends Object implements Serializable

Serialized Fields

pattern

Pattern pattern

topics

Set<String> topics

Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner

class RoundRobinManualPartitioner extends Object implements Serializable

Class org.apache.storm.kafka.spout.subscription.TopicAssigner

class TopicAssigner extends Object implements Serializable

serialVersionUID:

5423018073527583826L

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

Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter

class KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

emitter

KafkaTridentSpoutEmitter<K,V> emitter

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata

class KafkaTridentSpoutBatchMetadata extends Object implements Serializable

Serialized Fields

firstOffset

long firstOffset

lastOffset

long lastOffset

topologyId

String topologyId

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig

class KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable

serialVersionUID:

1L

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator

class KafkaTridentSpoutCoordinator extends Object implements Serializable

Serialized Fields

consumer

org.apache.kafka.clients.consumer.Consumer<K,V> consumer

kafkaSpoutConfig

KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

partitionsForBatch

Set<org.apache.kafka.common.TopicPartition> partitionsForBatch

refreshAssignmentTimer

Timer refreshAssignmentTimer

tpSerializer

TopicPartitionSerializer tpSerializer

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutEmitter

class KafkaTridentSpoutEmitter extends Object implements Serializable

serialVersionUID:

-7343927794834130435L

Serialized Fields

consumer

org.apache.kafka.clients.consumer.Consumer<K,V> consumer

firstPollOffsetStrategy

FirstPollOffsetStrategy firstPollOffsetStrategy

kafkaSpoutConfig

KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

pollTimeoutMs

long pollTimeoutMs

startTimeStamp

long startTimeStamp

topicAssigner

TopicAssigner topicAssigner

topologyContext

TopologyContext topologyContext

tpSerializer

TopicPartitionSerializer tpSerializer

tpToFirstSeekOffset

Map<org.apache.kafka.common.TopicPartition,Long> tpToFirstSeekOffset

translator

RecordTranslator<K,V> translator

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutOpaque

class KafkaTridentSpoutOpaque extends Object implements Serializable

serialVersionUID:

-8003272486566259640L

Serialized Fields

kafkaSpoutConfig

KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

outputFieldsExtractor

OutputFieldsExtractor outputFieldsExtractor

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition

class KafkaTridentSpoutTopicPartition extends Object implements Serializable

Serialized Fields

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional

class KafkaTridentSpoutTransactional extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

kafkaSpoutConfig

KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

outputFieldsExtractor

OutputFieldsExtractor outputFieldsExtractor

Class org.apache.storm.kafka.spout.trident.KafkaTridentTransactionalSpoutEmitter

class KafkaTridentTransactionalSpoutEmitter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

emitter

KafkaTridentSpoutEmitter<K,V> emitter

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

Class org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor

class OutputFieldsExtractor extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.storm.kafka.trident

Class org.apache.storm.kafka.trident.TridentKafkaStateFactory

class TridentKafkaStateFactory extends Object implements Serializable

serialVersionUID:

-3613240970062343385L

Serialized Fields

mapper

TridentTupleToKafkaMapper<K,V> mapper

producerProperties

Properties producerProperties

topicSelector

KafkaTopicSelector topicSelector

Class org.apache.storm.kafka.trident.TridentKafkaStateUpdater

class TridentKafkaStateUpdater extends BaseStateUpdater<TridentKafkaState<K,V>> implements Serializable

serialVersionUID:

3352659585225274402L

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

Class org.apache.storm.kafka.trident.mapper.FieldNameBasedTupleToKafkaMapper

class FieldNameBasedTupleToKafkaMapper extends Object implements Serializable

Serialized Fields

keyFieldName

String keyFieldName

msgFieldName

String msgFieldName

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

Class org.apache.storm.kafka.trident.selector.DefaultTopicSelector

class DefaultTopicSelector extends Object implements Serializable

serialVersionUID:

-1172454882072591493L

Serialized Fields

topicName

String topicName

Package org.apache.storm.lambda

Class org.apache.storm.lambda.LambdaBiConsumerBolt

class LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable

Serialized Fields

biConsumer

SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer

fields

String[] fields

Class org.apache.storm.lambda.LambdaConsumerBolt

class LambdaConsumerBolt extends BaseBasicBolt implements Serializable

Serialized Fields

consumer

SerializableConsumer<Tuple> consumer

Class org.apache.storm.lambda.LambdaSpout

class LambdaSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

supplier

SerializableSupplier<?> supplier

Package org.apache.storm.loadgen

Class org.apache.storm.loadgen.ExecAndProcessLatencyEngine

class ExecAndProcessLatencyEngine extends Object implements Serializable

Serialized Fields

parkOffset

AtomicLong parkOffset

rand

Random rand

skewedPattern

SlowExecutorPattern skewedPattern

timer

ScheduledExecutorService timer

Class org.apache.storm.loadgen.InputStream

class InputStream extends Object implements Serializable

Serialized Fields

execTime

NormalDistStats execTime

fromComponent

String fromComponent

groupingType

GroupingType groupingType

gsid

GlobalStreamId gsid

id

String id

processTime

NormalDistStats processTime

toComponent

String toComponent

Class org.apache.storm.loadgen.LoadBolt

class LoadBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

executorIndex

int executorIndex

inputStreams

Map<GlobalStreamId,InputStream> inputStreams

outputStreams

List<OutputStreamEngine> outputStreams

outputStreamStats

List<OutputStream> outputStreamStats

sleep

ExecAndProcessLatencyEngine sleep

Class org.apache.storm.loadgen.LoadSpout

class LoadSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

nextStreamCounter

long nextStreamCounter

numStreams

int numStreams

replays

Queue<org.apache.storm.loadgen.LoadSpout.SentWithTime> replays

streams

List<org.apache.storm.loadgen.LoadSpout.OutputStreamEngineWithHisto> streams

streamStats

List<OutputStream> streamStats

Class org.apache.storm.loadgen.NormalDistStats

class NormalDistStats extends Object implements Serializable

Serialized Fields

max

double max

mean

double mean

min

double min

stddev

double stddev

Class org.apache.storm.loadgen.OutputStream

class OutputStream extends Object implements Serializable

Serialized Fields

areKeysSkewed

boolean areKeysSkewed

id

String id

rate

NormalDistStats rate

Class org.apache.storm.loadgen.ScopedTopologySet

class ScopedTopologySet extends HashSet<String> implements Serializable

Serialized Fields

client

Nimbus.Iface client

closed

boolean closed

Class org.apache.storm.loadgen.SlowExecutorPattern

class SlowExecutorPattern extends Object implements Serializable

Serialized Fields

count

int count

maxSlownessMs

double maxSlownessMs

Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout

class FastRandomSentenceSpout extends LoadSpout implements Serializable

Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence

class SplitSentence extends BaseBasicBolt implements Serializable

Serialized Fields

executorIndex

int executorIndex

sleep

ExecAndProcessLatencyEngine sleep

Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount

class WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Package org.apache.storm.metric

Class org.apache.storm.metric.EventLoggerBolt

class EventLoggerBolt extends Object implements Serializable

Serialized Fields

eventLoggers

List<IEventLogger> eventLoggers

Class org.apache.storm.metric.MetricsConsumerBolt

class MetricsConsumerBolt extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

consumerClassName

String consumerClassName

expander

DataPointExpander expander

filterPredicate

org.apache.storm.shade.com.google.common.base.Predicate<IMetricsConsumer.DataPoint> filterPredicate

maxRetainMetricTuples

int maxRetainMetricTuples

metricsConsumer

IMetricsConsumer metricsConsumer

registrationArgument

Object registrationArgument

running

boolean running

taskExecuteThread

Thread taskExecuteThread

taskQueue

BlockingQueue<org.apache.storm.metric.MetricsConsumerBolt.MetricsTask> taskQueue

Class org.apache.storm.metric.SystemBolt

class SystemBolt extends Object implements Serializable

Package org.apache.storm.metric.filter

Class org.apache.storm.metric.filter.FilterByMetricName

class FilterByMetricName extends Object implements Serializable

Serialized Fields

blacklistPattern

List<Pattern> blacklistPattern

filterCache

org.apache.storm.shade.com.google.common.cache.Cache<String,Boolean> filterCache

noneSpecified

boolean noneSpecified

whitelistPattern

List<Pattern> whitelistPattern

Package org.apache.storm.metric.util

Class org.apache.storm.metric.util.DataPointExpander

class DataPointExpander extends Object implements Serializable

Serialized Fields

expandMapType

boolean expandMapType

metricNameSeparator

String metricNameSeparator

Package org.apache.storm.metricstore

Exception org.apache.storm.metricstore.MetricException

class MetricException extends Exception implements Serializable

Package org.apache.storm.multilang

Class org.apache.storm.multilang.JsonSerializer

class JsonSerializer extends Object implements Serializable

serialVersionUID:

2548814660410474022L

Exception org.apache.storm.multilang.NoOutputException

class NoOutputException extends Exception implements Serializable

Package org.apache.storm.nimbus

Class org.apache.storm.nimbus.NimbusInfo

class NimbusInfo extends Object implements Serializable

serialVersionUID:

2161446155116099333L

Serialized Fields

host

String host

isLeader

boolean isLeader

port

int port

Package org.apache.storm.pacemaker

Exception org.apache.storm.pacemaker.PacemakerConnectionException

class PacemakerConnectionException extends Exception implements Serializable

Package org.apache.storm.perf

Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter

class LineWriter extends Object implements Serializable

Serialized Fields

fieldName

String fieldName

lineDelimiter

String lineDelimiter

Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.LineWriter

class LineWriter extends Object implements Serializable

serialVersionUID:

7524288317405514146L

Serialized Fields

fieldName

String fieldName

lineDelimiter

String lineDelimiter

Package org.apache.storm.perf.bolt

Class org.apache.storm.perf.bolt.CountBolt

class CountBolt extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.perf.bolt.DevNullBolt

class DevNullBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

sleepNanos

Long sleepNanos

Class org.apache.storm.perf.bolt.IdBolt

class IdBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.perf.bolt.SplitSentenceBolt

class SplitSentenceBolt extends BaseBasicBolt implements Serializable

Package org.apache.storm.perf.spout

Class org.apache.storm.perf.spout.ConstSpout

class ConstSpout extends BaseRichSpout implements Serializable

Serialized Fields

ackCount

int ackCount

collector

SpoutOutputCollector collector

count

int count

fieldName

String fieldName

sleep

Long sleep

value

String value

Class org.apache.storm.perf.spout.FileReadSpout

class FileReadSpout extends BaseRichSpout implements Serializable

serialVersionUID:

-2582705611472467172L

Serialized Fields

ackEnabled

boolean ackEnabled

collector

SpoutOutputCollector collector

count

long count

file

String file

Class org.apache.storm.perf.spout.FileReadSpout.FileReader

class FileReader extends Object implements Serializable

serialVersionUID:

-7012334600647556267L

Serialized Fields

contents

List<String> contents

file

String file

index

int index

limit

int limit

Class org.apache.storm.perf.spout.StringGenSpout

class StringGenSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

count

int count

curr

int curr

fieldName

String fieldName

records

ArrayList<String> records

strCount

int strCount

strLen

int strLen

Class org.apache.storm.perf.spout.WordGenSpout

class WordGenSpout extends BaseRichSpout implements Serializable

serialVersionUID:

-2582705611472467172L

Serialized Fields

ackEnabled

boolean ackEnabled

collector

SpoutOutputCollector collector

count

long count

emitMeter

ThroughputMeter emitMeter

file

String file

index

int index

words

ArrayList<String> words

Package org.apache.storm.perf.utils

Class org.apache.storm.perf.utils.IdentityBolt

class IdentityBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Package org.apache.storm.planner

Class org.apache.storm.planner.TaskBundle

class TaskBundle extends Object implements Serializable

Serialized Fields

componentId

int componentId

task

IBolt task

Package org.apache.storm.redis.bolt

Class org.apache.storm.redis.bolt.AbstractRedisBolt

class AbstractRedisBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

jedisClusterConfig

JedisClusterConfig jedisClusterConfig

jedisPoolConfig

JedisPoolConfig jedisPoolConfig

Class org.apache.storm.redis.bolt.RedisFilterBolt

class RedisFilterBolt extends AbstractRedisBolt implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

filterMapper

RedisFilterMapper filterMapper

Class org.apache.storm.redis.bolt.RedisLookupBolt

class RedisLookupBolt extends AbstractRedisBolt implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

lookupMapper

RedisLookupMapper lookupMapper

Class org.apache.storm.redis.bolt.RedisStoreBolt

class RedisStoreBolt extends AbstractRedisBolt implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

storeMapper

RedisStoreMapper storeMapper

Package org.apache.storm.redis.common.config

Class org.apache.storm.redis.common.config.JedisClusterConfig

class JedisClusterConfig extends Object implements Serializable

Serialized Fields

maxRedirections

int maxRedirections

nodes

Set<InetSocketAddress> nodes

password

String password

timeout

int timeout

Class org.apache.storm.redis.common.config.JedisPoolConfig

class JedisPoolConfig extends Object implements Serializable

Serialized Fields

database

int database

host

String host

password

String password

port

int port

timeout

int timeout

Package org.apache.storm.redis.common.mapper

Class org.apache.storm.redis.common.mapper.RedisDataTypeDescription

class RedisDataTypeDescription extends Object implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

Package org.apache.storm.redis.topology

Class org.apache.storm.redis.topology.LookupWordCount.PrintWordTotalCountBolt

class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt

class PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.redis.topology.WordCounter

class WordCounter extends Object implements Serializable

Serialized Fields

wordCounter

Map<String,Integer> wordCounter

Class org.apache.storm.redis.topology.WordSpout

class WordSpout extends Object implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

isDistributed

boolean isDistributed

Package org.apache.storm.redis.trident

Class org.apache.storm.redis.trident.PrintFunction

class PrintFunction extends BaseFunction implements Serializable

Class org.apache.storm.redis.trident.WordCountLookupMapper

class WordCountLookupMapper extends Object implements Serializable

Class org.apache.storm.redis.trident.WordCountStoreMapper

class WordCountStoreMapper extends Object implements Serializable

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

Class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier

class AbstractRedisStateQuerier extends BaseQueryFunction<T extends State,List<Values>> implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

lookupMapper

RedisLookupMapper lookupMapper

Class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

class AbstractRedisStateUpdater extends BaseStateUpdater<T extends State> implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

expireIntervalSec

int expireIntervalSec

storeMapper

RedisStoreMapper storeMapper

Class org.apache.storm.redis.trident.state.KeyFactory.DefaultKeyFactory

class DefaultKeyFactory extends Object implements Serializable

Class org.apache.storm.redis.trident.state.Options

class Options extends Object implements Serializable

Serialized Fields

dataTypeDescription

RedisDataTypeDescription dataTypeDescription

expireIntervalSec

int expireIntervalSec

globalKey

String globalKey

keyFactory

KeyFactory keyFactory

localCacheSize

int localCacheSize

serializer

Serializer<T> serializer

Class org.apache.storm.redis.trident.state.RedisClusterMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

jedisClusterConfig

JedisClusterConfig jedisClusterConfig

keyFactory

KeyFactory keyFactory

options

Options options

serializer

Serializer serializer

type

StateType type

Class org.apache.storm.redis.trident.state.RedisClusterState.Factory

class Factory extends Object implements Serializable

Serialized Fields

jedisClusterConfig

JedisClusterConfig jedisClusterConfig

Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier

class RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater

class RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

jedisPoolConfig

JedisPoolConfig jedisPoolConfig

keyFactory

KeyFactory keyFactory

options

Options options

serializer

Serializer serializer

type

StateType type

Class org.apache.storm.redis.trident.state.RedisState.Factory

class Factory extends Object implements Serializable

Serialized Fields

jedisPoolConfig

JedisPoolConfig jedisPoolConfig

Class org.apache.storm.redis.trident.state.RedisStateQuerier

class RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisStateUpdater

class RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable

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

Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider

class SecurityProvider extends Provider implements Serializable

Package org.apache.storm.shade.org.apache.zookeeper

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException

class KeeperException extends Exception implements Serializable

Serialized Fields

code

org.apache.storm.shade.org.apache.zookeeper.KeeperException.Code code

path

String path

results

List<org.apache.storm.shade.org.apache.zookeeper.OpResult> results

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.APIErrorException

class APIErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.AuthFailedException

class AuthFailedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadArgumentsException

class BadArgumentsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.BadVersionException

class BadVersionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ConnectionLossException

class ConnectionLossException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.DataInconsistencyException

class DataInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.EphemeralOnLocalSessionException

class EphemeralOnLocalSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidACLException

class InvalidACLException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.InvalidCallbackException

class InvalidCallbackException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.MarshallingErrorException

class MarshallingErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NewConfigNoQuorum

class NewConfigNoQuorum extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoAuthException

class NoAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoChildrenForEphemeralsException

class NoChildrenForEphemeralsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NodeExistsException

class NodeExistsException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoNodeException

class NoNodeException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotEmptyException

class NotEmptyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NotReadOnlyException

class NotReadOnlyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.NoWatcherException

class NoWatcherException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.OperationTimeoutException

class OperationTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.QuotaExceededException

class QuotaExceededException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigDisabledException

class ReconfigDisabledException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ReconfigInProgress

class ReconfigInProgress extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RequestTimeoutException

class RequestTimeoutException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.RuntimeInconsistencyException

class RuntimeInconsistencyException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionClosedRequireAuthException

class SessionClosedRequireAuthException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionExpiredException

class SessionExpiredException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SessionMovedException

class SessionMovedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.SystemErrorException

class SystemErrorException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.ThrottledOpException

class ThrottledOpException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnimplementedException

class UnimplementedException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.KeeperException.UnknownSessionException

class UnknownSessionException extends org.apache.storm.shade.org.apache.zookeeper.KeeperException implements Serializable

Exception org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException

class ExitCodeException extends IOException implements Serializable

Serialized Fields

exitCode

int exitCode

Package org.apache.storm.spout

Class org.apache.storm.spout.CheckpointSpout

class CheckpointSpout extends BaseRichSpout implements Serializable

Serialized Fields

checkpointInterval

int checkpointInterval

checkpointState

KeyValueState<String,CheckPointState> checkpointState

checkpointStepInProgress

boolean checkpointStepInProgress

collector

SpoutOutputCollector collector

context

TopologyContext context

curTxState

CheckPointState curTxState

lastCheckpointTs

long lastCheckpointTs

recovering

boolean recovering

recoveryStepInProgress

boolean recoveryStepInProgress

sleepInterval

int sleepInterval

Class org.apache.storm.spout.RawMultiScheme

class RawMultiScheme extends Object implements Serializable

Class org.apache.storm.spout.RawScheme

class RawScheme extends Object implements Serializable

Class org.apache.storm.spout.SchemeAsMultiScheme

class SchemeAsMultiScheme extends Object implements Serializable

Serialized Fields

scheme

Scheme scheme

Class org.apache.storm.spout.ShellSpout

class ShellSpout extends Object implements Serializable

serialVersionUID:

5982357019665454L

Serialized Fields

changeDirectory

boolean changeDirectory

collector

SpoutOutputCollector collector

command

String[] command

context

TopologyContext context

env

Map<String,String> env

exception

RuntimeException exception

heartBeatExecutorService

ScheduledExecutorService heartBeatExecutorService

lastHeartbeatTimestamp

AtomicLong lastHeartbeatTimestamp

logHandler

ShellLogHandler logHandler

process

ShellProcess process

running

boolean running

spoutMsg

SpoutMsg spoutMsg

waitingOnSubprocess

AtomicBoolean waitingOnSubprocess

workerTimeoutMills

int workerTimeoutMills

Package org.apache.storm.sql.javac

Exception org.apache.storm.sql.javac.CompilingClassLoader.CompilerException

class CompilerException extends Exception implements Serializable

serialVersionUID:

-2936958840023603270L

Package org.apache.storm.sql.kafka

Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter

class RecordTranslatorSchemeAdapter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

delegate

Scheme delegate

Package org.apache.storm.sql.parser.impl

Exception org.apache.storm.sql.parser.impl.ParseException

class ParseException extends Exception implements Serializable

serialVersionUID:

1L

Serialized Fields

currentToken

Token currentToken

This is the last token that has been consumed successfully. If this object has been created due to a parse error, the token following this token will (therefore) be the first error token.

expectedTokenSequences

int[][] expectedTokenSequences

Each entry in this array is an array of integers. Each array of integers represents a sequence of tokens (by their ordinal values) that is expected at this point of the parse.

tokenImage

String[] tokenImage

This is a reference to the "tokenImage" array of the generated parser within which the parse error occurred. This array is defined in the generated ...Constants interface.

Class org.apache.storm.sql.parser.impl.Token

class Token extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

beginColumn

int beginColumn

The column number of the first character of this Token.

beginLine

int beginLine

The line number of the first character of this Token.

endColumn

int endColumn

The column number of the last character of this Token.

endLine

int endLine

The line number of the last character of this Token.

image

String image

The string image of the token.

kind

int kind

An integer that describes the kind of this token. This numbering system is determined by JavaCCParser, and a table of these numbers is stored in the file ...Constants.java.

next

Token next

A reference to the next regular (non-special) token from the input stream. If this is the last token from the input stream, or if the token manager has not read tokens beyond this one, this field is set to null. This is true only if this token is also a regular token. Otherwise, see below for a description of the contents of this field.

specialToken

Token specialToken

This field is used to access special tokens that occur prior to this token, but after the immediately preceding regular (non-special) token. If there are no such special tokens, this field is set to null. When there are more than one such special token, this field refers to the last of these special tokens, which in turn refers to the next previous special token through its specialToken field, and so on until the first special token (whose specialToken field is null). The next fields of special tokens refer to other special tokens that immediately follow it (without an intervening regular token). If there is no such token, this field is null.

Error org.apache.storm.sql.parser.impl.TokenMgrError

class TokenMgrError extends Error implements Serializable

serialVersionUID:

1L

Serialized Fields

errorCode

int errorCode

Indicates the reason why the exception is thrown. It will have one of the above 4 values.

Package org.apache.storm.sql.runtime

Class org.apache.storm.sql.runtime.FieldInfo

class FieldInfo extends Object implements Serializable

Serialized Fields

isPrimary

boolean isPrimary

name

String name

type

Class<?> type

Package org.apache.storm.sql.runtime.calcite

Class org.apache.storm.sql.runtime.calcite.DebuggableExecutableExpression

class DebuggableExecutableExpression extends Object implements Serializable

Serialized Fields

delegate

ExecutableExpression delegate

delegateCode

String delegateCode

Class org.apache.storm.sql.runtime.calcite.StormDataContext

class StormDataContext extends Object implements Serializable

Serialized Fields

map

com.google.common.collect.ImmutableMap<Object,Object> map

Package org.apache.storm.sql.runtime.datasource.socket.bolt

Class org.apache.storm.sql.runtime.datasource.socket.bolt.SocketBolt

class SocketBolt extends BaseRichBolt implements Serializable

Serialized Fields

host

String host

port

int port

serializer

IOutputSerializer serializer

Package org.apache.storm.sql.runtime.datasource.socket.spout

Class org.apache.storm.sql.runtime.datasource.socket.spout.SocketSpout

class SocketSpout extends Object implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

emitted

Map<String,List<Object>> emitted

host

String host

in

BufferedReader in

objectMapper

com.fasterxml.jackson.databind.ObjectMapper objectMapper

port

int port

queue

BlockingDeque<List<Object>> queue

readerThread

Thread readerThread

running

boolean running

scheme

Scheme scheme

socket

Socket socket

Package org.apache.storm.sql.runtime.serde.avro

Class org.apache.storm.sql.runtime.serde.avro.AvroScheme

class AvroScheme extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

schemas

CachedSchemas schemas

schemaString

String schemaString

Class org.apache.storm.sql.runtime.serde.avro.AvroSerializer

class AvroSerializer extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

schemas

CachedSchemas schemas

schemaString

String schemaString

Class org.apache.storm.sql.runtime.serde.avro.CachedSchemas

class CachedSchemas extends Object implements Serializable

Serialized Fields

cache

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

Package org.apache.storm.sql.runtime.serde.csv

Class org.apache.storm.sql.runtime.serde.csv.CsvScheme

class CsvScheme extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

Class org.apache.storm.sql.runtime.serde.csv.CsvSerializer

class CsvSerializer extends Object implements Serializable

Serialized Fields

fields

List<String> fields

Package org.apache.storm.sql.runtime.serde.json

Class org.apache.storm.sql.runtime.serde.json.JsonScheme

class JsonScheme extends Object implements Serializable

Serialized Fields

fields

List<String> fields

Class org.apache.storm.sql.runtime.serde.json.JsonSerializer

class JsonSerializer extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

jsonFactory

com.fasterxml.jackson.core.JsonFactory jsonFactory

Package org.apache.storm.sql.runtime.serde.tsv

Class org.apache.storm.sql.runtime.serde.tsv.TsvScheme

class TsvScheme extends Object implements Serializable

Serialized Fields

delimiter

char delimiter

fieldNames

List<String> fieldNames

Class org.apache.storm.sql.runtime.serde.tsv.TsvSerializer

class TsvSerializer extends Object implements Serializable

Serialized Fields

delimiter

char delimiter

fields

List<String> fields

Package org.apache.storm.sql.runtime.streams.functions

Class org.apache.storm.sql.runtime.streams.functions.EvaluationCalc

class EvaluationCalc extends Object implements Serializable

Serialized Fields

dataContext

org.apache.calcite.DataContext dataContext

filterInstance

ExecutableExpression filterInstance

outputValues

Object[] outputValues

projectionInstance

ExecutableExpression projectionInstance

Class org.apache.storm.sql.runtime.streams.functions.EvaluationFilter

class EvaluationFilter extends Object implements Serializable

Serialized Fields

dataContext

org.apache.calcite.DataContext dataContext

filterInstance

ExecutableExpression filterInstance

outputValues

Object[] outputValues

Class org.apache.storm.sql.runtime.streams.functions.EvaluationFunction

class EvaluationFunction extends Object implements Serializable

Serialized Fields

dataContext

org.apache.calcite.DataContext dataContext

outputValues

Object[] outputValues

projectionInstance

ExecutableExpression projectionInstance

Class org.apache.storm.sql.runtime.streams.functions.StreamInsertMapToPairFunction

class StreamInsertMapToPairFunction extends Object implements Serializable

Serialized Fields

primaryKeyIndex

int primaryKeyIndex

Class org.apache.storm.sql.runtime.streams.functions.StreamsScanTupleValueMapper

class StreamsScanTupleValueMapper extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

Package org.apache.storm.st.topology.window

Class org.apache.storm.st.topology.window.IncrementingSpout

class IncrementingSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

componentId

String componentId

currentNum

int currentNum

Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout

class TimeDataIncrementingSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

componentId

String componentId

currentNum

int currentNum

Class org.apache.storm.st.topology.window.TimeDataVerificationBolt

class TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

componentId

String componentId

Class org.apache.storm.st.topology.window.VerificationBolt

class VerificationBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

componentId

String componentId

Package org.apache.storm.starter

Class org.apache.storm.starter.AnchoredWordCount.RandomSentenceSpout

class RandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

random

Random random

Class org.apache.storm.starter.AnchoredWordCount.SplitSentence

class SplitSentence extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.AnchoredWordCount.WordCount

class WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt

class ExclaimBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords

class FilterWords extends BaseBasicBolt implements Serializable

Serialized Fields

poll

boolean poll

pollTime

long pollTime

wordSet

Set<String> wordSet

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout

class RandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence

class SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt

class ExclamationBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout

class FastRandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

rand

Random rand

Class org.apache.storm.starter.FastWordCountTopology.SplitSentence

class SplitSentence extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.FastWordCountTopology.WordCount

class WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.starter.InOrderDeliveryTest.Check

class Check extends BaseBasicBolt implements Serializable

Serialized Fields

expected

Map<Integer,Integer> expected

Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout

class InOrderSpout extends BaseRichSpout implements Serializable

Serialized Fields

base

int base

collector

SpoutOutputCollector collector

count

int count

Class org.apache.storm.starter.ManualDRPC.ExclamationBolt

class ExclamationBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.MultipleLoggerTopology.ExclamationLoggingBolt

class ExclamationLoggingBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

logger

org.slf4j.Logger logger

rootLogger

org.slf4j.Logger rootLogger

subLogger

org.slf4j.Logger subLogger

Class org.apache.storm.starter.MultiThreadWordCountTopology.MultiThreadedSplitSentence

class MultiThreadedSplitSentence extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

executor

ExecutorService executor

Class org.apache.storm.starter.ReachTopology.CountAggregator

class CountAggregator extends BaseBatchBolt<Object> implements Serializable

Serialized Fields

collector

BatchOutputCollector collector

count

int count

id

Object id

Class org.apache.storm.starter.ReachTopology.GetFollowers

class GetFollowers extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.ReachTopology.GetTweeters

class GetTweeters extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.ReachTopology.PartialUniquer

class PartialUniquer extends BaseBatchBolt<Object> implements Serializable

Serialized Fields

collector

BatchOutputCollector collector

followers

Set<String> followers

id

Object id

Class org.apache.storm.starter.ResourceAwareExampleTopology.ExclamationBolt

class ExclamationBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.starter.StatefulTopology.PrinterBolt

class PrinterBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.WordCountTopology.SplitSentence

class SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence

class RandomSentence extends ShellSpout implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence

class SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.WordCount

class WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Package org.apache.storm.starter.bolt

Class org.apache.storm.starter.bolt.AbstractRankerBolt

class AbstractRankerBolt extends BaseBasicBolt implements Serializable

serialVersionUID:

4931640198501530202L

Serialized Fields

count

int count

emitFrequencyInSeconds

int emitFrequencyInSeconds

rankings

Rankings rankings

Class org.apache.storm.starter.bolt.IntermediateRankingsBolt

class IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable

serialVersionUID:

-1369800530256637409L

Class org.apache.storm.starter.bolt.PrinterBolt

class PrinterBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.bolt.RollingCountAggBolt

class RollingCountAggBolt extends BaseRichBolt implements Serializable

serialVersionUID:

5537727428628598519L

Serialized Fields

collector

OutputCollector collector

counts

Map<Object,Map<Integer,Long>> counts

Class org.apache.storm.starter.bolt.RollingCountBolt

class RollingCountBolt extends BaseRichBolt implements Serializable

serialVersionUID:

5537727428628598519L

Serialized Fields

collector

OutputCollector collector

counter

SlidingWindowCounter<Object> counter

emitFrequencyInSeconds

int emitFrequencyInSeconds

lastModifiedTracker

NthLastModifiedTimeTracker lastModifiedTracker

windowLengthInSeconds

int windowLengthInSeconds

Class org.apache.storm.starter.bolt.SingleJoinBolt

class SingleJoinBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

fieldLocations

Map<String,GlobalStreamId> fieldLocations

idFields

Fields idFields

numSources

int numSources

outFields

Fields outFields

pending

TimeCacheMap<List<Object>,Map<GlobalStreamId,Tuple>> pending

Class org.apache.storm.starter.bolt.SlidingWindowSumBolt

class SlidingWindowSumBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

sum

int sum

Class org.apache.storm.starter.bolt.TotalRankingsBolt

class TotalRankingsBolt extends AbstractRankerBolt implements Serializable

serialVersionUID:

-8447525895532302198L

Class org.apache.storm.starter.bolt.WordCountBolt

class WordCountBolt extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Package org.apache.storm.starter.spout

Class org.apache.storm.starter.spout.RandomIntegerSpout

class RandomIntegerSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

msgId

long msgId

rand

Random rand

Class org.apache.storm.starter.spout.RandomNumberGeneratorSpout

class RandomNumberGeneratorSpout extends Object implements Serializable

Serialized Fields

batches

Map<Long,List<List<Object>>> batches

batchSize

int batchSize

fields

Fields fields

maxNumber

int maxNumber

Class org.apache.storm.starter.spout.RandomSentenceSpout

class RandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

rand

Random rand

Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped

class TimeStamped extends RandomSentenceSpout implements Serializable

Serialized Fields

prefix

String prefix

Package org.apache.storm.starter.tools

Class org.apache.storm.starter.tools.RankableObjectWithFields

class RankableObjectWithFields extends Object implements Serializable

serialVersionUID:

-9102878650001058090L

Serialized Fields

count

long count

fields

com.google.common.collect.ImmutableList<Object> fields

obj

Object obj

Class org.apache.storm.starter.tools.Rankings

class Rankings extends Object implements Serializable

serialVersionUID:

-1549827195410578903L

Serialized Fields

maxSize

int maxSize

rankedItems

List<Rankable> rankedItems

Class org.apache.storm.starter.tools.SlidingWindowCounter

class SlidingWindowCounter extends Object implements Serializable

serialVersionUID:

-2645063988768785810L

Serialized Fields

headSlot

int headSlot

objCounter

SlotBasedCounter<T> objCounter

tailSlot

int tailSlot

windowLengthInSlots

int windowLengthInSlots

Class org.apache.storm.starter.tools.SlotBasedCounter

class SlotBasedCounter extends Object implements Serializable

serialVersionUID:

4858185737378394432L

Serialized Fields

numSlots

int numSlots

objToCounts

Map<T,long[]> objToCounts

Package org.apache.storm.starter.trident

Class org.apache.storm.starter.trident.DebugMemoryMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.starter.trident.TridentReach.ExpandList

class ExpandList extends BaseFunction implements Serializable

Class org.apache.storm.starter.trident.TridentReach.One

class One extends Object implements Serializable

Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

map

Map map

Class org.apache.storm.starter.trident.TridentWordCount.Split

class Split extends BaseFunction implements Serializable

Package org.apache.storm.state

Class org.apache.storm.state.DefaultStateSerializer

class DefaultStateSerializer extends Object implements Serializable

Serialized Fields

context

TopologyContext context

kryo

ThreadLocal<com.esotericsoftware.kryo.Kryo> kryo

output

ThreadLocal<com.esotericsoftware.kryo.io.Output> output

registrations

List<String> registrations

topoConf

Map<String,Object> topoConf

Package org.apache.storm.streams

Class org.apache.storm.streams.Pair

class Pair extends Object implements Serializable

Serialized Fields

value1

T1 value1

The first value.

value2

T2 value2

The second value.

Class org.apache.storm.streams.ProcessorNode

class ProcessorNode extends org.apache.storm.streams.Node implements Serializable

Serialized Fields

isBatch

boolean isBatch

preservesKey

boolean preservesKey

processor

Processor<?> processor

windowedParentStreams

Set<String> windowedParentStreams

Class org.apache.storm.streams.StreamState

class StreamState extends Object implements Serializable

Class org.apache.storm.streams.WindowNode

class WindowNode extends org.apache.storm.streams.Node implements Serializable

Serialized Fields

windowParams

Window<?,?> windowParams

Package org.apache.storm.streams.operations

Class org.apache.storm.streams.operations.IdentityFunction

class IdentityFunction extends Object implements Serializable

Class org.apache.storm.streams.operations.PairValueJoiner

class PairValueJoiner extends Object implements Serializable

Class org.apache.storm.streams.operations.PrintConsumer

class PrintConsumer extends Object implements Serializable

Package org.apache.storm.streams.operations.aggregators

Class org.apache.storm.streams.operations.aggregators.Count

class Count extends Object implements Serializable

Class org.apache.storm.streams.operations.aggregators.LongSum

class LongSum extends Object implements Serializable

Package org.apache.storm.streams.operations.mappers

Class org.apache.storm.streams.operations.mappers.PairValueMapper

class PairValueMapper extends Object implements Serializable

Serialized Fields

keyIndex

int keyIndex

valueIndex

int valueIndex

Class org.apache.storm.streams.operations.mappers.ValueMapper

class ValueMapper extends Object implements Serializable

Serialized Fields

index

int index

Class org.apache.storm.streams.operations.mappers.ValuesMapper

class ValuesMapper extends Object implements Serializable

Serialized Fields

indices

int[] indices

Package org.apache.storm.streams.processors

Class org.apache.storm.streams.processors.AggregateByKeyProcessor

class AggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

Serialized Fields

aggregator

CombinerAggregator<V,A,R> aggregator

emitAggregate

boolean emitAggregate

state

Map<K,A> state

Class org.apache.storm.streams.processors.AggregateProcessor

class AggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

aggregator

CombinerAggregator<T,A,R> aggregator

emitAggregate

boolean emitAggregate

state

A state

Class org.apache.storm.streams.processors.BranchProcessor

class BranchProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

predicateToStream

Map<Predicate<? super T>,String> predicateToStream

Class org.apache.storm.streams.processors.ChainedProcessorContext

class ChainedProcessorContext extends Object implements Serializable

Serialized Fields

contexts

List<? extends ProcessorContext> contexts

processorNode

ProcessorNode processorNode

Class org.apache.storm.streams.processors.CoGroupByKeyProcessor

class CoGroupByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable

Serialized Fields

firstMap

org.apache.storm.shade.com.google.common.collect.Multimap<K,V1> firstMap

firstStream

String firstStream

secondMap

org.apache.storm.shade.com.google.common.collect.Multimap<K,V2> secondMap

secondStream

String secondStream

Class org.apache.storm.streams.processors.EmittingProcessorContext

class EmittingProcessorContext extends Object implements Serializable

Serialized Fields

anchors

List<RefCountedTuple> anchors

collector

OutputCollector collector

eventTimestamp

long eventTimestamp

outputFields

Fields outputFields

outputStreamId

String outputStreamId

processorNode

ProcessorNode processorNode

punctuation

Values punctuation

punctuationStreamId

String punctuationStreamId

timestampField

String timestampField

Class org.apache.storm.streams.processors.FilterProcessor

class FilterProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

predicate

Predicate<T> predicate

Class org.apache.storm.streams.processors.FlatMapProcessor

class FlatMapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

function

FlatMapFunction<T,R> function

Class org.apache.storm.streams.processors.FlatMapValuesProcessor

class FlatMapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

Serialized Fields

function

FlatMapFunction<V,R> function

Class org.apache.storm.streams.processors.ForEachProcessor

class ForEachProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

consumer

Consumer<T> consumer

Class org.apache.storm.streams.processors.ForwardingProcessorContext

class ForwardingProcessorContext extends Object implements Serializable

Serialized Fields

processorNode

ProcessorNode processorNode

streams

Set<String> streams

streamToChildren

org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren

Class org.apache.storm.streams.processors.JoinProcessor

class JoinProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,?>> implements Serializable

Serialized Fields

leftRows

List<Pair<K,V1>> leftRows

leftStream

String leftStream

leftType

JoinProcessor.JoinType leftType

rightRows

List<Pair<K,V2>> rightRows

rightStream

String rightStream

rightType

JoinProcessor.JoinType rightType

valueJoiner

ValueJoiner<V1,V2,R> valueJoiner

Class org.apache.storm.streams.processors.MapProcessor

class MapProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

function

Function<T,R> function

Class org.apache.storm.streams.processors.MapValuesProcessor

class MapValuesProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

Serialized Fields

function

Function<V,R> function

Class org.apache.storm.streams.processors.MergeAggregateByKeyProcessor

class MergeAggregateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,A>> implements Serializable

Serialized Fields

aggregator

CombinerAggregator<V,A,R> aggregator

state

Map<K,A> state

Class org.apache.storm.streams.processors.MergeAggregateProcessor

class MergeAggregateProcessor extends org.apache.storm.streams.processors.BaseProcessor<A> implements Serializable

Serialized Fields

aggregator

CombinerAggregator<T,A,R> aggregator

state

A state

Class org.apache.storm.streams.processors.PeekProcessor

class PeekProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

consumer

Consumer<T> consumer

Class org.apache.storm.streams.processors.ReduceByKeyProcessor

class ReduceByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

Serialized Fields

reducer

Reducer<V> reducer

state

Map<K,V> state

Class org.apache.storm.streams.processors.ReduceProcessor

class ReduceProcessor extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

agg

T agg

reducer

Reducer<T> reducer

Class org.apache.storm.streams.processors.StateQueryProcessor

class StateQueryProcessor extends org.apache.storm.streams.processors.BaseProcessor<K> implements Serializable

Serialized Fields

keyValueState

KeyValueState<K,V> keyValueState

streamState

StreamState<K,V> streamState

Class org.apache.storm.streams.processors.UpdateStateByKeyProcessor

class UpdateStateByKeyProcessor extends org.apache.storm.streams.processors.BaseProcessor<Pair<K,V>> implements Serializable

Serialized Fields

keyValueState

KeyValueState<K,R> keyValueState

stateUpdater

StateUpdater<V,R> stateUpdater

Package org.apache.storm.streams.windowing

Class org.apache.storm.streams.windowing.BaseWindow

class BaseWindow extends Object implements Serializable

Serialized Fields

lag

BaseWindowedBolt.Duration lag

lateTupleStream

String lateTupleStream

timestampField

String timestampField

Class org.apache.storm.streams.windowing.SlidingWindows

class SlidingWindows extends BaseWindow<L,I> implements Serializable

Serialized Fields

slidingInterval

I slidingInterval

windowLength

L windowLength

Class org.apache.storm.streams.windowing.TumblingWindows

class TumblingWindows extends BaseWindow<L,L> implements Serializable

Serialized Fields

windowLength

L windowLength

Package org.apache.storm.task

Class org.apache.storm.task.ShellBolt

class ShellBolt extends Object implements Serializable

serialVersionUID:

-339575186639193348L

Serialized Fields

changeDirectory

boolean changeDirectory

collector

OutputCollector collector

command

String[] command

context

TopologyContext context

env

Map<String,String> env

exception

Throwable exception

heartBeatExecutorService

ScheduledExecutorService heartBeatExecutorService

inputs

Map<String,Tuple> inputs

isLocalMode

boolean isLocalMode

lastHeartbeatTimestamp

AtomicLong lastHeartbeatTimestamp

logHandler

ShellLogHandler logHandler

pendingWrites

ShellBoltMessageQueue pendingWrites

process

ShellProcess process

rand

Random rand

readerThread

Thread readerThread

running

boolean running

sendHeartbeatFlag

AtomicBoolean sendHeartbeatFlag

workerTimeoutMills

int workerTimeoutMills

writerThread

Thread writerThread

Package org.apache.storm.testing

Class org.apache.storm.testing.AckFailMapTracker

class AckFailMapTracker extends Object implements Serializable

Serialized Fields

acked

String acked

failed

String failed

Class org.apache.storm.testing.AckTracker

class AckTracker extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.testing.BoltTracker

class BoltTracker extends NonRichBoltTracker implements Serializable

Serialized Fields

richDelegate

IRichBolt richDelegate

Class org.apache.storm.testing.FeederSpout

class FeederSpout extends BaseRichSpout implements Serializable

Serialized Fields

ackFailDelegate

AckFailDelegate ackFailDelegate

collector

SpoutOutputCollector collector

id

int id

outFields

Fields outFields

Class org.apache.storm.testing.FixedTuple

class FixedTuple extends Object implements Serializable

Serialized Fields

stream

String stream

values

List<Object> values

Class org.apache.storm.testing.FixedTupleSpout

class FixedTupleSpout extends Object implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

context

TopologyContext context

fields

Fields fields

id

String id

pending

Map<String,FixedTuple> pending

serveTuples

List<FixedTuple> serveTuples

tuples

List<FixedTuple> tuples

Class org.apache.storm.testing.IdentityBolt

class IdentityBolt extends BaseBasicBolt implements Serializable

Serialized Fields

fields

Fields fields

Class org.apache.storm.testing.NGrouping

class NGrouping extends Object implements Serializable

Serialized Fields

number

int number

outTasks

List<Integer> outTasks

Class org.apache.storm.testing.NonRichBoltTracker

class NonRichBoltTracker extends Object implements Serializable

Serialized Fields

delegate

IBolt delegate

trackId

String trackId

Class org.apache.storm.testing.PrepareBatchBolt

class PrepareBatchBolt extends BaseBasicBolt implements Serializable

Serialized Fields

outFields

Fields outFields

Class org.apache.storm.testing.PythonShellMetricsBolt

class PythonShellMetricsBolt extends ShellBolt implements Serializable

serialVersionUID:

1999209252187463355L

Class org.apache.storm.testing.PythonShellMetricsSpout

class PythonShellMetricsSpout extends ShellSpout implements Serializable

serialVersionUID:

1999209252187463355L

Class org.apache.storm.testing.SpoutTracker

class SpoutTracker extends BaseRichSpout implements Serializable

Serialized Fields

delegate

IRichSpout delegate

tracker

org.apache.storm.testing.SpoutTracker.SpoutTrackOutputCollector tracker

trackId

String trackId

Class org.apache.storm.testing.TestAggregatesCounter

class TestAggregatesCounter extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

Map<String,Integer> counts

Class org.apache.storm.testing.TestConfBolt

class TestConfBolt extends BaseBasicBolt implements Serializable

Serialized Fields

componentConf

Map<String,Object> componentConf

conf

Map<String,Object> conf

Class org.apache.storm.testing.TestEventLogSpout

class TestEventLogSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

eventId

long eventId

myCount

long myCount

source

int source

totalCount

long totalCount

uid

String uid

Class org.apache.storm.testing.TestEventOrderCheckBolt

class TestEventOrderCheckBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

recentEventId

Map<Integer,Long> recentEventId

Class org.apache.storm.testing.TestGlobalCount

class TestGlobalCount extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

Class org.apache.storm.testing.TestPlannerBolt

class TestPlannerBolt extends BaseRichBolt implements Serializable

Class org.apache.storm.testing.TestPlannerSpout

class TestPlannerSpout extends BaseRichSpout implements Serializable

Serialized Fields

isDistributed

boolean isDistributed

outFields

Fields outFields

Class org.apache.storm.testing.TestSerObject

class TestSerObject extends Object implements Serializable

Serialized Fields

f1

int f1

f2

int f2

Class org.apache.storm.testing.TestWordBytesCounter

class TestWordBytesCounter extends TestWordCounter implements Serializable

Class org.apache.storm.testing.TestWordCounter

class TestWordCounter extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.testing.TestWordSpout

class TestWordSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

isDistributed

boolean isDistributed

Class org.apache.storm.testing.TupleCaptureBolt

class TupleCaptureBolt extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

name

String name

Package org.apache.storm.topology

Class org.apache.storm.topology.BaseStatefulBoltExecutor

class BaseStatefulBoltExecutor extends Object implements Serializable

Serialized Fields

checkPointInputTaskCount

int checkPointInputTaskCount

collector

OutputCollector collector

lastTxid

long lastTxid

transactionRequestCount

Map<org.apache.storm.topology.BaseStatefulBoltExecutor.TransactionRequest,Integer> transactionRequestCount

Class org.apache.storm.topology.BasicBoltExecutor

class BasicBoltExecutor extends Object implements Serializable

Serialized Fields

bolt

IBasicBolt bolt

Class org.apache.storm.topology.CheckpointTupleForwarder

class CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable

Serialized Fields

bolt

IRichBolt bolt

Exception org.apache.storm.topology.FailedException

class FailedException extends RuntimeException implements Serializable

Class org.apache.storm.topology.PersistentWindowedBoltExecutor

class PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

Serialized Fields

statefulWindowedBolt

IStatefulWindowedBolt<T extends State> statefulWindowedBolt

Exception org.apache.storm.topology.ReportedFailedException

class ReportedFailedException extends FailedException implements Serializable

Class org.apache.storm.topology.SharedOffHeapWithinNode

class SharedOffHeapWithinNode extends SharedMemory implements Serializable

serialVersionUID:

1L

Class org.apache.storm.topology.SharedOffHeapWithinWorker

class SharedOffHeapWithinWorker extends SharedMemory implements Serializable

Class org.apache.storm.topology.SharedOnHeap

class SharedOnHeap extends SharedMemory implements Serializable

serialVersionUID:

1L

Class org.apache.storm.topology.StatefulBoltExecutor

class StatefulBoltExecutor extends BaseStatefulBoltExecutor implements Serializable

Serialized Fields

bolt

IStatefulBolt<T extends State> bolt

boltInitialized

boolean boltInitialized

collector

org.apache.storm.topology.StatefulBoltExecutor.AckTrackingOutputCollector collector

pendingTuples

List<Tuple> pendingTuples

preparedTuples

List<Tuple> preparedTuples

state

State state

Class org.apache.storm.topology.StatefulWindowedBoltExecutor

class StatefulWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

Serialized Fields

statefulWindowedBolt

IStatefulWindowedBolt<T extends State> statefulWindowedBolt

Class org.apache.storm.topology.TupleFieldTimestampExtractor

class TupleFieldTimestampExtractor extends Object implements Serializable

Serialized Fields

fieldName

String fieldName

Class org.apache.storm.topology.WindowedBoltExecutor

class WindowedBoltExecutor extends Object implements Serializable

Serialized Fields

bolt

IWindowedBolt bolt

timestampExtractor

TimestampExtractor timestampExtractor

Package org.apache.storm.topology.base

Class org.apache.storm.topology.base.BaseBasicBolt

class BaseBasicBolt extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseBatchBolt

class BaseBatchBolt extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseComponent

class BaseComponent extends Object implements Serializable

Class org.apache.storm.topology.base.BaseRichBolt

class BaseRichBolt extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseRichSpout

class BaseRichSpout extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseStatefulBolt

class BaseStatefulBolt extends Object implements Serializable

Class org.apache.storm.topology.base.BaseStatefulWindowedBolt

class BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

maxEventsInMemory

long maxEventsInMemory

persistent

boolean persistent

Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt

class BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable

Class org.apache.storm.topology.base.BaseWindowedBolt

class BaseWindowedBolt extends Object implements Serializable

Serialized Fields

timestampExtractor

TimestampExtractor timestampExtractor

Class org.apache.storm.topology.base.BaseWindowedBolt.Count

class Count extends Object implements Serializable

Serialized Fields

value

int value

Class org.apache.storm.topology.base.BaseWindowedBolt.Duration

class Duration extends Object implements Serializable

Serialized Fields

value

int value

Package org.apache.storm.trident.drpc

Class org.apache.storm.trident.drpc.ReturnResultsReducer

class ReturnResultsReducer extends Object implements Serializable

Serialized Fields

clients

Map<List,DRPCInvocationsClient> clients

conf

Map<String,Object> conf

local

boolean local

Package org.apache.storm.trident.operation

Class org.apache.storm.trident.operation.BaseAggregator

class BaseAggregator extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseFilter

class BaseFilter extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseFunction

class BaseFunction extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseMultiReducer

class BaseMultiReducer extends Object implements Serializable

Class org.apache.storm.trident.operation.BaseOperation

class BaseOperation extends Object implements Serializable

Package org.apache.storm.trident.operation.builtin

Class org.apache.storm.trident.operation.builtin.ComparisonAggregator

class ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable

Serialized Fields

batchId

Object batchId

inputFieldName

String inputFieldName

Class org.apache.storm.trident.operation.builtin.Count

class Count extends Object implements Serializable

Class org.apache.storm.trident.operation.builtin.Debug

class Debug extends BaseFilter implements Serializable

Serialized Fields

name

String name

useLogger

boolean useLogger

Class org.apache.storm.trident.operation.builtin.Equals

class Equals extends BaseFilter implements Serializable

Class org.apache.storm.trident.operation.builtin.FilterNull

class FilterNull extends BaseFilter implements Serializable

Class org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg

class FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable

Serialized Fields

number

int number

Class org.apache.storm.trident.operation.builtin.FirstN.FirstNSortedAgg

class FirstNSortedAgg extends BaseAggregator<PriorityQueue> implements Serializable

Serialized Fields

number

int number

reverse

boolean reverse

sortField

String sortField

Class org.apache.storm.trident.operation.builtin.MapGet

class MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable

Class org.apache.storm.trident.operation.builtin.Max

class Max extends ComparisonAggregator<Comparable<Object>> implements Serializable

Class org.apache.storm.trident.operation.builtin.MaxWithComparator

class MaxWithComparator extends ComparisonAggregator<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

Class org.apache.storm.trident.operation.builtin.Min

class Min extends ComparisonAggregator<Comparable<Object>> implements Serializable

Class org.apache.storm.trident.operation.builtin.MinWithComparator

class MinWithComparator extends ComparisonAggregator<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

Class org.apache.storm.trident.operation.builtin.Negate

class Negate extends Object implements Serializable

Serialized Fields

delegate

Filter delegate

Class org.apache.storm.trident.operation.builtin.SnapshotGet

class SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable

Class org.apache.storm.trident.operation.builtin.Sum

class Sum extends Object implements Serializable

Class org.apache.storm.trident.operation.builtin.TupleCollectionGet

class TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable

Package org.apache.storm.trident.operation.impl

Class org.apache.storm.trident.operation.impl.ChainedAggregatorImpl

class ChainedAggregatorImpl extends Object implements Serializable

Serialized Fields

aggs

Aggregator[] aggs

fact

ComboList.Factory fact

inputFactories

TridentTupleView.ProjectionFactory[] inputFactories

inputFields

Fields[] inputFields

Class org.apache.storm.trident.operation.impl.CombinerAggregatorCombineImpl

class CombinerAggregatorCombineImpl extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl

class CombinerAggregatorInitImpl extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater

class CombinerAggStateUpdater extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.ConsumerExecutor

class ConsumerExecutor extends BaseOperation implements Serializable

Serialized Fields

consumer

Consumer consumer

Class org.apache.storm.trident.operation.impl.FilterExecutor

class FilterExecutor extends Object implements Serializable

Serialized Fields

filter

Filter filter

Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor

class FlatMapFunctionExecutor extends BaseOperation implements Serializable

Serialized Fields

function

FlatMapFunction function

Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition

class GlobalBatchToPartition extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.GroupedAggregator

class GroupedAggregator extends Object implements Serializable

Serialized Fields

agg

Aggregator agg

fact

ComboList.Factory fact

groupFactory

TridentTupleView.ProjectionFactory groupFactory

groupFields

Fields groupFields

inFields

Fields inFields

inputFactory

TridentTupleView.ProjectionFactory inputFactory

Class org.apache.storm.trident.operation.impl.GroupedMultiReducerExecutor

class GroupedMultiReducerExecutor extends Object implements Serializable

Serialized Fields

groupFactories

List<TridentTupleView.ProjectionFactory> groupFactories

groupFields

List<Fields> groupFields

inputFactories

List<TridentTupleView.ProjectionFactory> inputFactories

inputFields

List<Fields> inputFields

reducer

GroupedMultiReducer reducer

Class org.apache.storm.trident.operation.impl.IdentityMultiReducer

class IdentityMultiReducer extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition

class IndexHashBatchToPartition extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.JoinerMultiReducer

class JoinerMultiReducer extends Object implements Serializable

Serialized Fields

factory

ComboList.Factory factory

numGroupFields

int numGroupFields

sideFields

List<Fields> sideFields

types

List<JoinType> types

Class org.apache.storm.trident.operation.impl.MapFunctionExecutor

class MapFunctionExecutor extends BaseOperation implements Serializable

Serialized Fields

function

MapFunction function

Class org.apache.storm.trident.operation.impl.PreservingFieldsOrderJoinerMultiReducer

class PreservingFieldsOrderJoinerMultiReducer extends Object implements Serializable

Serialized Fields

factory

ComboList.Factory factory

joiningFields

List<Fields> joiningFields

numGroupFields

int numGroupFields

originFields

List<Fields> originFields

sideFields

List<Fields> sideFields

types

List<JoinType> types

Class org.apache.storm.trident.operation.impl.ReducerAggregatorImpl

class ReducerAggregatorImpl extends Object implements Serializable

Serialized Fields

agg

ReducerAggregator agg

Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater

class ReducerAggStateUpdater extends Object implements Serializable

Serialized Fields

agg

ReducerAggregator agg

Class org.apache.storm.trident.operation.impl.SingleEmitAggregator

class SingleEmitAggregator extends Object implements Serializable

Serialized Fields

agg

Aggregator agg

batchToPartition

SingleEmitAggregator.BatchToPartition batchToPartition

myPartitionIndex

int myPartitionIndex

totalPartitions

int totalPartitions

Class org.apache.storm.trident.operation.impl.TrueFilter

class TrueFilter extends Object implements Serializable

Package org.apache.storm.trident.partition

Class org.apache.storm.trident.partition.GlobalGrouping

class GlobalGrouping extends Object implements Serializable

Serialized Fields

target

List<Integer> target

Class org.apache.storm.trident.partition.IdentityGrouping

class IdentityGrouping extends Object implements Serializable

Serialized Fields

precomputed

Map<Integer,List<Integer>> precomputed

Class org.apache.storm.trident.partition.IndexHashGrouping

class IndexHashGrouping extends Object implements Serializable

Serialized Fields

index

int index

targets

List<Integer> targets

Package org.apache.storm.trident.planner

Class org.apache.storm.trident.planner.Node

class Node extends DefaultResourceDeclarer<Node> implements Serializable

Serialized Fields

allOutputFields

Fields allOutputFields

creationIndex

int creationIndex

name

String name

nodeId

String nodeId

parallelismHint

Integer parallelismHint

stateInfo

NodeStateInfo stateInfo

streamId

String streamId

Class org.apache.storm.trident.planner.NodeStateInfo

class NodeStateInfo extends Object implements Serializable

Serialized Fields

id

String id

spec

StateSpec spec

Class org.apache.storm.trident.planner.PartitionNode

class PartitionNode extends Node implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream oos)
                  throws IOException

Throws:

IOException

Class org.apache.storm.trident.planner.ProcessorNode

class ProcessorNode extends Node implements Serializable

Serialized Fields

committer

boolean committer

processor

TridentProcessor processor

selfOutFields

Fields selfOutFields

Class org.apache.storm.trident.planner.SpoutNode

class SpoutNode extends Node implements Serializable

Serialized Fields

spout

Object spout

txId

String txId

type

SpoutNode.SpoutType type

Class org.apache.storm.trident.planner.SubtopologyBolt

class SubtopologyBolt extends Object implements Serializable

serialVersionUID:

1475508603138688412L

Serialized Fields

batchGroups

Map<Node,String> batchGroups

graph

org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph

myTopologicallyOrdered

Map<String,List<TridentProcessor>> myTopologicallyOrdered

nodes

Set<Node> nodes

outputFactories

Map<Node,TridentTuple.Factory> outputFactories

roots

Map<String,SubtopologyBolt.InitialReceiver> roots

Package org.apache.storm.trident.planner.processor

Class org.apache.storm.trident.planner.processor.AggregateProcessor

class AggregateProcessor extends Object implements Serializable

Serialized Fields

agg

Aggregator agg

collector

FreshCollector collector

context

TridentContext context

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

Class org.apache.storm.trident.planner.processor.EachProcessor

class EachProcessor extends Object implements Serializable

Serialized Fields

collector

AppendCollector collector

context

TridentContext context

function

Function function

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

Class org.apache.storm.trident.planner.processor.MapProcessor

class MapProcessor extends Object implements Serializable

Serialized Fields

collector

FreshCollector collector

context

TridentContext context

function

Function function

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

Class org.apache.storm.trident.planner.processor.MultiReducerProcessor

class MultiReducerProcessor extends Object implements Serializable

Serialized Fields

collector

FreshCollector collector

context

TridentContext context

projectFields

List<Fields> projectFields

projectionFactories

TridentTupleView.ProjectionFactory[] projectionFactories

reducer

MultiReducer reducer

streamToIndex

Map<String,Integer> streamToIndex

Class org.apache.storm.trident.planner.processor.PartitionPersistProcessor

class PartitionPersistProcessor extends Object implements Serializable

Serialized Fields

collector

FreshCollector collector

context

TridentContext context

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

state

State state

stateId

String stateId

updater

StateUpdater updater

Class org.apache.storm.trident.planner.processor.ProjectedProcessor

class ProjectedProcessor extends Object implements Serializable

Serialized Fields

context

TridentContext context

factory

TridentTupleView.ProjectionFactory factory

projectFields

Fields projectFields

Class org.apache.storm.trident.planner.processor.StateQueryProcessor

class StateQueryProcessor extends Object implements Serializable

Serialized Fields

collector

AppendCollector collector

context

TridentContext context

function

QueryFunction function

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

state

State state

stateId

String stateId

Package org.apache.storm.trident.spout

Class org.apache.storm.trident.spout.BatchSpoutExecutor

class BatchSpoutExecutor extends Object implements Serializable

Serialized Fields

spout

IBatchSpout spout

Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor

class OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable

Serialized Fields

spout

IOpaquePartitionedTridentSpout<Object,ISpoutPartition,Object> spout

Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor

class PartitionedTridentSpoutExecutor extends Object implements Serializable

Serialized Fields

spout

IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout

Class org.apache.storm.trident.spout.RichSpoutBatchExecutor

class RichSpoutBatchExecutor extends Object implements Serializable

Serialized Fields

spout

IRichSpout spout

Class org.apache.storm.trident.spout.RichSpoutBatchTriggerer

class RichSpoutBatchTriggerer extends Object implements Serializable

Serialized Fields

coordStream

String coordStream

delegate

IRichSpout delegate

finishConditions

Map<Long,org.apache.storm.trident.spout.RichSpoutBatchTriggerer.FinishCondition> finishConditions

msgIdToBatchId

Map<Long,Long> msgIdToBatchId

outputTasks

List<Integer> outputTasks

rand

Random rand

stream

String stream

Class org.apache.storm.trident.spout.TridentSpoutCoordinator

class TridentSpoutCoordinator extends Object implements Serializable

Serialized Fields

coord

ITridentSpout.BatchCoordinator<Object> coord

id

String id

spout

ITridentSpout<Object> spout

state

RotatingTransactionalState state

underlyingState

TransactionalState underlyingState

Class org.apache.storm.trident.spout.TridentSpoutExecutor

class TridentSpoutExecutor extends Object implements Serializable

Serialized Fields

activeBatches

TreeMap<Long,TransactionAttempt> activeBatches

collector

org.apache.storm.trident.spout.TridentSpoutExecutor.AddIdCollector collector

emitter

ITridentSpout.Emitter<Object> emitter

spout

ITridentSpout<Object> spout

streamName

String streamName

txStateId

String txStateId

Package org.apache.storm.trident.state

Class org.apache.storm.trident.state.BaseQueryFunction

class BaseQueryFunction extends BaseOperation implements Serializable

Class org.apache.storm.trident.state.BaseStateUpdater

class BaseStateUpdater extends BaseOperation implements Serializable

Class org.apache.storm.trident.state.JSONNonTransactionalSerializer

class JSONNonTransactionalSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.JSONOpaqueSerializer

class JSONOpaqueSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.JSONTransactionalSerializer

class JSONTransactionalSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.StateSpec

class StateSpec extends Object implements Serializable

Serialized Fields

requiredNumPartitions

Integer requiredNumPartitions

stateFactory

StateFactory stateFactory

Package org.apache.storm.trident.state.map

Class org.apache.storm.trident.state.map.MapCombinerAggStateUpdater

class MapCombinerAggStateUpdater extends Object implements Serializable

serialVersionUID:

-3960578785572592092L

Serialized Fields

agg

CombinerAggregator agg

factory

ComboList.Factory factory

groupFields

Fields groupFields

inputFields

Fields inputFields

Class org.apache.storm.trident.state.map.MapReducerAggStateUpdater

class MapReducerAggStateUpdater extends Object implements Serializable

serialVersionUID:

8667174018978959987L

Serialized Fields

agg

ReducerAggregator agg

factory

ComboList.Factory factory

groupFields

Fields groupFields

inputFields

Fields inputFields

Class org.apache.storm.trident.state.map.MicroBatchIBackingMap.Options

class Options extends Object implements Serializable

Serialized Fields

maxMultiGetBatchSize

int maxMultiGetBatchSize

maxMultiPutBatchSize

int maxMultiPutBatchSize

Package org.apache.storm.trident.testing

Class org.apache.storm.trident.testing.CountAsAggregator

class CountAsAggregator extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable

Class org.apache.storm.trident.testing.FeederBatchSpout

class FeederBatchSpout extends Object implements Serializable

Serialized Fields

id

String id

outFields

Fields outFields

semaphoreId

String semaphoreId

waitToEmit

boolean waitToEmit

Class org.apache.storm.trident.testing.FeederCommitterBatchSpout

class FeederCommitterBatchSpout extends Object implements Serializable

Serialized Fields

spout

FeederBatchSpout spout

Class org.apache.storm.trident.testing.FixedBatchSpout

class FixedBatchSpout extends Object implements Serializable

Serialized Fields

batches

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

cycle

boolean cycle

fields

Fields fields

index

int index

maxBatchSize

int maxBatchSize

outputs

List<Object>[] outputs

Class org.apache.storm.trident.testing.LRUMemoryMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

id

String id

maxSize

int maxSize

Class org.apache.storm.trident.testing.MemoryMapState.Factory

class Factory extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.trident.testing.Split

class Split extends BaseFunction implements Serializable

Class org.apache.storm.trident.testing.StringLength

class StringLength extends BaseFunction implements Serializable

Class org.apache.storm.trident.testing.TrueFilter

class TrueFilter extends BaseFilter implements Serializable

Class org.apache.storm.trident.testing.TuplifyArgs

class TuplifyArgs extends BaseFunction implements Serializable

Package org.apache.storm.trident.topology

Class org.apache.storm.trident.topology.MasterBatchCoordinator

class MasterBatchCoordinator extends BaseRichSpout implements Serializable

Serialized Fields

active

boolean active

activeTx

TreeMap<Long,org.apache.storm.trident.topology.MasterBatchCoordinator.TransactionStatus> activeTx

attemptIds

TreeMap<Long,Integer> attemptIds

collector

SpoutOutputCollector collector

coordinators

List<ITridentSpout.BatchCoordinator> coordinators

currTransaction

Long currTransaction

managedSpoutIds

List<String> managedSpoutIds

maxTransactionActive

int maxTransactionActive

spouts

List<ITridentSpout> spouts

states

List<TransactionalState> states

throttler

WindowedTimeThrottler throttler

Class org.apache.storm.trident.topology.TridentBoltExecutor

class TridentBoltExecutor extends Object implements Serializable

Serialized Fields

batches

RotatingMap<Object,TridentBoltExecutor.TrackedBatch> batches

batchGroupIds

Map<GlobalStreamId,String> batchGroupIds

bolt

ITridentBatchBolt bolt

collector

OutputCollector collector

context

TopologyContext context

coordCollector

org.apache.storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector coordCollector

coordConditions

Map<String,TridentBoltExecutor.CoordCondition> coordConditions

coordOutputCollector

BatchOutputCollector coordOutputCollector

coordSpecs

Map<String,TridentBoltExecutor.CoordSpec> coordSpecs

lastRotate

long lastRotate

messageTimeoutMs

long messageTimeoutMs

Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition

class CoordCondition extends Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

expectedTaskReports

int expectedTaskReports

targetTasks

Set<Integer> targetTasks

Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec

class CoordSpec extends Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

coords

Map<String,TridentBoltExecutor.CoordType> coords

Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType

class CoordType extends Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package org.apache.storm.trident.tuple

Class org.apache.storm.trident.tuple.ComboList.Factory

class Factory extends Object implements Serializable

Serialized Fields

index

org.apache.storm.trident.tuple.ComboList.Pointer[] index

sizes

int[] sizes

Class org.apache.storm.trident.tuple.TridentTupleView.FreshOutputFactory

class FreshOutputFactory extends Object implements Serializable

Serialized Fields

fieldIndex

Map<String,ValuePointer> fieldIndex

index

ValuePointer[] index

Class org.apache.storm.trident.tuple.TridentTupleView.OperationOutputFactory

class OperationOutputFactory extends Object implements Serializable

Serialized Fields

fieldIndex

Map<String,ValuePointer> fieldIndex

index

ValuePointer[] index

parent

TridentTuple.Factory parent

Class org.apache.storm.trident.tuple.TridentTupleView.ProjectionFactory

class ProjectionFactory extends Object implements Serializable

Serialized Fields

fieldIndex

Map<String,ValuePointer> fieldIndex

index

ValuePointer[] index

parent

TridentTuple.Factory parent

Class org.apache.storm.trident.tuple.TridentTupleView.RootFactory

class RootFactory extends Object implements Serializable

Serialized Fields

fieldIndex

Map<String,ValuePointer> fieldIndex

index

ValuePointer[] index

Package org.apache.storm.trident.util

Class org.apache.storm.trident.util.ErrorEdgeFactory

class ErrorEdgeFactory extends Object implements Serializable

Class org.apache.storm.trident.util.IndexedEdge

class IndexedEdge extends Object implements Serializable

Serialized Fields

index

int index

source

T source

target

T target

Class org.apache.storm.trident.util.LRUMap

class LRUMap extends LinkedHashMap<A,B> implements Serializable

Serialized Fields

maxSize

int maxSize

Package org.apache.storm.trident.windowing

Class org.apache.storm.trident.windowing.InMemoryWindowsStore

class InMemoryWindowsStore extends Object implements Serializable

Serialized Fields

backingStore

WindowsStore backingStore

currentSize

AtomicInteger currentSize

maxSize

int maxSize

store

ConcurrentHashMap<String,Object> store

Class org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory

class InMemoryWindowsStoreFactory extends Object implements Serializable

Serialized Fields

inMemoryWindowsStore

InMemoryWindowsStore inMemoryWindowsStore

Class org.apache.storm.trident.windowing.WindowsStateFactory

class WindowsStateFactory extends Object implements Serializable

Class org.apache.storm.trident.windowing.WindowsStateUpdater

class WindowsStateUpdater extends Object implements Serializable

Serialized Fields

windowsStore

WindowsStore windowsStore

windowStoreFactory

WindowsStoreFactory windowStoreFactory

Class org.apache.storm.trident.windowing.WindowsStore.Entry

class Entry extends Object implements Serializable

Serialized Fields

key

String key

value

Object value

Class org.apache.storm.trident.windowing.WindowTridentProcessor

class WindowTridentProcessor extends Object implements Serializable

Serialized Fields

aggregator

Aggregator aggregator

collector

FreshCollector collector

inputFields

Fields inputFields

projection

TridentTupleView.ProjectionFactory projection

storeTuplesInStore

boolean storeTuplesInStore

topologyContext

TopologyContext topologyContext

tridentContext

TridentContext tridentContext

tridentWindowManager

ITridentWindowManager tridentWindowManager

windowConfig

WindowConfig windowConfig

windowId

String windowId

windowStore

WindowsStore windowStore

windowStoreFactory

WindowsStoreFactory windowStoreFactory

windowTaskId

String windowTaskId

windowTriggerInprocessId

String windowTriggerInprocessId

Class org.apache.storm.trident.windowing.WindowTridentProcessor.TriggerInfo

class TriggerInfo extends Object implements Serializable

Serialized Fields

triggerId

int triggerId

windowTaskId

String windowTaskId

Package org.apache.storm.trident.windowing.config

Class org.apache.storm.trident.windowing.config.BaseWindowConfig

class BaseWindowConfig extends Object implements Serializable

Serialized Fields

slideLength

int slideLength

windowLength

int windowLength

Class org.apache.storm.trident.windowing.config.SlidingCountWindow

class SlidingCountWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.SlidingDurationWindow

class SlidingDurationWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.TumblingCountWindow

class TumblingCountWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.TumblingDurationWindow

class TumblingDurationWindow extends BaseWindowConfig implements Serializable

Package org.apache.storm.tuple

Class org.apache.storm.tuple.Fields

class Fields extends Object implements Serializable

serialVersionUID:

-3377931843059975424L

Serialized Fields

fields

List<String> fields

index

Map<String,Integer> index

Class org.apache.storm.tuple.Values

class Values extends ArrayList<Object> implements Serializable

Package org.apache.storm.utils

Exception org.apache.storm.utils.DisallowedStrategyException

class DisallowedStrategyException extends RuntimeException implements Serializable

Serialized Fields

allowedStrategies

List<String> allowedStrategies

attemptedClass

String attemptedClass

Class org.apache.storm.utils.LruMap

class LruMap extends LinkedHashMap<A,B> implements Serializable

Serialized Fields

evCb

LruMap.CacheEvictionCallback evCb

maxSize

int maxSize

Exception org.apache.storm.utils.NimbusLeaderNotFoundException

class NimbusLeaderNotFoundException extends RuntimeException implements Serializable

Class org.apache.storm.utils.ShellBoltMessageQueue

class ShellBoltMessageQueue extends Object implements Serializable

Serialized Fields

boltMsgQueue

LinkedBlockingQueue<BoltMsg> boltMsgQueue

notEmpty

Condition notEmpty

takeLock

ReentrantLock takeLock

taskIdsQueue

LinkedList<List<Integer>> taskIdsQueue

Class org.apache.storm.utils.ShellProcess

class ShellProcess extends Object implements Serializable

Serialized Fields

command

String[] command

componentName

String componentName

env

Map<String,String> env

pid

Number pid

processErrorStream

InputStream processErrorStream

serializer

ISerializer serializer

subprocess

Process subprocess

Exception org.apache.storm.utils.ShellUtils.ExitCodeException

class ExitCodeException extends IOException implements Serializable

Serialized Fields

exitCode

int exitCode

Exception org.apache.storm.utils.WrappedAlreadyAliveException

class WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable

Exception org.apache.storm.utils.WrappedAuthorizationException

class WrappedAuthorizationException extends AuthorizationException implements Serializable

Exception org.apache.storm.utils.WrappedDRPCExecutionException

class WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable

Exception org.apache.storm.utils.WrappedHBExecutionException

class WrappedHBExecutionException extends HBExecutionException implements Serializable

Exception org.apache.storm.utils.WrappedIllegalStateException

class WrappedIllegalStateException extends IllegalStateException implements Serializable

Exception org.apache.storm.utils.WrappedInvalidTopologyException

class WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable

Exception org.apache.storm.utils.WrappedKeyAlreadyExistsException

class WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable

Exception org.apache.storm.utils.WrappedKeyNotFoundException

class WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable

Exception org.apache.storm.utils.WrappedNotAliveException

class WrappedNotAliveException extends NotAliveException implements Serializable

Package org.apache.storm.windowing