public static final class LambdaFunctionProcessor.Builder
extends java.lang.Object
LambdaFunctionProcessor
.Modifier and Type | Method and Description |
---|---|
LambdaFunctionProcessor.Builder |
bufferInterval(Duration bufferInterval)
(experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
|
LambdaFunctionProcessor.Builder |
bufferSize(Size bufferSize)
(experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
|
LambdaFunctionProcessor |
build() |
static LambdaFunctionProcessor.Builder |
create(IFunction lambdaFunction) |
LambdaFunctionProcessor.Builder |
retries(java.lang.Number retries)
(experimental) The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.
|
public static LambdaFunctionProcessor.Builder create(IFunction lambdaFunction)
lambdaFunction
- This parameter is required.LambdaFunctionProcessor.Builder
.public LambdaFunctionProcessor.Builder bufferInterval(Duration bufferInterval)
s
Default: Duration.minutes(1)
bufferInterval
- The length of time Kinesis Data Firehose will buffer incoming data before calling the processor. This parameter is required.this
public LambdaFunctionProcessor.Builder bufferSize(Size bufferSize)
Default: Size.mebibytes(3)
bufferSize
- The amount of incoming data Kinesis Data Firehose will buffer before calling the processor. This parameter is required.this
public LambdaFunctionProcessor.Builder retries(java.lang.Number retries)
Default: 3
retries
- The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits. This parameter is required.this
public LambdaFunctionProcessor build()