​

Method Details

• ​

  getClassSchema

  public static org.apache.avro.Schema getClassSchema()

  This method supports the Avro framework and is not intended to be called directly by the user.

  Returns:

  The schema for the class.

• ​

  getName

  public String getName()

  Name of the data source to be created.

  Returns:

  The current value of name.

• ​

  setName

  public CreateDatasourceRequest setName(String name)

  Name of the data source to be created.

  Parameters:

  name - The new value for name.

  Returns:

  this to mimic the builder pattern.

• ​

  getLocation

  public String getLocation()

  Location of the remote storage in ‘storage_provider_type://[storage_path[:storage_port]]’ format.

  Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘jdbc’, ‘kafka’, ‘confluent’, and ‘s3’.

  Returns:

  The current value of location.

• ​

  setLocation

  public CreateDatasourceRequest setLocation(String location)

  Location of the remote storage in ‘storage_provider_type://[storage_path[:storage_port]]’ format.

  Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘jdbc’, ‘kafka’, ‘confluent’, and ‘s3’.

  Parameters:

  location - The new value for location.

  Returns:

  this to mimic the builder pattern.

• ​

  getUserName

  public String getUserName()

  Name of the remote system user; may be an empty string.

  Returns:

  The current value of userName.

• ​

  setUserName

  public CreateDatasourceRequest setUserName(String userName)

  Name of the remote system user; may be an empty string.

  Parameters:

  userName - The new value for userName.

  Returns:

  this to mimic the builder pattern.

• ​

  getPassword

  public String getPassword()

  Password for the remote system user; may be an empty string.

  Returns:

  The current value of password.

• ​

  setPassword

  public CreateDatasourceRequest setPassword(String password)

  Password for the remote system user; may be an empty string.

  Parameters:

  password - The new value for password.

  Returns:

  this to mimic the builder pattern.

• ​

  getOptions

  public Map<String,String> getOptions()

  Optional parameters.

  • SKIP_VALIDATION: Bypass validation of connection to remote source. Supported values:
    • TRUE
    • FALSE
    The default value is FALSE.
  • CONNECTION_TIMEOUT: Timeout in seconds for connecting to this storage provider.
  • WAIT_TIMEOUT: Timeout in seconds for reading from this storage provider.
  • CREDENTIAL: Name of the credential object to be used in data source.
  • S3_BUCKET_NAME: Name of the Amazon S3 bucket to use as the data source.
  • S3_REGION: Name of the Amazon S3 region where the given bucket is located.
  • S3_VERIFY_SSL: Whether to verify SSL connections. Supported values:
    • TRUE: Connect with SSL verification.
    • FALSE: Connect without verifying the SSL connection; for testing purposes, bypassing TLS errors, self-signed certificates, etc.
    The default value is TRUE.
  • S3_USE_VIRTUAL_ADDRESSING: Whether to use virtual addressing when referencing the Amazon S3 source. Supported values:
    • 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.
    The default value is TRUE.
  • S3_AWS_ROLE_ARN: Amazon IAM Role ARN which has required S3 permissions that can be assumed for the given S3 IAM user.
  • S3_ENCRYPTION_CUSTOMER_ALGORITHM: Customer encryption algorithm used encrypting data.
  • S3_ENCRYPTION_CUSTOMER_KEY: Customer encryption key to encrypt or decrypt data.
  • 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:
    • TRUE
    • FALSE
    The default value is FALSE.
  • AZURE_STORAGE_ACCOUNT_NAME: Name of the Azure storage account to use as the data source, this is valid only if tenant_id is specified.
  • AZURE_CONTAINER_NAME: Name of the Azure storage container to use as the data source.
  • 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 source.
  • AZURE_OAUTH_TOKEN: OAuth token to access given storage container.
  • AZURE_USE_VIRTUAL_ADDRESSING: Whether to use virtual addressing when referencing the Azure source. Supported values:
    • 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.
    The default value is TRUE.
  • GCS_BUCKET_NAME: Name of the Google Cloud Storage bucket to use as the data source.
  • GCS_PROJECT_ID: Name of the Google Cloud project to use as the data source.
  • GCS_SERVICE_ACCOUNT_KEYS: Google Cloud service account keys to use for authenticating the data source.
  • IS_STREAM: To load from Azure/GCS/S3 as a stream continuously. Supported values:
    • TRUE
    • FALSE
    The default value is FALSE.
  • KAFKA_TOPIC_NAME: Name of the Kafka topic to use as the data source.
  • JDBC_DRIVER_JAR_PATH: JDBC driver jar file location. This may be a KIFS file.
  • JDBC_DRIVER_CLASS_NAME: Name of the JDBC driver class.
  • ANONYMOUS: Use anonymous connection to storage provider—DEPRECATED: this is now the default. Specify use_managed_credentials for non-anonymous connection. Supported values:
    • TRUE
    • FALSE
    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:
    • TRUE
    • FALSE
    The default value is FALSE.
  • USE_HTTPS: Use HTTPS to connect to datasource if true, otherwise use HTTP. Supported values:
    • TRUE
    • FALSE
    The default value is TRUE.
  • SCHEMA_REGISTRY_LOCATION: Location of Confluent Schema Registry in ‘[storage_path[:storage_port]]’ format.
  • SCHEMA_REGISTRY_CREDENTIAL: Confluent Schema Registry credential object name.
  • SCHEMA_REGISTRY_PORT: Confluent Schema Registry port (optional).
  • SCHEMA_REGISTRY_CONNECTION_RETRIES: Confluent Schema registry connection timeout (in secs).
  • SCHEMA_REGISTRY_CONNECTION_TIMEOUT: Confluent Schema registry connection timeout (in secs).

  The default value is an empty Map.

  Returns:

  The current value of options.

