Serialized Form

Package org.apache.calcite.interpreter

Class org.apache.calcite.interpreter.StormContext extends org.apache.calcite.interpreter.Context implements Serializable

Package org.apache.storm

Class org.apache.storm.clojure$ack_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$bolt extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$bolt_execute extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$bolt$fn__728 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_bolt extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_bolt_STAR_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_spout extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$clojure_spout_STAR_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$collectify extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$defalias extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$defbolt extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$defspout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$direct_stream extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$emit_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_direct_bolt_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_direct_spout_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$emit_spout_BANG_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$fail_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__695 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__759 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__762 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__762$G__757__771 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__758

Object G__758

Class org.apache.storm.clojure$fn__762$G__758__766 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__777 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__777$iter__778__782 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__778

Object iter__778

s__779

Object s__779

Class org.apache.storm.clojure$fn__777$iter__778__782$fn__783$fn__784 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__781

Object b__781

c__6394__auto__

Object c__6394__auto__

size__6395__auto__

int size__6395__auto__

Class org.apache.storm.clojure$fn__799 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__818 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__820 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__822 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__824 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$fn__826 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$loading__6812__auto____693 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$local_cluster extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter__703__707 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__703

Object iter__703

s__704

Object s__704

Class org.apache.storm.clojure$normalize_fns$iter__703__707$fn__708$fn__709 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__706

Object b__706

c__6394__auto__

Object c__6394__auto__

size__6395__auto__

int size__6395__auto__

Class org.apache.storm.clojure$report_error_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$reset_timeout_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$spout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.clojure$spout$fn__736 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$submit_remote_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.clojure$to_spec extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.Config extends HashMap<String,Object> implements Serializable

serialVersionUID:

-1550278723792864455L

Class org.apache.storm.config$clojure_config_name extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$fn__269 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$fn__276 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.config$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.ExclamationTopology.FixedOrderWordSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

currentIndex

int currentIndex

numEmitted

int numEmitted

Class org.apache.storm.LocalCluster.LocalTopology extends StormTopology implements Serializable

serialVersionUID:

6145919776650637748L

Serialized Fields

topoName

String topoName

Class org.apache.storm.log$fn__495 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.log$loading__6812__auto____284 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.log$log_debug extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_error extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_message extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.log$log_warn extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$add_supervisor extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$advance_cluster_time extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$capture_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$complete_topology extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$fn__478 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$get_supervisor extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$global_amt extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$increment_global_BANG_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$kill_local_storm_cluster extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$kill_supervisor extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$loading__6812__auto____267 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$local_cluster_state extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$mk_local_storm_cluster extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$mk_mocked_nimbus extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$mk_tracked_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$mkClusterParam extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$mock_leader_elector extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$ms_EQ_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$read_tuples extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$simulate_wait extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects$iter__527__531 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__527

Object iter__527

s__528

Object s__528

Class org.apache.storm.testing$spout_objects$iter__527__531$fn__532$fn__533 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__530

Object b__530

c__6394__auto__

Object c__6394__auto__

size__6395__auto__

int size__6395__auto__

Class org.apache.storm.testing$submit_local_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$submit_local_topology_with_opts extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$test_tuple extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$tracked_wait extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$wait_for_condition extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$wait_for_condition$fn__499 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$wait_until_cluster_waiting extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.testing$while_timeout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_inprocess_zookeeper extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_local_cluster extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_mocked_nimbus extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_simulated_time_local_cluster extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_timeout extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.testing$with_tracked_cluster extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$add_inputs extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$deserialized_component_object extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$direct_output_fields extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$field_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$fn__571 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$global_grouping_QMARK_ extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$grouping_type extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$instantiate_java_object extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$instantiate_java_object$fn__574 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$loading__6812__auto____280 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_all_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_bolt_spec extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_bolt_spec_STAR_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_direct_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_fields_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_global_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_inputs extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_inputs$iter__615__619 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620 extends clojure.lang.AFunction implements Serializable

Serialized Fields

iter__615

Object iter__615

s__616

Object s__616

Class org.apache.storm.thrift$mk_inputs$iter__615__619$fn__620$fn__621 extends clojure.lang.AFunction implements Serializable

Serialized Fields

b__618

Object b__618

c__6394__auto__

Object c__6394__auto__

size__6395__auto__

int size__6395__auto__

Class org.apache.storm.thrift$mk_local_or_shuffle_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_none_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_output_spec extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_output_spec$fn__598 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_plain_component_common extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_shell_bolt_spec extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_shell_spout_spec extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_shuffle_grouping extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$mk_spout_spec extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_spout_spec_STAR_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$mk_topology extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$nimbus_client_and_conn extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$output_fields extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$parallelism_hint extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$serialize_component_object extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$shell_component_params extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.thrift$with_configured_nimbus_connection extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.thrift$with_nimbus_connection extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.util$__LT__GT_ extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.util$__LT__GT_$fn__567 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$clojurify_error extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$clojurify_structure extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$clojurify_structure$fn__527 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$defnk extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.util$defnk$fn__521 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$dofor extends clojure.lang.RestFn implements Serializable

Class org.apache.storm.util$filter_key extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$filter_key$fn__553 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

Class org.apache.storm.util$fn__501 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$hashmap_to_persistent extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$loading__6812__auto____282 extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$map_val extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$map_val$iter__531__535 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

Class org.apache.storm.util$map_val$iter__531__535$fn__536 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

iter__531

Object iter__531

s__532

Object s__532

Class org.apache.storm.util$map_val$iter__531__535$fn__536$fn__537 extends clojure.lang.AFunction implements Serializable

Serialized Fields

afn

Object afn

b__534

Object b__534

c__6394__auto__

Object c__6394__auto__

size__6395__auto__

int size__6395__auto__

Class org.apache.storm.util$name_with_attributes extends clojure.lang.AFunction implements Serializable

Class org.apache.storm.util$thrown_cause_QMARK_ extends clojure.lang.RestFn implements Serializable

Package org.apache.storm.bolt

Class org.apache.storm.bolt.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 extends Object implements Serializable

Serialized Fields

field

String[] field

outputName

String outputName

streamName

String streamName

Class org.apache.storm.bolt.JoinBolt.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 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 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 extends ShellBolt implements Serializable

Serialized Fields

outputs

Map<String,StreamInfo> outputs

Class org.apache.storm.clojure.RichShellSpout extends ShellSpout implements Serializable

