software.amazon.awscdk.services.kinesisfirehose

Class LambdaFunctionProcessor.Builder

java.lang.Object

software.amazon.awscdk.services.kinesisfirehose.LambdaFunctionProcessor.Builder

Enclosing class:

LambdaFunctionProcessor

public static final class LambdaFunctionProcessor.Builder
extends java.lang.Object

(experimental) A fluent builder for LambdaFunctionProcessor.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static LambdaFunctionProcessor.Builder create(IFunction lambdaFunction)

Parameters:

lambdaFunction - This parameter is required.

Returns:

a new instance of LambdaFunctionProcessor.Builder.

bufferInterval

public LambdaFunctionProcessor.Builder bufferInterval(Duration bufferInterval)

(experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.

s

Default: Duration.minutes(1)

Parameters:

bufferInterval - The length of time Kinesis Data Firehose will buffer incoming data before calling the processor. This parameter is required.

Returns:

this

bufferSize

public LambdaFunctionProcessor.Builder bufferSize(Size bufferSize)

(experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.

Default: Size.mebibytes(3)

Parameters:

bufferSize - The amount of incoming data Kinesis Data Firehose will buffer before calling the processor. This parameter is required.

Returns:

this

retries

public 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.

Default: 3

Parameters:

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.

Returns:

this

build

public LambdaFunctionProcessor build()