Pipe
data class PipeSourceParametersKinesisStreamParameters(val batchSize: Int? = null, val deadLetterConfig: PipeSourceParametersKinesisStreamParametersDeadLetterConfig? = null, val maximumBatchingWindowInSeconds: Int? = null, val maximumRecordAgeInSeconds: Int? = null, val maximumRetryAttempts: Int? = null, val onPartialBatchItemFailure: String? = null, val parallelizationFactor: Int? = null, val startingPosition: String, val startingPositionTimestamp: String? = null)
Constructors
Link copied to clipboard
fun PipeSourceParametersKinesisStreamParameters(batchSize: Int? = null, deadLetterConfig: PipeSourceParametersKinesisStreamParametersDeadLetterConfig? = null, maximumBatchingWindowInSeconds: Int? = null, maximumRecordAgeInSeconds: Int? = null, maximumRetryAttempts: Int? = null, onPartialBatchItemFailure: String? = null, parallelizationFactor: Int? = null, startingPosition: String, startingPositionTimestamp: String? = null)