Serialized Fields

outputs

Map<String,StreamInfo> outputs

Package org.apache.storm.coordination

Class org.apache.storm.coordination.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 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 extends Object implements Serializable

Serialized Fields

id

GlobalStreamId id

Class org.apache.storm.coordination.CoordinatedBolt.SourceArgs extends Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package org.apache.storm.daemon

Class org.apache.storm.daemon.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 extends Object implements Serializable

Serialized Fields

targetTasks

List<Integer> targetTasks

Class org.apache.storm.daemon.GrouperFactory.BasicLoadAwareCustomStreamGrouping extends Object implements Serializable

Serialized Fields

customStreamGrouping

CustomStreamGrouping customStreamGrouping

Class org.apache.storm.daemon.GrouperFactory.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 extends Object implements Serializable

Serialized Fields

targetTasks

List<Integer> targetTasks

Class org.apache.storm.daemon.GrouperFactory.NoneGrouper extends Object implements Serializable

Serialized Fields

numTasks

int numTasks

random

Random random

targetTasks

List<Integer> targetTasks

Package org.apache.storm.daemon.supervisor

Class org.apache.storm.daemon.supervisor.ContainerRecoveryException extends RuntimeException implements Serializable

Class org.apache.storm.daemon.supervisor.TimerDecoratedAssignment extends LocalAssignment implements Serializable

Serialized Fields

timing

com.codahale.metrics.Timer.Context timing

Package org.apache.storm.daemon.ui

Class org.apache.storm.daemon.ui.InvalidRequestException extends Exception implements Serializable

Package org.apache.storm.dependency

Class org.apache.storm.dependency.FileNotAvailableException extends RuntimeException implements Serializable

Package org.apache.storm.drpc

Class org.apache.storm.drpc.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 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 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 extends BaseBasicBolt implements Serializable

Serialized Fields

rand

Random rand

Class org.apache.storm.drpc.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.executor

Class org.apache.storm.executor.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 extends Object implements Serializable

Class org.apache.storm.flux.examples.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 extends BaseBasicBolt implements Serializable

Class org.apache.storm.flux.examples.TestWindowBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.flux.examples.WordCounter extends BaseBasicBolt implements Serializable

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

Class org.apache.storm.flux.wrappers.bolts.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 extends BaseBasicBolt implements Serializable

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

Class org.apache.storm.flux.wrappers.spouts.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 extends Object implements Serializable

Serialization Methods

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

Class org.apache.storm.generated.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 extends Object implements Serializable

Serialization Methods

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

Class org.apache.storm.generated.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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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.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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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

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

Class org.apache.storm.generated.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 extends Object implements Serializable

Serialization Methods

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 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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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

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

Class org.apache.storm.generated.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 extends Object implements Serializable

Serialization Methods

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 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

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

Class org.apache.storm.generated.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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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

tlsPort

int tlsPort

uptime_secs

int uptime_secs

version

String version

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

Class org.apache.storm.generated.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 extends Object implements Serializable

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 extends Object implements Serializable

Serialization Methods

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 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 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 extends Object implements Serializable

Serialized Fields

targetTaskStats

Map<Integer,Long> targetTaskStats

Class org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator extends Object implements Serializable

Class org.apache.storm.grouping.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 extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer> implements Serializable

Class org.apache.storm.hdfs.avro.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 extends AbstractAvroSerializer implements Serializable

Package org.apache.storm.hdfs.bolt

Class org.apache.storm.hdfs.bolt.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 extends AbstractHdfsBolt implements Serializable

Class org.apache.storm.hdfs.bolt.HdfsBolt extends AbstractHdfsBolt implements Serializable

Serialized Fields

format

RecordFormat format

Class org.apache.storm.hdfs.bolt.HdfsFileTopology.MyBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

HashMap<String,Long> counts

Class org.apache.storm.hdfs.bolt.HdfsFileTopology.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 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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

HashMap<String,Long> counts

Class org.apache.storm.hdfs.bolt.SequenceFileTopology.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 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 extends Object implements Serializable

Serialized Fields

keyField

String keyField

valueField

String valueField

Class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat extends Object implements Serializable

Serialized Fields

fieldDelimiter

String fieldDelimiter

fields

Fields fields

recordDelimiter

String recordDelimiter

Class org.apache.storm.hdfs.bolt.format.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 extends Object implements Serializable

Serialized Fields

currentBytesWritten

long currentBytesWritten

lastOffset

long lastOffset

maxBytes

long maxBytes

Class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy extends Object implements Serializable

Class org.apache.storm.hdfs.bolt.rotation.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 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 extends Object implements Serializable

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

Class org.apache.storm.hdfs.common.rotation.MoveFileAction extends Object implements Serializable

Serialized Fields

destination

String destination

Package org.apache.storm.hdfs.spout

Class org.apache.storm.hdfs.spout.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 extends BaseRichBolt implements Serializable

serialVersionUID:

-5313598399155365865L

Serialized Fields

collector

OutputCollector collector

count

int count

Class org.apache.storm.hdfs.spout.ParseException extends Exception implements Serializable

Package org.apache.storm.hdfs.trident

Class org.apache.storm.hdfs.trident.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 extends HdfsState.Options implements Serializable

Serialized Fields

bufferSize

int bufferSize

format

RecordFormat format

offset

long offset

Class org.apache.storm.hdfs.trident.HdfsState.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 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 extends Object implements Serializable

Serialized Fields

options

HdfsState.Options options

Class org.apache.storm.hdfs.trident.HdfsUpdater extends BaseStateUpdater<HdfsState> implements Serializable

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

Class org.apache.storm.hdfs.trident.format.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 extends Object implements Serializable

Serialized Fields

keyField

String keyField

valueField

String valueField

Class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat extends Object implements Serializable

Serialized Fields

fieldDelimiter

String fieldDelimiter

fields

Fields fields

recordDelimiter

String recordDelimiter

Class org.apache.storm.hdfs.trident.format.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 extends Object implements Serializable

Serialized Fields

currentBytesWritten

long currentBytesWritten

lastOffset

long lastOffset

maxBytes

long maxBytes

Class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy extends Object implements Serializable

Class org.apache.storm.hdfs.trident.rotation.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 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 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 extends BaseRichBolt implements Serializable

Serialized Fields

allWriters

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

Deprecated, for removal: This API element is subject to removal in a future version.

batchHelper

BatchHelper batchHelper

Deprecated, for removal: This API element is subject to removal in a future version.

callTimeoutPool

ExecutorService callTimeoutPool

