public static final class CreateDatasinkRequest.Options extends Object
Modifier and Type | Field and Description |
---|---|
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 data sink
|
static String |
CREDENTIAL
|
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 publish to if
destination is a Kafka broker |
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 |
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 data sink
|
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_TOPIC_NAME
destination
is a Kafka brokerpublic 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 USE_MANAGED_CREDENTIALS
FALSE
.public static final String USE_HTTPS
TRUE
.public static final String SKIP_VALIDATION
FALSE
.Copyright © 2025. All rights reserved.