morpheus.pipeline
All objects related to building and running a pipeline.
Modules
morpheus.pipeline.boundary_stage_mixin |
|
morpheus.pipeline.configurable_output_source |
Base class for single output source stages which support both MessageMeta and ControlMessage as output types. |
morpheus.pipeline.control_message_stage |
|
morpheus.pipeline.execution_mode_mixins |
Mixins to indicate which execution modes are supported for a given stage. |
morpheus.pipeline.linear_pipeline |
|
morpheus.pipeline.pass_thru_type_mixin |
Mixin for single port stages which receive and emit the same type. |
morpheus.pipeline.pipeline |
|
morpheus.pipeline.preallocator_mixin |
Mixin used by stages which are emitting newly constructed DataFrame or MessageMeta instances into the segment. |
morpheus.pipeline.receiver |
|
morpheus.pipeline.sender |
|
morpheus.pipeline.single_output_source |
|
morpheus.pipeline.single_port_stage |
|
morpheus.pipeline.source_stage |
|
morpheus.pipeline.stage |
|
morpheus.pipeline.stage_base |
|
morpheus.pipeline.stage_decorator |
|
morpheus.pipeline.stage_schema |