converter.runner.dask

Module Contents

Classes

DaskRunner

Default implementation for a pandas like runner

Functions

read_pandas_chunk(c)

converter.runner.dask.read_pandas_chunk(c)
class converter.runner.dask.DaskRunner(config, **options)

Bases: converter.runner.pandas.PandasRunner

Default implementation for a pandas like runner

dataframe_type
series_type
create_series(self, index, value)
chunk(self, iterable)
get_dataframe(self, extractor)

Builds a dataframe from the extractors data

Parameters

extractor – The extractor providing the input data

Returns

The created dataframe