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

Class MskJsonDeserializer

java.lang.Object

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

com.amazonaws.athena.connectors.msk.serde.MskJsonDeserializer

All Implemented Interfaces:

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

public class MskJsonDeserializer
extends MskDeserializer

Field Summary

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

schema

Constructor Summary

Constructors

Constructor	Description
MskJsonDeserializer(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

MskJsonDeserializer

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

Method Detail

deserialize

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