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.StringGCS_CHANNEL_READ_CHUNK_SIZEstatic java.lang.StringGCS_CHANNEL_WRITE_CHUNK_SIZEstatic java.lang.StringGCS_CLIENT_LIB_TOKENstatic java.lang.StringGCS_DECRYPTION_KEYstatic java.lang.StringGCS_DELETE_BATCH_SIZEConfigure the batch size used when deleting multiple files from a given GCS bucketstatic intGCS_DELETE_BATCH_SIZE_DEFAULTMax possible batch size for deletion.static java.lang.StringGCS_ENCRYPTION_KEYstatic java.lang.StringGCS_OAUTH2_TOKENstatic java.lang.StringGCS_OAUTH2_TOKEN_EXPIRES_ATstatic java.lang.StringGCS_PROJECT_IDstatic java.lang.StringGCS_SERVICE_HOSTstatic java.lang.StringGCS_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()intdeleteBatchSize()java.util.Optional<java.lang.String>encryptionKey()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_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()
-
oauth2TokenExpiresAt
public java.util.Optional<java.util.Date> oauth2TokenExpiresAt()
-
deleteBatchSize
public int deleteBatchSize()
-
-