The Streamer object¶
The StreamLearner object¶
Stream manipulation¶
Utility functions for stream manipulations
mux(seed_pool, n_samples, k[, lam, ...]) |
Stochastic multiplexor for generator seeds. |
buffer_batch(generator, buffer_size) |
Buffer an iterable of batches into larger (or smaller) batches |
buffer_streamer(streamer, buffer_size, ...) |
Buffer a stream of batches |
batch_length(batch) |
Determine the number of samples in a batch. |
Parallelism¶
ZMQ-baesd stream multiplexing
zmq_stream(streamer[, max_batches, ...]) |
Parallel data streaming over zeromq sockets. |