Deprecated, for removal: This API element is subject to removal in a future version.

collector

OutputCollector collector

Deprecated, for removal: This API element is subject to removal in a future version.

options

HiveOptions options

Deprecated, for removal: This API element is subject to removal in a future version.

sendHeartBeat

AtomicBoolean sendHeartBeat

Deprecated, for removal: This API element is subject to removal in a future version.

tokenAuthEnabled

boolean tokenAuthEnabled

Deprecated, for removal: This API element is subject to removal in a future version.

ugi

org.apache.hadoop.security.UserGroupInformation ugi

Deprecated, for removal: This API element is subject to removal in a future version.

Class org.apache.storm.hive.bolt.HiveTopology.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 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 extends Object implements Serializable

Serialized Fields

columnFields

Fields columnFields

Deprecated, for removal: This API element is subject to removal in a future version.

columnNames

String[] columnNames

Deprecated, for removal: This API element is subject to removal in a future version.

fieldDelimiter

String fieldDelimiter

Deprecated, for removal: This API element is subject to removal in a future version.

parseDate

SimpleDateFormat parseDate

Deprecated, for removal: This API element is subject to removal in a future version.

partitionFields

Fields partitionFields

Deprecated, for removal: This API element is subject to removal in a future version.

timeFormat

String timeFormat

Deprecated, for removal: This API element is subject to removal in a future version.

Class org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper extends Object implements Serializable

Serialized Fields

columnFields

Fields columnFields

Deprecated, for removal: This API element is subject to removal in a future version.

parseDate

SimpleDateFormat parseDate

Deprecated, for removal: This API element is subject to removal in a future version.

partitionFields

Fields partitionFields

Deprecated, for removal: This API element is subject to removal in a future version.

timeFormat

String timeFormat

Deprecated, for removal: This API element is subject to removal in a future version.

Package org.apache.storm.hive.common

Class org.apache.storm.hive.common.HiveOptions extends Object implements Serializable

Serialized Fields

autoCreatePartitions

Boolean autoCreatePartitions

Deprecated, for removal: This API element is subject to removal in a future version.

batchSize

Integer batchSize

Deprecated, for removal: This API element is subject to removal in a future version.

callTimeout

Integer callTimeout

Deprecated, for removal: This API element is subject to removal in a future version.

databaseName

String databaseName

Deprecated, for removal: This API element is subject to removal in a future version.

heartBeatInterval

Integer heartBeatInterval

Deprecated, for removal: This API element is subject to removal in a future version.

idleTimeout

Integer idleTimeout

Deprecated, for removal: This API element is subject to removal in a future version.

kerberosKeytab

String kerberosKeytab

Deprecated, for removal: This API element is subject to removal in a future version.

kerberosPrincipal

String kerberosPrincipal

Deprecated, for removal: This API element is subject to removal in a future version.

mapper

HiveMapper mapper

Deprecated, for removal: This API element is subject to removal in a future version.

maxOpenConnections

Integer maxOpenConnections

Deprecated, for removal: This API element is subject to removal in a future version.

metaStoreURI

String metaStoreURI

Deprecated, for removal: This API element is subject to removal in a future version.

tableName

String tableName

Deprecated, for removal: This API element is subject to removal in a future version.

tickTupleInterval

Integer tickTupleInterval

Deprecated, for removal: This API element is subject to removal in a future version.

txnsPerBatch

Integer txnsPerBatch

Deprecated, for removal: This API element is subject to removal in a future version.

Class org.apache.storm.hive.common.HiveUtils.AuthenticationFailed extends Exception implements Serializable

Class org.apache.storm.hive.common.HiveWriter.CommitFailure extends HiveWriter.Failure implements Serializable

Class org.apache.storm.hive.common.HiveWriter.ConnectFailure extends HiveWriter.Failure implements Serializable

Class org.apache.storm.hive.common.HiveWriter.Failure extends Exception implements Serializable

Class org.apache.storm.hive.common.HiveWriter.TxnBatchFailure extends HiveWriter.Failure implements Serializable

Class org.apache.storm.hive.common.HiveWriter.TxnFailure extends HiveWriter.Failure implements Serializable

Class org.apache.storm.hive.common.HiveWriter.WriteFailure extends HiveWriter.Failure implements Serializable

Package org.apache.storm.hive.trident

Class org.apache.storm.hive.trident.HiveStateFactory extends Object implements Serializable

Serialized Fields

options

HiveOptions options

Deprecated, for removal: This API element is subject to removal in a future version.

Class org.apache.storm.hive.trident.HiveUpdater extends BaseStateUpdater<HiveState> implements Serializable

Class org.apache.storm.hive.trident.TridentHiveTopology.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 extends Object implements Serializable

serialVersionUID:

2589466485198339529L

Class org.apache.storm.hooks.SubmitterHookException extends RuntimeException implements Serializable

Package org.apache.storm.jdbc.bolt

Class org.apache.storm.jdbc.bolt.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 extends AbstractJdbcBolt implements Serializable

Serialized Fields

insertQuery

String insertQuery

jdbcMapper

JdbcMapper jdbcMapper

tableName

String tableName

Class org.apache.storm.jdbc.bolt.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 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 extends Object implements Serializable

Serialized Fields

configMap

Map<String,Object> configMap

Package org.apache.storm.jdbc.mapper

Class org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper extends SimpleJdbcMapper implements Serializable

Serialized Fields

outputFields

Fields outputFields

Class org.apache.storm.jdbc.mapper.SimpleJdbcMapper extends Object implements Serializable

Serialized Fields

schemaColumns

List<Column> schemaColumns

Package org.apache.storm.jdbc.spout

Class org.apache.storm.jdbc.spout.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 extends BaseQueryFunction<JdbcState,List<Values>> implements Serializable

Class org.apache.storm.jdbc.trident.state.JdbcState.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 extends Object implements Serializable

Serialized Fields

options

JdbcState.Options options

Class org.apache.storm.jdbc.trident.state.JdbcUpdater extends BaseStateUpdater<JdbcState> implements Serializable

Package org.apache.storm.jms

Package org.apache.storm.jms.bolt

Class org.apache.storm.jms.bolt.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 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 extends Object implements Serializable

Class org.apache.storm.jms.example.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 extends Object implements Serializable

Serialized Fields

jmsId

String jmsId

sequence

Long sequence

Class org.apache.storm.jms.spout.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 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 extends Object implements Serializable

Serialized Fields

options

JmsState.Options options

Class org.apache.storm.jms.trident.JmsUpdater extends BaseStateUpdater<JmsState> implements Serializable

