kartothek.io_components.cube.common module¶
Common utilities used by all IO operations.
-
kartothek.io_components.cube.common.
assert_stores_different
(store1, store2, prefix)[source]¶ 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)[source]¶ 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.: