`intake_io.dataset.remote`

Module Contents

Classes

`CachedRemoteDataset`
`DatasetServer`
`DatasetWorker`

Functions

start_server(datasets, *args, **kwargs)

class intake_io.dataset.remote.CachedRemoteDataset(hostname, port, key, data_name, cache_dir, map_size_gb=1, **kwargs): Bases: intake_io.dataset.cache.CachedDataset

class intake_io.dataset.remote.DatasetServer(datasets, port, key, num_workers=4)

class intake_io.dataset.remote.DatasetWorker(i, datasets, key)

deserialize(self, x)

serialize(self, x)

intake_io.dataset.remote.start_server(datasets, *args, **kwargs)