Class org.apache.storm.jms.trident.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 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 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 extends Object implements Serializable

serialVersionUID:

4601118062437851265L

Serialized Fields

topicName

String topicName

Class org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector extends Object implements Serializable

serialVersionUID:

-3830575380208166367L

Serialized Fields

defaultTopicName

String defaultTopicName

fieldIndex

int fieldIndex

Class org.apache.storm.kafka.bolt.selector.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 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 extends Object implements Serializable

serialVersionUID:

-5782462870112305750L

Class org.apache.storm.kafka.spout.EmptyKafkaTupleListener extends Object implements Serializable

Class org.apache.storm.kafka.spout.KafkaSpout extends BaseRichSpout implements Serializable

serialVersionUID:

4151921085047987154L

Serialized Fields

collector

SpoutOutputCollector collector

kafkaClientFactory

ClientFactory<K,V> kafkaClientFactory

kafkaSpoutConfig

KafkaSpoutConfig<K,V> kafkaSpoutConfig

topicAssigner

TopicAssigner topicAssigner

Class org.apache.storm.kafka.spout.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 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 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 extends Object implements Serializable

Serialized Fields

length

long length

lengthNanos

long lengthNanos

timeUnit

TimeUnit timeUnit

Class org.apache.storm.kafka.spout.KafkaSpoutTestBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.kafka.spout.KafkaTuple extends Values implements Serializable

serialVersionUID:

4803794470450587992L

Serialized Fields

stream

String stream

Class org.apache.storm.kafka.spout.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.ClientFactoryDefault extends Object implements Serializable

Class org.apache.storm.kafka.spout.internal.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

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

Class org.apache.storm.kafka.spout.subscription.NamedTopicFilter extends Object implements Serializable

Serialized Fields

topics

Set<String> topics

Class org.apache.storm.kafka.spout.subscription.PatternTopicFilter extends Object implements Serializable

Serialized Fields

pattern

Pattern pattern

topics

Set<String> topics

Class org.apache.storm.kafka.spout.subscription.RoundRobinManualPartitioner extends Object implements Serializable

Class org.apache.storm.kafka.spout.subscription.TopicAssigner extends Object implements Serializable

serialVersionUID:

5423018073527583826L

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

Class org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

emitter

KafkaTridentSpoutEmitter<K,V> emitter

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata extends Object implements Serializable

Serialized Fields

firstOffset

long firstOffset

lastOffset

long lastOffset

topologyId

String topologyId

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig extends CommonKafkaSpoutConfig<K,V> implements Serializable

serialVersionUID:

1L

Class org.apache.storm.kafka.spout.trident.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 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 extends Object implements Serializable

serialVersionUID:

-8003272486566259640L

Serialized Fields

kafkaSpoutConfig

KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig

outputFieldsExtractor

OutputFieldsExtractor outputFieldsExtractor

Class org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition extends Object implements Serializable

Serialized Fields

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.apache.storm.kafka.spout.trident.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 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 extends Object implements Serializable

serialVersionUID:

1L

Package org.apache.storm.kafka.trident

Class org.apache.storm.kafka.trident.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 extends BaseStateUpdater<TridentKafkaState<K,V>> implements Serializable

serialVersionUID:

3352659585225274402L

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

Class org.apache.storm.kafka.trident.mapper.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 extends Object implements Serializable

serialVersionUID:

-1172454882072591493L

Serialized Fields

topicName

String topicName

Package org.apache.storm.lambda

Class org.apache.storm.lambda.LambdaBiConsumerBolt extends BaseBasicBolt implements Serializable

Serialized Fields

biConsumer

SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer

fields

String[] fields

Class org.apache.storm.lambda.LambdaConsumerBolt extends BaseBasicBolt implements Serializable

Serialized Fields

consumer

SerializableConsumer<Tuple> consumer

Class org.apache.storm.lambda.LambdaSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

supplier

SerializableSupplier<?> supplier

Package org.apache.storm.loadgen

Class org.apache.storm.loadgen.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 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 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 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 extends Object implements Serializable

Serialized Fields

max

double max

mean

double mean

min

double min

stddev

double stddev

Class org.apache.storm.loadgen.OutputStream extends Object implements Serializable

Serialized Fields

areKeysSkewed

boolean areKeysSkewed

id

String id

rate

NormalDistStats rate

Class org.apache.storm.loadgen.ScopedTopologySet extends HashSet<String> implements Serializable

Serialized Fields

client

Nimbus.Iface client

closed

boolean closed

Class org.apache.storm.loadgen.SlowExecutorPattern extends Object implements Serializable

Serialized Fields

count

int count

maxSlownessMs

double maxSlownessMs

Class org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout extends LoadSpout implements Serializable

Class org.apache.storm.loadgen.ThroughputVsLatency.SplitSentence extends BaseBasicBolt implements Serializable

Serialized Fields

executorIndex

int executorIndex

sleep

ExecAndProcessLatencyEngine sleep

Class org.apache.storm.loadgen.ThroughputVsLatency.WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Package org.apache.storm.metric

Class org.apache.storm.metric.EventLoggerBolt extends Object implements Serializable

Serialized Fields

eventLoggers

List<IEventLogger> eventLoggers

Class org.apache.storm.metric.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 extends Object implements Serializable

Package org.apache.storm.metric.filter

Class org.apache.storm.metric.filter.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 extends Object implements Serializable

Serialized Fields

expandMapType

boolean expandMapType

metricNameSeparator

String metricNameSeparator

Package org.apache.storm.metricstore

Class org.apache.storm.metricstore.MetricException extends Exception implements Serializable

Package org.apache.storm.multilang

Class org.apache.storm.multilang.JsonSerializer extends Object implements Serializable

serialVersionUID:

2548814660410474022L

Class org.apache.storm.multilang.NoOutputException extends Exception implements Serializable

Package org.apache.storm.nimbus

Class org.apache.storm.nimbus.NimbusInfo extends Object implements Serializable

serialVersionUID:

2161446155116099333L

Serialized Fields

host

String host

isLeader

boolean isLeader

port

int port

tlsPort

int tlsPort

Package org.apache.storm.pacemaker

Class org.apache.storm.pacemaker.PacemakerConnectionException extends Exception implements Serializable

Package org.apache.storm.perf

Class org.apache.storm.perf.KafkaClientHdfsTopo.LineWriter extends Object implements Serializable

Serialized Fields

fieldName

String fieldName

lineDelimiter

String lineDelimiter

