Class SerializeStage#

Inheritance Relationships#

Base Type#

  • public mrc::pymrc::PythonNode< std::shared_ptr< ControlMessage >, std::shared_ptr< MessageMeta > >

Class Documentation#

class SerializeStage : public mrc::pymrc::PythonNode<std::shared_ptr<ControlMessage>, std::shared_ptr<MessageMeta>>#

Include & exclude columns from messages. This class filters columns from a ControlMessage object emitting a MessageMeta.

Public Types

using base_t = mrc::pymrc::PythonNode<std::shared_ptr<ControlMessage>, std::shared_ptr<MessageMeta>>#

Public Functions

SerializeStage(
const std::vector<std::string> &include,
const std::vector<std::string> &exclude,
bool fixed_columns = true
)#

Construct a new Serialize Stage object.

Parameters:

  • include – : Attributes that are required send to downstream stage.

  • exclude – : Attributes that are not required send to downstream stage.

  • fixed_columns – : When True SerializeStage will assume that the Dataframe in all messages contain the same columns as the first message received.