Path Lines of Code parquet_flask/__init__.py 7 parquet_flask/__main__.py 33 parquet_flask/authenticator/__init__.py 1 parquet_flask/authenticator/authenticator_abstract.py 9 parquet_flask/authenticator/authenticator_aws_secret_manager.py 31 parquet_flask/authenticator/authenticator_factory.py 15 parquet_flask/authenticator/authenticator_filebased.py 27 parquet_flask/authenticator/authenticator_pass_through.py 7 parquet_flask/aws/__init__.py 2 parquet_flask/aws/aws_cred.py 44 parquet_flask/aws/aws_ddb.py 215 parquet_flask/aws/aws_s3.py 95 parquet_flask/aws/aws_secret_manager.py 29 parquet_flask/aws/aws_sns.py 13 parquet_flask/aws/aws_sqs.py 12 parquet_flask/aws/es_abstract.py 41 parquet_flask/aws/es_factory.py 13 parquet_flask/aws/es_middleware.py 175 parquet_flask/aws/es_middleware_aws.py 24 parquet_flask/cdms_lambda_func/__init__.py 1 parquet_flask/cdms_lambda_func/audit_tool/__init__.py 1 parquet_flask/cdms_lambda_func/audit_tool/execute_lambda.py 44 parquet_flask/cdms_lambda_func/cdms_lambda_constants.py 8 parquet_flask/cdms_lambda_func/index_to_es/__init__.py 1 parquet_flask/cdms_lambda_func/index_to_es/execute_lambda.py 14 parquet_flask/cdms_lambda_func/index_to_es/parquet_file_es_indexer.py 70 parquet_flask/cdms_lambda_func/index_to_es/parquet_stat_extractor.py 28 parquet_flask/cdms_lambda_func/index_to_es/s3_stat_extractor.py 130 parquet_flask/cdms_lambda_func/ingest_s3_to_cdms/__init__.py 1 parquet_flask/cdms_lambda_func/ingest_s3_to_cdms/execute_lambda.py 4 parquet_flask/cdms_lambda_func/ingest_s3_to_cdms/ingest_s3_to_cdms.py 60 parquet_flask/cdms_lambda_func/lambda_func_env.py 8 parquet_flask/cdms_lambda_func/lambda_logger_generator.py 25 parquet_flask/cdms_lambda_func/s3_records/__init__.py 1 parquet_flask/cdms_lambda_func/s3_records/s3_2_sqs.py 96 parquet_flask/cdms_lambda_func/s3_records/s3_event_validator_abstract.py 13 parquet_flask/io_logic/__init__.py 1 parquet_flask/io_logic/cdms_constants.py 40 parquet_flask/io_logic/cdms_schema.py 145 parquet_flask/io_logic/ingest_new_file.py 113 parquet_flask/io_logic/metadata_tbl_es.py 42 parquet_flask/io_logic/metadata_tbl_interface.py 20 parquet_flask/io_logic/metadata_tbl_io.py 26 parquet_flask/io_logic/parquet_paths_es_retriever.py 75 parquet_flask/io_logic/parquet_query_condition_management_v3.py 198 parquet_flask/io_logic/parquet_query_condition_management_v4.py 137 parquet_flask/io_logic/partitioned_parquet_path.py 127 parquet_flask/io_logic/query_v2.py 186 parquet_flask/io_logic/query_v4.py 173 parquet_flask/io_logic/raw_query.py 77 parquet_flask/io_logic/replace_file.py 32 parquet_flask/io_logic/retrieve_spark_session.py 63 parquet_flask/io_logic/sanitize_record.py 73 parquet_flask/io_logic/spark_constants.py 7 parquet_flask/io_logic/sub_collection_statistics.py 173 parquet_flask/parquet_stat_extractor/__init__.py 1 parquet_flask/parquet_stat_extractor/local_spark_session.py 11 parquet_flask/parquet_stat_extractor/local_statistics_retriever.py 27 parquet_flask/parquet_stat_extractor/statistics_retriever.py 136 parquet_flask/parquet_stat_extractor/statistics_retriever_wrapper.py 33 parquet_flask/utils/__init__.py 1 parquet_flask/utils/config.py 53 parquet_flask/utils/factory_abstract.py 5 parquet_flask/utils/file_utils.py 65 parquet_flask/utils/general_utils.py 57 parquet_flask/utils/parallel_json_validator.py 49 parquet_flask/utils/singleton.py 7 parquet_flask/utils/spatial_utils.py 17 parquet_flask/utils/time_utils.py 15 parquet_flask/v1/__init__.py 33 parquet_flask/v1/authenticator_decorator.py 19 parquet_flask/v1/cdms_schema.py 20 parquet_flask/v1/extract_statistics_from_parquet_file.py 25 parquet_flask/v1/ingest_aws_json.py 176 parquet_flask/v1/ingest_json_s3.py 38 parquet_flask/v1/insitu_query_swagger.py 12 parquet_flask/v1/insitu_query_swagger/index.html 55 parquet_flask/v1/query_data.py 32 parquet_flask/v1/query_data_doms.py 100 parquet_flask/v1/query_data_doms_custom_pagination.py 120 parquet_flask/v1/replace_json_s3.py 42 parquet_flask/v1/sub_collection_statistics_endpoint.py 53