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

Class backtype.storm.clojure.RichShellSpout extends ShellSpout 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 BaseRichSpout 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.NoOpSpout extends java.lang.Object implements Serializable

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

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

Serialized Fields

_collector

SpoutOutputCollector _collector

_command

java.lang.String[] _command

_process

ShellProcess _process

_next

JSONObject _next

_ack

JSONObject _ack

_fail

JSONObject _fail

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

_collector

OutputCollector _collector

_inputs

java.util.Map<K,V> _inputs

_command

java.lang.String[] _command

_process

ShellProcess _process

_running

boolean _running

_exception

java.lang.Throwable _exception

_pendingWrites

java.util.concurrent.LinkedBlockingQueue<E> _pendingWrites

_rand

java.util.Random _rand

_readerThread

java.lang.Thread _readerThread

_writerThread

java.lang.Thread _writerThread

Package backtype.storm.testing

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

Serialized Fields

_acked

java.lang.String _acked

_failed

java.lang.String _failed

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

Serialized Fields

_id

java.lang.String _id

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

Serialized Fields

_wordComponent

java.lang.String _wordComponent

word

java.lang.String word

intSet

java.util.List<E> intSet

_collector

BatchOutputCollector _collector

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

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

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

_initialPartitions

java.util.Map<K,V> _initialPartitions

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

Serialized Fields

_n

int _n

_outTasks

java.util.List<E> _outTasks

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

Serialized Fields

_id

java.lang.String _id

_finishedPartitionsId

java.lang.String _finishedPartitionsId

_disabledId

java.lang.String _disabledId

_takeAmt

int _takeAmt

_outFields

Fields _outFields

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

Serialized Fields

_outFields

Fields _outFields

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.TrackedTopology extends java.util.HashMap implements Serializable

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

_rand

java.util.Random _rand

_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

Package storm.trident.drpc

Class storm.trident.drpc.ReturnResultsReducer extends java.lang.Object implements Serializable

Serialized Fields

local

boolean local

_clients

java.util.Map<K,V> _clients

Package storm.trident.operation

Class storm.trident.operation.BaseAggregator extends BaseOperation implements Serializable

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

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

Class storm.trident.operation.BaseMultiReducer extends java.lang.Object implements Serializable

Class storm.trident.operation.BaseOperation extends java.lang.Object implements Serializable

Package storm.trident.operation.builtin

Class storm.trident.operation.builtin.Count extends java.lang.Object implements Serializable

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

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

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

Class storm.trident.operation.builtin.FirstN.FirstNAgg extends BaseAggregator<storm.trident.operation.builtin.FirstN.FirstNAgg.State> implements Serializable

Serialized Fields

_n

int _n

Class storm.trident.operation.builtin.FirstN.FirstNSortedAgg extends BaseAggregator<java.util.PriorityQueue> implements Serializable

Serialized Fields

_n

int _n

_sortField

java.lang.String _sortField

_reverse

boolean _reverse

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

Class storm.trident.operation.builtin.Negate extends java.lang.Object implements Serializable

Serialized Fields

_delegate

Filter _delegate

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

Class storm.trident.operation.builtin.Sum extends java.lang.Object implements Serializable

Package storm.trident.operation.impl

Class storm.trident.operation.impl.ChainedAggregatorImpl extends java.lang.Object implements Serializable

Serialized Fields

_aggs

Aggregator<T>[] _aggs

_inputFactories

TridentTupleView.ProjectionFactory[] _inputFactories

_fact

ComboList.Factory _fact

_inputFields

Fields[] _inputFields

Class storm.trident.operation.impl.CombinerAggregatorCombineImpl extends java.lang.Object implements Serializable

Serialized Fields

_agg

CombinerAggregator<T> _agg

Class storm.trident.operation.impl.CombinerAggregatorInitImpl extends java.lang.Object implements Serializable

Serialized Fields

_agg

CombinerAggregator<T> _agg

Class storm.trident.operation.impl.CombinerAggStateUpdater extends java.lang.Object implements Serializable

Serialized Fields

_agg

CombinerAggregator<T> _agg

Class storm.trident.operation.impl.FilterExecutor extends java.lang.Object implements Serializable

Serialized Fields

_filter

Filter _filter

Class storm.trident.operation.impl.GlobalBatchToPartition extends java.lang.Object implements Serializable

Class storm.trident.operation.impl.GroupedAggregator extends java.lang.Object implements Serializable

Serialized Fields

_groupFactory

TridentTupleView.ProjectionFactory _groupFactory

_inputFactory

TridentTupleView.ProjectionFactory _inputFactory

_agg

Aggregator<T> _agg

_fact

ComboList.Factory _fact

_inFields

Fields _inFields

_groupFields

