SharedArray#

class streaming.base.shared.SharedArray(shape, dtype, name)[source]#

A numpy array of predetermined shape and dtype that lives in shared memory.

Parameters:
  • shape (Union[int, Tuple[int]]) โ€“ Shape of the array.

  • dtype (type) โ€“ Dtype of the array.

  • name (str) โ€“ Its name in shared memory.

numpy()[source]#

Get as a numpy array.

We canโ€™t just internally store and use this numpy array shared memory wrapper because itโ€™s not compatible with spawn.