public static final class StreamEventSourceProps.Builder
extends java.lang.Object
StreamEventSourceProps
Constructor and Description |
---|
Builder() |
public StreamEventSourceProps.Builder bisectBatchOnError(java.lang.Boolean bisectBatchOnError)
StreamEventSourceProps.getBisectBatchOnError()
bisectBatchOnError
- If the function returns an error, split the batch in two and retry.this
public StreamEventSourceProps.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 StreamEventSourceProps.Builder onFailure(IEventSourceDlq onFailure)
StreamEventSourceProps.getOnFailure()
onFailure
- An Amazon SQS queue or Amazon SNS topic destination for discarded records.this
public StreamEventSourceProps.Builder parallelizationFactor(java.lang.Number parallelizationFactor)
StreamEventSourceProps.getParallelizationFactor()
parallelizationFactor
- The number of batches to process from each shard concurrently.
Valid Range:
this
public StreamEventSourceProps.Builder reportBatchItemFailures(java.lang.Boolean reportBatchItemFailures)
StreamEventSourceProps.getReportBatchItemFailures()
reportBatchItemFailures
- Allow functions to return partially successful responses for a batch of records.this
public StreamEventSourceProps.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 StreamEventSourceProps.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 StreamEventSourceProps.Builder startingPosition(StartingPosition startingPosition)
BaseStreamEventSourceProps.getStartingPosition()
startingPosition
- Where to begin consuming the stream. This parameter is required.this
public StreamEventSourceProps.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 StreamEventSourceProps.Builder enabled(java.lang.Boolean enabled)
BaseStreamEventSourceProps.getEnabled()
enabled
- If the stream event source mapping should be enabled.this
public StreamEventSourceProps.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 StreamEventSourceProps build()
StreamEventSourceProps
java.lang.NullPointerException
- if any required attribute was not provided