Class SerializeStage

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.

© Copyright 2023, NVIDIA. Last updated on Apr 11, 2023.