Class org.apache.storm.perf.StrGenSpoutHdfsBoltTopo.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 extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.perf.bolt.DevNullBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

sleepNanos

Long sleepNanos

Class org.apache.storm.perf.bolt.IdBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.perf.bolt.SplitSentenceBolt extends BaseBasicBolt implements Serializable

Package org.apache.storm.perf.spout

Class org.apache.storm.perf.spout.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 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 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 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 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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Package org.apache.storm.planner

Class org.apache.storm.planner.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 extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

jedisClusterConfig

JedisClusterConfig jedisClusterConfig

jedisPoolConfig

JedisPoolConfig jedisPoolConfig

Class org.apache.storm.redis.bolt.RedisFilterBolt extends AbstractRedisBolt implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

filterMapper

RedisFilterMapper filterMapper

Class org.apache.storm.redis.bolt.RedisLookupBolt extends AbstractRedisBolt implements Serializable

Serialized Fields

additionalKey

String additionalKey

dataType

RedisDataTypeDescription.RedisDataType dataType

lookupMapper

RedisLookupMapper lookupMapper

Class org.apache.storm.redis.bolt.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 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 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 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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.redis.topology.WhitelistWordCount.PrintWordTotalCountBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.redis.topology.WordCounter extends Object implements Serializable

Serialized Fields

wordCounter

Map<String,Integer> wordCounter

Class org.apache.storm.redis.topology.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 extends BaseFunction implements Serializable

Class org.apache.storm.redis.trident.WordCountLookupMapper extends Object implements Serializable

Class org.apache.storm.redis.trident.WordCountStoreMapper extends Object implements Serializable

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

Class org.apache.storm.redis.trident.state.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 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 extends Object implements Serializable

Class org.apache.storm.redis.trident.state.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 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 extends Object implements Serializable

Serialized Fields

jedisClusterConfig

JedisClusterConfig jedisClusterConfig

Class org.apache.storm.redis.trident.state.RedisClusterStateQuerier extends AbstractRedisStateQuerier<RedisClusterState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisClusterStateUpdater extends AbstractRedisStateUpdater<RedisClusterState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisMapState.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 extends Object implements Serializable

Serialized Fields

jedisPoolConfig

JedisPoolConfig jedisPoolConfig

Class org.apache.storm.redis.trident.state.RedisStateQuerier extends AbstractRedisStateQuerier<RedisState> implements Serializable

Class org.apache.storm.redis.trident.state.RedisStateUpdater extends AbstractRedisStateUpdater<RedisState> implements Serializable

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

Class org.apache.storm.security.auth.plain.SaslPlainServer.SecurityProvider extends Provider implements Serializable

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

Class org.apache.storm.shade.org.apache.zookeeper.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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Class org.apache.storm.shade.org.apache.zookeeper.Shell.ExitCodeException extends IOException implements Serializable

Serialized Fields

exitCode

int exitCode

Package org.apache.storm.spout

Class org.apache.storm.spout.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 extends Object implements Serializable

Class org.apache.storm.spout.RawScheme extends Object implements Serializable

Class org.apache.storm.spout.SchemeAsMultiScheme extends Object implements Serializable

Serialized Fields

scheme

Scheme scheme

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

Class org.apache.storm.sql.javac.CompilingClassLoader.CompilerException extends Exception implements Serializable

serialVersionUID:

-2936958840023603270L

Package org.apache.storm.sql.kafka

Class org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

delegate

Scheme delegate

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

Class org.apache.storm.sql.parser.impl.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 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.

Class org.apache.storm.sql.parser.impl.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 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 extends Object implements Serializable

Serialized Fields

delegate

ExecutableExpression delegate

delegateCode

String delegateCode

Class org.apache.storm.sql.runtime.calcite.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 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 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 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 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 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 extends Object implements Serializable

Serialized Fields

fieldNames

List<String> fieldNames

Class org.apache.storm.sql.runtime.serde.csv.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 extends Object implements Serializable

Serialized Fields

fields

List<String> fields

Class org.apache.storm.sql.runtime.serde.json.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 extends Object implements Serializable

Serialized Fields

delimiter

char delimiter

fieldNames

List<String> fieldNames

Class org.apache.storm.sql.runtime.serde.tsv.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 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 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 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 extends Object implements Serializable

Serialized Fields

primaryKeyIndex

int primaryKeyIndex

Class org.apache.storm.sql.runtime.streams.functions.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 extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

componentId

String componentId

currentNum

int currentNum

Class org.apache.storm.st.topology.window.TimeDataIncrementingSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

componentId

String componentId

currentNum

int currentNum

Class org.apache.storm.st.topology.window.TimeDataVerificationBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

componentId

String componentId

Class org.apache.storm.st.topology.window.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 extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

random

Random random

Class org.apache.storm.starter.AnchoredWordCount.SplitSentence extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.AnchoredWordCount.WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.starter.BasicDRPCTopology.ExclaimBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.FilterWords extends BaseBasicBolt implements Serializable

Serialized Fields

poll

boolean poll

pollTime

long pollTime

wordSet

Set<String> wordSet

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.RandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

Class org.apache.storm.starter.BlobStoreAPIWordCountTopology.SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.ExclamationTopology.ExclamationBolt extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.starter.FastWordCountTopology.FastRandomSentenceSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

rand

Random rand

Class org.apache.storm.starter.FastWordCountTopology.SplitSentence extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.FastWordCountTopology.WordCount extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.starter.InOrderDeliveryTest.Check extends BaseBasicBolt implements Serializable

Serialized Fields

expected

Map<Integer,Integer> expected

Class org.apache.storm.starter.InOrderDeliveryTest.InOrderSpout extends BaseRichSpout implements Serializable

Serialized Fields

base

int base

collector

SpoutOutputCollector collector

count

int count

Class org.apache.storm.starter.ManualDRPC.ExclamationBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.MultipleLoggerTopology.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 extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

executor

ExecutorService executor

Class org.apache.storm.starter.ReachTopology.CountAggregator extends BaseBatchBolt<Object> implements Serializable

Serialized Fields

collector

BatchOutputCollector collector

count

int count

id

Object id

Class org.apache.storm.starter.ReachTopology.GetFollowers extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.ReachTopology.GetTweeters extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.ReachTopology.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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

Class org.apache.storm.starter.StatefulTopology.PrinterBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.WordCountTopology.SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.RandomSentence extends ShellSpout implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.SplitSentence extends ShellBolt implements Serializable

Class org.apache.storm.starter.WordCountTopologyNode.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 extends BaseBasicBolt implements Serializable

