Package com.pulumi.aws.pipes.inputs

Class PipeSourceParametersKinesisStreamParametersArgs.Builder

java.lang.Object

com.pulumi.aws.pipes.inputs.PipeSourceParametersKinesisStreamParametersArgs.Builder

Enclosing class:

PipeSourceParametersKinesisStreamParametersArgs

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

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersKinesisStreamParametersArgs defaults)

Method Summary

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

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

Method Detail

batchSize

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

batchSize

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

deadLetterConfig

public PipeSourceParametersKinesisStreamParametersArgs.Builder deadLetterConfig(@Nullable
                                                                                com.pulumi.core.Output<PipeSourceParametersKinesisStreamParametersDeadLetterConfigArgs> deadLetterConfig)

deadLetterConfig

public PipeSourceParametersKinesisStreamParametersArgs.Builder deadLetterConfig(PipeSourceParametersKinesisStreamParametersDeadLetterConfigArgs deadLetterConfig)

maximumBatchingWindowInSeconds

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

maximumBatchingWindowInSeconds

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

maximumRecordAgeInSeconds

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

maximumRecordAgeInSeconds

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

maximumRetryAttempts

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

maximumRetryAttempts

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

onPartialBatchItemFailure

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

onPartialBatchItemFailure

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

parallelizationFactor

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

parallelizationFactor

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

startingPosition

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

startingPosition

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

startingPositionTimestamp

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

Parameters:

startingPositionTimestamp - With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

Returns:

builder

startingPositionTimestamp

public PipeSourceParametersKinesisStreamParametersArgs.Builder startingPositionTimestamp(java.lang.String startingPositionTimestamp)

Parameters:

startingPositionTimestamp - With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

Returns:

builder

build

public PipeSourceParametersKinesisStreamParametersArgs build()