Package com.amazonaws.athena.connectors.msk

Class GlueRegistryReader

java.lang.Object

com.amazonaws.athena.connectors.msk.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)
List<MSKField>	getProtobufFields(String glueRegistryName, String glueSchemaName)	Parse protobuf schema definition from Glue Schema Registry using protoc compiler
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

getProtobufFields

public List<MSKField> getProtobufFields(String glueRegistryName,
                                        String glueSchemaName)

Parse protobuf schema definition from Glue Schema Registry using protoc compiler

Parameters:

glueRegistryName - Registry name

glueSchemaName - Schema name

Returns:

List of MSKField objects containing field information

Throws:

AthenaConnectorException - if schema parsing fails

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)