Fields _groupFields

Class storm.trident.operation.impl.GroupedMultiReducerExecutor extends java.lang.Object implements Serializable

Serialized Fields

_reducer

GroupedMultiReducer<T> _reducer

_groupFields

java.util.List<E> _groupFields

_inputFields

java.util.List<E> _inputFields

_groupFactories

java.util.List<E> _groupFactories

_inputFactories

java.util.List<E> _inputFactories

Class storm.trident.operation.impl.IdentityMultiReducer extends java.lang.Object implements Serializable

Class storm.trident.operation.impl.IndexHashBatchToPartition extends java.lang.Object implements Serializable

Class storm.trident.operation.impl.JoinerMultiReducer extends java.lang.Object implements Serializable

Serialized Fields

_types

java.util.List<E> _types

_sideFields

java.util.List<E> _sideFields

_numGroupFields

int _numGroupFields

_factory

ComboList.Factory _factory

Class storm.trident.operation.impl.ReducerAggregatorImpl extends java.lang.Object implements Serializable

Serialized Fields

_agg

ReducerAggregator<T> _agg

Class storm.trident.operation.impl.ReducerAggStateUpdater extends java.lang.Object implements Serializable

Serialized Fields

_agg

ReducerAggregator<T> _agg

Class storm.trident.operation.impl.SingleEmitAggregator extends java.lang.Object implements Serializable

Serialized Fields

_agg

Aggregator<T> _agg

_batchToPartition

SingleEmitAggregator.BatchToPartition _batchToPartition

myPartitionIndex

int myPartitionIndex

totalPartitions

int totalPartitions

Class storm.trident.operation.impl.TrueFilter extends java.lang.Object implements Serializable

Package storm.trident.partition

Class storm.trident.partition.GlobalGrouping extends java.lang.Object implements Serializable

Serialized Fields

target

java.util.List<E> target

Class storm.trident.partition.IdentityGrouping extends java.lang.Object implements Serializable

Serialized Fields

ret

java.util.List<E> ret

_precomputed

java.util.Map<K,V> _precomputed

Class storm.trident.partition.IndexHashGrouping extends java.lang.Object implements Serializable

Serialized Fields

_index

int _index

_targets

java.util.List<E> _targets

Package storm.trident.planner

Class storm.trident.planner.Node extends java.lang.Object implements Serializable

Serialized Fields

nodeId

java.lang.String nodeId

allOutputFields

Fields allOutputFields

streamId

java.lang.String streamId

parallelismHint

java.lang.Integer parallelismHint

stateInfo

NodeStateInfo stateInfo

creationIndex

int creationIndex

Class storm.trident.planner.NodeStateInfo extends java.lang.Object implements Serializable

Serialized Fields

id

java.lang.String id

spec

StateSpec spec

Class storm.trident.planner.PartitionNode extends Node implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream ois)
                 throws java.lang.ClassNotFoundException,
                        java.io.IOException

Throws:

java.lang.ClassNotFoundException

java.io.IOException

writeObject

private void writeObject(java.io.ObjectOutputStream oos)
                  throws java.io.IOException

Throws:

java.io.IOException

Class storm.trident.planner.ProcessorNode extends Node implements Serializable

Serialized Fields

committer

boolean committer

processor

TridentProcessor processor

selfOutFields

Fields selfOutFields

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

Serialized Fields

spout

java.lang.Object spout

txId

java.lang.String txId

type

SpoutNode.SpoutType type

Class storm.trident.planner.SubtopologyBolt extends java.lang.Object implements Serializable

Serialized Fields

_graph

DirectedGraph _graph

_nodes

java.util.Set<E> _nodes

_roots

java.util.Map<K,V> _roots

_outputFactories

java.util.Map<K,V> _outputFactories

_myTopologicallyOrdered

java.util.Map<K,V> _myTopologicallyOrdered

_batchGroups

java.util.Map<K,V> _batchGroups

Package storm.trident.planner.processor

Class storm.trident.planner.processor.AggregateProcessor extends java.lang.Object implements Serializable

Serialized Fields

_agg

Aggregator<T> _agg

_context

TridentContext _context

_collector

FreshCollector _collector

_inputFields

Fields _inputFields

_projection

TridentTupleView.ProjectionFactory _projection

Class storm.trident.planner.processor.EachProcessor extends java.lang.Object implements Serializable

Serialized Fields

_function

Function _function

_context

TridentContext _context

_collector

AppendCollector _collector

_inputFields

Fields _inputFields

_projection

TridentTupleView.ProjectionFactory _projection

Class storm.trident.planner.processor.MultiReducerProcessor extends java.lang.Object implements Serializable

Serialized Fields

_reducer

MultiReducer<T> _reducer

_context

