gluonts.nursery.glide.parallel module

class gluonts.nursery.glide.parallel.ParApply(fn, emitter, batch_size=1, queue_size=50, encode=<function identity>, decode=<function identity>)[source]

Bases: object

class gluonts.nursery.glide.parallel.ParApplyIterator(procs, queue, decode)[source]

Bases: object

join()[source]
kill()[source]
start()[source]
terminate()[source]
gluonts.nursery.glide.parallel.map_to_queue(fn, emitter, queue, encode, batch_size)[source]
class gluonts.nursery.glide.parallel.sentinel[source]

Bases: object