Interface | Description |
---|---|
IBatchID | |
IBatchSpout | |
ICommitterTridentSpout<X> | |
ICommitterTridentSpout.Emitter | |
IOpaquePartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,M> |
This defines a transactional spout which does not necessarily replay the same batch every time it emits a batch for a transaction id.
|
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT> |
Coordinator for batches.
|
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,M> | |
IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T> |
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers.
|
IPartitionedTridentSpout.Coordinator<PartitionsT> | |
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,X> | |
ISpoutPartition | |
ITridentDataSource |
ITridentDataSource marks all spouts that provide data into Trident.
|
ITridentSpout<T> | |
ITridentSpout.BatchCoordinator<X> | |
ITridentSpout.Emitter<X> |
Copyright © 2022 The Apache Software Foundation. All rights reserved.