Package com.pulumi.aws.pipes.inputs

Class PipeSourceParametersDynamodbStreamParametersArgs.Builder

java.lang.Object

com.pulumi.aws.pipes.inputs.PipeSourceParametersDynamodbStreamParametersArgs.Builder

Enclosing class:

PipeSourceParametersDynamodbStreamParametersArgs

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

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersDynamodbStreamParametersArgs defaults)

Method Summary

Modifier and Type	Method	Description
PipeSourceParametersDynamodbStreamParametersArgs.Builder	batchSize(com.pulumi.core.Output<java.lang.Integer> batchSize)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	batchSize(java.lang.Integer batchSize)
PipeSourceParametersDynamodbStreamParametersArgs	build()
PipeSourceParametersDynamodbStreamParametersArgs.Builder	deadLetterConfig(PipeSourceParametersDynamodbStreamParametersDeadLetterConfigArgs deadLetterConfig)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	deadLetterConfig(com.pulumi.core.Output<PipeSourceParametersDynamodbStreamParametersDeadLetterConfigArgs> deadLetterConfig)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumBatchingWindowInSeconds(com.pulumi.core.Output<java.lang.Integer> maximumBatchingWindowInSeconds)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumRecordAgeInSeconds(com.pulumi.core.Output<java.lang.Integer> maximumRecordAgeInSeconds)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumRecordAgeInSeconds(java.lang.Integer maximumRecordAgeInSeconds)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumRetryAttempts(com.pulumi.core.Output<java.lang.Integer> maximumRetryAttempts)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	maximumRetryAttempts(java.lang.Integer maximumRetryAttempts)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	onPartialBatchItemFailure(com.pulumi.core.Output<java.lang.String> onPartialBatchItemFailure)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	onPartialBatchItemFailure(java.lang.String onPartialBatchItemFailure)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	parallelizationFactor(com.pulumi.core.Output<java.lang.Integer> parallelizationFactor)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	parallelizationFactor(java.lang.Integer parallelizationFactor)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	startingPosition(com.pulumi.core.Output<java.lang.String> startingPosition)
PipeSourceParametersDynamodbStreamParametersArgs.Builder	startingPosition(java.lang.String startingPosition)

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(PipeSourceParametersDynamodbStreamParametersArgs defaults)

Method Detail

batchSize

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

Parameters:

batchSize - Maximum number of records to include in each batch. Maximum value of 10000.

Returns:

builder

batchSize

public PipeSourceParametersDynamodbStreamParametersArgs.Builder batchSize(java.lang.Integer batchSize)

Parameters:

batchSize - Maximum number of records to include in each batch. Maximum value of 10000.

Returns:

builder

deadLetterConfig

public PipeSourceParametersDynamodbStreamParametersArgs.Builder deadLetterConfig(@Nullable
                                                                                 com.pulumi.core.Output<PipeSourceParametersDynamodbStreamParametersDeadLetterConfigArgs> deadLetterConfig)

Parameters:

deadLetterConfig - Define the target queue to send dead-letter queue events to. See `deadLetterConfig` Block for details.

Returns:

builder

deadLetterConfig

public PipeSourceParametersDynamodbStreamParametersArgs.Builder deadLetterConfig(PipeSourceParametersDynamodbStreamParametersDeadLetterConfigArgs deadLetterConfig)

Parameters:

deadLetterConfig - Define the target queue to send dead-letter queue events to. See `deadLetterConfig` Block for details.

Returns:

builder

maximumBatchingWindowInSeconds

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

Parameters:

maximumBatchingWindowInSeconds - Maximum length of a time to wait for events. Maximum value of 300.

Returns:

builder

maximumBatchingWindowInSeconds

public PipeSourceParametersDynamodbStreamParametersArgs.Builder maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)

Parameters:

maximumBatchingWindowInSeconds - Maximum length of a time to wait for events. Maximum value of 300.

Returns:

builder

maximumRecordAgeInSeconds

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

Parameters:

maximumRecordAgeInSeconds - Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records. Maximum value of 604,800.

Returns:

builder

maximumRecordAgeInSeconds

public PipeSourceParametersDynamodbStreamParametersArgs.Builder maximumRecordAgeInSeconds(java.lang.Integer maximumRecordAgeInSeconds)

Parameters:

maximumRecordAgeInSeconds - Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records. Maximum value of 604,800.

Returns:

builder

maximumRetryAttempts

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

Parameters:

maximumRetryAttempts - Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source. Maximum value of 10,000.

Returns:

builder

maximumRetryAttempts

public PipeSourceParametersDynamodbStreamParametersArgs.Builder maximumRetryAttempts(java.lang.Integer maximumRetryAttempts)

Parameters:

maximumRetryAttempts - Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source. Maximum value of 10,000.

Returns:

builder

onPartialBatchItemFailure

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

Parameters:

onPartialBatchItemFailure - Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch. Valid values: AUTOMATIC_BISECT.

Returns:

builder

onPartialBatchItemFailure

public PipeSourceParametersDynamodbStreamParametersArgs.Builder onPartialBatchItemFailure(java.lang.String onPartialBatchItemFailure)

Parameters:

onPartialBatchItemFailure - Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch. Valid values: AUTOMATIC_BISECT.

Returns:

builder

parallelizationFactor

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

Parameters:

parallelizationFactor - Number of batches to process concurrently from each shard. The default value is 1. Maximum value of 10.

Returns:

builder

parallelizationFactor

public PipeSourceParametersDynamodbStreamParametersArgs.Builder parallelizationFactor(java.lang.Integer parallelizationFactor)

Parameters:

parallelizationFactor - Number of batches to process concurrently from each shard. The default value is 1. Maximum value of 10.

Returns:

builder

startingPosition

public PipeSourceParametersDynamodbStreamParametersArgs.Builder startingPosition(com.pulumi.core.Output<java.lang.String> startingPosition)

Parameters:

startingPosition - Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

Returns:

builder

startingPosition

public PipeSourceParametersDynamodbStreamParametersArgs.Builder startingPosition(java.lang.String startingPosition)

Parameters:

startingPosition - Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

Returns:

builder

build

public PipeSourceParametersDynamodbStreamParametersArgs build()