meerkat.writers package#

Submodules#

meerkat.writers.abstract module#

class AbstractWriter(*args, **kwargs)[source]#

Bases: ABC

abstract close(*args, **kwargs) None[source]#
abstract finalize(*args, **kwargs) None[source]#
abstract flush(*args, **kwargs) None[source]#
abstract open(*args, **kwargs) None[source]#
abstract write(data, *args, **kwargs) None[source]#

meerkat.writers.concat_writer module#

class ConcatWriter(output_type: type = <class 'meerkat.columns.abstract.AbstractColumn'>, template: ~meerkat.columns.abstract.AbstractColumn | None = None, *args, **kwargs)[source]#

Bases: AbstractWriter

close(*args, **kwargs)[source]#
finalize(*args, **kwargs) None[source]#
flush()[source]#
open() None[source]#
write(data, **kwargs) None[source]#

meerkat.writers.numpy_writer module#

class NumpyMemmapWriter(path: str | None = None, dtype: str = 'float32', mode: str = 'r', shape: tuple | None = None, output_type: type = <class 'meerkat.columns.numpy_column.NumpyArrayColumn'>, template: ~meerkat.columns.abstract.AbstractColumn | None = None, *args, **kwargs)[source]#

Bases: AbstractWriter

close(*args, **kwargs) None[source]#
finalize(*args, **kwargs) AbstractColumn[source]#
flush()[source]#

Close the mmap file and reopen to release memory.

open(path: str, dtype: str = 'float32', mode: str = 'w+', shape: tuple | None = None) None[source]#
write(arr, **kwargs) None[source]#