Serialized Form

Package backtype.storm

Class backtype.storm.Config extends java.util.HashMap<java.lang.String,java.lang.Object> implements Serializable

Package backtype.storm.clojure

Class backtype.storm.clojure.ClojureBolt extends java.lang.Object implements Serializable

Serialized Fields

_fields

java.util.Map<K,V> _fields

_fnSpec

java.util.List<E> _fnSpec

_confSpec

java.util.List<E> _confSpec

_params

java.util.List<E> _params

_bolt

IBolt _bolt

Class backtype.storm.clojure.ClojureSpout extends java.lang.Object implements Serializable

Serialized Fields

_fields

java.util.Map<K,V> _fields

_fnSpec

java.util.List<E> _fnSpec

_confSpec

java.util.List<E> _confSpec

_params

java.util.List<E> _params

_spout

ISpout _spout

Class backtype.storm.clojure.RichShellBolt extends ShellBolt implements Serializable

Serialized Fields

_outputs

java.util.Map<K,V> _outputs

Package backtype.storm.coordination

Class backtype.storm.coordination.BatchBoltExecutor extends java.lang.Object implements Serializable

Serialized Fields

_boltSer

byte[] _boltSer

_openTransactions

java.util.Map<K,V> _openTransactions

_conf

java.util.Map<K,V> _conf

_context

TopologyContext _context

_collector

BatchOutputCollectorImpl _collector

Class backtype.storm.coordination.CoordinatedBolt extends java.lang.Object implements Serializable

Serialized Fields

_sourceArgs

java.util.Map<K,V> _sourceArgs

_idStreamSpec

CoordinatedBolt.IdStreamSpec _idStreamSpec

_delegate

IRichBolt _delegate

_numSourceReports

java.lang.Integer _numSourceReports

_countOutTasks

java.util.List<E> _countOutTasks

_collector

OutputCollector _collector

_tracked

TimeCacheMap<K,V> _tracked

Class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec extends java.lang.Object implements Serializable

Serialized Fields

_id

GlobalStreamId _id

Class backtype.storm.coordination.CoordinatedBolt.SourceArgs extends java.lang.Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package backtype.storm.drpc

Class backtype.storm.drpc.DRPCSpout extends java.lang.Object implements Serializable

Serialized Fields

_collector

SpoutOutputCollector _collector

_clients

java.util.List<E> _clients

_function

java.lang.String _function

_local_drpc_id

java.lang.String _local_drpc_id

Class backtype.storm.drpc.JoinResult extends BaseRichBolt implements Serializable

Serialized Fields

returnComponent

java.lang.String returnComponent

returns

java.util.Map<K,V> returns

results

java.util.Map<K,V> results

_collector

OutputCollector _collector

Class backtype.storm.drpc.KeyedFairBolt extends java.lang.Object implements Serializable

Serialized Fields

_delegate

IRichBolt _delegate

_rrQueue

KeyedRoundRobinQueue<V> _rrQueue

_executor

java.lang.Thread _executor

_callback

CoordinatedBolt.FinishedCallback _callback

Class backtype.storm.drpc.PrepareRequest extends BaseBasicBolt implements Serializable

Serialized Fields

rand

java.util.Random rand

Class backtype.storm.drpc.ReturnResults extends BaseRichBolt implements Serializable

Serialized Fields

_collector

OutputCollector _collector

local

boolean local

_clients

java.util.Map<K,V> _clients

Package backtype.storm.grouping

Package backtype.storm.planner

Class backtype.storm.planner.TaskBundle extends java.lang.Object implements Serializable

Serialized Fields

task

IBolt task

componentId

int componentId

Package backtype.storm.spout

Class backtype.storm.spout.RawScheme extends java.lang.Object implements Serializable

Class backtype.storm.spout.ShellSpout extends java.lang.Object implements Serializable

Package backtype.storm.state

Package backtype.storm.task

Class backtype.storm.task.ShellBolt extends java.lang.Object implements Serializable

Serialized Fields

_subprocess

java.lang.Process _subprocess

_processin

java.io.DataOutputStream _processin

_processout

java.io.BufferedReader _processout

_collector

OutputCollector _collector

_inputs

java.util.Map<K,V> _inputs

command

java.lang.String[] command

Package backtype.storm.testing

Class backtype.storm.testing.AckTracker extends java.lang.Object implements Serializable

Serialized Fields

_id

java.lang.String _id

Class backtype.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable

Serialized Fields

_richDelegate

IRichBolt _richDelegate

Class backtype.storm.testing.CountingBatchBolt extends BaseBatchBolt implements Serializable

Serialized Fields

_collector

BatchOutputCollector _collector

_id

java.lang.Object _id

_count

int _count

Class backtype.storm.testing.CountingCommitBolt extends BaseTransactionalBolt implements Serializable

Serialized Fields

_collector

BatchOutputCollector _collector

_id

TransactionAttempt _id

_count

int _count

Class backtype.storm.testing.FeederSpout extends java.lang.Object implements Serializable

Serialized Fields

_id

int _id

_outFields

Fields _outFields

_collector

SpoutOutputCollector _collector

_ackFailDelegate

AckFailDelegate _ackFailDelegate

Class backtype.storm.testing.FixedTuple extends java.lang.Object implements Serializable

Serialized Fields

stream

java.lang.String stream

values

java.util.List<E> values

Class backtype.storm.testing.FixedTupleSpout extends java.lang.Object implements Serializable

Serialized Fields

_tuples

java.util.List<E> _tuples

_collector

SpoutOutputCollector _collector

_context

TopologyContext _context