serialVersionUID:

4931640198501530202L

Serialized Fields

count

int count

emitFrequencyInSeconds

int emitFrequencyInSeconds

rankings

Rankings rankings

Class org.apache.storm.starter.bolt.IntermediateRankingsBolt extends AbstractRankerBolt implements Serializable

serialVersionUID:

-1369800530256637409L

Class org.apache.storm.starter.bolt.PrinterBolt extends BaseBasicBolt implements Serializable

Class org.apache.storm.starter.bolt.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 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 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 extends BaseWindowedBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

sum

int sum

Class org.apache.storm.starter.bolt.TotalRankingsBolt extends AbstractRankerBolt implements Serializable

serialVersionUID:

-8447525895532302198L

Class org.apache.storm.starter.bolt.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 extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

msgId

long msgId

rand

Random rand

Class org.apache.storm.starter.spout.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 extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

rand

Random rand

Class org.apache.storm.starter.spout.RandomSentenceSpout.TimeStamped extends RandomSentenceSpout implements Serializable

Serialized Fields

prefix

String prefix

Package org.apache.storm.starter.tools

Class org.apache.storm.starter.tools.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 extends Object implements Serializable

serialVersionUID:

-1549827195410578903L

Serialized Fields

maxSize

int maxSize

rankedItems

List<Rankable> rankedItems

Class org.apache.storm.starter.tools.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 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 extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.starter.trident.TridentReach.ExpandList extends BaseFunction implements Serializable

Class org.apache.storm.starter.trident.TridentReach.One extends Object implements Serializable

Class org.apache.storm.starter.trident.TridentReach.StaticSingleKeyMapState.Factory extends Object implements Serializable

Serialized Fields

map

Map map

Class org.apache.storm.starter.trident.TridentWordCount.Split extends BaseFunction implements Serializable

Package org.apache.storm.state

Class org.apache.storm.state.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 extends Object implements Serializable

Serialized Fields

value1

T1 value1

The first value.

value2

T2 value2

The second value.

Class org.apache.storm.streams.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 extends Object implements Serializable

Class org.apache.storm.streams.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 extends Object implements Serializable

Class org.apache.storm.streams.operations.PairValueJoiner extends Object implements Serializable

Class org.apache.storm.streams.operations.PrintConsumer extends Object implements Serializable

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

Class org.apache.storm.streams.operations.aggregators.Count extends Object implements Serializable

Class org.apache.storm.streams.operations.aggregators.LongSum extends Object implements Serializable

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

Class org.apache.storm.streams.operations.mappers.PairValueMapper extends Object implements Serializable

Serialized Fields

keyIndex

int keyIndex

valueIndex

int valueIndex

Class org.apache.storm.streams.operations.mappers.ValueMapper extends Object implements Serializable

Serialized Fields

index

int index

Class org.apache.storm.streams.operations.mappers.ValuesMapper extends Object implements Serializable

Serialized Fields

indices

int[] indices

Package org.apache.storm.streams.processors

Class org.apache.storm.streams.processors.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 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 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 extends Object implements Serializable

Serialized Fields

contexts

List<? extends ProcessorContext> contexts

processorNode

ProcessorNode processorNode

Class org.apache.storm.streams.processors.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 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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

predicate

Predicate<T> predicate

Class org.apache.storm.streams.processors.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 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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

consumer

Consumer<T> consumer

Class org.apache.storm.streams.processors.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 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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

function

Function<T,R> function

Class org.apache.storm.streams.processors.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 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 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 extends org.apache.storm.streams.processors.BaseProcessor<T> implements Serializable

Serialized Fields

consumer

Consumer<T> consumer

Class org.apache.storm.streams.processors.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 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 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 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 extends Object implements Serializable

Serialized Fields

lag

BaseWindowedBolt.Duration lag

lateTupleStream

String lateTupleStream

timestampField

String timestampField

Class org.apache.storm.streams.windowing.SlidingWindows extends BaseWindow<L,I> implements Serializable

Serialized Fields

slidingInterval

I slidingInterval

windowLength

L windowLength

Class org.apache.storm.streams.windowing.TumblingWindows extends BaseWindow<L,L> implements Serializable

Serialized Fields

windowLength

L windowLength

Package org.apache.storm.task

Class org.apache.storm.task.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 extends Object implements Serializable

Serialized Fields

acked

String acked

failed

String failed

Class org.apache.storm.testing.AckTracker extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable

Serialized Fields

richDelegate

IRichBolt richDelegate

Class org.apache.storm.testing.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 extends Object implements Serializable

Serialized Fields

stream

String stream

values

List<Object> values

Class org.apache.storm.testing.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 extends BaseBasicBolt implements Serializable

Serialized Fields

fields

Fields fields

Class org.apache.storm.testing.NGrouping extends Object implements Serializable

Serialized Fields

number

int number

outTasks

List<Integer> outTasks

Class org.apache.storm.testing.NonRichBoltTracker extends Object implements Serializable

Serialized Fields

delegate

IBolt delegate

trackId

String trackId

Class org.apache.storm.testing.PrepareBatchBolt extends BaseBasicBolt implements Serializable

Serialized Fields

outFields

Fields outFields

Class org.apache.storm.testing.PythonShellMetricsBolt extends ShellBolt implements Serializable

serialVersionUID:

1999209252187463355L

Class org.apache.storm.testing.PythonShellMetricsSpout extends ShellSpout implements Serializable

serialVersionUID:

1999209252187463355L

Class org.apache.storm.testing.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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

counts

Map<String,Integer> counts

Class org.apache.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable

Serialized Fields

componentConf

Map<String,Object> componentConf

conf

Map<String,Object> conf

Class org.apache.storm.testing.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 extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

recentEventId

Map<Integer,Long> recentEventId

Class org.apache.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable

Serialized Fields

collector

OutputCollector collector

count

int count

Class org.apache.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable

Class org.apache.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable

Serialized Fields

isDistributed

boolean isDistributed

outFields

Fields outFields

Class org.apache.storm.testing.TestSerObject extends Object implements Serializable

Serialized Fields

f1

int f1

f2

int f2

Class org.apache.storm.testing.TestWordBytesCounter extends TestWordCounter implements Serializable

Class org.apache.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable

Serialized Fields

counts

Map<String,Integer> counts

Class org.apache.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable

Serialized Fields

collector

SpoutOutputCollector collector

isDistributed

boolean isDistributed

Class org.apache.storm.testing.TupleCaptureBolt extends Object implements Serializable

Serialized Fields

collector

