Defined in File deserialize.hpp
-
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>>
-
static std::shared_ptr<mrc::segment::Object<DeserializeStage>> init(mrc::segment::Builder &builder, const std::string &name, size_t batch_size)