Genotype Data Parquet Writers

• dae.parquet package
  • Subpackages
    • dae.parquet.schema2 package
  • Submodules
  • dae.parquet.helpers module
    • merge_parquets()
    • url_to_pyarrow_fs()
  • dae.parquet.parquet_writer module
    • add_missing_parquet_fields()
    • append_meta_to_parquet()
    • collect_pedigree_parquet_schema()
    • fill_family_bins()
    • merge_variants_parquets()
    • pedigree_parquet_schema()
    • save_ped_df_to_parquet()
    • serialize_summary_schema()
  • dae.parquet.partition_descriptor module
    • Partition
    • PartitionDescriptor
  • Module contents
• dae.parquet.schema2 package
  • Submodules
  • dae.parquet.schema2.annotation module
    • AnnotateSchema2ParquetTool
    • cli()
  • dae.parquet.schema2.annotation_utils module
    • backup_schema2_study()
    • merge_non_partitioned()
    • merge_partitioned()
    • process_parquet()
    • produce_regions()
    • produce_schema2_annotation_tasks()
    • produce_schema2_merging_tasks()
    • symlink_pedigree_and_family_variants()
    • write_new_meta()
  • dae.parquet.schema2.loader module
    • MultiReader
    • ParquetLoader
    • ParquetLoaderException
    • Reader
  • dae.parquet.schema2.merge_parquet module
    • merge_parquet_directory()
  • dae.parquet.schema2.parquet_io module
    • ContinuousParquetFileWriter
    • VariantsParquetWriterDeprecated()
  • dae.parquet.schema2.processing_pipeline module
    • AnnotationPipelineVariantsBatchFilter
    • AnnotationPipelineVariantsFilter
    • AnnotationPipelineVariantsFilterMixin
    • DeleteAttributesFromVariantFilter
    • DeleteAttributesFromVariantsBatchFilter
    • Schema2SummaryVariantsBatchSource
    • Schema2SummaryVariantsSource
    • VariantsBatchConsumer
    • VariantsBatchFilter
    • VariantsBatchPipelineProcessor
    • VariantsBatchSource
    • VariantsConsumer
    • VariantsFilter
    • VariantsLoaderBatchSource
    • VariantsLoaderSource
    • VariantsPipelineProcessor
    • VariantsSource
  • dae.parquet.schema2.serializers module
    • AlleleParquetSerializer
    • FamilyAlleleParquetSerializer
    • JsonVariantsDataSerializer
    • SummaryAlleleParquetSerializer
    • VariantsDataAvroSerializer
    • VariantsDataSerializer
    • build_family_schema()
    • build_summary_blob_schema()
    • build_summary_schema()
    • construct_avro_family_schema()
    • construct_avro_summary_schema()
  • dae.parquet.schema2.variants_parquet_writer module
    • ContinuousParquetFileWriter
    • Schema2SummaryVariantConsumer
    • VariantsParquetWriter
  • Module contents