Struct SerializeStageInterfaceProxy
Defined in File serialize.hpp
-
struct SerializeStageInterfaceProxy
Interface proxy, used to insulate python bindings.
Public Static Functions
-
static std::shared_ptr<mrc::segment::Object<SerializeStage>> init(mrc::segment::Builder &builder, const std::string &name, const std::vector<std::string> &include, const std::vector<std::string> &exclude, bool fixed_columns = true)
Create and initialize a SerializeStage, and return the result.
- Parameters
builder – : Pipeline context object reference
name – : Name of a stage reference
include – : Reference to the attributes that are required send to downstream stage.
exclude – : Reference to the 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.- Returns
std::shared_ptr<mrc::segment::Object<SerializeStage>>
-
static std::shared_ptr<mrc::segment::Object<SerializeStage>> init(mrc::segment::Builder &builder, const std::string &name, const std::vector<std::string> &include, const std::vector<std::string> &exclude, bool fixed_columns = true)