beamds.beam.transformer package

Submodules

beamds.beam.transformer.reducer module

class beamds.beam.transformer.reducer.Reducer(*args, _store_init_path=None, _save_init_args=True, **kwargs)

Bases: Processor

reduce(*xs, **kwargs)

beamds.beam.transformer.transformer module

class beamds.beam.transformer.transformer.TransformStrategy(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

C = 'C'

CC = 'CC'

CS = 'CS'

S = 'S'

SC = 'SC'

SS = 'SS'

class beamds.beam.transformer.transformer.Transformer(*args, _store_init_path=None, _save_init_args=True, **kwargs)

Bases: Processor

cached_transform(x, transform_kwargs=None, parallel_kwargs=None, **kwargs)

chunks(x, chunksize=None, n_chunks=None, squeeze=None, split_by=None, partition=None, chunksize_policy=None)

property exceptions

fit(x, **kwargs)

fit_transform(x, **kwargs)

reduce(y, reduce_dim=None, split_by=None, squeeze=True, x_in=None)

reset()

transform(x, transform_kwargs=None, parallel_kwargs=None, **kwargs)

transform_callback(x, _key=None, _is_chunk=False, _fit=False, path=None, _store=False, **kwargs)

worker(x, key=None, is_chunk=False, fit=False, cache=True, store_path=None, store=False, override=False, return_results=True, use_cache=False, task_kwargs=None, retries=1, retries_delay=1.0)

Module contents