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.101.0 (build b95fe5d)", date="2024-08-02T00:29:19.557Z") @Stability(Experimental) public interface DataProcessorProps extends software.amazon.jsii.JsiiSerializable
(experimental) 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")
         .destinations(List.of(s3Destination))
         .build();

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static final class 
    DataProcessorProps.Builder
    A builder for DataProcessorProps
    static final class 
    DataProcessorProps.Jsii$Proxy
    An implementation for DataProcessorProps

  • Method Summary

    Modifier and Type
    Method
    Description
    static DataProcessorProps.Builder
    builder()
     
    default Duration
    getBufferInterval()
    (experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
    default Size
    getBufferSize()
    (experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
    default Number
    getRetries()
    (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 interface software.amazon.jsii.JsiiSerializable

    $jsii$toJson

  • Method Details

    • getBufferInterval

      @Stability(Experimental) @Nullable default Duration getBufferInterval()
      (experimental) The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.

      s

      Default: Duration.minutes(1)

    • getBufferSize

      @Stability(Experimental) @Nullable default Size getBufferSize()
      (experimental) The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.

      Default: Size.mebibytes(3)

    • getRetries

      @Stability(Experimental) @Nullable default Number getRetries()
      (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

    • builder

      @Stability(Experimental) static DataProcessorProps.Builder builder()
      Returns:
      a DataProcessorProps.Builder of DataProcessorProps