public static final class AlterDatasinkRequest.DatasinkUpdatesMap extends Object
DESTINATION
: Destination for the output data in format
'destination_type://path[:port]'.
Supported destination types are 'http', 'https' and 'kafka'.
CONNECTION_TIMEOUT
: Timeout in seconds for connecting to this sink
WAIT_TIMEOUT
: Timeout in seconds for waiting for a response from this
sink
CREDENTIAL
: Name of the credential object to be used in this data sink
S3_BUCKET_NAME
: Name of the Amazon S3 bucket to use as the data sink
S3_REGION
: Name of the Amazon S3 region where the given bucket is
located
S3_AWS_ROLE_ARN
: Amazon IAM Role ARN which has required S3 permissions
that can be assumed for the given S3 IAM user
HDFS_KERBEROS_KEYTAB
: Kerberos keytab file location for the given HDFS
user. This may be a KIFS file.
HDFS_DELEGATION_TOKEN
: Delegation token for the given HDFS user
HDFS_USE_KERBEROS
: Use kerberos authentication for the given HDFS
cluster
Supported values:
The default value is FALSE
.
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
AZURE_CONTAINER_NAME
: Name of the Azure storage container to use as the
data sink
AZURE_TENANT_ID
: Active Directory tenant ID (or directory ID)
AZURE_SAS_TOKEN
: Shared access signature token for Azure storage
account to use as the data sink
AZURE_OAUTH_TOKEN
: Oauth token to access given storage container
GCS_BUCKET_NAME
: Name of the Google Cloud Storage bucket to use as the
data sink
GCS_PROJECT_ID
: Name of the Google Cloud project to use as the data
sink
GCS_SERVICE_ACCOUNT_KEYS
: Google Cloud service account keys to use for
authenticating the data sink
KAFKA_URL
: The publicly-accessible full path URL to the kafka broker,
e.g., 'http://172.123.45.67:9300'.
KAFKA_TOPIC_NAME
: Name of the Kafka topic to use for this data sink, if
it references a Kafka broker
ANONYMOUS
: Create an anonymous connection to the storage
provider--DEPRECATED: this is now the default. Specify
use_managed_credentials for non-anonymous connection
Supported values:
The default value is TRUE
.
USE_MANAGED_CREDENTIALS
: When no credentials are supplied, we use
anonymous access by default. If this is set, we will use cloud provider
user settings.
Supported values:
The default value is FALSE
.
USE_HTTPS
: Use https to connect to datasink if true, otherwise use http
Supported values:
The default value is TRUE
.
MAX_BATCH_SIZE
: Maximum number of records per notification message.
The default value is '1'.
MAX_MESSAGE_SIZE
: Maximum size in bytes of each notification message.
The default value is '1000000'.
JSON_FORMAT
: The desired format of JSON encoded notifications message.
If nested
, records are returned as an array.
Otherwise, only a single record per messages is returned.
Supported values:
FLAT
.
SKIP_VALIDATION
: Bypass validation of connection to this data sink.
Supported values:
The default value is FALSE
.
SCHEMA_NAME
: Updates the schema name. If schema_name
doesn't exist, an error will be thrown. If schema_name
is empty,
then the user's
default schema will be used.
datasinkUpdatesMap
.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 |
||
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
|
||
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 |
||
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_REGION
Name of the Amazon S3 region where the given bucket is located
|
||
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
|
||
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 'http', 'https' and 'kafka'.
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_AWS_ROLE_ARN
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 TRUE
public static final String 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 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
If nested
, records are returned as an array.
Otherwise, only a single record per messages is returned.
Supported values:
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 © 2024. All rights reserved.