Package com.amazonaws.athena.connectors.kafka

Class GlueRegistryReader

java.lang.Object

com.amazonaws.athena.connectors.kafka.GlueRegistryReader

public class GlueRegistryReader
extends Object

Constructor Summary

Constructors

Constructor	Description
GlueRegistryReader()

Method Summary

Modifier and Type	Method	Description
<T> T	getGlueSchema(String glueRegistryName, String glueSchemaName, Class<T> clazz)	fetch schema file content from glue schema.
com.amazonaws.services.glue.model.GetSchemaVersionResult	getSchemaVersionResult(String glueRegistryName, String glueSchemaName)	Fetch glue schema content for latest version

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GlueRegistryReader

public GlueRegistryReader()

Method Detail

getSchemaVersionResult

public com.amazonaws.services.glue.model.GetSchemaVersionResult getSchemaVersionResult(String glueRegistryName,
                                                                                       String glueSchemaName)

Fetch glue schema content for latest version

Parameters:

glueRegistryName -

glueSchemaName -

Returns:

getGlueSchema

public <T> T getGlueSchema(String glueRegistryName,
                           String glueSchemaName,
                           Class<T> clazz)
                    throws Exception

fetch schema file content from glue schema.

Type Parameters:

T -

Parameters:

glueRegistryName -

glueSchemaName -

clazz -

Returns:

Throws:

Exception