kartothek.io.testing.copy_cube module

kartothek.io.testing.copy_cube.assert_same_keys(store1, store2, keys)[source]
kartothek.io.testing.copy_cube.built_cube(df_seed, df_enrich, cube, function_store)[source]
kartothek.io.testing.copy_cube.cube()[source]
kartothek.io.testing.copy_cube.df_enrich()[source]
kartothek.io.testing.copy_cube.df_seed()[source]
kartothek.io.testing.copy_cube.simple_cube_1(function_store, built_cube)[source]
kartothek.io.testing.copy_cube.simple_cube_2(df_seed, df_enrich, cube, function_store2)[source]
kartothek.io.testing.copy_cube.test_copy_fail_overwrite_false(driver, mocker, cube, simple_cube_1, function_store, function_store2)[source]
kartothek.io.testing.copy_cube.test_copy_fail_overwrite_true(driver, mocker, cube, simple_cube_1, function_store, function_store2)[source]
kartothek.io.testing.copy_cube.test_fail_blocksize_negative(driver, function_store, function_store2, cube, simple_cube_1, skip_eager)[source]
kartothek.io.testing.copy_cube.test_fail_blocksize_wrong_type(driver, function_store, function_store2, cube, simple_cube_1, skip_eager)[source]
kartothek.io.testing.copy_cube.test_fail_blocksize_zero(driver, function_store, function_store2, cube, simple_cube_1, skip_eager)[source]
kartothek.io.testing.copy_cube.test_fail_no_src_cube(cube, function_store, function_store2, driver)[source]
kartothek.io.testing.copy_cube.test_fail_no_src_cube_dataset(cube, built_cube, function_store, function_store2, driver)[source]
kartothek.io.testing.copy_cube.test_fail_no_store_factory_src(driver, function_store, function_store2, cube, skip_eager)[source]
kartothek.io.testing.copy_cube.test_fail_no_store_factory_tgt(driver, function_store, function_store2, cube, skip_eager)[source]
kartothek.io.testing.copy_cube.test_fail_stores_identical_overwrite_false(driver, function_store, cube, built_cube, overwrite)[source]
kartothek.io.testing.copy_cube.test_ignore_other(driver, function_store, function_store2)[source]
kartothek.io.testing.copy_cube.test_invalid_partial_copy(driver, df_seed, df_enrich, function_store, function_store2, cube, built_cube)[source]
kartothek.io.testing.copy_cube.test_invalid_partial_copy1(df_seed, df_enrich, cube, function_store, function_store2, simple_cube_2, driver)[source]
kartothek.io.testing.copy_cube.test_invalid_partial_copy2(df_seed, df_enrich, cube, function_store, function_store2, simple_cube_1, driver)[source]
kartothek.io.testing.copy_cube.test_overwrite_fail(driver, function_store, function_store2, cube, simple_cube_1, simple_cube_2)[source]
kartothek.io.testing.copy_cube.test_overwrite_ok(driver, function_store, function_store2, cube, simple_cube_1, simple_cube_2)[source]
kartothek.io.testing.copy_cube.test_partial_copy_dataset_dict(driver, function_store, function_store2, cube, built_cube)[source]
kartothek.io.testing.copy_cube.test_partial_copy_dataset_list(driver, function_store, function_store2, cube, built_cube)[source]
kartothek.io.testing.copy_cube.test_read_only_source(driver, function_store_ro, function_store2, cube, simple_cube_1)[source]
kartothek.io.testing.copy_cube.test_simple(driver, function_store, function_store2, cube, simple_cube_1)[source]
kartothek.io.testing.copy_cube.test_simple_copy_cube_rename_cube_prefix(driver, function_store, function_store2, cube, simple_cube_1, df_seed, df_enrich)[source]

Rename a cube while copying, but leave the dataset names as they are

kartothek.io.testing.copy_cube.test_simple_copy_cube_rename_cube_prefix_and_dataset(driver, function_store, function_store2, cube, simple_cube_1, df_seed, df_enrich)[source]

Rename a cube and a dataset while copying

kartothek.io.testing.copy_cube.test_simple_copy_cube_rename_dataset(driver, function_store, function_store2, cube, simple_cube_1, df_seed, df_enrich)[source]

Rename a dataset while copying, but leave the cube name as is

kartothek.io.testing.copy_cube.test_simple_rename_cube_same_stores(driver, function_store, cube, simple_cube_1, df_seed, df_enrich)[source]