jaclearn.dataflow.collections#

Classes

`DictDataFlowProxy`
`DictToBatchDataFlow`
`EmptyDictDataFlow`
`KVStoreDataFlow`
`KVStoreRandomSampleDataFlow`
`LOARandomSampleDataFlow`
`ListOfArrayDataFlow`
`PoolDataFlow`
`PoolRandomSampleDataFlow`
`QueueDataFlow`
`RandomIndexDataFlow`
`RandomRepeatDataFlow`

Functions

`DOARandomSampleDataFlow`(doa[, seed])
`DictOfArrayDataFlow`(doa)

Class DictDataFlowProxy

class DictDataFlowProxy[source]#

Bases: ProxyDataFlowBase

__init__(keys, iterable)[source]#

__new__(**kwargs)#

property unwrapped#

Class DictToBatchDataFlow

class DictToBatchDataFlow[source]#

Bases: ProxyDataFlowBase

__init__(iterable, excludes=None)[source]#

__new__(**kwargs)#

property unwrapped#

Class EmptyDictDataFlow

class EmptyDictDataFlow[source]#

Bases: SimpleDataFlowBase

__init__()#

__new__(**kwargs)#

Class KVStoreDataFlow

class KVStoreDataFlow[source]#

Bases: SimpleDataFlowBase

__init__(kv_getter)[source]#

__new__(**kwargs)#

Class KVStoreRandomSampleDataFlow

class KVStoreRandomSampleDataFlow[source]#

Bases: RandomizedDataFlowBase

__init__(kv_getter, seed=None)[source]#

__new__(**kwargs)#

Class LOARandomSampleDataFlow

class LOARandomSampleDataFlow[source]#

Bases: RandomizedDataFlowBase

__init__(loa, seed=None)[source]#

__new__(**kwargs)#

Class ListOfArrayDataFlow

class ListOfArrayDataFlow[source]#

Bases: SimpleDataFlowBase

__init__(loa)[source]#

__new__(**kwargs)#

Class PoolDataFlow

class PoolDataFlow[source]#

Bases: SimpleDataFlowBase

__init__(pool)[source]#

__new__(**kwargs)#

Class PoolRandomSampleDataFlow

class PoolRandomSampleDataFlow[source]#

Bases: RandomizedDataFlowBase

__init__(pool, seed=None)[source]#

__new__(**kwargs)#

Class QueueDataFlow

class QueueDataFlow[source]#

Bases: SimpleDataFlowBase

__init__(queue)[source]#

__new__(**kwargs)#

Class RandomIndexDataFlow

class RandomIndexDataFlow[source]#

Bases: RandomizedDataFlowBase

__init__(source, nr_repeat=1, seed=None)[source]#

__new__(**kwargs)#

Class RandomRepeatDataFlow

class RandomRepeatDataFlow[source]#

Bases: RandomizedDataFlowBase

__init__(source, nr_repeat, cache_size, block=False, seed=None)[source]#

__new__(**kwargs)#

Functions

DOARandomSampleDataFlow(doa, seed=None)[source]#

DictOfArrayDataFlow(doa)[source]#