Package com.amazonaws.athena.connectors.gcs

Class GcsUtil

java.lang.Object

com.amazonaws.athena.connectors.gcs.GcsUtil

public class GcsUtil
extends Object

Method Summary

Modifier and Type	Method	Description
static Object	coerce(org.apache.arrow.vector.FieldVector vector, Object value)
static String	createUri(String path)	Builds a GCS uri
static String	createUri(String bucketName, String path)	Builds a GCS uri
static software.amazon.awssdk.services.glue.model.Table	getGlueTable(TableName tableName, software.amazon.awssdk.services.glue.GlueClient awsGlue)	Get AWS Glue table object
static void	installCaCertificate()	Write out the cacerts that we trust from the default java truststore.
static void	installGoogleCredentialsJsonFile(Map<String,String> configOptions)	Install/place Google cloud platform credentials from AWS secret manager to temp location This is required for dataset api
static void	setupNativeEnvironmentVariables()

Methods inherited from class java.lang.Object

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

Method Detail

installCaCertificate

public static void installCaCertificate()
                                 throws IOException,
                                        NoSuchAlgorithmException,
                                        KeyStoreException,
                                        CertificateEncodingException

Write out the cacerts that we trust from the default java truststore. Code adapted from: https://stackoverflow.com/a/63678794

Throws:

IOException

NoSuchAlgorithmException

KeyStoreException

CertificateEncodingException

installGoogleCredentialsJsonFile

public static void installGoogleCredentialsJsonFile(Map<String,String> configOptions)
                                             throws IOException

Install/place Google cloud platform credentials from AWS secret manager to temp location This is required for dataset api

Throws:

IOException

createUri

public static String createUri(String bucketName,
                               String path)

Builds a GCS uri

Parameters:

bucketName - bucket name

path - folder path

Returns:

String representation uri

createUri

public static String createUri(String path)

Builds a GCS uri

Parameters:

path - bucket path

Returns:

String representation uri

getGlueTable

public static software.amazon.awssdk.services.glue.model.Table getGlueTable(TableName tableName,
                                                                            software.amazon.awssdk.services.glue.GlueClient awsGlue)

Get AWS Glue table object

Parameters:

tableName - table info

awsGlue - AWS Glue client

Returns:

Table object

coerce

public static Object coerce(org.apache.arrow.vector.FieldVector vector,
                            Object value)

setupNativeEnvironmentVariables

public static void setupNativeEnvironmentVariables()