Module protocol

Re-exported Classes

• class Serialize
  Mark an object that should be serialized
  [distributed.protocol.serialize.Serialize]
• class Serialized
  An object that is already serialized into header and frames
  [distributed.protocol.serialize.Serialized]

Re-exported Functions

• def decompress(header, frames)
  Decompress frames according to information in the header
  [distributed.protocol.compression.decompress]
• def deserialize(header, frames, deserializers=None)
  Convert serialized header and list of bytestrings back to a Python object
  [distributed.protocol.serialize.deserialize]
• def deserialize_bytes(b)
  [distributed.protocol.serialize.deserialize_bytes]
• def dumps(msg, serializers=None, on_error="message", context=None)
  Transform Python message to bytestream suitable for communication
  [distributed.protocol.core.dumps]
• def loads(frames, deserialize=True, deserializers=None)
  Transform bytestream back into Python value
  [distributed.protocol.core.loads]
• def maybe_compress(payload, min_size=1e4, sample_size=1e4, nsamples=5, compression=dask.config.get("distributed.comm.compression"))
  Maybe compress payload
  [distributed.protocol.compression.maybe_compress]
• def nested_deserialize(x)
  Replace all Serialize and Serialized values nested in *x* with the original values. Returns a copy of *x*.
  [distributed.protocol.serialize.nested_deserialize]
• def register_generic(cls, serializer_name="dask", serialize_func=dask_serialize, deserialize_func=dask_deserialize)
  Register (de)serialize to traverse through __dict__
  [distributed.protocol.serialize.register_generic]
• def register_serialization(cls, serialize, deserialize)
  Register a new class for dask-custom serialization
  [distributed.protocol.serialize.register_serialization]
• def register_serialization_family(name, dumps, loads)
  [distributed.protocol.serialize.register_serialization_family]
• def serialize_bytelist(x, **kwargs)
  [distributed.protocol.serialize.serialize_bytelist]
• def serialize_bytes(x, **kwargs)
  [distributed.protocol.serialize.serialize_bytes]

Submodules

• Module distributed.protocol.arrow
• Module distributed.protocol.compression
  Record known compressors
• Module distributed.protocol.core
• Module distributed.protocol.cuda
• Module distributed.protocol.cupy
  Efficient serialization GPU arrays.
• Module distributed.protocol.h5py
• Module distributed.protocol.highlevelgraph
• Module distributed.protocol.keras
• Module distributed.protocol.netcdf4
• Module distributed.protocol.numba
• Module distributed.protocol.numpy
• Module distributed.protocol.pickle
• Module distributed.protocol.rmm
• Module distributed.protocol.scipy
  Efficient serialization of SciPy sparse matrices.
• Module distributed.protocol.serialize
• Module distributed.protocol.sparse
• Module distributed.protocol.tests
• Module distributed.protocol.torch
• Module distributed.protocol.utils

Generated by nedoc v0.9 at 2020-12-29 14:05