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

Class KafkaDeserializer

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

KafkaCsvDeserializer, KafkaJsonDeserializer

public abstract class KafkaDeserializer
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
KafkaDeserializer(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

KafkaDeserializer

public KafkaDeserializer(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