OutputCollector collector

name

String name

Package org.apache.storm.topology

Class org.apache.storm.topology.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 extends Object implements Serializable

Serialized Fields

bolt

IBasicBolt bolt

Class org.apache.storm.topology.CheckpointTupleForwarder extends BaseStatefulBoltExecutor implements Serializable

Serialized Fields

bolt

IRichBolt bolt

Class org.apache.storm.topology.FailedException extends RuntimeException implements Serializable

Class org.apache.storm.topology.PersistentWindowedBoltExecutor extends WindowedBoltExecutor implements Serializable

Serialized Fields

statefulWindowedBolt

IStatefulWindowedBolt<T extends State> statefulWindowedBolt

Class org.apache.storm.topology.ReportedFailedException extends FailedException implements Serializable

Class org.apache.storm.topology.SharedOffHeapWithinNode extends SharedMemory implements Serializable

serialVersionUID:

1L

Class org.apache.storm.topology.SharedOffHeapWithinWorker extends SharedMemory implements Serializable

Class org.apache.storm.topology.SharedOnHeap extends SharedMemory implements Serializable

serialVersionUID:

1L

Class org.apache.storm.topology.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 extends WindowedBoltExecutor implements Serializable

Serialized Fields

statefulWindowedBolt

IStatefulWindowedBolt<T extends State> statefulWindowedBolt

Class org.apache.storm.topology.TupleFieldTimestampExtractor extends Object implements Serializable

Serialized Fields

fieldName

String fieldName

Class org.apache.storm.topology.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 extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseBatchBolt extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseComponent extends Object implements Serializable

Class org.apache.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable

Class org.apache.storm.topology.base.BaseStatefulBolt extends Object implements Serializable

Class org.apache.storm.topology.base.BaseStatefulWindowedBolt extends BaseWindowedBolt implements Serializable

Serialized Fields

maxEventsInMemory

long maxEventsInMemory

persistent

boolean persistent

Class org.apache.storm.topology.base.BaseTickTupleAwareRichBolt extends BaseRichBolt implements Serializable

Class org.apache.storm.topology.base.BaseWindowedBolt extends Object implements Serializable

Serialized Fields

timestampExtractor

TimestampExtractor timestampExtractor

Class org.apache.storm.topology.base.BaseWindowedBolt.Count extends Object implements Serializable

Serialized Fields

value

int value

Class org.apache.storm.topology.base.BaseWindowedBolt.Duration extends Object implements Serializable

Serialized Fields

value

int value

Package org.apache.storm.trident.drpc

Class org.apache.storm.trident.drpc.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 extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseFilter extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseFunction extends BaseOperation implements Serializable

Class org.apache.storm.trident.operation.BaseMultiReducer extends Object implements Serializable

Class org.apache.storm.trident.operation.BaseOperation extends Object implements Serializable

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

Class org.apache.storm.trident.operation.builtin.ComparisonAggregator extends BaseAggregator<ComparisonAggregator.State> implements Serializable

Serialized Fields

batchId

Object batchId

inputFieldName

String inputFieldName

Class org.apache.storm.trident.operation.builtin.Count extends Object implements Serializable

Class org.apache.storm.trident.operation.builtin.Debug extends BaseFilter implements Serializable

Serialized Fields

name

String name

useLogger

boolean useLogger

Class org.apache.storm.trident.operation.builtin.Equals extends BaseFilter implements Serializable

Class org.apache.storm.trident.operation.builtin.FilterNull extends BaseFilter implements Serializable

Class org.apache.storm.trident.operation.builtin.FirstN.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 extends BaseAggregator<PriorityQueue> implements Serializable

Serialized Fields

number

int number

reverse

boolean reverse

sortField

String sortField

Class org.apache.storm.trident.operation.builtin.MapGet extends BaseQueryFunction<ReadOnlyMapState,Object> implements Serializable

Class org.apache.storm.trident.operation.builtin.Max extends ComparisonAggregator<Comparable<Object>> implements Serializable

Class org.apache.storm.trident.operation.builtin.MaxWithComparator extends ComparisonAggregator<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

Class org.apache.storm.trident.operation.builtin.Min extends ComparisonAggregator<Comparable<Object>> implements Serializable

Class org.apache.storm.trident.operation.builtin.MinWithComparator extends ComparisonAggregator<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

Class org.apache.storm.trident.operation.builtin.Negate extends Object implements Serializable

Serialized Fields

delegate

Filter delegate

Class org.apache.storm.trident.operation.builtin.SnapshotGet extends BaseQueryFunction<ReadOnlySnapshottable,Object> implements Serializable

Class org.apache.storm.trident.operation.builtin.Sum extends Object implements Serializable

Class org.apache.storm.trident.operation.builtin.TupleCollectionGet extends BaseQueryFunction<State,Iterator<List<Object>>> implements Serializable

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

Class org.apache.storm.trident.operation.impl.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 extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.CombinerAggregatorInitImpl extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.CombinerAggStateUpdater extends Object implements Serializable

Serialized Fields

agg

CombinerAggregator agg

Class org.apache.storm.trident.operation.impl.ConsumerExecutor extends BaseOperation implements Serializable

Serialized Fields

consumer

Consumer consumer

Class org.apache.storm.trident.operation.impl.FilterExecutor extends Object implements Serializable

Serialized Fields

filter

Filter filter

Class org.apache.storm.trident.operation.impl.FlatMapFunctionExecutor extends BaseOperation implements Serializable

Serialized Fields

function

FlatMapFunction function

Class org.apache.storm.trident.operation.impl.GlobalBatchToPartition extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.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 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 extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.IndexHashBatchToPartition extends Object implements Serializable

Class org.apache.storm.trident.operation.impl.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 extends BaseOperation implements Serializable

Serialized Fields

function

MapFunction function

Class org.apache.storm.trident.operation.impl.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 extends Object implements Serializable

Serialized Fields

agg

ReducerAggregator agg

Class org.apache.storm.trident.operation.impl.ReducerAggStateUpdater extends Object implements Serializable

Serialized Fields

agg

ReducerAggregator agg

Class org.apache.storm.trident.operation.impl.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 extends Object implements Serializable

Package org.apache.storm.trident.partition

Class org.apache.storm.trident.partition.GlobalGrouping extends Object implements Serializable

Serialized Fields

target

List<Integer> target

Class org.apache.storm.trident.partition.IdentityGrouping extends Object implements Serializable

Serialized Fields

precomputed

Map<Integer,List<Integer>> precomputed

Class org.apache.storm.trident.partition.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 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 extends Object implements Serializable

