Package com.amazonaws.athena.connectors.msk.serde

Class MskCsvDeserializer

java.lang.Object

com.amazonaws.athena.connectors.msk.serde.MskDeserializer

com.amazonaws.athena.connectors.msk.serde.MskCsvDeserializer

All Implemented Interfaces:

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

public class MskCsvDeserializer
extends MskDeserializer

Field Summary

Fields inherited from class com.amazonaws.athena.connectors.msk.serde.MskDeserializer

schema

Constructor Summary

Constructors

Constructor	Description
MskCsvDeserializer(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.msk.serde.MskDeserializer

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

MskCsvDeserializer

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

Method Detail

deserialize

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