morpheus.pipeline.preallocator_mixin#
Mixin used by stages which are emitting newly constructed DataFrame or MessageMeta instances into the segment.
Classes
Mixin intented to be added to stages, typically source stages, which are emitting newly constructed DataFrame or MessageMeta instances into the segment. |