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
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.msk.serde.MskDeserializer
cast
-
-
-
-
Method Detail
-
deserialize
public TopicResultSet deserialize(String topic, byte[] data)
-
-