Package com.pulumi.aws.pipes.outputs

Class PipeSourceParametersKinesisStreamParameters.Builder

java.lang.Object

com.pulumi.aws.pipes.outputs.PipeSourceParametersKinesisStreamParameters.Builder

Enclosing class:

PipeSourceParametersKinesisStreamParameters

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

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersKinesisStreamParameters defaults)

Method Summary

Modifier and Type	Method	Description
PipeSourceParametersKinesisStreamParameters.Builder	batchSize(java.lang.Integer batchSize)
PipeSourceParametersKinesisStreamParameters	build()
PipeSourceParametersKinesisStreamParameters.Builder	deadLetterConfig(PipeSourceParametersKinesisStreamParametersDeadLetterConfig deadLetterConfig)
PipeSourceParametersKinesisStreamParameters.Builder	maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)
PipeSourceParametersKinesisStreamParameters.Builder	maximumRecordAgeInSeconds(java.lang.Integer maximumRecordAgeInSeconds)
PipeSourceParametersKinesisStreamParameters.Builder	maximumRetryAttempts(java.lang.Integer maximumRetryAttempts)
PipeSourceParametersKinesisStreamParameters.Builder	onPartialBatchItemFailure(java.lang.String onPartialBatchItemFailure)
PipeSourceParametersKinesisStreamParameters.Builder	parallelizationFactor(java.lang.Integer parallelizationFactor)
PipeSourceParametersKinesisStreamParameters.Builder	startingPosition(java.lang.String startingPosition)
PipeSourceParametersKinesisStreamParameters.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(PipeSourceParametersKinesisStreamParameters defaults)

Method Detail

batchSize

public PipeSourceParametersKinesisStreamParameters.Builder batchSize(@Nullable
                                                                     java.lang.Integer batchSize)

deadLetterConfig

public PipeSourceParametersKinesisStreamParameters.Builder deadLetterConfig(@Nullable
                                                                            PipeSourceParametersKinesisStreamParametersDeadLetterConfig deadLetterConfig)

maximumBatchingWindowInSeconds

public PipeSourceParametersKinesisStreamParameters.Builder maximumBatchingWindowInSeconds(@Nullable
                                                                                          java.lang.Integer maximumBatchingWindowInSeconds)

maximumRecordAgeInSeconds

public PipeSourceParametersKinesisStreamParameters.Builder maximumRecordAgeInSeconds(@Nullable
                                                                                     java.lang.Integer maximumRecordAgeInSeconds)

maximumRetryAttempts

public PipeSourceParametersKinesisStreamParameters.Builder maximumRetryAttempts(@Nullable
                                                                                java.lang.Integer maximumRetryAttempts)

onPartialBatchItemFailure

public PipeSourceParametersKinesisStreamParameters.Builder onPartialBatchItemFailure(@Nullable
                                                                                     java.lang.String onPartialBatchItemFailure)

parallelizationFactor

public PipeSourceParametersKinesisStreamParameters.Builder parallelizationFactor(@Nullable
                                                                                 java.lang.Integer parallelizationFactor)

startingPosition

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

startingPositionTimestamp

public PipeSourceParametersKinesisStreamParameters.Builder startingPositionTimestamp(@Nullable
                                                                                     java.lang.String startingPositionTimestamp)

build

public PipeSourceParametersKinesisStreamParameters build()