public static final class AlterDatasinkRequest.DatasinkUpdatesMap extends Object
AlterDatasinkRequest
parameter
datasinkUpdatesMap
.
Map containing the properties of the data sink to be updated. Error if empty.
Modifier and Type | Field and Description | ||
---|---|---|---|
static String |
ANONYMOUS
Create an anonymous connection to the storage provider--DEPRECATED:
this is now the default.
|
||
static String |
AZURE_CONTAINER_NAME
Name of the Azure storage container to use as the data sink
|
||
static String |
AZURE_OAUTH_TOKEN
Oauth token to access given storage container
|
||
static String |
AZURE_SAS_TOKEN
Shared access signature token for Azure storage account to use as
the data sink
|
||
static String |
AZURE_STORAGE_ACCOUNT_NAME
Name of the Azure storage account to use as the data sink, this is
valid only if tenant_id is specified
|
||
static String |
AZURE_TENANT_ID
Active Directory tenant ID (or directory ID)
|
||
static String |
CONNECTION_TIMEOUT
Timeout in seconds for connecting to this sink
|
||
static String |
CREDENTIAL
Name of the
static String DESTINATION
Destination for the output data in format
'destination_type://path[:port]'.
| ||
static String |
FALSE |
||
static String |
FLAT
A single record is returned per message
|
||
static String |
GCS_BUCKET_NAME
Name of the Google Cloud Storage bucket to use as the data sink
|
||
static String |
GCS_PROJECT_ID
Name of the Google Cloud project to use as the data sink
|
||
static String |
GCS_SERVICE_ACCOUNT_KEYS
Google Cloud service account keys to use for authenticating the data
sink
|
||
static String |
HDFS_DELEGATION_TOKEN
Delegation token for the given HDFS user
|
||
static String |
HDFS_KERBEROS_KEYTAB
Kerberos keytab file location for the given HDFS user.
|
||
static String |
HDFS_USE_KERBEROS
Use kerberos authentication for the given HDFS cluster.
|
||
static String |
JDBC_DRIVER_CLASS_NAME
Name of the JDBC driver class
|
||
static String |
JDBC_DRIVER_JAR_PATH
JDBC driver jar file location.
|
||
static String |
JSON_FORMAT
The desired format of JSON encoded notifications message.
|
||
static String |
KAFKA_TOPIC_NAME
Name of the Kafka topic to use for this data sink, if it references
a Kafka broker
|
||
static String |
KAFKA_URL
The publicly-accessible full path URL to the kafka broker, e.g.,
'http://172.123.45.67:9300'.
|
||
static String |
MAX_BATCH_SIZE
Maximum number of records per notification message.
|
||
static String |
MAX_MESSAGE_SIZE
Maximum size in bytes of each notification message.
|
||
static String |
NESTED
Records are returned as an array per message
|
||
static String |
S3_AWS_ROLE_ARN
Amazon IAM Role ARN which has required S3 permissions that can be
assumed for the given S3 IAM user
|
||
static String |
S3_BUCKET_NAME
Name of the Amazon S3 bucket to use as the data sink
|
||
static String |
S3_ENCRYPTION_CUSTOMER_ALGORITHM
Customer encryption algorithm used encrypting data
|
||
static String |
S3_ENCRYPTION_CUSTOMER_KEY
Customer encryption key to encrypt or decrypt data
|
||
static String |
S3_ENCRYPTION_TYPE
Server side encryption type
|
||
static String |
S3_KMS_KEY_ID
KMS key
|
||
static String |
S3_REGION
Name of the Amazon S3 region where the given bucket is located
|
||
static String |
S3_USE_VIRTUAL_ADDRESSING
Whether to use virtual addressing when referencing the Amazon S3
sink.
|
||
static String |
S3_VERIFY_SSL
Whether to verify SSL connections.
|
||
static String |
SCHEMA_NAME
Updates the schema name.
|
||
static String |
SKIP_VALIDATION
Bypass validation of connection to this data sink.
|
||
static String |
TRUE |
||
static String |
USE_HTTPS
Use https to connect to datasink if true, otherwise use http.
|
||
static String |
USE_MANAGED_CREDENTIALS
When no credentials are supplied, we use anonymous access by
default.
|
||
static String |
WAIT_TIMEOUT
Timeout in seconds for waiting for a response from this sink
|
public static final String DESTINATION
Supported destination types are 'azure', 'gcs', 'hdfs', 'http', 'https', 'jdbc', 'kafka', and 's3'.
public static final String CONNECTION_TIMEOUT
public static final String WAIT_TIMEOUT
public static final String CREDENTIAL
public static final String S3_BUCKET_NAME
public static final String S3_REGION
public static final String S3_VERIFY_SSL
TRUE
: Connect with SSL
verification
FALSE
: Connect without
verifying the SSL connection; for testing purposes,
bypassing TLS errors, self-signed certificates, etc.
TRUE
.public static final String TRUE
public static final String FALSE
public static final String S3_USE_VIRTUAL_ADDRESSING
TRUE
: The requests URI
should be specified in virtual-hosted-style format where the
bucket name is part of the domain name in the URL.
FALSE
: Use path-style URI
for requests.
TRUE
.public static final String S3_AWS_ROLE_ARN
public static final String S3_ENCRYPTION_CUSTOMER_ALGORITHM
public static final String S3_ENCRYPTION_CUSTOMER_KEY
public static final String S3_ENCRYPTION_TYPE
public static final String S3_KMS_KEY_ID
public static final String HDFS_KERBEROS_KEYTAB
public static final String HDFS_DELEGATION_TOKEN
public static final String HDFS_USE_KERBEROS
FALSE
.public static final String AZURE_STORAGE_ACCOUNT_NAME
public static final String AZURE_CONTAINER_NAME
public static final String AZURE_TENANT_ID
public static final String AZURE_SAS_TOKEN
public static final String AZURE_OAUTH_TOKEN
public static final String GCS_BUCKET_NAME
public static final String GCS_PROJECT_ID
public static final String GCS_SERVICE_ACCOUNT_KEYS
public static final String JDBC_DRIVER_JAR_PATH
public static final String JDBC_DRIVER_CLASS_NAME
public static final String KAFKA_URL
public static final String KAFKA_TOPIC_NAME
public static final String ANONYMOUS
TRUE
.public static final String USE_MANAGED_CREDENTIALS
FALSE
.public static final String USE_HTTPS
TRUE
.public static final String MAX_BATCH_SIZE
public static final String MAX_MESSAGE_SIZE
public static final String JSON_FORMAT
FLAT
.public static final String FLAT
public static final String NESTED
public static final String SKIP_VALIDATION
FALSE
.public static final String SCHEMA_NAME
SCHEMA_NAME
doesn't exist, an error will be thrown. If SCHEMA_NAME
is empty, then the
user's default schema will be used.Copyright © 2025. All rights reserved.