Package 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 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 bucketstatic 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 Description GCPProperties()
GCPProperties(java.util.Map<java.lang.String,java.lang.String> properties)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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
-
-
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()
-
-