Package software.amazon.awscdk.services.kinesisfirehose

Class RecordDeAggregationProcessor

java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.services.kinesisfirehose.RecordDeAggregationProcessor
All Implemented Interfaces:
IDataProcessor, software.amazon.jsii.JsiiSerializable
@Generated(value="jsii-pacmak/1.126.0 (build 206d44b)", date="2026-02-19T19:23:42.317Z") @Stability(Stable) public class RecordDeAggregationProcessor extends software.amazon.jsii.JsiiObject implements IDataProcessor
The data processor for multi record deaggrecation.

Record deaggregation by JSON or by delimiter is capped at 500 per record.

Example: 

 Bucket bucket;
 S3Bucket s3Destination = S3Bucket.Builder.create(bucket)
         .dynamicPartitioning(DynamicPartitioningProps.builder().enabled(true).build())
         .processors(List.of(RecordDeAggregationProcessor.json()))
         .build();

See Also:

  • Constructor Details

    • RecordDeAggregationProcessor

      protected RecordDeAggregationProcessor(software.amazon.jsii.JsiiObjectRef objRef)

    • RecordDeAggregationProcessor

      protected RecordDeAggregationProcessor(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

    • RecordDeAggregationProcessor

      @Stability(Stable) public RecordDeAggregationProcessor(@NotNull RecordDeAggregationProcessorOptions options)
      Parameters:
      options - This parameter is required.

  • Method Details

    • delimited

      @Stability(Stable) @NotNull public static RecordDeAggregationProcessor delimited(@NotNull String delimiter)
      Perform deaggregation based on a specified custom delimiter.

      Parameters:
      delimiter - The custom delimiter. This parameter is required.

    • json

      @Stability(Stable) @NotNull public static RecordDeAggregationProcessor json()
      Perform deaggregation from JSON objects on a single line with no delimiter or newline-delimited (JSONL).

    • bind

      @Stability(Stable) @NotNull public DataProcessorConfig bind(@NotNull software.constructs.Construct scope, @NotNull DataProcessorBindOptions options)
      Binds this processor to a destination of a delivery stream.

      Implementers should use this method to grant processor invocation permissions to the provided stream and return the necessary configuration to register as a processor.

      Specified by:
      bind in interface IDataProcessor
      Parameters:
      scope - This parameter is required.
      options - This parameter is required.

    • getProps

      @Stability(Stable) @NotNull public DataProcessorProps getProps()
      The constructor props of the DataProcessor.
      Specified by:
      getProps in interface IDataProcessor