kartothek.io.testing.update module¶
-
kartothek.io.testing.update.
test_metadata_version
(store_factory, bound_update_dataset, mock_default_metadata_version, backend_identifier)[source]¶
-
kartothek.io.testing.update.
test_raises_on_invalid_input
(store_factory, bound_update_dataset)[source]¶
-
kartothek.io.testing.update.
test_raises_on_new_index_creation
(backend_identifier, store_factory, bound_update_dataset, define_indices_on_partition)[source]¶
-
kartothek.io.testing.update.
test_schema_check_update
(dfs, ok, store_factory, bound_update_dataset)[source]¶
-
kartothek.io.testing.update.
test_sort_partitions_by
(store_factory, metadata_version, frozen_time_em, bound_update_dataset)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions__reducer
(store_factory, metadata_version, bound_update_dataset, mocker, store)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions__reducer_delete_only
(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions__reducer_nonexistent
(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions__reducer_partitions
(store_factory, frozen_time_em, bound_update_dataset)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions_alternative_name
(bound_update_dataset, store, dataset_alternative_table_name, store_factory, dataset_factory_alternative_table_name, alternative_table_name)[source]¶
-
kartothek.io.testing.update.
test_update_dataset_with_partitions_no_index_input_info
(store_factory, metadata_version, bound_update_dataset, store)[source]¶
-
kartothek.io.testing.update.
test_update_first_time_with_secondary_indices
(store_factory, bound_update_dataset, define_indices_on_partition)[source]¶ Check it is possible to create a new dataset with indices defined either on partition or using the secondary_indices kwarg. The intention of this test is to verify that there are no exceptions raised related to index validation when a dataset is created using an update function
-
kartothek.io.testing.update.
test_update_infers_partition_on
(store_factory, bound_update_dataset, df_not_nested)[source]¶
-
kartothek.io.testing.update.
test_update_raises_incompatible_inidces
(store_factory, bound_update_dataset, df_not_nested)[source]¶