Package com.amazonaws.athena.connectors.kafka.serde

Class KafkaCsvDeserializer

java.lang.Object

com.amazonaws.athena.connectors.kafka.serde.KafkaDeserializer

com.amazonaws.athena.connectors.kafka.serde.KafkaCsvDeserializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<TopicResultSet>

public class KafkaCsvDeserializer
extends KafkaDeserializer

Field Summary

Fields inherited from class com.amazonaws.athena.connectors.kafka.serde.KafkaDeserializer

schema

Constructor Summary

Constructors

Constructor	Description
KafkaCsvDeserializer(org.apache.arrow.vector.types.pojo.Schema schema)

Method Summary

Modifier and Type	Method	Description
TopicResultSet	deserialize(String topic, byte[] data)

Methods inherited from class com.amazonaws.athena.connectors.kafka.serde.KafkaDeserializer

cast

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

close, configure, deserialize, deserialize

Constructor Detail

KafkaCsvDeserializer

public KafkaCsvDeserializer(org.apache.arrow.vector.types.pojo.Schema schema)

Method Detail

deserialize

public TopicResultSet deserialize(String topic,
                                  byte[] data)