Path	Lines of Code
core/src/athena-default-setup.ts	21
core/src/common/context-options.ts	3
core/src/common/pre-bundled-function.ts	18
core/src/common/tracked-construct.ts	14
core/src/data-generator/batch-replayer.ts	112
core/src/data-generator/data-generator.ts	292
core/src/data-generator/index.ts	2
core/src/data-generator/resources/lambdas/find-file-paths/find-file-paths.py	65
core/src/data-generator/resources/lambdas/setup/lambda.py	17
core/src/data-generator/resources/lambdas/write-in-batch/write-in-batch.py	123
core/src/data-lake-catalog.ts	19
core/src/data-lake-exporter.ts	155
core/src/data-lake-storage.ts	92
core/src/datasets/dataset.ts	267
core/src/datasets/index.ts	2
core/src/datasets/partitioned-dataset.ts	82
core/src/datasets/read-sql-file.ts	5
core/src/datasets/retail-customer-address.ts	6
core/src/datasets/retail-customer.ts	6
core/src/datasets/retail-item.ts	5
core/src/datasets/retail-promo.ts	5
core/src/datasets/retail-store-sale.ts	5
core/src/datasets/retail-store.ts	5
core/src/datasets/retail-warehouse.ts	5
core/src/datasets/retail-web-sale.ts	5
core/src/db-schema-manager/flyway-runner.ts	80
core/src/db-schema-manager/index.ts	1
core/src/db-schema-manager/integ.default.ts	23
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/FlywayCustomResourceHandler.java	66
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/FlywayHandler.java	54
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/FlywayService.java	253
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/DBRequest.java	54
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/EnvironmentVars.java	17
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/FlywayMethod.java	9
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/FlywayRequest.java	274
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/GitRequest.java	103
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/Request.java	35
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/S3Request.java	25
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/SecretVars.java	5
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/SystemEnvironment.java	9
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/request/ValueManager.java	101
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/response/Response.java	47
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/flyway/response/ResponseInfo.java	33
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/lambda/MigrationFilesException.java	12
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/lambda/MigrationFilesService.java	9
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/lambda/git/GitService.java	182
core/src/db-schema-manager/resources/flyway-lambda/src/main/java/com/geekoosh/lambda/s3/S3Service.java	87
core/src/ec2-ssm-role.ts	8
core/src/emr-eks-platform/config-override-schema-validation.ts	17
core/src/emr-eks-platform/emr-eks-cluster.ts	487
core/src/emr-eks-platform/emr-eks-nodegroup-asg-tag.ts	49
core/src/emr-eks-platform/emr-eks-nodegroup.ts	119
core/src/emr-eks-platform/emr-managed-endpoint.ts	73
core/src/emr-eks-platform/emr-virtual-cluster.ts	5
core/src/emr-eks-platform/index.ts	4
core/src/emr-eks-platform/resources/k8s/pod-template/critical-driver.yaml	11
core/src/emr-eks-platform/resources/k8s/pod-template/critical-executor.yaml	18
core/src/emr-eks-platform/resources/k8s/pod-template/notebook-driver.yaml	12
core/src/emr-eks-platform/resources/k8s/pod-template/notebook-executor.yaml	16
core/src/emr-eks-platform/resources/k8s/pod-template/shared-driver.yaml	7
core/src/emr-eks-platform/resources/k8s/pod-template/shared-executor.yaml	12
core/src/emr-eks-platform/resources/k8s/rbac/emr-containers.yaml	133
core/src/emr-eks-platform/resources/lambdas/managed-endpoint/lambda.py	79
core/src/emr-eks-platform/resources/lambdas/nodegroup-asg-tag/lambda.py	74
core/src/example.ts	14
core/src/index.ts	15
core/src/integ.data-replayer.ts	13
core/src/integ.default.ts	51
core/src/notebook-platform/index.ts	3
core/src/notebook-platform/notebook-managed-endpoint.ts	6
core/src/notebook-platform/notebook-platform-bak.ts	1
core/src/notebook-platform/notebook-platform-helpers.ts	131
core/src/notebook-platform/notebook-platform.ts	223
core/src/notebook-platform/notebook-user.ts	6
core/src/singleton-bucket.ts	16
core/src/singleton-glue-database.ts	11
core/src/singleton-glue-default-role.ts	46
core/src/singleton-launch-template.ts	14
core/src/synchronous-athena-query/index.ts	1
core/src/synchronous-athena-query/resources/lambdas/lambda.py	57
core/src/synchronous-athena-query/synchronous-athena-query.ts	114
core/src/synchronous-crawler/index.ts	1
core/src/synchronous-crawler/resources/lambdas/lambda.py	61
core/src/synchronous-crawler/synchronous-crawler.ts	64
core/src/utils.ts	8
doc/content/javascripts/config.js	1
doc/content/stylesheets/extra.css	14
doc/mkdocs.yml	43
refarch/aws-native/app.py	34
refarch/aws-native/batch/batch_cdk/batch_module.py	78
refarch/aws-native/batch/batch_cdk/crawler.py	88
refarch/aws-native/batch/batch_cdk/raw2clean_job.py	146
refarch/aws-native/batch/glue-scripts/raw2clean_hudi.py	100
refarch/aws-native/batch/glue-scripts/raw2clean_parquet.py	51
refarch/aws-native/cicd/pipeline.py	42
refarch/aws-native/cicd/pipeline_stage.py	6
refarch/aws-native/common/common_cdk/audit_trail_glue.py	83
refarch/aws-native/common/common_cdk/auto_empty_bucket.py	55
refarch/aws-native/common/common_cdk/auto_empty_security_group.py	44
refarch/aws-native/common/common_cdk/batch_data_generator.py	416
refarch/aws-native/common/common_cdk/config.py	631
refarch/aws-native/common/common_cdk/data_lake.py	101
refarch/aws-native/common/common_cdk/foundations.py	83
refarch/aws-native/common/common_cdk/lambda/datagen_config.py	40
refarch/aws-native/common/common_cdk/lambda/empty_bucket.py	14
refarch/aws-native/common/common_cdk/lambda/empty_security_group.py	14
refarch/aws-native/common/common_cdk/lambda/stepfunctions_terminate_emr.py	27
refarch/aws-native/common/common_cdk/lambda/stepfunctions_trigger.py	16
refarch/aws-native/common/common_cdk/lambda/stream_generator.py	45
refarch/aws-native/common/common_cdk/stream_data_generator.py	446
refarch/aws-native/common/data-generator/build.sbt	18
refarch/aws-native/common/data-generator/buildspec.yaml	33
refarch/aws-native/common/data-generator/project/project.sbt	9
refarch/aws-native/common/data-generator/src/main/scala/BaseData.scala	176
refarch/aws-native/common/data-generator/src/main/scala/BaseSchema.scala	149
refarch/aws-native/common/data-generator/src/main/scala/BatchModuleData.scala	42
refarch/aws-native/common/data-generator/src/main/scala/CleanSchema.scala	138
refarch/aws-native/common/data-generator/src/main/scala/DataGenParam.scala	20
refarch/aws-native/common/data-generator/src/main/scala/DataGenerator.scala	89
refarch/aws-native/common/data-generator/src/main/scala/DataframeUtils.scala	80
refarch/aws-native/common/data-generator/src/main/scala/DwhModuleData.scala	52
refarch/aws-native/common/data-generator/src/main/scala/RawSchema.scala	230
refarch/aws-native/common/data-generator/src/main/scala/StreamGenParam.scala	12
refarch/aws-native/common/data-generator/src/main/scala/StreamGenerator.scala	106
refarch/aws-native/common/data-generator/src/main/scala/StreamingModuleData.scala	33
refarch/aws-native/dataviz/dataviz_cdk/dataviz_module.py	68
refarch/aws-native/dataviz/dataviz_cdk/qs_athena_analysis.py	62
refarch/aws-native/dataviz/dataviz_cdk/qs_athena_dataset.py	76
refarch/aws-native/dataviz/dataviz_cdk/qs_athena_datasource.py	56
refarch/aws-native/dataviz/dataviz_cdk/qs_group.py	72
refarch/aws-native/dataviz/dataviz_cdk/qs_vpc_conn_reqs.py	24
refarch/aws-native/dataviz/dataviz_redshift_cdk/app.py	5
refarch/aws-native/dataviz/dataviz_redshift_cdk/dataviz_redshift/dataviz_redshift_stack.py	75
refarch/aws-native/dataviz/dataviz_redshift_cdk/dataviz_redshift/lambda/redshift_datasource.py	83
refarch/aws-native/dataviz/dataviz_redshift_cdk/dataviz_redshift/qs_redshift_analysis.py	62
refarch/aws-native/dataviz/dataviz_redshift_cdk/dataviz_redshift/qs_redshift_dataset.py	81
refarch/aws-native/dataviz/dataviz_redshift_cdk/dataviz_redshift/redshift_config.py	415
refarch/aws-native/dataviz/dataviz_redshift_cdk/setup.py	30
refarch/aws-native/dwh/dwh_cdk/bastion_host.py	73
refarch/aws-native/dwh/dwh_cdk/bootstrap_lambda/redshift_setup.py	76
refarch/aws-native/dwh/dwh_cdk/dwh_loader.py	148
refarch/aws-native/dwh/dwh_cdk/dwh_module.py	59
refarch/aws-native/dwh/dwh_cdk/redshift.py	115
refarch/aws-native/dwh/dwh_cdk/redshift_admin.py	161
refarch/aws-native/dwh/dwh_loader/dwh_loader.py	45
refarch/aws-native/setup.py	56
refarch/aws-native/streaming/stream-processing/buildspec.yml	19
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/http/AWSRequestSigningApacheInterceptor.java	112
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/StreamFactory.java	128
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/StreamingJob.java	76
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Address.java	20
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Customer.java	29
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Geolocation.java	10
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Item.java	23
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Promo.java	17
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Sale.java	40
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/dto/Warehouse.java	23
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/AsyncGeocoderRequest.java	15
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/CustomerAddressJoiner.java	46
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/CustomerBirthdateCleaner.java	13
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/ItemParser.java	53
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/PromoParser.java	49
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SaleBillCustomerJoiner.java	34
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SaleCustomerJoiner.java	29
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SaleElasticsearchSinkFunction.java	43
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SaleItemJoiner.java	45
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SalePromoJoiner.java	47
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/operators/SaleShipCustomerJoiner.java	34
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/schemas/JsonDeserializationSchema.java	16
refarch/aws-native/streaming/stream-processing/src/main/java/com/amazonaws/ara/streaming/utils/SaleBucketAssigner.java	26
refarch/aws-native/streaming/streaming_cdk/cognito-lambda/handler.py	52
refarch/aws-native/streaming/streaming_cdk/es_domain.py	220
refarch/aws-native/streaming/streaming_cdk/kda-start-stop-lambda/handler.py	18
refarch/aws-native/streaming/streaming_cdk/kda_application.py	143
refarch/aws-native/streaming/streaming_cdk/streaming_module.py	59