MskDeserializer (AWS Athena Query Federation 2022.47.1 API)

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

All Methods Instance Methods Concrete Methods
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