TridentContext _context

_streamToIndex

java.util.Map<K,V> _streamToIndex

_projectFields

java.util.List<E> _projectFields

_projectionFactories

TridentTupleView.ProjectionFactory[] _projectionFactories

_collector

FreshCollector _collector

Class storm.trident.planner.processor.PartitionPersistProcessor extends java.lang.Object implements Serializable

Serialized Fields

_updater

StateUpdater<S extends State> _updater

_state

State _state

_stateId

java.lang.String _stateId

_context

TridentContext _context

_inputFields

Fields _inputFields

_projection

TridentTupleView.ProjectionFactory _projection

_collector

FreshCollector _collector

Class storm.trident.planner.processor.ProjectedProcessor extends java.lang.Object implements Serializable

Serialized Fields

_projectFields

Fields _projectFields

_factory

TridentTupleView.ProjectionFactory _factory

_context

TridentContext _context

Class storm.trident.planner.processor.StateQueryProcessor extends java.lang.Object implements Serializable

Serialized Fields

_function

QueryFunction<S extends State,T> _function

_state

State _state

_stateId

java.lang.String _stateId

_context

TridentContext _context

_inputFields

Fields _inputFields

_projection

TridentTupleView.ProjectionFactory _projection

_collector

AppendCollector _collector

Package storm.trident.spout

Class storm.trident.spout.BatchSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IBatchSpout _spout

Class storm.trident.spout.OpaquePartitionedTridentSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IOpaquePartitionedTridentSpout<T> _spout

Class storm.trident.spout.PartitionedTridentSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IPartitionedTridentSpout<T> _spout

Class storm.trident.spout.RichSpoutBatchExecutor extends java.lang.Object implements Serializable

Serialized Fields

_spout

IRichSpout _spout

Class storm.trident.spout.RichSpoutBatchTriggerer extends java.lang.Object implements Serializable

Serialized Fields

_stream

java.lang.String _stream

_delegate

IRichSpout _delegate

_outputTasks

java.util.List<E> _outputTasks

_rand

java.util.Random _rand

_coordStream

java.lang.String _coordStream

_msgIdToBatchId

java.util.Map<K,V> _msgIdToBatchId

_finishConditions

java.util.Map<K,V> _finishConditions

Class storm.trident.spout.TridentSpoutCoordinator extends java.lang.Object implements Serializable

Serialized Fields

_spout

ITridentSpout<T> _spout

_coord

ITridentSpout.BatchCoordinator<X> _coord

_state

RotatingTransactionalState _state

_underlyingState

TransactionalState _underlyingState

_id

java.lang.String _id

_initializer

storm.trident.spout.TridentSpoutCoordinator.StateInitializer _initializer

Class storm.trident.spout.TridentSpoutExecutor extends java.lang.Object implements Serializable

Serialized Fields

_collector

storm.trident.spout.TridentSpoutExecutor.AddIdCollector _collector

_spout

ITridentSpout<T> _spout

_emitter

ITridentSpout.Emitter<X> _emitter

_streamName

java.lang.String _streamName

_txStateId

java.lang.String _txStateId

_activeBatches

java.util.TreeMap<K,V> _activeBatches

Package storm.trident.state

Class storm.trident.state.BaseQueryFunction extends BaseOperation implements Serializable

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

Class storm.trident.state.JSONNonTransactionalSerializer extends java.lang.Object implements Serializable

Class storm.trident.state.JSONOpaqueSerializer extends java.lang.Object implements Serializable

Class storm.trident.state.JSONTransactionalSerializer extends java.lang.Object implements Serializable

Class storm.trident.state.StateSpec extends java.lang.Object implements Serializable

Serialized Fields

stateFactory

StateFactory stateFactory

requiredNumPartitions

java.lang.Integer requiredNumPartitions

Package storm.trident.state.map

Class storm.trident.state.map.MapCombinerAggStateUpdater extends java.lang.Object implements Serializable

Serialized Fields

_agg

CombinerAggregator<T> _agg

_groupFields

Fields _groupFields

_inputFields

Fields _inputFields

_groupFactory

TridentTupleView.ProjectionFactory _groupFactory

_inputFactory

TridentTupleView.ProjectionFactory _inputFactory

_factory

ComboList.Factory _factory

Class storm.trident.state.map.MapReducerAggStateUpdater extends java.lang.Object implements Serializable

Serialized Fields

_agg

ReducerAggregator<T> _agg

_groupFields

Fields _groupFields

_inputFields

Fields _inputFields

_groupFactory

TridentTupleView.ProjectionFactory _groupFactory

_inputFactory

TridentTupleView.ProjectionFactory _inputFactory

_factory

ComboList.Factory _factory

Package storm.trident.testing

