Classes
DeserializeStage(c)
DeserializeStage
Messages are logically partitioned based on the specified c.pipeline_batch_size.
c.pipeline_batch_size