morpheus.pipeline.multi_message_stage

Classes

MultiMessageStage(c)

Subclass of SinglePortStage with option to log timestamps in MessageMeta dataframe.