Name | Description | Type | Package | Framework |
AggregateProcessor | Class | storm.trident.planner.processor | Apache Storm | |
Aggregator | Interface | storm.trident.operation | Apache Storm | |
AppendCollector | Class | storm.trident.planner.processor | Apache Storm | |
BaseAggregator | Class | storm.trident.operation | Apache Storm | |
BaseFilter | Class | storm.trident.operation | Apache Storm | |
BaseFunction | Class | storm.trident.operation | Apache Storm | |
BaseMultiReducer | Class | storm.trident.operation | Apache Storm | |
BaseOperation | Class | storm.trident.operation | Apache Storm | |
BaseQueryFunction | Class | storm.trident.state | Apache Storm | |
BaseStateUpdater | Class | storm.trident.state | Apache Storm | |
BatchInfo | Class | storm.trident.topology | Apache Storm | |
BatchSpoutExecutor | Class | storm.trident.spout | Apache Storm | |
BatchSpoutExecutor .EmptyCoordinator | Class | storm.trident.spout.BatchSpoutExecutor | Apache Storm | |
BridgeReceiver | Class | storm.trident.planner | Apache Storm | |
CachedBatchReadsMap | Class | storm.trident.state.map | Apache Storm | |
CachedBatchReadsMap .RetVal | Class | storm.trident.state.map.CachedBatchReadsMap | Apache Storm | |
CachedMap | Useful to layer over a map that communicates with a database. | Class | storm.trident.state.map | Apache Storm |
CaptureCollector | Class | storm.trident.operation.impl | Apache Storm | |
ChainedAggregatorDeclarer | Class | storm.trident.fluent | Apache Storm | |
ChainedAggregatorDeclarer .AggregationPartition | Interface | storm.trident.fluent.ChainedAggregatorDeclarer | Apache Storm | |
ChainedAggregatorImpl | Class | storm.trident.operation.impl | Apache Storm | |
ChainedFullAggregatorDeclarer | Interface | storm.trident.fluent | Apache Storm | |
ChainedPartitionAggregatorDeclarer | Interface | storm.trident.fluent | Apache Storm | |
ChainedResult | Class | storm.trident.operation.impl | Apache Storm | |
CombinerAggregator | Interface | storm.trident.operation | Apache Storm | |
CombinerAggregatorCombineImpl | Class | storm.trident.operation.impl | Apache Storm | |
CombinerAggregatorInitImpl | Class | storm.trident.operation.impl | Apache Storm | |
CombinerAggStateUpdater | Class | storm.trident.operation.impl | Apache Storm | |
CombinerValueUpdater | Class | storm.trident.state | Apache Storm | |
ComboList | Class | storm.trident.tuple | Apache Storm | |
ComboList .Factory | Class | storm.trident.tuple.ComboList | Apache Storm | |
ConsList | Class | storm.trident.tuple | Apache Storm | |
Count | Class | storm.trident.operation.builtin | Apache Storm | |
CountAsAggregator | Class | storm.trident.testing | Apache Storm | |
Debug | Class | storm.trident.operation.builtin | Apache Storm | |
EachProcessor | Class | storm.trident.planner.processor | Apache Storm | |
Equals | Class | storm.trident.operation.builtin | Apache Storm | |
ErrorEdgeFactory | Class | storm.trident.util | Apache Storm | |
FeederBatchSpout | Class | storm.trident.testing | Apache Storm | |
FeederCommitterBatchSpout | Class | storm.trident.testing | Apache Storm | |
Filter | Interface | storm.trident.operation | Apache Storm | |
FilterExecutor | Class | storm.trident.operation.impl | Apache Storm | |
FilterNull | Class | storm.trident.operation.builtin | Apache Storm | |
FirstN | Class | storm.trident.operation.builtin | Apache Storm | |
FirstN .FirstNAgg | Class | storm.trident.operation.builtin.FirstN | Apache Storm | |
FirstN .FirstNSortedAgg | Class | storm.trident.operation.builtin.FirstN | Apache Storm | |
FixedBatchSpout | Class | storm.trident.testing | Apache Storm | |
FreshCollector | Class | storm.trident.planner.processor | Apache Storm | |
Function | Interface | storm.trident.operation | Apache Storm | |
GlobalAggregationScheme | Interface | storm.trident.fluent | Apache Storm | |
GlobalBatchToPartition | Class | storm.trident.operation.impl | Apache Storm | |
GlobalGrouping | Class | storm.trident.partition | Apache Storm | |
GraphGrouper | Class | storm.trident.graph | Apache Storm | |
Group | Class | storm.trident.graph | Apache Storm | |
GroupCollector | Class | storm.trident.operation.impl | Apache Storm | |
GroupedAggregator | Class | storm.trident.operation.impl | Apache Storm | |
GroupedMultiReducer | Interface | storm.trident.operation | Apache Storm | |
GroupedMultiReducerExecutor | Class | storm.trident.operation.impl | Apache Storm | |
GroupedStream | Class | storm.trident.fluent | Apache Storm | |
IAggregatableStream | Interface | storm.trident.fluent | Apache Storm | |
IBackingMap | Interface | storm.trident.state.map | Apache Storm | |
IBatchID | Skip navigation linksOverviewPackageClassUseTreeDeprecatedIndexHelp | Interface | storm.trident.spout | Apache Storm |
IBatchSpout | Interface | storm.trident.spout | Apache Storm | |
IChainedAggregatorDeclarer | Skip navigation linksOverviewPackageClassUseTreeDeprecatedIndexHelp | Interface | storm.trident.fluent | Apache Storm |
ICommitterTridentSpout | Interface | storm.trident.spout | Apache Storm | |
ICommitterTridentSpout .Emitter | Interface | storm.trident.spout.ICommitterTridentSpout | Apache Storm | |
IdentityGrouping | Class | storm.trident.partition | Apache Storm | |
IdentityMultiReducer | Class | storm.trident.operation.impl | Apache Storm | |
IndexedEdge | Class | storm.trident.util | Apache Storm | |
IndexHashBatchToPartition | Class | storm.trident.operation.impl | Apache Storm | |
IndexHashGrouping | Class | storm.trident.partition | Apache Storm | |
IOpaquePartitionedTridentSpout | This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id. | Interface | storm.trident.spout | Apache Storm |
IOpaquePartitionedTridentSpout .Coordinator | Interface | storm.trident.spout.IOpaquePartitionedTridentSpout | Apache Storm | |
IOpaquePartitionedTridentSpout .Emitter | Interface | storm.trident.spout.IOpaquePartitionedTridentSpout | Apache Storm | |
IPartitionedTridentSpout | This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. | Interface | storm.trident.spout | Apache Storm |
IPartitionedTridentSpout .Coordinator | Return the partitions currently in the source of data. | Interface | storm.trident.spout.IPartitionedTridentSpout | Apache Storm |
IPartitionedTridentSpout .Emitter | Interface | storm.trident.spout.IPartitionedTridentSpout | Apache Storm | |
ISpoutPartition | This is used as a Zookeeper node path for storing metadata. | Interface | storm.trident.spout | Apache Storm |
ITridentBatchBolt | Interface | storm.trident.topology | Apache Storm | |
ITridentSpout | Interface | storm.trident.spout | Apache Storm | |
ITridentSpout .BatchCoordinator | Release any resources from this coordinator. | Interface | storm.trident.spout.ITridentSpout | Apache Storm |
ITridentSpout .Emitter | Release any resources held by this emitter. | Interface | storm.trident.spout.ITridentSpout | Apache Storm |
ITupleCollection | Interface | storm.trident.state | Apache Storm | |
JoinerMultiReducer | Class | storm.trident.operation.impl | Apache Storm | |
JoinerMultiReducer .JoinState | Class | storm.trident.operation.impl.JoinerMultiReducer | Apache Storm | |
JoinType | Class | storm.trident | Apache Storm | |
JSONNonTransactionalSerializer | Class | storm.trident.state | Apache Storm | |
JSONOpaqueSerializer | Class | storm.trident.state | Apache Storm | |
JSONTransactionalSerializer | Class | storm.trident.state | Apache Storm | |
LRUMap | Class | storm.trident.util | Apache Storm | |
LRUMemoryMapState | Class | storm.trident.testing | Apache Storm | |
LRUMemoryMapState .Factory | Class | storm.trident.testing.LRUMemoryMapState | Apache Storm | |
MapCombinerAggStateUpdater | Class | storm.trident.state.map | Apache Storm | |
MapGet | Class | storm.trident.operation.builtin | Apache Storm | |
MapReducerAggStateUpdater | Class | storm.trident.state.map | Apache Storm | |
MapState | Interface | storm.trident.state.map | Apache Storm | |
MasterBatchCoordinator | Class | storm.trident.topology | Apache Storm | |
MemoryBackingMap | Class | storm.trident.testing | Apache Storm | |
MemoryMapState | Class | storm.trident.testing | Apache Storm | |
MemoryMapState .Factory | Class | storm.trident.testing.MemoryMapState | Apache Storm | |
MicroBatchIBackingMap | Class | storm.trident.state.map | Apache Storm | |
MicroBatchIBackingMap .Options | Class | storm.trident.state.map.MicroBatchIBackingMap | Apache Storm | |
MultiReducer | Interface | storm.trident.operation | Apache Storm | |
MultiReducerProcessor | Class | storm.trident.planner.processor | Apache Storm | |
Negate | Class | storm.trident.operation.builtin | Apache Storm | |
Node | Class | storm.trident.planner | Apache Storm | |
NodeStateInfo | Class | storm.trident.planner | Apache Storm | |
NonTransactionalMap | Class | storm.trident.state.map | Apache Storm | |
OpaqueMap | Class | storm.trident.state.map | Apache Storm | |
OpaquePartitionedTridentSpoutExecutor | Class | storm.trident.spout | Apache Storm | |
OpaqueValue | Class | storm.trident.state | Apache Storm | |
Operation | Interface | storm.trident.operation | Apache Storm | |
PartitionedTridentSpoutExecutor | Class | storm.trident.spout | Apache Storm | |
PartitionNode | Class | storm.trident.planner | Apache Storm | |
PartitionPersistProcessor | Class | storm.trident.planner.processor | Apache Storm | |
ProcessorContext | Class | storm.trident.planner | Apache Storm | |
ProcessorNode | Class | storm.trident.planner | Apache Storm | |
ProjectedProcessor | Class | storm.trident.planner.processor | Apache Storm | |
QueryFunction | Interface | storm.trident.state | Apache Storm | |
ReadOnlyMapState | Interface | storm.trident.state.map | Apache Storm | |
ReadOnlySnapshottable | Interface | storm.trident.state.snapshot | Apache Storm | |
ReadOnlyState | Class | storm.trident.state | Apache Storm | |
ReducerAggregator | Interface | storm.trident.operation | Apache Storm | |
ReducerAggregatorImpl | Class | storm.trident.operation.impl | Apache Storm | |
ReducerAggStateUpdater | Class | storm.trident.operation.impl | Apache Storm | |
ReducerValueUpdater | Class | storm.trident.state | Apache Storm | |
RemovableMapState | Interface | storm.trident.state.map | Apache Storm | |
Result | Class | storm.trident.operation.impl | Apache Storm | |
ReturnResultsReducer | Class | storm.trident.drpc | Apache Storm | |
ReturnResultsReducer .ReturnResultsState | Class | storm.trident.drpc.ReturnResultsReducer | Apache Storm | |
RichSpoutBatchExecutor | Class | storm.trident.spout | Apache Storm | |
RichSpoutBatchId | Class | storm.trident.spout | Apache Storm | |
RichSpoutBatchIdSerializer | Class | storm.trident.spout | Apache Storm | |
RichSpoutBatchTriggerer | Class | storm.trident.spout | Apache Storm | |
RotatingTransactionalState | Class | storm.trident.topology.state | Apache Storm | |
RotatingTransactionalState .StateInitializer | Interface | storm.trident.topology.state.RotatingTransactionalState | Apache Storm | |
Serializer | Interface | storm.trident.state | Apache Storm | |
SingleEmitAggregator | Class | storm.trident.operation.impl | Apache Storm | |
SingleEmitAggregator .BatchToPartition | Interface | storm.trident.operation.impl.SingleEmitAggregator | Apache Storm | |
SnapshotGet | Class | storm.trident.operation.builtin | Apache Storm | |
Snapshottable | Interface | storm.trident.state.snapshot | Apache Storm | |
SnapshottableMap | Class | storm.trident.state.map | Apache Storm | |
Split | Class | storm.trident.testing | Apache Storm | |
SpoutNode | Class | storm.trident.planner | Apache Storm | |
SpoutNode .SpoutType | Returns the enum constant of this type with the specified name. | Class | storm.trident.planner.SpoutNode | Apache Storm |
State | There's 3 different kinds of state: 1. | Interface | storm.trident.state | Apache Storm |
StateFactory | Interface | storm.trident.state | Apache Storm | |
StateQueryProcessor | Class | storm.trident.planner.processor | Apache Storm | |
StateSpec | Class | storm.trident.state | Apache Storm | |
StateType | Class | storm.trident.state | Apache Storm | |
StateUpdater | Interface | storm.trident.state | Apache Storm | |
Stream | Class | storm.trident | Apache Storm | |
StringLength | Class | storm.trident.testing | Apache Storm | |
SubtopologyBolt | Class | storm.trident.planner | Apache Storm | |
Sum | Class | storm.trident.operation.builtin | Apache Storm | |
TestTransactionalState | Facilitates testing of non-public methods in the parent class. | Class | storm.trident.topology.state | Apache Storm |
TransactionalMap | Class | storm.trident.state.map | Apache Storm | |
TransactionalState | Class | storm.trident.topology.state | Apache Storm | |
TransactionalValue | Class | storm.trident.state | Apache Storm | |
TransactionAttempt | Class | storm.trident.topology | Apache Storm | |
TridentBoltExecutor | Class | storm.trident.topology | Apache Storm | |
TridentBoltExecutor .CoordCondition | Class | storm.trident.topology.TridentBoltExecutor | Apache Storm | |
TridentBoltExecutor .CoordSpec | Class | storm.trident.topology.TridentBoltExecutor | Apache Storm | |
TridentBoltExecutor .CoordType | Class | storm.trident.topology.TridentBoltExecutor | Apache Storm | |
TridentBoltExecutor .TrackedBatch | Class | storm.trident.topology.TridentBoltExecutor | Apache Storm | |
TridentCollector | Interface | storm.trident.operation | Apache Storm | |
TridentContext | Class | storm.trident.planner.processor | Apache Storm | |
TridentMultiReducerContext | Class | storm.trident.operation | Apache Storm | |
TridentOperationContext | Class | storm.trident.operation | Apache Storm | |
TridentProcessor | Interface | storm.trident.planner | Apache Storm | |
TridentSpoutCoordinator | Class | storm.trident.spout | Apache Storm | |
TridentSpoutExecutor | Class | storm.trident.spout | Apache Storm | |
TridentState | Class | storm.trident | Apache Storm | |
TridentTopology | Class | storm.trident | Apache Storm | |
TridentTopologyBuilder | Class | storm.trident.topology | Apache Storm | |
TridentTuple | Interface | storm.trident.tuple | Apache Storm | |
TridentTuple .Factory | Interface | storm.trident.tuple.TridentTuple | Apache Storm | |
TridentTupleView | Class | storm.trident.tuple | Apache Storm | |
TridentTupleView .FreshOutputFactory | Class | storm.trident.tuple.TridentTupleView | Apache Storm | |
TridentTupleView .OperationOutputFactory | Class | storm.trident.tuple.TridentTupleView | Apache Storm | |
TridentTupleView .ProjectionFactory | Class | storm.trident.tuple.TridentTupleView | Apache Storm | |
TridentTupleView .RootFactory | Class | storm.trident.tuple.TridentTupleView | Apache Storm | |
TridentUtils | Class | storm.trident.util | Apache Storm | |
TrueFilter | Class | storm.trident.operation.impl | Apache Storm | |
TrueFilter | Class | storm.trident.testing | Apache Storm | |
TupleCollectionGet | Class | storm.trident.operation.builtin | Apache Storm | |
TupleReceiver | Interface | storm.trident.planner | Apache Storm | |
TuplifyArgs | Class | storm.trident.testing | Apache Storm | |
UniqueIdGen | Class | storm.trident.fluent | Apache Storm | |
ValuePointer | Class | storm.trident.tuple | Apache Storm | |