plateau.io_components package

Submodules

• plateau.io_components.delete module
  • delete_common_metadata()
  • delete_indices()
  • delete_top_level_metadata()
• plateau.io_components.gc module
  • delete_files()
  • dispatch_files_to_gc()
• plateau.io_components.index module
  • update_indices_from_partitions()
• plateau.io_components.metapartition module
  • MetaPartition
    • MetaPartition.add_metapartition()
    • MetaPartition.apply()
    • MetaPartition.as_sentinel()
    • MetaPartition.build_indices()
    • MetaPartition.concat_metapartitions()
    • MetaPartition.copy()
    • MetaPartition.data
    • MetaPartition.delete_from_store()
    • MetaPartition.file
    • MetaPartition.from_dict()
    • MetaPartition.from_partition()
    • MetaPartition.get_parquet_metadata()
    • MetaPartition.indices
    • MetaPartition.is_sentinel
    • MetaPartition.label
    • MetaPartition.load_dataframes()
    • MetaPartition.load_schema()
    • MetaPartition.merge_indices()
    • MetaPartition.partition
    • MetaPartition.partition_on()
    • MetaPartition.remove_dataframes()
    • MetaPartition.store_dataframes()
    • MetaPartition.to_dict()
    • MetaPartition.validate_schema_compatible()
  • MetaPartitionIterator
    • MetaPartitionIterator.next()
  • parse_input_to_metapartition()
  • partition_labels_from_mps()
• plateau.io_components.read module
  • dispatch_metapartitions()
• plateau.io_components.update module
  • update_dataset_from_partitions()
• plateau.io_components.utils module
  • InvalidObject
  • align_categories()
  • combine_metadata()
  • extract_duplicates()
  • raise_if_indices_overlap()
  • sort_values_categorical()
  • validate_partition_keys()
• plateau.io_components.write module
  • coerce_schema_timestamps()
  • persist_common_metadata()
  • persist_indices()
  • raise_if_dataset_exists()
  • store_dataset_from_partitions()
  • update_indices()
  • update_metadata()
  • update_partitions()
  • write_partition()

Module contents