| Class | Description |
|---|---|
| KafkaTridentOpaqueSpoutEmitter<K,V> | |
| KafkaTridentSpoutBatchMetadata |
Wraps transaction batch information.
|
| KafkaTridentSpoutConfig<K,V> |
Defines the required Kafka-related configuration for the Trident spouts.
|
| KafkaTridentSpoutConfig.Builder<K,V> | |
| KafkaTridentSpoutCoordinator<K,V> | |
| KafkaTridentSpoutEmitter<K,V> | |
| KafkaTridentSpoutOpaque<K,V> | |
| KafkaTridentSpoutTopicPartition |
ISpoutPartition that wraps TopicPartition information. |
| KafkaTridentSpoutTransactional<K,V> | |
| KafkaTridentTransactionalSpoutEmitter<K,V> | |
| TopicPartitionSerializer |
Copyright © 2021 The Apache Software Foundation. All rights reserved.