Class storm.trident.testing.CountAsAggregator extends BaseAggregator<storm.trident.testing.CountAsAggregator.State> implements Serializable

Class storm.trident.testing.FeederBatchSpout extends java.lang.Object implements Serializable

Serialized Fields

_id

java.lang.String _id

_semaphoreId

java.lang.String _semaphoreId

_outFields

Fields _outFields

_waitToEmit

boolean _waitToEmit

Class storm.trident.testing.FeederCommitterBatchSpout extends java.lang.Object implements Serializable

Serialized Fields

_spout

FeederBatchSpout _spout

Class storm.trident.testing.FixedBatchSpout extends java.lang.Object implements Serializable

Serialized Fields

fields

Fields fields

outputs

java.util.List<E>[] outputs

maxBatchSize

int maxBatchSize

index

int index

cycle

boolean cycle

Class storm.trident.testing.LRUMemoryMapState.Factory extends java.lang.Object implements Serializable

Serialized Fields

_id

java.lang.String _id

_maxSize

int _maxSize

Class storm.trident.testing.MemoryMapState.Factory extends java.lang.Object implements Serializable

Serialized Fields

_id

java.lang.String _id

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

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

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

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

Package storm.trident.topology

Class storm.trident.topology.MasterBatchCoordinator extends BaseRichSpout implements Serializable

Serialized Fields

_states

java.util.List<E> _states

_activeTx

java.util.TreeMap<K,V> _activeTx

_collector

SpoutOutputCollector _collector

_rand

java.util.Random _rand

_currTransaction

java.lang.Long _currTransaction

_maxTransactionActive

int _maxTransactionActive

_coordinators

java.util.List<E> _coordinators

_managedSpoutIds

java.util.List<E> _managedSpoutIds

_spouts

java.util.List<E> _spouts

_active

boolean _active

Class storm.trident.topology.TridentBoltExecutor extends java.lang.Object implements Serializable

Serialized Fields

_batchGroupIds

java.util.Map<K,V> _batchGroupIds

_coordSpecs

java.util.Map<K,V> _coordSpecs

_coordConditions

java.util.Map<K,V> _coordConditions

_bolt

ITridentBatchBolt _bolt

_messageTimeoutMs

long _messageTimeoutMs

_lastRotate

long _lastRotate

_batches

RotatingMap<K,V> _batches

_collector

OutputCollector _collector

_coordCollector

TridentBoltExecutor.CoordinatedOutputCollector _coordCollector

_coordOutputCollector

BatchOutputCollector _coordOutputCollector

_context

TopologyContext _context

Class storm.trident.topology.TridentBoltExecutor.CoordCondition extends java.lang.Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

expectedTaskReports

int expectedTaskReports

targetTasks

java.util.Set<E> targetTasks

Class storm.trident.topology.TridentBoltExecutor.CoordSpec extends java.lang.Object implements Serializable

Serialized Fields

commitStream

GlobalStreamId commitStream

coords

java.util.Map<K,V> coords

Class storm.trident.topology.TridentBoltExecutor.CoordType extends java.lang.Object implements Serializable

Serialized Fields

singleCount

boolean singleCount

Package storm.trident.tuple

Class storm.trident.tuple.ComboList.Factory extends java.lang.Object implements Serializable

Serialized Fields

index

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

Class storm.trident.tuple.TridentTupleView.FreshOutputFactory extends java.lang.Object implements Serializable

Serialized Fields

_fieldIndex

java.util.Map<K,V> _fieldIndex

_index

ValuePointer[] _index

Class storm.trident.tuple.TridentTupleView.OperationOutputFactory extends java.lang.Object implements Serializable

Serialized Fields

_fieldIndex

java.util.Map<K,V> _fieldIndex

_index

ValuePointer[] _index

_parent

TridentTuple.Factory _parent

Class storm.trident.tuple.TridentTupleView.ProjectionFactory extends java.lang.Object implements Serializable

Serialized Fields

_fieldIndex

java.util.Map<K,V> _fieldIndex

_index

ValuePointer[] _index

_parent

TridentTuple.Factory _parent

Class storm.trident.tuple.TridentTupleView.RootFactory extends java.lang.Object implements Serializable

Serialized Fields

index

ValuePointer[] index

fieldIndex

java.util.Map<K,V> fieldIndex

Package storm.trident.util

Class storm.trident.util.ErrorEdgeFactory extends java.lang.Object implements Serializable

Class storm.trident.util.IndexedEdge extends java.lang.Object implements Serializable

Serialized Fields

source

java.lang.Object source

target

java.lang.Object target

index

int index

Class storm.trident.util.LRUMap extends java.util.LinkedHashMap<A,B> implements Serializable

Serialized Fields

_maxSize

int _maxSize