Catalog Streaming

Catalog Streaming#

CatalogStream(catalog[, client, ...])

Stream partitons from a catalog

InfiniteStream(catalog[, client, ...])

Stream continuously yielding random subsets of partitions from a catalog.