kartothek.io_components.cube.common module

Common utilities used by all IO operations.

kartothek.io_components.cube.common.assert_stores_different(store1, store2, prefix)

Check that given stores are different.

This is a workaround for tha fact that simplekv stores normally do not implemenent some sane equality check.

Parameters

• store1 (Union[simplekv.KeyValueStore, Callable[[], simplekv.KeyValueStore]]) – First store.

• store2 (Union[simplekv.KeyValueStore, Callable[[], simplekv.KeyValueStore]]) – Second store, will be used to write a test key to.

• prefix (str) – Prefix to be used for the temporary key used for the equality check.

Raises

ValueError – If stores are considered to be identical.:

kartothek.io_components.cube.common.check_blocksize(blocksize)

Check that given blocksize is a positive integer.

Parameters

blocksize (Any) – Blocksize passed by the user.

Raises

• TypeError – In case the blocksize is not an integer.:

• ValueError – In case the blocksize is < 0.:

kartothek.io_components.cube.common.check_store_factory(store)

Check that given store is a factory.

Parameters

store (Any) – Store passed by the user.

Raises

TypeError – In case the store is not a factory.: