Classes
DeserializeStage(c[, ensure_sliceable_index])
DeserializeStage
Messages are logically partitioned based on the pipeline config's pipeline_batch_size parameter.
pipeline_batch_size