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 © 2019 The Apache Software Foundation. All rights reserved.