Module arrow

Functions

▷ def deserialize_batch(header, frames) @dask_deserialize.register(pyarrow.RecordBatch)
@dask_deserialize.register(pyarrow.RecordBatch)
def deserialize_batch(
header,
frames,
)
source link
▷ def deserialize_table(header, frames) @dask_deserialize.register(pyarrow.Table)
@dask_deserialize.register(pyarrow.Table)
def deserialize_table(
header,
frames,
)
source link
▷ def serialize_batch(batch) @dask_serialize.register(pyarrow.RecordBatch)
@dask_serialize.register(pyarrow.RecordBatch)
def serialize_batch(batch)
source link
▷ def serialize_table(tbl) @dask_serialize.register(pyarrow.Table)
@dask_serialize.register(pyarrow.Table)
def serialize_table(tbl)
source link