Skip to content

Instantly share code, notes, and snippets.

@fsanal
Created December 12, 2022 21:18
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Embed
What would you like to do?
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();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment