morpheus.pipeline.preallocator_mixin

PreallocatorMixin()

Mixin intented to be added to stages, typically source stages, which are emitting newly constructed DataFrame or MessageMeta instances into the segment.