Class SnowflakeDestinationConfiguration

    • Method Detail

      • accountUrl

        public final String accountUrl()

        URL for accessing your Snowflake account. This URL must include your account identifier. Note that the protocol (https://) and port number are optional.

        Returns:
        URL for accessing your Snowflake account. This URL must include your account identifier. Note that the protocol (https://) and port number are optional.
      • user

        public final String user()

        User login name for the Snowflake account.

        Returns:
        User login name for the Snowflake account.
      • database

        public final String database()

        All data in Snowflake is maintained in databases.

        Returns:
        All data in Snowflake is maintained in databases.
      • schema

        public final String schema()

        Each database consists of one or more schemas, which are logical groupings of database objects, such as tables and views

        Returns:
        Each database consists of one or more schemas, which are logical groupings of database objects, such as tables and views
      • table

        public final String table()

        All data in Snowflake is stored in database tables, logically structured as collections of columns and rows.

        Returns:
        All data in Snowflake is stored in database tables, logically structured as collections of columns and rows.
      • snowflakeRoleConfiguration

        public final SnowflakeRoleConfiguration snowflakeRoleConfiguration()

        Optionally configure a Snowflake role. Otherwise the default user role will be used.

        Returns:
        Optionally configure a Snowflake role. Otherwise the default user role will be used.
      • dataLoadingOption

        public final SnowflakeDataLoadingOption dataLoadingOption()

        Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.

        If the service returns an enum value that is not available in the current SDK version, dataLoadingOption will return SnowflakeDataLoadingOption.UNKNOWN_TO_SDK_VERSION. The raw value returned by the service is available from dataLoadingOptionAsString().

        Returns:
        Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.
        See Also:
        SnowflakeDataLoadingOption
      • dataLoadingOptionAsString

        public final String dataLoadingOptionAsString()

        Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.

        If the service returns an enum value that is not available in the current SDK version, dataLoadingOption will return SnowflakeDataLoadingOption.UNKNOWN_TO_SDK_VERSION. The raw value returned by the service is available from dataLoadingOptionAsString().

        Returns:
        Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.
        See Also:
        SnowflakeDataLoadingOption
      • metaDataColumnName

        public final String metaDataColumnName()

        Specify a column name in the table, where the metadata information has to be loaded. When you enable this field, you will see the following column in the snowflake table, which differs based on the source type.

        For Direct PUT as source

        { "firehoseDeliveryStreamName" : "streamname", "IngestionTime" : "timestamp" }

        For Kinesis Data Stream as source

        "kinesisStreamName" : "streamname", "kinesisShardId" : "Id", "kinesisPartitionKey" : "key", "kinesisSequenceNumber" : "1234", "subsequenceNumber" : "2334", "IngestionTime" : "timestamp" }

        Returns:
        Specify a column name in the table, where the metadata information has to be loaded. When you enable this field, you will see the following column in the snowflake table, which differs based on the source type.

        For Direct PUT as source

        { "firehoseDeliveryStreamName" : "streamname", "IngestionTime" : "timestamp" }

        For Kinesis Data Stream as source

        "kinesisStreamName" : "streamname", "kinesisShardId" : "Id", "kinesisPartitionKey" : "key", "kinesisSequenceNumber" : "1234", "subsequenceNumber" : "2334", "IngestionTime" : "timestamp" }

      • contentColumnName

        public final String contentColumnName()

        The name of the record content column.

        Returns:
        The name of the record content column.
      • snowflakeVpcConfiguration

        public final SnowflakeVpcConfiguration snowflakeVpcConfiguration()

        The VPCE ID for Firehose to privately connect with Snowflake. The ID format is com.amazonaws.vpce.[region].vpce-svc-<[id]>. For more information, see Amazon PrivateLink & Snowflake

        Returns:
        The VPCE ID for Firehose to privately connect with Snowflake. The ID format is com.amazonaws.vpce.[region].vpce-svc-<[id]>. For more information, see Amazon PrivateLink & Snowflake
      • cloudWatchLoggingOptions

        public final CloudWatchLoggingOptions cloudWatchLoggingOptions()
        Returns the value of the CloudWatchLoggingOptions property for this object.
        Returns:
        The value of the CloudWatchLoggingOptions property for this object.
      • processingConfiguration

        public final ProcessingConfiguration processingConfiguration()
        Returns the value of the ProcessingConfiguration property for this object.
        Returns:
        The value of the ProcessingConfiguration property for this object.
      • roleARN

        public final String roleARN()

        The Amazon Resource Name (ARN) of the Snowflake role

        Returns:
        The Amazon Resource Name (ARN) of the Snowflake role
      • retryOptions

        public final SnowflakeRetryOptions retryOptions()

        The time period where Firehose will retry sending data to the chosen HTTP endpoint.

        Returns:
        The time period where Firehose will retry sending data to the chosen HTTP endpoint.
      • s3Configuration

        public final S3DestinationConfiguration s3Configuration()
        Returns the value of the S3Configuration property for this object.
        Returns:
        The value of the S3Configuration property for this object.
      • secretsManagerConfiguration

        public final SecretsManagerConfiguration secretsManagerConfiguration()

        The configuration that defines how you access secrets for Snowflake.

        Returns:
        The configuration that defines how you access secrets for Snowflake.
      • bufferingHints

        public final SnowflakeBufferingHints bufferingHints()

        Describes the buffering to perform before delivering data to the Snowflake destination. If you do not specify any value, Firehose uses the default values.

        Returns:
        Describes the buffering to perform before delivering data to the Snowflake destination. If you do not specify any value, Firehose uses the default values.
      • hashCode

        public final int hashCode()
        Overrides:
        hashCode in class Object
      • equals

        public final boolean equals​(Object obj)
        Overrides:
        equals in class Object
      • toString

        public final String toString()
        Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value.
        Overrides:
        toString in class Object
      • getValueForField

        public final <T> Optional<T> getValueForField​(String fieldName,
                                                      Class<T> clazz)