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.
String	getGlueSchemaType(String glueRegistryName, String glueSchemaName)
String	getSchemaDef(String glueRegistryName, String glueSchemaName)
software.amazon.awssdk.services.glue.model.GetSchemaVersionResponse	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 software.amazon.awssdk.services.glue.model.GetSchemaVersionResponse 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

getGlueSchemaType

public String getGlueSchemaType(String glueRegistryName,
                                String glueSchemaName)

getSchemaDef

public String getSchemaDef(String glueRegistryName,
                           String glueSchemaName)