Interface CfnChannel.IcebergDestinationConfigurationProperty
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
CfnChannel.IcebergDestinationConfigurationProperty.Jsii$Proxy
- Enclosing class:
CfnChannel
@Stability(Stable)
public static interface CfnChannel.IcebergDestinationConfigurationProperty
extends software.amazon.jsii.JsiiSerializable
Iceberg destination configuration.
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.msk.*;
IcebergDestinationConfigurationProperty icebergDestinationConfigurationProperty = IcebergDestinationConfigurationProperty.builder()
.appendOnly(false)
.deadLetterQueueS3(DeadLetterQueueS3Property.builder()
.bucketArn("bucketArn")
.errorOutputPrefix("errorOutputPrefix")
// the properties below are optional
.expectedBucketOwner("expectedBucketOwner")
.build())
.destinationTableList(List.of(DestinationTableProperty.builder()
.destinationDatabaseName("destinationDatabaseName")
.destinationTableName("destinationTableName")
// the properties below are optional
.partitionSpec(PartitionSpecProperty.builder()
.partitionStrategy("partitionStrategy")
// the properties below are optional
.sourceList(List.of(PartitionSourceProperty.builder()
.sourceName("sourceName")
.build()))
.build())
.build()))
.schemaEvolution(SchemaEvolutionProperty.builder()
.enableSchemaEvolution(false)
.build())
.serviceExecutionRoleArn("serviceExecutionRoleArn")
.tableCreation(TableCreationProperty.builder()
.enableTableCreation(false)
.build())
// the properties below are optional
.catalog(CatalogProperty.builder()
.catalogArn("catalogArn")
.warehouseLocation("warehouseLocation")
.build())
.compressionType("compressionType")
.dataFreshnessInSeconds(123)
.build();
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic final classA builder forCfnChannel.IcebergDestinationConfigurationPropertystatic final classAn implementation forCfnChannel.IcebergDestinationConfigurationProperty -
Method Summary
Modifier and TypeMethodDescriptionbuilder()Append only mode.default ObjectCatalog configuration of the destination.default StringCompression codec for Iceberg table data files.default NumberData freshness in seconds.Dead letter queue S3 configuration of the destination.List of destination tables.Schema evolution configuration of the destination.The Amazon Resource Name (ARN) of an IAM role used by MSK to access the table.Table creation configuration of the destination.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getAppendOnly
Append only mode.Returns union: either
BooleanorIResolvableDefault: - true
- See Also:
-
getDeadLetterQueueS3
Dead letter queue S3 configuration of the destination.Returns union: either
IResolvableorCfnChannel.DeadLetterQueueS3Property- See Also:
-
getDestinationTableList
List of destination tables.Returns union: either
IResolvableor Listinvalid input: '<'eitherIResolvableorCfnChannel.DestinationTableProperty>- See Also:
-
getSchemaEvolution
Schema evolution configuration of the destination.Returns union: either
IResolvableorCfnChannel.SchemaEvolutionProperty- See Also:
-
getServiceExecutionRoleArn
The Amazon Resource Name (ARN) of an IAM role used by MSK to access the table.- See Also:
-
getTableCreation
Table creation configuration of the destination.Returns union: either
IResolvableorCfnChannel.TableCreationProperty- See Also:
-
getCatalog
Catalog configuration of the destination.Returns union: either
IResolvableorCfnChannel.CatalogProperty- See Also:
-
getCompressionType
Compression codec for Iceberg table data files.Defaults to ZSTD.
- See Also:
-
getDataFreshnessInSeconds
Data freshness in seconds.- See Also:
-
builder
-