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