KinesisPipeline.java

public KinesisPipeline(final Construct scope, final String id, final KinesisPipelineProps props) {
    super(scope, id);
 
    firehoseDeliveryRole = props.getFirehoseDeliveryRole();
    lambdaExecutionRole = props.getLambdaExecutionRole();
    streamKey = props.getStreamKey();
    catalogId = props.getCatalogId();
    glueDatabaseName = props.getGlueDatabaseName();
    glueTableName = props.getGlueTableName();
    streamId = props.getStreamId();
    streamName = props.getStreamName();
    transformFunction = props.getTransformFunction();
    deliveryStreamPrefix = props.getDeliveryStreamPrefix();
    deliveryStreamErrorPrefix = props.getDeliveryStreamErrorPrefix();
    deliveryStreamParquetPrefix = props.getDeliveryStreamParquetPrefix();
    deliveryStreamParquetErrorPrefix = props.getDeliveryStreamParquetErrorPrefix();
    platformResourceName = props.getPlatformResourceName();
    autoPartitionLambda = props.getAutoPartitionLambda();
 
    createStream();
    createDeliveryStream();
    createDeliveryStreamParquetGlue();
    createAutoPartitionLambda();
  }