Template Class SerializeStage

Base Type

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

template<typename InputT>
class SerializeStage : public mrc::pymrc::PythonNode<std::shared_ptr<InputT>, 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<InputT>, 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.

Previous Class RMMTensor
Next Class SlicedMessageMeta
© Copyright 2024, NVIDIA. Last updated on Apr 25, 2024.