Class OutputFieldsExtractor

java.lang.Object
org.apache.storm.kafka.spout.trident.internal.OutputFieldsExtractor
All Implemented Interfaces:
Serializable

public class OutputFieldsExtractor extends Object implements Serializable
See Also:
  • Constructor Details

    • OutputFieldsExtractor

      public OutputFieldsExtractor()
  • Method Details

    • getOutputFields

      public <K, V> Fields getOutputFields(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
      Extract 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.