public static final class StreamEventSourceProps.Jsii$Proxy extends software.amazon.jsii.JsiiObject implements StreamEventSourceProps
StreamEventSourceProps
StreamEventSourceProps.Builder, StreamEventSourceProps.Jsii$Proxy
Modifier | Constructor and Description |
---|---|
protected |
Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)
Constructor that initializes the object based on values retrieved from the JsiiObject.
|
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.databind.JsonNode |
$jsii$toJson() |
boolean |
equals(java.lang.Object o) |
java.lang.Number |
getBatchSize()
The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
|
java.lang.Boolean |
getBisectBatchOnError()
If the function returns an error, split the batch in two and retry.
|
java.lang.Boolean |
getEnabled()
If the stream event source mapping should be enabled.
|
Duration |
getMaxBatchingWindow()
The maximum amount of time to gather records before invoking the function.
|
Duration |
getMaxRecordAge()
The maximum age of a record that Lambda sends to a function for processing.
|
IEventSourceDlq |
getOnFailure()
An Amazon SQS queue or Amazon SNS topic destination for discarded records.
|
java.lang.Number |
getParallelizationFactor()
The number of batches to process from each shard concurrently.
|
java.lang.Boolean |
getReportBatchItemFailures()
Allow functions to return partially successful responses for a batch of records.
|
java.lang.Number |
getRetryAttempts()
Maximum number of retry attempts Valid Range: * Minimum value of 0 * Maximum value of 10000.
|
StartingPosition |
getStartingPosition()
Where to begin consuming the stream.
|
Duration |
getTumblingWindow()
The size of the tumbling windows to group records sent to DynamoDB or Kinesis Valid Range: 0 - 15 minutes.
|
int |
hashCode() |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
builder
protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)
objRef
- Reference to the JSII managed object.public final java.lang.Boolean getBisectBatchOnError()
StreamEventSourceProps
Default: false
getBisectBatchOnError
in interface StreamEventSourceProps
public final Duration getMaxRecordAge()
StreamEventSourceProps
Valid Range:
Default: - the retention period configured on the stream
getMaxRecordAge
in interface StreamEventSourceProps
public final IEventSourceDlq getOnFailure()
StreamEventSourceProps
Default: - discarded records are ignored
getOnFailure
in interface StreamEventSourceProps
public final java.lang.Number getParallelizationFactor()
StreamEventSourceProps
Valid Range:
Default: 1
getParallelizationFactor
in interface StreamEventSourceProps
public final java.lang.Boolean getReportBatchItemFailures()
StreamEventSourceProps
Default: false
getReportBatchItemFailures
in interface StreamEventSourceProps
public final java.lang.Number getRetryAttempts()
StreamEventSourceProps
Default: - retry until the record expires
getRetryAttempts
in interface StreamEventSourceProps
public final Duration getTumblingWindow()
StreamEventSourceProps
Default: - None
getTumblingWindow
in interface StreamEventSourceProps
public final StartingPosition getStartingPosition()
BaseStreamEventSourceProps
getStartingPosition
in interface BaseStreamEventSourceProps
public final java.lang.Number getBatchSize()
BaseStreamEventSourceProps
Your function receives an event with all the retrieved records.
Valid Range:
Default: 100
getBatchSize
in interface BaseStreamEventSourceProps
public final java.lang.Boolean getEnabled()
BaseStreamEventSourceProps
Default: true
getEnabled
in interface BaseStreamEventSourceProps
public final Duration getMaxBatchingWindow()
BaseStreamEventSourceProps
Maximum of Duration.minutes(5)
Default: Duration.seconds(0)
getMaxBatchingWindow
in interface BaseStreamEventSourceProps
public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()
public final boolean equals(java.lang.Object o)
public final int hashCode()