org.apache.iceberg.gcp

Class GCPProperties

java.lang.Object

org.apache.iceberg.gcp.GCPProperties

All Implemented Interfaces:

java.io.Serializable

public class GCPProperties
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	GCS_CHANNEL_READ_CHUNK_SIZE
static java.lang.String	GCS_CHANNEL_WRITE_CHUNK_SIZE
static java.lang.String	GCS_CLIENT_LIB_TOKEN
static java.lang.String	GCS_DECRYPTION_KEY
static java.lang.String	GCS_DELETE_BATCH_SIZE Configure the batch size used when deleting multiple files from a given GCS bucket
static int	GCS_DELETE_BATCH_SIZE_DEFAULT Max possible batch size for deletion.
static java.lang.String	GCS_ENCRYPTION_KEY
static java.lang.String	GCS_NO_AUTH
static java.lang.String	GCS_OAUTH2_TOKEN
static java.lang.String	GCS_OAUTH2_TOKEN_EXPIRES_AT
static java.lang.String	GCS_PROJECT_ID
static java.lang.String	GCS_SERVICE_HOST
static java.lang.String	GCS_USER_PROJECT

Constructor Summary

Constructors

Constructor and Description
GCPProperties()
GCPProperties(java.util.Map<java.lang.String,java.lang.String> properties)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.Integer>	channelReadChunkSize()
java.util.Optional<java.lang.Integer>	channelWriteChunkSize()
java.util.Optional<java.lang.String>	clientLibToken()
java.util.Optional<java.lang.String>	decryptionKey()
int	deleteBatchSize()
java.util.Optional<java.lang.String>	encryptionKey()
boolean	noAuth()
java.util.Optional<java.lang.String>	oauth2Token()
java.util.Optional<java.util.Date>	oauth2TokenExpiresAt()
java.util.Optional<java.lang.String>	projectId()
java.util.Optional<java.lang.String>	serviceHost()
java.util.Optional<java.lang.String>	userProject()

Methods inherited from class java.lang.Object

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

Field Detail

GCS_PROJECT_ID

public static final java.lang.String GCS_PROJECT_ID

See Also:

Constant Field Values

GCS_CLIENT_LIB_TOKEN

public static final java.lang.String GCS_CLIENT_LIB_TOKEN

See Also:

Constant Field Values

GCS_SERVICE_HOST

public static final java.lang.String GCS_SERVICE_HOST

See Also:

Constant Field Values

GCS_DECRYPTION_KEY

public static final java.lang.String GCS_DECRYPTION_KEY

See Also:

Constant Field Values

GCS_ENCRYPTION_KEY

public static final java.lang.String GCS_ENCRYPTION_KEY

See Also:

Constant Field Values

GCS_USER_PROJECT

public static final java.lang.String GCS_USER_PROJECT

See Also:

Constant Field Values

GCS_CHANNEL_READ_CHUNK_SIZE

public static final java.lang.String GCS_CHANNEL_READ_CHUNK_SIZE

See Also:

Constant Field Values

GCS_CHANNEL_WRITE_CHUNK_SIZE

public static final java.lang.String GCS_CHANNEL_WRITE_CHUNK_SIZE

See Also:

Constant Field Values

GCS_OAUTH2_TOKEN

public static final java.lang.String GCS_OAUTH2_TOKEN

See Also:

Constant Field Values

GCS_OAUTH2_TOKEN_EXPIRES_AT

public static final java.lang.String GCS_OAUTH2_TOKEN_EXPIRES_AT

See Also:

Constant Field Values

GCS_NO_AUTH

public static final java.lang.String GCS_NO_AUTH

See Also:

Constant Field Values

GCS_DELETE_BATCH_SIZE

public static final java.lang.String GCS_DELETE_BATCH_SIZE

Configure the batch size used when deleting multiple files from a given GCS bucket

See Also:

Constant Field Values

GCS_DELETE_BATCH_SIZE_DEFAULT

public static final int GCS_DELETE_BATCH_SIZE_DEFAULT

Max possible batch size for deletion. Currently, a max of 100 keys is advised, so we default to a number below that. https://cloud.google.com/storage/docs/batch

See Also:

Constant Field Values

Constructor Detail

GCPProperties

public GCPProperties()

GCPProperties

public GCPProperties(java.util.Map<java.lang.String,java.lang.String> properties)

Method Detail

channelReadChunkSize

public java.util.Optional<java.lang.Integer> channelReadChunkSize()

channelWriteChunkSize

public java.util.Optional<java.lang.Integer> channelWriteChunkSize()

clientLibToken

public java.util.Optional<java.lang.String> clientLibToken()

decryptionKey

public java.util.Optional<java.lang.String> decryptionKey()

encryptionKey

public java.util.Optional<java.lang.String> encryptionKey()

projectId

public java.util.Optional<java.lang.String> projectId()

serviceHost

public java.util.Optional<java.lang.String> serviceHost()

userProject

public java.util.Optional<java.lang.String> userProject()

oauth2Token

public java.util.Optional<java.lang.String> oauth2Token()

noAuth

public boolean noAuth()

oauth2TokenExpiresAt

public java.util.Optional<java.util.Date> oauth2TokenExpiresAt()

deleteBatchSize

public int deleteBatchSize()