Package software.amazon.awscdk.services.kinesisfirehose.alpha

Interface DataProcessorProps

All Superinterfaces:

software.amazon.jsii.JsiiSerializable

All Known Implementing Classes:

DataProcessorProps.Jsii$Proxy

@Generated(value="jsii-pacmak/1.106.0 (build e852934)",
           date="2025-02-26T00:07:49.194Z")
@Stability(Deprecated)
@Deprecated
public interface DataProcessorProps
extends software.amazon.jsii.JsiiSerializable

Deprecated.

(deprecated) Configure the data processor.

Example:

 Bucket bucket;
 // Provide a Lambda function that will transform records before delivery, with custom
 // buffering and retry configuration
 Function lambdaFunction = Function.Builder.create(this, "Processor")
         .runtime(Runtime.NODEJS_LATEST)
         .handler("index.handler")
         .code(Code.fromAsset(join(__dirname, "process-records")))
         .build();
 LambdaFunctionProcessor lambdaProcessor = LambdaFunctionProcessor.Builder.create(lambdaFunction)
         .bufferInterval(Duration.minutes(5))
         .bufferSize(Size.mebibytes(5))
         .retries(5)
         .build();
 S3Bucket s3Destination = S3Bucket.Builder.create(bucket)
         .processor(lambdaProcessor)
         .build();
 DeliveryStream.Builder.create(this, "Delivery Stream")
         .destination(s3Destination)
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	DataProcessorProps.Builder	Deprecated.
static final class	DataProcessorProps.Jsii$Proxy	Deprecated.

Method Summary

Modifier and Type	Method	Description
static DataProcessorProps.Builder	builder()	Deprecated.
default Duration	getBufferInterval()	Deprecated.
default Size	getBufferSize()	Deprecated.
default Number	getRetries()	Deprecated.

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Method Details

getBufferInterval

@Stability(Deprecated)
@Deprecated
@Nullable
default Duration getBufferInterval()

Deprecated.

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

s

Default: Duration.minutes(1)

getBufferSize

@Stability(Deprecated)
@Deprecated
@Nullable
default Size getBufferSize()

Deprecated.

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

Default: Size.mebibytes(3)

getRetries

@Stability(Deprecated)
@Deprecated
@Nullable
default Number getRetries()

Deprecated.

(deprecated) The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.

Default: 3

builder

@Stability(Deprecated)
@Deprecated
static DataProcessorProps.Builder builder()

Deprecated.

Returns:

a DataProcessorProps.Builder of DataProcessorProps