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

Class KafkaJsonDeserializer

java.lang.Object

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

com.amazonaws.athena.connectors.kafka.serde.KafkaJsonDeserializer

All Implemented Interfaces:

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

public class KafkaJsonDeserializer
extends KafkaDeserializer

Field Summary

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

schema

Constructor Summary

Constructors

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

KafkaJsonDeserializer

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

Method Detail

deserialize

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