func (*MAccumulatorChunk) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{10}
}
Deprecated: Use MAccumulatorChunk.ProtoReflect.Descriptor instead.
package rpc
import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
)
const (
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type MAssignPartitionRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Loader []byte `protobuf:"bytes,1,opt,name=loader,proto3" json:"loader,omitempty"`
}
func (x *MAssignPartitionRequest) Reset() {
	*x = MAssignPartitionRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[0]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MAssignPartitionRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MAssignPartitionRequest) ProtoMessage() {}
func (x *MAssignPartitionRequest) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[0]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MAssignPartitionRequest) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{0}
}
func (x *MAssignPartitionRequest) GetLoader() []byte {
	if x != nil {
		return x.Loader
	}
	return nil
}
type MAssignPartitionResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *MAssignPartitionResponse) Reset() {
	*x = MAssignPartitionResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[1]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MAssignPartitionResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MAssignPartitionResponse) ProtoMessage() {}
func (x *MAssignPartitionResponse) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[1]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MAssignPartitionResponse) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{1}
}
type MPartitionMeta struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bytes uint32 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
}
func (x *MPartitionMeta) Reset() {
	*x = MPartitionMeta{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[2]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MPartitionMeta) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MPartitionMeta) ProtoMessage() {}
func (x *MPartitionMeta) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[2]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MPartitionMeta) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{2}
}
func (x *MPartitionMeta) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}
func (x *MPartitionMeta) GetBytes() uint32 {
	if x != nil {
		return x.Bytes
	}
	return 0
}
type MShufflePartitionRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Bucket uint64 `protobuf:"varint,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
}
func (x *MShufflePartitionRequest) Reset() {
	*x = MShufflePartitionRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[3]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MShufflePartitionRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MShufflePartitionRequest) ProtoMessage() {}
func (x *MShufflePartitionRequest) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[3]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MShufflePartitionRequest) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{3}
}
func (x *MShufflePartitionRequest) GetBucket() uint64 {
	if x != nil {
		return x.Bucket
	}
	return 0
}
type MShufflePartitionResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Ready   bool            `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	HasNext bool            `protobuf:"varint,2,opt,name=hasNext,proto3" json:"hasNext,omitempty"`
	Part    *MPartitionMeta `protobuf:"bytes,3,opt,name=part,proto3" json:"part,omitempty"`
}
func (x *MShufflePartitionResponse) Reset() {
	*x = MShufflePartitionResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[4]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MShufflePartitionResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MShufflePartitionResponse) ProtoMessage() {}
func (x *MShufflePartitionResponse) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[4]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MShufflePartitionResponse) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{4}
}
func (x *MShufflePartitionResponse) GetReady() bool {
	if x != nil {
		return x.Ready
	}
	return false
}
func (x *MShufflePartitionResponse) GetHasNext() bool {
	if x != nil {
		return x.HasNext
	}
	return false
}
func (x *MShufflePartitionResponse) GetPart() *MPartitionMeta {
	if x != nil {
		return x.Part
	}
	return nil
}
type MTransferPartitionDataRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (x *MTransferPartitionDataRequest) Reset() {
	*x = MTransferPartitionDataRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[5]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MTransferPartitionDataRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MTransferPartitionDataRequest) ProtoMessage() {}
func (x *MTransferPartitionDataRequest) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[5]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MTransferPartitionDataRequest) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{5}
}
func (x *MTransferPartitionDataRequest) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}
type MPartitionChunk struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	DataType int32  `protobuf:"varint,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
}
func (x *MPartitionChunk) Reset() {
	*x = MPartitionChunk{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[6]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MPartitionChunk) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MPartitionChunk) ProtoMessage() {}
func (x *MPartitionChunk) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[6]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MPartitionChunk) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{6}
}
func (x *MPartitionChunk) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}
func (x *MPartitionChunk) GetDataType() int32 {
	if x != nil {
		return x.DataType
	}
	return 0
}
type MShuffleAccumulatorRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *MShuffleAccumulatorRequest) Reset() {
	*x = MShuffleAccumulatorRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[7]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MShuffleAccumulatorRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MShuffleAccumulatorRequest) ProtoMessage() {}
func (x *MShuffleAccumulatorRequest) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[7]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MShuffleAccumulatorRequest) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{7}
}
type MShuffleAccumulatorResponse struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Ready          bool  `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	TotalSizeBytes int32 `protobuf:"varint,2,opt,name=totalSizeBytes,proto3" json:"totalSizeBytes,omitempty"`
}
func (x *MShuffleAccumulatorResponse) Reset() {
	*x = MShuffleAccumulatorResponse{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[8]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MShuffleAccumulatorResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MShuffleAccumulatorResponse) ProtoMessage() {}
func (x *MShuffleAccumulatorResponse) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[8]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MShuffleAccumulatorResponse) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{8}
}
func (x *MShuffleAccumulatorResponse) GetReady() bool {
	if x != nil {
		return x.Ready
	}
	return false
}
func (x *MShuffleAccumulatorResponse) GetTotalSizeBytes() int32 {
	if x != nil {
		return x.TotalSizeBytes
	}
	return 0
}
type MTransferAccumulatorDataRequest struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
}
func (x *MTransferAccumulatorDataRequest) Reset() {
	*x = MTransferAccumulatorDataRequest{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[9]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MTransferAccumulatorDataRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MTransferAccumulatorDataRequest) ProtoMessage() {}
func (x *MTransferAccumulatorDataRequest) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[9]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*MTransferAccumulatorDataRequest) Descriptor() ([]byte, []int) {
	return file_s_partition_proto_rawDescGZIP(), []int{9}
}
type MAccumulatorChunk struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
func (x *MAccumulatorChunk) Reset() {
	*x = MAccumulatorChunk{}
	if protoimpl.UnsafeEnabled {
		mi := &file_s_partition_proto_msgTypes[10]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *MAccumulatorChunk) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*MAccumulatorChunk) ProtoMessage() {}
func (x *MAccumulatorChunk) ProtoReflect() protoreflect.Message {
	mi := &file_s_partition_proto_msgTypes[10]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}