Package com.pulumi.aws.msk.inputs

Class ChannelIcebergDestinationArgs.Builder

java.lang.Object

com.pulumi.aws.msk.inputs.ChannelIcebergDestinationArgs.Builder

Enclosing class:

ChannelIcebergDestinationArgs

public static final class ChannelIcebergDestinationArgs.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(ChannelIcebergDestinationArgs defaults)

Method Summary

Modifier and Type	Method	Description
ChannelIcebergDestinationArgs.Builder	appendOnly(com.pulumi.core.Output<java.lang.Boolean> appendOnly)
ChannelIcebergDestinationArgs.Builder	appendOnly(java.lang.Boolean appendOnly)
ChannelIcebergDestinationArgs	build()
ChannelIcebergDestinationArgs.Builder	catalog(ChannelIcebergDestinationCatalogArgs catalog)
ChannelIcebergDestinationArgs.Builder	catalog(com.pulumi.core.Output<ChannelIcebergDestinationCatalogArgs> catalog)
ChannelIcebergDestinationArgs.Builder	compressionType(com.pulumi.core.Output<java.lang.String> compressionType)
ChannelIcebergDestinationArgs.Builder	compressionType(java.lang.String compressionType)
ChannelIcebergDestinationArgs.Builder	dataFreshnessInSeconds(com.pulumi.core.Output<java.lang.Integer> dataFreshnessInSeconds)
ChannelIcebergDestinationArgs.Builder	dataFreshnessInSeconds(java.lang.Integer dataFreshnessInSeconds)
ChannelIcebergDestinationArgs.Builder	deadLetterQueueS3(ChannelIcebergDestinationDeadLetterQueueS3Args deadLetterQueueS3)
ChannelIcebergDestinationArgs.Builder	deadLetterQueueS3(com.pulumi.core.Output<ChannelIcebergDestinationDeadLetterQueueS3Args> deadLetterQueueS3)
ChannelIcebergDestinationArgs.Builder	destinationTable(ChannelIcebergDestinationDestinationTableArgs destinationTable)
ChannelIcebergDestinationArgs.Builder	destinationTable(com.pulumi.core.Output<ChannelIcebergDestinationDestinationTableArgs> destinationTable)
ChannelIcebergDestinationArgs.Builder	schemaEvolution(ChannelIcebergDestinationSchemaEvolutionArgs schemaEvolution)
ChannelIcebergDestinationArgs.Builder	schemaEvolution(com.pulumi.core.Output<ChannelIcebergDestinationSchemaEvolutionArgs> schemaEvolution)
ChannelIcebergDestinationArgs.Builder	serviceExecutionRoleArn(com.pulumi.core.Output<java.lang.String> serviceExecutionRoleArn)
ChannelIcebergDestinationArgs.Builder	serviceExecutionRoleArn(java.lang.String serviceExecutionRoleArn)
ChannelIcebergDestinationArgs.Builder	tableCreation(ChannelIcebergDestinationTableCreationArgs tableCreation)
ChannelIcebergDestinationArgs.Builder	tableCreation(com.pulumi.core.Output<ChannelIcebergDestinationTableCreationArgs> tableCreation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Builder

public Builder(ChannelIcebergDestinationArgs defaults)

Method Detail

appendOnly

public ChannelIcebergDestinationArgs.Builder appendOnly(com.pulumi.core.Output<java.lang.Boolean> appendOnly)

Parameters:

appendOnly - Whether the destination is append-only. Must be `true`; updates and deletes are not supported.

Returns:

builder

appendOnly

public ChannelIcebergDestinationArgs.Builder appendOnly(java.lang.Boolean appendOnly)

Parameters:

appendOnly - Whether the destination is append-only. Must be `true`; updates and deletes are not supported.

Returns:

builder

catalog

public ChannelIcebergDestinationArgs.Builder catalog(@Nullable
                                                     com.pulumi.core.Output<ChannelIcebergDestinationCatalogArgs> catalog)

Parameters:

catalog - AWS Glue Data Catalog and S3 Tables warehouse used by the destination. See `catalog` Block below.

Returns:

builder

catalog

public ChannelIcebergDestinationArgs.Builder catalog(ChannelIcebergDestinationCatalogArgs catalog)

Parameters:

catalog - AWS Glue Data Catalog and S3 Tables warehouse used by the destination. See `catalog` Block below.

Returns:

builder

compressionType

public ChannelIcebergDestinationArgs.Builder compressionType(@Nullable
                                                             com.pulumi.core.Output<java.lang.String> compressionType)

Parameters:

compressionType - Compression codec for Iceberg table data files. Defaults to `ZSTD`.

Returns:

builder

compressionType

public ChannelIcebergDestinationArgs.Builder compressionType(java.lang.String compressionType)

Parameters:

compressionType - Compression codec for Iceberg table data files. Defaults to `ZSTD`.

Returns:

builder

dataFreshnessInSeconds

public ChannelIcebergDestinationArgs.Builder dataFreshnessInSeconds(@Nullable
                                                                    com.pulumi.core.Output<java.lang.Integer> dataFreshnessInSeconds)

Parameters:

dataFreshnessInSeconds - Maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Valid values are between `300` and `900`. Defaults to `600`. Can be updated in place without recreating the channel.

Returns:

builder

dataFreshnessInSeconds

public ChannelIcebergDestinationArgs.Builder dataFreshnessInSeconds(java.lang.Integer dataFreshnessInSeconds)

Parameters:

dataFreshnessInSeconds - Maximum time, in seconds, that records buffer in MSK before being flushed to the destination. Valid values are between `300` and `900`. Defaults to `600`. Can be updated in place without recreating the channel.

Returns:

builder

deadLetterQueueS3

public ChannelIcebergDestinationArgs.Builder deadLetterQueueS3(com.pulumi.core.Output<ChannelIcebergDestinationDeadLetterQueueS3Args> deadLetterQueueS3)

Parameters:

deadLetterQueueS3 - Amazon S3 bucket and prefix where MSK writes records that fail to deliver. See `deadLetterQueueS3` Block below.

Returns:

builder

deadLetterQueueS3

public ChannelIcebergDestinationArgs.Builder deadLetterQueueS3(ChannelIcebergDestinationDeadLetterQueueS3Args deadLetterQueueS3)

Parameters:

deadLetterQueueS3 - Amazon S3 bucket and prefix where MSK writes records that fail to deliver. See `deadLetterQueueS3` Block below.

Returns:

builder

destinationTable

public ChannelIcebergDestinationArgs.Builder destinationTable(com.pulumi.core.Output<ChannelIcebergDestinationDestinationTableArgs> destinationTable)

Parameters:

destinationTable - Destination Iceberg table. See `destinationTable` Block below.

Returns:

builder

destinationTable

public ChannelIcebergDestinationArgs.Builder destinationTable(ChannelIcebergDestinationDestinationTableArgs destinationTable)

Parameters:

destinationTable - Destination Iceberg table. See `destinationTable` Block below.

Returns:

builder

schemaEvolution

public ChannelIcebergDestinationArgs.Builder schemaEvolution(com.pulumi.core.Output<ChannelIcebergDestinationSchemaEvolutionArgs> schemaEvolution)

Parameters:

schemaEvolution - Configuration controlling whether the destination table's schema is evolved to match incoming records. See `schemaEvolution` Block below.

Returns:

builder

schemaEvolution

public ChannelIcebergDestinationArgs.Builder schemaEvolution(ChannelIcebergDestinationSchemaEvolutionArgs schemaEvolution)

Parameters:

schemaEvolution - Configuration controlling whether the destination table's schema is evolved to match incoming records. See `schemaEvolution` Block below.

Returns:

builder

serviceExecutionRoleArn

public ChannelIcebergDestinationArgs.Builder serviceExecutionRoleArn(com.pulumi.core.Output<java.lang.String> serviceExecutionRoleArn)

Parameters:

serviceExecutionRoleArn - ARN of the IAM role that MSK assumes to access the destination table, the AWS Glue Data Catalog, and the dead-letter Amazon S3 bucket.

Returns:

builder

serviceExecutionRoleArn

public ChannelIcebergDestinationArgs.Builder serviceExecutionRoleArn(java.lang.String serviceExecutionRoleArn)

Parameters:

serviceExecutionRoleArn - ARN of the IAM role that MSK assumes to access the destination table, the AWS Glue Data Catalog, and the dead-letter Amazon S3 bucket.

Returns:

builder

tableCreation

public ChannelIcebergDestinationArgs.Builder tableCreation(com.pulumi.core.Output<ChannelIcebergDestinationTableCreationArgs> tableCreation)

Parameters:

tableCreation - Configuration controlling whether MSK creates the destination table if it does not already exist. See `tableCreation` Block below. The following arguments are optional:

Returns:

builder

tableCreation

public ChannelIcebergDestinationArgs.Builder tableCreation(ChannelIcebergDestinationTableCreationArgs tableCreation)

Parameters:

tableCreation - Configuration controlling whether MSK creates the destination table if it does not already exist. See `tableCreation` Block below. The following arguments are optional:

Returns:

builder

build

public ChannelIcebergDestinationArgs build()