Struct SerializeStageInterfaceProxy#

Struct Documentation#

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>>