Class GlueRegistryReader


  • public class GlueRegistryReader
    extends Object
    • 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)