_serveTuples

java.util.List<E> _serveTuples

_pending

java.util.Map<K,V> _pending

_id

java.lang.String _id

Class backtype.storm.testing.IdentityBolt extends BaseBasicBolt implements Serializable

Serialized Fields

_fields

Fields _fields

Class backtype.storm.testing.KeyedCountingBatchBolt extends BaseBatchBolt implements Serializable

Serialized Fields

_collector

BatchOutputCollector _collector

_id

java.lang.Object _id

_counts

java.util.Map<K,V> _counts

Class backtype.storm.testing.KeyedCountingCommitterBolt extends KeyedCountingBatchBolt implements Serializable

Class backtype.storm.testing.KeyedSummingBatchBolt extends BaseBatchBolt implements Serializable

Serialized Fields

_collector

BatchOutputCollector _collector

_id

java.lang.Object _id

_sums

java.util.Map<K,V> _sums

Class backtype.storm.testing.MemoryTransactionalSpout extends java.lang.Object implements Serializable

Serialized Fields

_id

java.lang.String _id

_finishedPartitionsId

java.lang.String _finishedPartitionsId

_takeAmt

int _takeAmt

_outFields

Fields _outFields

Class backtype.storm.testing.NGrouping extends java.lang.Object implements Serializable

Serialized Fields

_n

int _n

Class backtype.storm.testing.NonRichBoltTracker extends java.lang.Object implements Serializable

Serialized Fields

_delegate

IBolt _delegate

_trackId

java.lang.String _trackId

Class backtype.storm.testing.SpoutTracker extends BaseRichSpout implements Serializable

Serialized Fields

_delegate

IRichSpout _delegate

_tracker

backtype.storm.testing.SpoutTracker.SpoutTrackOutputCollector _tracker

_trackId

java.lang.String _trackId

Class backtype.storm.testing.TestAggregatesCounter extends BaseRichBolt implements Serializable

Serialized Fields

_counts

java.util.Map<K,V> _counts

_collector

OutputCollector _collector

Class backtype.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable

Serialized Fields

_componentConf

java.util.Map<K,V> _componentConf

_conf

java.util.Map<K,V> _conf

Class backtype.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable

Serialized Fields

_count

int _count

_collector

OutputCollector _collector

Class backtype.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable

Class backtype.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable

Serialized Fields

_isDistributed

boolean _isDistributed

_outFields

Fields _outFields

Class backtype.storm.testing.TestSerObject extends java.lang.Object implements Serializable

Serialized Fields

f1

int f1

f2

int f2

Class backtype.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable

Serialized Fields

_counts

java.util.Map<K,V> _counts

Class backtype.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable

Serialized Fields

_isDistributed

boolean _isDistributed

_collector

SpoutOutputCollector _collector

Class backtype.storm.testing.TupleCaptureBolt extends java.lang.Object implements Serializable

Serialized Fields

_name

java.lang.String _name

_collector

OutputCollector _collector

Package backtype.storm.topology

Class backtype.storm.topology.BasicBoltExecutor extends java.lang.Object implements Serializable

Serialized Fields

_bolt

IBasicBolt _bolt

Class backtype.storm.topology.FailedException extends java.lang.RuntimeException implements Serializable

Package backtype.storm.topology.base

Class backtype.storm.topology.base.BaseBasicBolt extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BaseBatchBolt extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BaseComponent extends java.lang.Object implements Serializable

Class backtype.storm.topology.base.BaseOpaquePartitionedTransactionalSpout extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BasePartitionedTransactionalSpout extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BaseRichBolt extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BaseRichSpout extends BaseComponent implements Serializable

Class backtype.storm.topology.base.BaseTransactionalBolt extends BaseBatchBolt<TransactionAttempt> implements Serializable

Class backtype.storm.topology.base.BaseTransactionalSpout extends BaseComponent implements Serializable

Package backtype.storm.transactional

Class backtype.storm.transactional.TransactionalSpoutBatchExecutor extends java.lang.Object implements Serializable

Serialized Fields

_collector

BatchOutputCollectorImpl _collector

_spout

ITransactionalSpout<T> _spout

_emitter

ITransactionalSpout.Emitter<X> _emitter

_activeTransactions

java.util.TreeMap<K,V> _activeTransactions

Class backtype.storm.transactional.TransactionalSpoutCoordinator extends java.lang.Object implements Serializable

Serialized Fields

_spout

ITransactionalSpout<T> _spout

_coordinator

ITransactionalSpout.Coordinator<X> _coordinator

_state

TransactionalState _state

_coordinatorState

RotatingTransactionalState _coordinatorState

_activeTx

java.util.TreeMap<K,V> _activeTx

_collector

SpoutOutputCollector _collector

_currTransaction

java.math.BigInteger _currTransaction

_maxTransactionActive

int _maxTransactionActive

_initializer

backtype.storm.transactional.TransactionalSpoutCoordinator.StateInitializer _initializer

Package backtype.storm.transactional.partitioned

Class backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IOpaquePartitionedTransactionalSpout<T> _spout

Class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IPartitionedTransactionalSpout<T> _spout

Package backtype.storm.tuple

Class backtype.storm.tuple.Fields extends java.lang.Object implements Serializable

Serialized Fields

_fields

java.util.List<E> _fields

_index

java.util.Map<K,V> _index

Class backtype.storm.tuple.Values extends java.util.ArrayList<java.lang.Object> implements Serializable

Package backtype.storm.utils

Class backtype.storm.utils.Container extends java.lang.Object implements Serializable

Serialized Fields

object

java.lang.Object object