Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig
Package
Description
-
Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.spout.trident
ModifierConstructorDescriptionKafkaTridentSpoutCoordinator
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new coordinator based on the given spout config.KafkaTridentSpoutEmitter
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig, TopologyContext topologyContext) Create a new Kafka spout emitter.KafkaTridentSpoutOpaque
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new opaque transactional Trident Kafka spout.KafkaTridentSpoutTransactional
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new non-opaque transactional Trident Kafka spout. -
Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.spout.trident.internal
Modifier and TypeMethodDescription<K,
V> Fields OutputFieldsExtractor.getOutputFields
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Extract the output fields from the config. -
Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.trident
Modifier and TypeMethodDescriptionprotected KafkaTridentSpoutConfig<String,
String> TridentKafkaClientTopologyNamedTopics.newKafkaSpoutConfig
(String bootstrapServers) protected KafkaTridentSpoutConfig<String,
String> TridentKafkaClientTopologyWildcardTopics.newKafkaSpoutConfig
(String bootstrapServers)