public static final class KinesisEventSourceProps.Builder
extends java.lang.Object
KinesisEventSourceProps
Constructor and Description |
---|
Builder() |
public KinesisEventSourceProps.Builder bisectBatchOnError(java.lang.Boolean bisectBatchOnError)
StreamEventSourceProps.getBisectBatchOnError()
bisectBatchOnError
- If the function returns an error, split the batch in two and retry.this
public KinesisEventSourceProps.Builder maxRecordAge(Duration maxRecordAge)
StreamEventSourceProps.getMaxRecordAge()
maxRecordAge
- The maximum age of a record that Lambda sends to a function for processing.
Valid Range:
this
public KinesisEventSourceProps.Builder onFailure(IEventSourceDlq onFailure)
StreamEventSourceProps.getOnFailure()
onFailure
- An Amazon SQS queue or Amazon SNS topic destination for discarded records.this
public KinesisEventSourceProps.Builder parallelizationFactor(java.lang.Number parallelizationFactor)
StreamEventSourceProps.getParallelizationFactor()
parallelizationFactor
- The number of batches to process from each shard concurrently.
Valid Range:
this
public KinesisEventSourceProps.Builder reportBatchItemFailures(java.lang.Boolean reportBatchItemFailures)
StreamEventSourceProps.getReportBatchItemFailures()
reportBatchItemFailures
- Allow functions to return partially successful responses for a batch of records.this
public KinesisEventSourceProps.Builder retryAttempts(java.lang.Number retryAttempts)
StreamEventSourceProps.getRetryAttempts()
retryAttempts
- Maximum number of retry attempts Valid Range: * Minimum value of 0 * Maximum value of 10000.this
public KinesisEventSourceProps.Builder tumblingWindow(Duration tumblingWindow)
StreamEventSourceProps.getTumblingWindow()
tumblingWindow
- The size of the tumbling windows to group records sent to DynamoDB or Kinesis Valid Range: 0 - 15 minutes.this
public KinesisEventSourceProps.Builder startingPosition(StartingPosition startingPosition)
BaseStreamEventSourceProps.getStartingPosition()
startingPosition
- Where to begin consuming the stream. This parameter is required.this
public KinesisEventSourceProps.Builder batchSize(java.lang.Number batchSize)
BaseStreamEventSourceProps.getBatchSize()
batchSize
- The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
Your function receives an
event with all the retrieved records.
Valid Range:
this
public KinesisEventSourceProps.Builder enabled(java.lang.Boolean enabled)
BaseStreamEventSourceProps.getEnabled()
enabled
- If the stream event source mapping should be enabled.this
public KinesisEventSourceProps.Builder maxBatchingWindow(Duration maxBatchingWindow)
BaseStreamEventSourceProps.getMaxBatchingWindow()
maxBatchingWindow
- The maximum amount of time to gather records before invoking the function.
Maximum of Duration.minutes(5)this
public KinesisEventSourceProps build()
KinesisEventSourceProps
java.lang.NullPointerException
- if any required attribute was not provided