Package com.pulumi.aws.pipes.outputs

Class PipeSourceParametersKinesisStreamParameters

java.lang.Object

com.pulumi.aws.pipes.outputs.PipeSourceParametersKinesisStreamParameters

public final class PipeSourceParametersKinesisStreamParameters
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PipeSourceParametersKinesisStreamParameters.Builder

Method Summary

Modifier and Type	Method	Description
java.util.Optional<java.lang.Integer>	batchSize()
static PipeSourceParametersKinesisStreamParameters.Builder	builder()
static PipeSourceParametersKinesisStreamParameters.Builder	builder(PipeSourceParametersKinesisStreamParameters defaults)
java.util.Optional<PipeSourceParametersKinesisStreamParametersDeadLetterConfig>	deadLetterConfig()
java.util.Optional<java.lang.Integer>	maximumBatchingWindowInSeconds()
java.util.Optional<java.lang.Integer>	maximumRecordAgeInSeconds()
java.util.Optional<java.lang.Integer>	maximumRetryAttempts()
java.util.Optional<java.lang.String>	onPartialBatchItemFailure()
java.util.Optional<java.lang.Integer>	parallelizationFactor()
java.lang.String	startingPosition()
java.util.Optional<java.lang.String>	startingPositionTimestamp()

Methods inherited from class java.lang.Object

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

Method Detail

batchSize

public java.util.Optional<java.lang.Integer> batchSize()

deadLetterConfig

public java.util.Optional<PipeSourceParametersKinesisStreamParametersDeadLetterConfig> deadLetterConfig()

maximumBatchingWindowInSeconds

public java.util.Optional<java.lang.Integer> maximumBatchingWindowInSeconds()

maximumRecordAgeInSeconds

public java.util.Optional<java.lang.Integer> maximumRecordAgeInSeconds()

maximumRetryAttempts

public java.util.Optional<java.lang.Integer> maximumRetryAttempts()

onPartialBatchItemFailure

public java.util.Optional<java.lang.String> onPartialBatchItemFailure()

parallelizationFactor

public java.util.Optional<java.lang.Integer> parallelizationFactor()

startingPosition

public java.lang.String startingPosition()

startingPositionTimestamp

public java.util.Optional<java.lang.String> startingPositionTimestamp()

Returns:

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

builder

public static PipeSourceParametersKinesisStreamParameters.Builder builder()

builder

public static PipeSourceParametersKinesisStreamParameters.Builder builder(PipeSourceParametersKinesisStreamParameters defaults)