Interface CfnDeliveryStream.IcebergDestinationConfigurationProperty
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
CfnDeliveryStream.IcebergDestinationConfigurationProperty.Jsii$Proxy
- Enclosing class:
CfnDeliveryStream
Example:
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import software.amazon.awscdk.services.kinesisfirehose.*;
IcebergDestinationConfigurationProperty icebergDestinationConfigurationProperty = IcebergDestinationConfigurationProperty.builder()
.catalogConfiguration(CatalogConfigurationProperty.builder()
.catalogArn("catalogArn")
.warehouseLocation("warehouseLocation")
.build())
.roleArn("roleArn")
.s3Configuration(S3DestinationConfigurationProperty.builder()
.bucketArn("bucketArn")
.roleArn("roleArn")
// the properties below are optional
.bufferingHints(BufferingHintsProperty.builder()
.intervalInSeconds(123)
.sizeInMBs(123)
.build())
.cloudWatchLoggingOptions(CloudWatchLoggingOptionsProperty.builder()
.enabled(false)
.logGroupName("logGroupName")
.logStreamName("logStreamName")
.build())
.compressionFormat("compressionFormat")
.encryptionConfiguration(EncryptionConfigurationProperty.builder()
.kmsEncryptionConfig(KMSEncryptionConfigProperty.builder()
.awskmsKeyArn("awskmsKeyArn")
.build())
.noEncryptionConfig("noEncryptionConfig")
.build())
.errorOutputPrefix("errorOutputPrefix")
.prefix("prefix")
.build())
// the properties below are optional
.appendOnly(false)
.bufferingHints(BufferingHintsProperty.builder()
.intervalInSeconds(123)
.sizeInMBs(123)
.build())
.cloudWatchLoggingOptions(CloudWatchLoggingOptionsProperty.builder()
.enabled(false)
.logGroupName("logGroupName")
.logStreamName("logStreamName")
.build())
.destinationTableConfigurationList(List.of(DestinationTableConfigurationProperty.builder()
.destinationDatabaseName("destinationDatabaseName")
.destinationTableName("destinationTableName")
// the properties below are optional
.partitionSpec(PartitionSpecProperty.builder()
.identity(List.of(PartitionFieldProperty.builder()
.sourceName("sourceName")
.build()))
.build())
.s3ErrorOutputPrefix("s3ErrorOutputPrefix")
.uniqueKeys(List.of("uniqueKeys"))
.build()))
.processingConfiguration(ProcessingConfigurationProperty.builder()
.enabled(false)
.processors(List.of(ProcessorProperty.builder()
.type("type")
// the properties below are optional
.parameters(List.of(ProcessorParameterProperty.builder()
.parameterName("parameterName")
.parameterValue("parameterValue")
.build()))
.build()))
.build())
.retryOptions(RetryOptionsProperty.builder()
.durationInSeconds(123)
.build())
.s3BackupMode("s3BackupMode")
.schemaEvolutionConfiguration(SchemaEvolutionConfigurationProperty.builder()
.enabled(false)
.build())
.tableCreationConfiguration(TableCreationConfigurationProperty.builder()
.enabled(false)
.build())
.build();
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic final classstatic final classAn implementation forCfnDeliveryStream.IcebergDestinationConfigurationProperty -
Method Summary
Modifier and TypeMethodDescriptionbuilder()default ObjectDescribes whether all incoming data for this delivery stream will be append only (inserts only and not for updates and deletes) for Iceberg delivery.default ObjectReturns union: eitherIResolvableorCfnDeliveryStream.BufferingHintsPropertyConfiguration describing where the destination Apache Iceberg Tables are persisted.default ObjectReturns union: eitherIResolvableorCfnDeliveryStream.CloudWatchLoggingOptionsPropertydefault ObjectProvides a list ofDestinationTableConfigurationswhich Firehose uses to deliver data to Apache Iceberg Tables.default ObjectReturns union: eitherIResolvableorCfnDeliveryStream.ProcessingConfigurationPropertydefault ObjectReturns union: eitherIResolvableorCfnDeliveryStream.RetryOptionsPropertyThe Amazon Resource Name (ARN) of the IAM role to be assumed by Firehose for calling Apache Iceberg Tables.default StringDescribes how Firehose will backup records.Returns union: eitherIResolvableorCfnDeliveryStream.S3DestinationConfigurationPropertydefault ObjectThe configuration to enable automatic schema evolution.default ObjectThe configuration to enable automatic table creation.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getCatalogConfiguration
Configuration describing where the destination Apache Iceberg Tables are persisted.Returns union: either
IResolvableorCfnDeliveryStream.CatalogConfigurationProperty- See Also:
-
getRoleArn
The Amazon Resource Name (ARN) of the IAM role to be assumed by Firehose for calling Apache Iceberg Tables.- See Also:
-
getS3Configuration
Returns union: eitherIResolvableorCfnDeliveryStream.S3DestinationConfigurationProperty- See Also:
-
getAppendOnly
Describes whether all incoming data for this delivery stream will be append only (inserts only and not for updates and deletes) for Iceberg delivery.This feature is only applicable for Apache Iceberg Tables.
The default value is false. If you set this value to true, Firehose automatically increases the throughput limit of a stream based on the throttling levels of the stream. If you set this parameter to true for a stream with updates and deletes, you will see out of order delivery.
Returns union: either
BooleanorIResolvable- See Also:
-
getBufferingHints
Returns union: eitherIResolvableorCfnDeliveryStream.BufferingHintsProperty- See Also:
-
getCloudWatchLoggingOptions
Returns union: eitherIResolvableorCfnDeliveryStream.CloudWatchLoggingOptionsProperty- See Also:
-
getDestinationTableConfigurationList
Provides a list ofDestinationTableConfigurationswhich Firehose uses to deliver data to Apache Iceberg Tables.Firehose will write data with insert if table specific configuration is not provided here.
Returns union: either
IResolvableor Listinvalid input: '<'eitherIResolvableorCfnDeliveryStream.DestinationTableConfigurationProperty>- See Also:
-
getProcessingConfiguration
Returns union: eitherIResolvableorCfnDeliveryStream.ProcessingConfigurationProperty- See Also:
-
getRetryOptions
Returns union: eitherIResolvableorCfnDeliveryStream.RetryOptionsProperty- See Also:
-
getS3BackupMode
Describes how Firehose will backup records.Currently,S3 backup only supports
FailedDataOnly.- See Also:
-
getSchemaEvolutionConfiguration
The configuration to enable automatic schema evolution.Amazon Data Firehose is in preview release and is subject to change.
Returns union: either
IResolvableorCfnDeliveryStream.SchemaEvolutionConfigurationProperty- See Also:
-
getTableCreationConfiguration
The configuration to enable automatic table creation.Amazon Data Firehose is in preview release and is subject to change.
Returns union: either
IResolvableorCfnDeliveryStream.TableCreationConfigurationProperty- See Also:
-
builder
@Stability(Stable) static CfnDeliveryStream.IcebergDestinationConfigurationProperty.Builder builder()
-