Package org.apache.storm.kafka.spout.trident.internal

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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
OutputFieldsExtractor()

Method Summary

Modifier and Type	Method	Description
<K, V> Fields	getOutputFields(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)	Extract the output fields from the config.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.