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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TopicResultSet
deserialize(String topic, byte[] data)
-
Methods inherited from class com.amazonaws.athena.connectors.kafka.serde.KafkaDeserializer
cast
-
-
-
-
Method Detail
-
deserialize
public TopicResultSet deserialize(String topic, byte[] data)
-
-