|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
---|
java.util.Map<K,V> _fields
java.util.List<E> _fnSpec
java.util.List<E> _confSpec
java.util.List<E> _params
IBolt _bolt
Class backtype.storm.clojure.ClojureSpout extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _fields
java.util.List<E> _fnSpec
java.util.List<E> _confSpec
java.util.List<E> _params
ISpout _spout
Class backtype.storm.clojure.RichShellBolt extends ShellBolt implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _outputs
Package backtype.storm.coordination |
---|
Class backtype.storm.coordination.BatchBoltExecutor extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
byte[] _boltSer
java.util.Map<K,V> _openTransactions
java.util.Map<K,V> _conf
TopologyContext _context
BatchOutputCollectorImpl _collector
Class backtype.storm.coordination.CoordinatedBolt extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _sourceArgs
CoordinatedBolt.IdStreamSpec _idStreamSpec
IRichBolt _delegate
java.lang.Integer _numSourceReports
java.util.List<E> _countOutTasks
OutputCollector _collector
TimeCacheMap<K,V> _tracked
Class backtype.storm.coordination.CoordinatedBolt.IdStreamSpec extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
GlobalStreamId _id
Class backtype.storm.coordination.CoordinatedBolt.SourceArgs extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
boolean singleCount
Package backtype.storm.drpc |
---|
Class backtype.storm.drpc.DRPCSpout extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
SpoutOutputCollector _collector
java.util.List<E> _clients
java.lang.String _function
java.lang.String _local_drpc_id
Class backtype.storm.drpc.JoinResult extends BaseRichBolt implements Serializable |
---|
Serialized Fields |
---|
java.lang.String returnComponent
java.util.Map<K,V> returns
java.util.Map<K,V> results
OutputCollector _collector
Class backtype.storm.drpc.KeyedFairBolt extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
IRichBolt _delegate
KeyedRoundRobinQueue<V> _rrQueue
java.lang.Thread _executor
CoordinatedBolt.FinishedCallback _callback
Class backtype.storm.drpc.PrepareRequest extends BaseBasicBolt implements Serializable |
---|
Serialized Fields |
---|
java.util.Random rand
Class backtype.storm.drpc.ReturnResults extends BaseRichBolt implements Serializable |
---|
Serialized Fields |
---|
OutputCollector _collector
boolean local
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 |
---|
IBolt task
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 |
---|
java.lang.Process _subprocess
java.io.DataOutputStream _processin
java.io.BufferedReader _processout
OutputCollector _collector
java.util.Map<K,V> _inputs
java.lang.String[] command
Package backtype.storm.testing |
---|
Class backtype.storm.testing.AckTracker extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.lang.String _id
Class backtype.storm.testing.BoltTracker extends NonRichBoltTracker implements Serializable |
---|
Serialized Fields |
---|
IRichBolt _richDelegate
Class backtype.storm.testing.CountingBatchBolt extends BaseBatchBolt implements Serializable |
---|
Serialized Fields |
---|
BatchOutputCollector _collector
java.lang.Object _id
int _count
Class backtype.storm.testing.CountingCommitBolt extends BaseTransactionalBolt implements Serializable |
---|
Serialized Fields |
---|
BatchOutputCollector _collector
TransactionAttempt _id
int _count
Class backtype.storm.testing.FeederSpout extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
int _id
Fields _outFields
SpoutOutputCollector _collector
AckFailDelegate _ackFailDelegate
Class backtype.storm.testing.FixedTuple extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.lang.String stream
java.util.List<E> values
Class backtype.storm.testing.FixedTupleSpout extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.util.List<E> _tuples
SpoutOutputCollector _collector
TopologyContext _context
java.util.List<E> _serveTuples
java.util.Map<K,V> _pending
java.lang.String _id
Class backtype.storm.testing.IdentityBolt extends BaseBasicBolt implements Serializable |
---|
Serialized Fields |
---|
Fields _fields
Class backtype.storm.testing.KeyedCountingBatchBolt extends BaseBatchBolt implements Serializable |
---|
Serialized Fields |
---|
BatchOutputCollector _collector
java.lang.Object _id
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 |
---|
BatchOutputCollector _collector
java.lang.Object _id
java.util.Map<K,V> _sums
Class backtype.storm.testing.MemoryTransactionalSpout extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.lang.String _id
java.lang.String _finishedPartitionsId
int _takeAmt
Fields _outFields
Class backtype.storm.testing.NGrouping extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
int _n
Class backtype.storm.testing.NonRichBoltTracker extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
IBolt _delegate
java.lang.String _trackId
Class backtype.storm.testing.SpoutTracker extends BaseRichSpout implements Serializable |
---|
Serialized Fields |
---|
IRichSpout _delegate
backtype.storm.testing.SpoutTracker.SpoutTrackOutputCollector _tracker
java.lang.String _trackId
Class backtype.storm.testing.TestAggregatesCounter extends BaseRichBolt implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _counts
OutputCollector _collector
Class backtype.storm.testing.TestConfBolt extends BaseBasicBolt implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _componentConf
java.util.Map<K,V> _conf
Class backtype.storm.testing.TestGlobalCount extends BaseRichBolt implements Serializable |
---|
Serialized Fields |
---|
int _count
OutputCollector _collector
Class backtype.storm.testing.TestPlannerBolt extends BaseRichBolt implements Serializable |
---|
Class backtype.storm.testing.TestPlannerSpout extends BaseRichSpout implements Serializable |
---|
Serialized Fields |
---|
boolean _isDistributed
Fields _outFields
Class backtype.storm.testing.TestSerObject extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
int f1
int f2
Class backtype.storm.testing.TestWordCounter extends BaseBasicBolt implements Serializable |
---|
Serialized Fields |
---|
java.util.Map<K,V> _counts
Class backtype.storm.testing.TestWordSpout extends BaseRichSpout implements Serializable |
---|
Serialized Fields |
---|
boolean _isDistributed
SpoutOutputCollector _collector
Class backtype.storm.testing.TupleCaptureBolt extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.lang.String _name
OutputCollector _collector
Package backtype.storm.topology |
---|
Class backtype.storm.topology.BasicBoltExecutor extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
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 |
---|
BatchOutputCollectorImpl _collector
ITransactionalSpout<T> _spout
ITransactionalSpout.Emitter<X> _emitter
java.util.TreeMap<K,V> _activeTransactions
Class backtype.storm.transactional.TransactionalSpoutCoordinator extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
ITransactionalSpout<T> _spout
ITransactionalSpout.Coordinator<X> _coordinator
TransactionalState _state
RotatingTransactionalState _coordinatorState
java.util.TreeMap<K,V> _activeTx
SpoutOutputCollector _collector
java.math.BigInteger _currTransaction
int _maxTransactionActive
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 |
---|
IOpaquePartitionedTransactionalSpout<T> _spout
Class backtype.storm.transactional.partitioned.PartitionedTransactionalSpoutExecutor extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
IPartitionedTransactionalSpout<T> _spout
Package backtype.storm.tuple |
---|
Class backtype.storm.tuple.Fields extends java.lang.Object implements Serializable |
---|
Serialized Fields |
---|
java.util.List<E> _fields
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 |
---|
java.lang.Object object
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |