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 and Description
OutputFieldsExtractor()

Method Summary

Modifier and Type	Method and 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 Detail

OutputFieldsExtractor

public OutputFieldsExtractor()

Method Detail

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.