Serialized Fields

id

String id

spec

StateSpec spec

Class org.apache.storm.trident.planner.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 extends Node implements Serializable

Serialized Fields

committer

boolean committer

processor

TridentProcessor processor

selfOutFields

Fields selfOutFields

Class org.apache.storm.trident.planner.SpoutNode extends Node implements Serializable

Serialized Fields

spout

Object spout

txId

String txId

type

SpoutNode.SpoutType type

Class org.apache.storm.trident.planner.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 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 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 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 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 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 extends Object implements Serializable

Serialized Fields

context

TridentContext context

factory

TridentTupleView.ProjectionFactory factory

projectFields

Fields projectFields

Class org.apache.storm.trident.planner.processor.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 extends Object implements Serializable

Serialized Fields

spout

IBatchSpout spout

Class org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor extends Object implements Serializable

Serialized Fields

spout

IOpaquePartitionedTridentSpout<Object,ISpoutPartition,Object> spout

Class org.apache.storm.trident.spout.PartitionedTridentSpoutExecutor extends Object implements Serializable

Serialized Fields

spout

IPartitionedTridentSpout<Object,ISpoutPartition,Object> spout

Class org.apache.storm.trident.spout.RichSpoutBatchExecutor extends Object implements Serializable

Serialized Fields

spout

IRichSpout spout

Class org.apache.storm.trident.spout.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 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 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 extends BaseOperation implements Serializable

Class org.apache.storm.trident.state.BaseStateUpdater extends BaseOperation implements Serializable

Class org.apache.storm.trident.state.JSONNonTransactionalSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.JSONOpaqueSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.JSONTransactionalSerializer extends Object implements Serializable

Class org.apache.storm.trident.state.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 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 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 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 extends BaseAggregator<org.apache.storm.trident.testing.CountAsAggregator.State> implements Serializable

Class org.apache.storm.trident.testing.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 extends Object implements Serializable

Serialized Fields

spout

FeederBatchSpout spout

Class org.apache.storm.trident.testing.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 extends Object implements Serializable

Serialized Fields

id

String id

maxSize

int maxSize

Class org.apache.storm.trident.testing.MemoryMapState.Factory extends Object implements Serializable

Serialized Fields

id

String id

Class org.apache.storm.trident.testing.Split extends BaseFunction implements Serializable

Class org.apache.storm.trident.testing.StringLength extends BaseFunction implements Serializable

Class org.apache.storm.trident.testing.TrueFilter extends BaseFilter implements Serializable

Class org.apache.storm.trident.testing.TuplifyArgs extends BaseFunction implements Serializable

Package org.apache.storm.trident.topology

Class org.apache.storm.trident.topology.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 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 extends Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

expectedTaskReports

int expectedTaskReports

targetTasks

Set<Integer> targetTasks

Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordSpec extends Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

coords

Map<String,TridentBoltExecutor.CoordType> coords

Class org.apache.storm.trident.topology.TridentBoltExecutor.CoordType extends Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package org.apache.storm.trident.tuple

Class org.apache.storm.trident.tuple.ComboList.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 extends Object implements Serializable

Serialized Fields

fieldIndex

Map<String,ValuePointer> fieldIndex

index

ValuePointer[] index

Class org.apache.storm.trident.tuple.TridentTupleView.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 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 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 extends Object implements Serializable

Class org.apache.storm.trident.util.IndexedEdge extends Object implements Serializable

Serialized Fields

index

int index

source

T source

target

T target

Class org.apache.storm.trident.util.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 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 extends Object implements Serializable

Serialized Fields

inMemoryWindowsStore

InMemoryWindowsStore inMemoryWindowsStore

Class org.apache.storm.trident.windowing.WindowsStateFactory extends Object implements Serializable

Class org.apache.storm.trident.windowing.WindowsStateUpdater extends Object implements Serializable

Serialized Fields

windowsStore

WindowsStore windowsStore

windowStoreFactory

WindowsStoreFactory windowStoreFactory

Class org.apache.storm.trident.windowing.WindowsStore.Entry extends Object implements Serializable

Serialized Fields

key

String key

value

Object value

Class org.apache.storm.trident.windowing.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 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 extends Object implements Serializable

Serialized Fields

slideLength

int slideLength

windowLength

int windowLength

Class org.apache.storm.trident.windowing.config.SlidingCountWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.SlidingDurationWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.TumblingCountWindow extends BaseWindowConfig implements Serializable

Class org.apache.storm.trident.windowing.config.TumblingDurationWindow extends BaseWindowConfig implements Serializable

Package org.apache.storm.tuple

Class org.apache.storm.tuple.Fields extends Object implements Serializable

serialVersionUID:

-3377931843059975424L

Serialized Fields

fields

List<String> fields

index

Map<String,Integer> index

Class org.apache.storm.tuple.Values extends ArrayList<Object> implements Serializable

Package org.apache.storm.utils

Class org.apache.storm.utils.DisallowedStrategyException extends RuntimeException implements Serializable

Serialized Fields

allowedStrategies

List<String> allowedStrategies

attemptedClass

String attemptedClass

Class org.apache.storm.utils.LruMap extends LinkedHashMap<A,B> implements Serializable

Serialized Fields

evCb

LruMap.CacheEvictionCallback evCb

maxSize

int maxSize

Class org.apache.storm.utils.NimbusLeaderNotFoundException extends RuntimeException implements Serializable

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

Class org.apache.storm.utils.ShellUtils.ExitCodeException extends IOException implements Serializable

Serialized Fields

exitCode

int exitCode

Class org.apache.storm.utils.WrappedAlreadyAliveException extends AlreadyAliveException implements Serializable

Class org.apache.storm.utils.WrappedAuthorizationException extends AuthorizationException implements Serializable

Class org.apache.storm.utils.WrappedDRPCExecutionException extends DRPCExecutionException implements Serializable

Class org.apache.storm.utils.WrappedHBExecutionException extends HBExecutionException implements Serializable

Class org.apache.storm.utils.WrappedIllegalStateException extends IllegalStateException implements Serializable

Class org.apache.storm.utils.WrappedInvalidTopologyException extends InvalidTopologyException implements Serializable

Class org.apache.storm.utils.WrappedKeyAlreadyExistsException extends KeyAlreadyExistsException implements Serializable

Class org.apache.storm.utils.WrappedKeyNotFoundException extends KeyNotFoundException implements Serializable

Class org.apache.storm.utils.WrappedNotAliveException extends NotAliveException implements Serializable

Package org.apache.storm.windowing