Class SerializeStage

• Defined in File serialize.hpp

Base Type

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

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

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

Public Types

using base_t = mrc::pymrc::PythonNode<std::shared_ptr<MultiMessage>, 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.