plateau package

Subpackages

• plateau.api package
  • Submodules
    • plateau.api.dataset module
    • plateau.api.serialization module
  • Module contents
• plateau.core package
  • Submodules
    • plateau.core.common_metadata module
      • SchemaWrapper
      • empty_dataframe_from_schema()
      • make_meta()
      • normalize_column_order()
      • normalize_type()
      • validate_compatible()
    • plateau.core.dataset module
      • DatasetMetadata
      • DatasetMetadataBase
    • plateau.core.docs module
      • default_docs()
    • plateau.core.factory module
      • DatasetFactory
    • plateau.core.index module
      • ExplicitSecondaryIndex
      • IndexBase
      • PartitionIndex
    • plateau.core.naming module
      • get_partition_file_prefix()
      • metadata_key_from_uuid()
    • plateau.core.partition module
      • Partition
    • plateau.core.testing module
      • cm_frozen_time()
      • get_dataframe_alltypes()
      • get_dataframe_not_nested()
      • get_numpy_array_strategy()
      • get_scalar_dtype_strategy()
    • plateau.core.typing module
    • plateau.core.urlencode module
      • decode_key()
      • quote()
      • quote_indices()
      • unquote()
      • unquote_indices()
    • plateau.core.utils module
      • ensure_store()
      • lazy_store()
    • plateau.core.uuid module
      • gen_uuid()
      • gen_uuid_object()
  • Module contents
• plateau.io package
  • Subpackages
    • plateau.io.dask package
      • Submodules
      • Module contents
    • plateau.io.testing package
      • Submodules
      • Module contents
  • Submodules
    • plateau.io.eager module
      • build_dataset_indices()
      • commit_dataset()
      • create_empty_dataset_header()
      • delete_dataset()
      • garbage_collect_dataset()
      • read_dataset_as_dataframes()
      • read_table()
      • store_dataframes_as_dataset()
      • update_dataset_from_dataframes()
      • write_single_partition()
    • plateau.io.iter module
      • read_dataset_as_dataframes__iterator()
      • store_dataframes_as_dataset__iter()
      • update_dataset_from_dataframes__iter()
  • Module contents
• 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
      • MetaPartitionIterator
      • 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
• plateau.serialization package
  • Submodules
    • plateau.serialization.testing module
      • get_dataframe_not_nested()
  • Module contents
    • CsvSerializer
      • CsvSerializer.restore_dataframe()
      • CsvSerializer.store()
    • DataFrameSerializer
      • DataFrameSerializer.register_serializer()
      • DataFrameSerializer.restore_dataframe()
      • DataFrameSerializer.store()
      • DataFrameSerializer.type_stable
    • ParquetSerializer
      • ParquetSerializer.restore_dataframe()
      • ParquetSerializer.store()
      • ParquetSerializer.type_stable
    • check_predicates()
    • columns_in_predicates()
    • default_serializer()
    • filter_array_like()
    • filter_df()
    • filter_df_from_predicates()
    • filter_predicates_by_column()
• plateau.utils package
  • Submodules
    • plateau.utils.converters module
      • converter_str()
      • converter_str_set()
      • converter_str_set_optional()
      • converter_str_tupleset()
      • converter_tuple()
      • get_str_to_python_converter()
    • plateau.utils.pandas module
      • aggregate_to_lists()
      • concat_dataframes()
      • drop_sorted_duplicates_keep_last()
      • is_dataframe_sorted()
      • mask_sorted_duplicates_keep_last()
      • merge_dataframes_robust()
      • sort_dataframe()
    • plateau.utils.store module
      • copy_keys()
  • Module contents

Module contents