Struct DeserializeStageInterfaceProxy

Interface proxy, used to insulate python bindings.

Public Static Functions

static std::shared_ptr<mrc::segment::Object<DeserializeStage>> init(mrc::segment::Builder &builder, const std::string &name, size_t batch_size)

Create and initialize a DeserializationStage, and return the result.

Parameters

• builder – : Pipeline context object reference

• name – : Name of a stage reference

• batch_size – : Number of messages to be divided into each batch

Returns

std::shared_ptr<mrc::segment::Object<DeserializeStage>>