Class OutputFieldsExtractor
java.lang.Object
org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor
- All Implemented Interfaces:
- Serializable
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescription<K,V> Fields getOutputFields(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Extract the output fields from the config.
- 
Constructor Details- 
OutputFieldsExtractorpublic OutputFieldsExtractor()
 
- 
- 
Method Details- 
getOutputFieldsExtract the output fields from the config. Throws an error if there are multiple declared output streams, since Trident only supports one output stream per spout.
 
-