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

Class MskDeserializer

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

MskCsvDeserializer, MskJsonDeserializer

public abstract class MskDeserializer
extends Object
implements org.apache.kafka.common.serialization.Deserializer<TopicResultSet>

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.arrow.vector.types.pojo.Schema	schema

Constructor Summary

Constructors

Constructor	Description
MskDeserializer(org.apache.arrow.vector.types.pojo.Schema schema)

Method Summary

Modifier and Type	Method	Description
Object	cast(org.apache.arrow.vector.types.pojo.Field field, String value)	Converts string data to other data type based on datatype of source schema registered in Glue schema registry.

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, deserialize

Field Detail

schema

protected final org.apache.arrow.vector.types.pojo.Schema schema

Constructor Detail

MskDeserializer

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

Method Detail

cast

public Object cast(org.apache.arrow.vector.types.pojo.Field field,
                   String value)
            throws Exception

Converts string data to other data type based on datatype of source schema registered in Glue schema registry.

Parameters:

field - - arrow type field

value - - raw value

Returns:

Object

Throws:

ParseException - - ParseException

Exception