kartothek.io_components.read module

kartothek.io_components.read.dispatch_metapartitions(dataset_uuid: str, store: Union[str, simplekv.KeyValueStore, Callable[[], simplekv.KeyValueStore]], load_dataset_metadata: bool = True, keep_indices: bool = True, keep_table_meta: bool = True, label_filter: Optional[Callable] = None, concat_partitions_on_primary_index: bool = False, predicates: Optional[List[List[Tuple[str, str, LiteralValue]]]] = None, dispatch_by: Optional[List[str]] = None, dispatch_metadata: bool = False) → Union[Iterator[kartothek.io_components.metapartition.MetaPartition], Iterator[List[kartothek.io_components.metapartition.MetaPartition]]][source]
kartothek.io_components.read.dispatch_metapartitions_from_factory(dataset_factory: kartothek.core.factory.DatasetFactory, label_filter: Optional[Callable] = None, concat_partitions_on_primary_index: bool = False, predicates: Optional[List[List[Tuple[str, str, LiteralValue]]]] = None, store: Union[str, simplekv.KeyValueStore, Callable[[], simplekv.KeyValueStore], None] = None, dispatch_by: Optional[List[str]] = None, dispatch_metadata: bool = False) → Union[Iterator[kartothek.io_components.metapartition.MetaPartition], Iterator[List[kartothek.io_components.metapartition.MetaPartition]]][source]