Class Hierarchy
- java.lang.Object
- org.apache.storm.sql.kafka.KafkaDataSourcesProvider (implements org.apache.storm.sql.runtime.DataSourcesProvider)
- org.apache.storm.sql.kafka.RecordTranslatorSchemeAdapter (implements org.apache.storm.kafka.spout.RecordTranslator<K,V>)