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