• ​

  setOptions

  public CreateDatasourceRequest setOptions(Map<String,String> options)

  Optional parameters.

  • SKIP_VALIDATION: Bypass validation of connection to remote source. Supported values:
    • TRUE
    • FALSE
    The default value is FALSE.
  • CONNECTION_TIMEOUT: Timeout in seconds for connecting to this storage provider.
  • WAIT_TIMEOUT: Timeout in seconds for reading from this storage provider.
  • CREDENTIAL: Name of the credential object to be used in data source.
  • S3_BUCKET_NAME: Name of the Amazon S3 bucket to use as the data source.
  • S3_REGION: Name of the Amazon S3 region where the given bucket is located.
  • S3_VERIFY_SSL: Whether to verify SSL connections. Supported values:
    • TRUE: Connect with SSL verification.
    • FALSE: Connect without verifying the SSL connection; for testing purposes, bypassing TLS errors, self-signed certificates, etc.
    The default value is TRUE.
  • S3_USE_VIRTUAL_ADDRESSING: Whether to use virtual addressing when referencing the Amazon S3 source. Supported values:
    • 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.
    The default value is TRUE.
  • S3_AWS_ROLE_ARN: Amazon IAM Role ARN which has required S3 permissions that can be assumed for the given S3 IAM user.
  • S3_ENCRYPTION_CUSTOMER_ALGORITHM: Customer encryption algorithm used encrypting data.
  • S3_ENCRYPTION_CUSTOMER_KEY: Customer encryption key to encrypt or decrypt data.
  • 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:
    • TRUE
    • FALSE
    The default value is FALSE.
  • AZURE_STORAGE_ACCOUNT_NAME: Name of the Azure storage account to use as the data source, this is valid only if tenant_id is specified.
  • AZURE_CONTAINER_NAME: Name of the Azure storage container to use as the data source.
  • 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 source.
  • AZURE_OAUTH_TOKEN: OAuth token to access given storage container.
  • AZURE_USE_VIRTUAL_ADDRESSING: Whether to use virtual addressing when referencing the Azure source. Supported values:
    • 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.
    The default value is TRUE.
  • GCS_BUCKET_NAME: Name of the Google Cloud Storage bucket to use as the data source.
  • GCS_PROJECT_ID: Name of the Google Cloud project to use as the data source.
  • GCS_SERVICE_ACCOUNT_KEYS: Google Cloud service account keys to use for authenticating the data source.
  • IS_STREAM: To load from Azure/GCS/S3 as a stream continuously. Supported values:
    • TRUE
    • FALSE
    The default value is FALSE.
  • KAFKA_TOPIC_NAME: Name of the Kafka topic to use as the data source.
  • JDBC_DRIVER_JAR_PATH: JDBC driver jar file location. This may be a KIFS file.
  • JDBC_DRIVER_CLASS_NAME: Name of the JDBC driver class.
  • ANONYMOUS: Use anonymous connection to storage provider—DEPRECATED: this is now the default. Specify use_managed_credentials for non-anonymous connection. Supported values:
    • TRUE
    • FALSE
    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:
    • TRUE
    • FALSE
    The default value is FALSE.
  • USE_HTTPS: Use HTTPS to connect to datasource if true, otherwise use HTTP. Supported values:
    • TRUE
    • FALSE
    The default value is TRUE.
  • SCHEMA_REGISTRY_LOCATION: Location of Confluent Schema Registry in ‘[storage_path[:storage_port]]’ format.
  • SCHEMA_REGISTRY_CREDENTIAL: Confluent Schema Registry credential object name.
  • SCHEMA_REGISTRY_PORT: Confluent Schema Registry port (optional).
  • SCHEMA_REGISTRY_CONNECTION_RETRIES: Confluent Schema registry connection timeout (in secs).
  • SCHEMA_REGISTRY_CONNECTION_TIMEOUT: Confluent Schema registry connection timeout (in secs).

  The default value is an empty Map.

  Parameters:

  options - The new value for options.

  Returns:

  this to mimic the builder pattern.

• ​

  getSchema

  public org.apache.avro.Schema getSchema()

  This method supports the Avro framework and is not intended to be called directly by the user.

  Specified by:

  getSchema in interface org.apache.avro.generic.GenericContainer

  Returns:

  The schema object describing this class.

• ​

  get

  public Object get(int index)

  This method supports the Avro framework and is not intended to be called directly by the user.

  Specified by:

  get in interface org.apache.avro.generic.IndexedRecord

  Parameters:

  index - the position of the field to get

  Returns:

  value of the field with the given index.

  Throws:

  IndexOutOfBoundsException

• ​

  put

  public void put(int index, Object value)

  This method supports the Avro framework and is not intended to be called directly by the user.

  Specified by:

  put in interface org.apache.avro.generic.IndexedRecord

  Parameters:

  index - the position of the field to set

  value - the value to set

  Throws:

  IndexOutOfBoundsException

• ​

  equals

  public boolean equals(Object obj)

  Overrides:

  equals in class Object

• ​

  toString

  public String toString()

  Overrides:

  toString in class Object

• ​

  hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object