morpheus.stages.preprocess.deserialize_stage

DeserializeStage(c[, ensure_sliceable_index])

Messages are logically partitioned based on the specified c.pipeline_batch_size.