// Code generated by protoc-gen-go. DO NOT EDIT.
// source: delivery.proto

package otsprotocol

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package

type DeliveryTaskType int32

const (
	DeliveryTaskType_BASE     DeliveryTaskType = 0
	DeliveryTaskType_INC      DeliveryTaskType = 1
	DeliveryTaskType_BASE_INC DeliveryTaskType = 2
)

var DeliveryTaskType_name = map[int32]string{
	0: "BASE",
	1: "INC",
	2: "BASE_INC",
}
var DeliveryTaskType_value = map[string]int32{
	"BASE":     0,
	"INC":      1,
	"BASE_INC": 2,
}

func (x DeliveryTaskType) Enum() *DeliveryTaskType {
	p := new(DeliveryTaskType)
	*p = x
	return p
}
func (x DeliveryTaskType) String() string {
	return proto.EnumName(DeliveryTaskType_name, int32(x))
}
func (x *DeliveryTaskType) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(DeliveryTaskType_value, data, "DeliveryTaskType")
	if err != nil {
		return err
	}
	*x = DeliveryTaskType(value)
	return nil
}
func (DeliveryTaskType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{0}
}

type Format int32

const (
	Format_Parquet Format = 0
)

var Format_name = map[int32]string{
	0: "Parquet",
}
var Format_value = map[string]int32{
	"Parquet": 0,
}

func (x Format) Enum() *Format {
	p := new(Format)
	*p = x
	return p
}
func (x Format) String() string {
	return proto.EnumName(Format_name, int32(x))
}
func (x *Format) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(Format_value, data, "Format")
	if err != nil {
		return err
	}
	*x = Format(value)
	return nil
}
func (Format) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{1}
}

type Encoding int32

const (
	Encoding_PLAIN                   Encoding = 0
	Encoding_PLAIN_DICTIONARY        Encoding = 1
	Encoding_DELTA_BINARY_PACKED     Encoding = 2
	Encoding_DELTA_BYTE_ARRAY        Encoding = 3
	Encoding_DELTA_LENGTH_BYTE_ARRAY Encoding = 4
)

var Encoding_name = map[int32]string{
	0: "PLAIN",
	1: "PLAIN_DICTIONARY",
	2: "DELTA_BINARY_PACKED",
	3: "DELTA_BYTE_ARRAY",
	4: "DELTA_LENGTH_BYTE_ARRAY",
}
var Encoding_value = map[string]int32{
	"PLAIN":                   0,
	"PLAIN_DICTIONARY":        1,
	"DELTA_BINARY_PACKED":     2,
	"DELTA_BYTE_ARRAY":        3,
	"DELTA_LENGTH_BYTE_ARRAY": 4,
}

func (x Encoding) Enum() *Encoding {
	p := new(Encoding)
	*p = x
	return p
}
func (x Encoding) String() string {
	return proto.EnumName(Encoding_name, int32(x))
}
func (x *Encoding) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(Encoding_value, data, "Encoding")
	if err != nil {
		return err
	}
	*x = Encoding(value)
	return nil
}
func (Encoding) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{2}
}

type TimeFormatter int32

const (
	TimeFormatter_YDMFormatter TimeFormatter = 0
)

var TimeFormatter_name = map[int32]string{
	0: "YDMFormatter",
}
var TimeFormatter_value = map[string]int32{
	"YDMFormatter": 0,
}

func (x TimeFormatter) Enum() *TimeFormatter {
	p := new(TimeFormatter)
	*p = x
	return p
}
func (x TimeFormatter) String() string {
	return proto.EnumName(TimeFormatter_name, int32(x))
}
func (x *TimeFormatter) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(TimeFormatter_value, data, "TimeFormatter")
	if err != nil {
		return err
	}
	*x = TimeFormatter(value)
	return nil
}
func (TimeFormatter) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{3}
}

type ErrorType int32

const (
	ErrorType_UNAUTHORIZED       ErrorType = 1
	ErrorType_INVALID_OSS_BUCKET ErrorType = 2
)

var ErrorType_name = map[int32]string{
	1: "UNAUTHORIZED",
	2: "INVALID_OSS_BUCKET",
}
var ErrorType_value = map[string]int32{
	"UNAUTHORIZED":       1,
	"INVALID_OSS_BUCKET": 2,
}

func (x ErrorType) Enum() *ErrorType {
	p := new(ErrorType)
	*p = x
	return p
}
func (x ErrorType) String() string {
	return proto.EnumName(ErrorType_name, int32(x))
}
func (x *ErrorType) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(ErrorType_value, data, "ErrorType")
	if err != nil {
		return err
	}
	*x = ErrorType(value)
	return nil
}
func (ErrorType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{4}
}

type TaskSyncStat_TaskSyncPhase int32

const (
	TaskSyncStat_INIT TaskSyncStat_TaskSyncPhase = 0
	TaskSyncStat_FULL TaskSyncStat_TaskSyncPhase = 1
	TaskSyncStat_INCR TaskSyncStat_TaskSyncPhase = 2
)

var TaskSyncStat_TaskSyncPhase_name = map[int32]string{
	0: "INIT",
	1: "FULL",
	2: "INCR",
}
var TaskSyncStat_TaskSyncPhase_value = map[string]int32{
	"INIT": 0,
	"FULL": 1,
	"INCR": 2,
}

func (x TaskSyncStat_TaskSyncPhase) Enum() *TaskSyncStat_TaskSyncPhase {
	p := new(TaskSyncStat_TaskSyncPhase)
	*p = x
	return p
}
func (x TaskSyncStat_TaskSyncPhase) String() string {
	return proto.EnumName(TaskSyncStat_TaskSyncPhase_name, int32(x))
}
func (x *TaskSyncStat_TaskSyncPhase) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(TaskSyncStat_TaskSyncPhase_value, data, "TaskSyncStat_TaskSyncPhase")
	if err != nil {
		return err
	}
	*x = TaskSyncStat_TaskSyncPhase(value)
	return nil
}
func (TaskSyncStat_TaskSyncPhase) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{7, 0}
}

type EventColumnEventTimeFormat int32

const (
	EventColumn_RFC822  EventColumnEventTimeFormat = 1
	EventColumn_RFC850  EventColumnEventTimeFormat = 2
	EventColumn_RFC1123 EventColumnEventTimeFormat = 3
	EventColumn_RFC3339 EventColumnEventTimeFormat = 4
	EventColumn_Unix    EventColumnEventTimeFormat = 5
)

var EventColumnEventTimeFormat_name = map[int32]string{
	1: "RFC822",
	2: "RFC850",
	3: "RFC1123",
	4: "RFC3339",
	5: "Unix",
}
var EventColumnEventTimeFormat_value = map[string]int32{
	"RFC822":  1,
	"RFC850":  2,
	"RFC1123": 3,
	"RFC3339": 4,
	"Unix":    5,
}

func (x EventColumnEventTimeFormat) Enum() *EventColumnEventTimeFormat {
	p := new(EventColumnEventTimeFormat)
	*p = x
	return p
}
func (x EventColumnEventTimeFormat) String() string {
	return proto.EnumName(EventColumnEventTimeFormat_name, int32(x))
}
func (x *EventColumnEventTimeFormat) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(EventColumnEventTimeFormat_value, data, "EventColumnEventTimeFormat")
	if err != nil {
		return err
	}
	*x = EventColumnEventTimeFormat(value)
	return nil
}
func (EventColumnEventTimeFormat) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{13, 0}
}

type ParquetSchema_DataType int32

const (
	ParquetSchema_BOOL             ParquetSchema_DataType = 0
	ParquetSchema_INT64            ParquetSchema_DataType = 1
	ParquetSchema_UTF8             ParquetSchema_DataType = 2
	ParquetSchema_DOUBLE           ParquetSchema_DataType = 3
	ParquetSchema_DATE             ParquetSchema_DataType = 4
	ParquetSchema_DECIMAL          ParquetSchema_DataType = 5
	ParquetSchema_TIME_MILLIS      ParquetSchema_DataType = 6
	ParquetSchema_TIME_MICROS      ParquetSchema_DataType = 7
	ParquetSchema_TIMESTAMP_MILLIS ParquetSchema_DataType = 8
	ParquetSchema_TIMESTAMP_MICROS ParquetSchema_DataType = 9
	ParquetSchema_LIST             ParquetSchema_DataType = 10
	ParquetSchema_MAP              ParquetSchema_DataType = 11
	ParquetSchema_INTERVAL         ParquetSchema_DataType = 12
	ParquetSchema_FLOAT            ParquetSchema_DataType = 13
	ParquetSchema_INT32            ParquetSchema_DataType = 14
	ParquetSchema_INT96            ParquetSchema_DataType = 15
)

var ParquetSchema_DataType_name = map[int32]string{
	0:  "BOOL",
	1:  "INT64",
	2:  "UTF8",
	3:  "DOUBLE",
	4:  "DATE",
	5:  "DECIMAL",
	6:  "TIME_MILLIS",
	7:  "TIME_MICROS",
	8:  "TIMESTAMP_MILLIS",
	9:  "TIMESTAMP_MICROS",
	10: "LIST",
	11: "MAP",
	12: "INTERVAL",
	13: "FLOAT",
	14: "INT32",
	15: "INT96",
}
var ParquetSchema_DataType_value = map[string]int32{
	"BOOL":             0,
	"INT64":            1,
	"UTF8":             2,
	"DOUBLE":           3,
	"DATE":             4,
	"DECIMAL":          5,
	"TIME_MILLIS":      6,
	"TIME_MICROS":      7,
	"TIMESTAMP_MILLIS": 8,
	"TIMESTAMP_MICROS": 9,
	"LIST":             10,
	"MAP":              11,
	"INTERVAL":         12,
	"FLOAT":            13,
	"INT32":            14,
	"INT96":            15,
}

func (x ParquetSchema_DataType) Enum() *ParquetSchema_DataType {
	p := new(ParquetSchema_DataType)
	*p = x
	return p
}
func (x ParquetSchema_DataType) String() string {
	return proto.EnumName(ParquetSchema_DataType_name, int32(x))
}
func (x *ParquetSchema_DataType) UnmarshalJSON(data []byte) error {
	value, err := proto.UnmarshalJSONEnum(ParquetSchema_DataType_value, data, "ParquetSchema_DataType")
	if err != nil {
		return err
	}
	*x = ParquetSchema_DataType(value)
	return nil
}
func (ParquetSchema_DataType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{14, 0}
}

type CreateDeliveryTaskRequest struct {
	TableName            *string           `protobuf:"bytes,1,opt,name=tableName" json:"tableName,omitempty"`
	TaskName             *string           `protobuf:"bytes,2,opt,name=taskName" json:"taskName,omitempty"`
	TaskConfig           *OSSTaskConfig    `protobuf:"bytes,3,opt,name=taskConfig" json:"taskConfig,omitempty"`
	TaskType             *DeliveryTaskType `protobuf:"varint,4,opt,name=taskType,enum=otsprotocol.DeliveryTaskType" json:"taskType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *CreateDeliveryTaskRequest) Reset()         { *m = CreateDeliveryTaskRequest{} }
func (m *CreateDeliveryTaskRequest) String() string { return proto.CompactTextString(m) }
func (*CreateDeliveryTaskRequest) ProtoMessage()    {}
func (*CreateDeliveryTaskRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{0}
}
func (m *CreateDeliveryTaskRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateDeliveryTaskRequest.Unmarshal(m, b)
}
func (m *CreateDeliveryTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateDeliveryTaskRequest.Marshal(b, m, deterministic)
}
func (dst *CreateDeliveryTaskRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateDeliveryTaskRequest.Merge(dst, src)
}
func (m *CreateDeliveryTaskRequest) XXX_Size() int {
	return xxx_messageInfo_CreateDeliveryTaskRequest.Size(m)
}
func (m *CreateDeliveryTaskRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateDeliveryTaskRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateDeliveryTaskRequest proto.InternalMessageInfo

func (m *CreateDeliveryTaskRequest) GetTableName() string {
	if m != nil && m.TableName != nil {
		return *m.TableName
	}
	return ""
}

func (m *CreateDeliveryTaskRequest) GetTaskName() string {
	if m != nil && m.TaskName != nil {
		return *m.TaskName
	}
	return ""
}

func (m *CreateDeliveryTaskRequest) GetTaskConfig() *OSSTaskConfig {
	if m != nil {
		return m.TaskConfig
	}
	return nil
}

func (m *CreateDeliveryTaskRequest) GetTaskType() DeliveryTaskType {
	if m != nil && m.TaskType != nil {
		return *m.TaskType
	}
	return DeliveryTaskType_BASE
}

type OSSTaskConfig struct {
	OssPrefix            *string          `protobuf:"bytes,1,opt,name=ossPrefix" json:"ossPrefix,omitempty"`
	Formatter            *TimeFormatter   `protobuf:"varint,2,opt,name=formatter,enum=otsprotocol.TimeFormatter" json:"formatter,omitempty"`
	OssDirtyPrefix       *string          `protobuf:"bytes,3,opt,name=ossDirtyPrefix" json:"ossDirtyPrefix,omitempty"`
	OssBucket            *string          `protobuf:"bytes,4,opt,name=ossBucket" json:"ossBucket,omitempty"`
	OssEndpoint          *string          `protobuf:"bytes,5,opt,name=ossEndpoint" json:"ossEndpoint,omitempty"`
	OssStsRole           *string          `protobuf:"bytes,6,opt,name=ossStsRole" json:"ossStsRole,omitempty"`
	EventTimeColumn      *EventColumn     `protobuf:"bytes,7,opt,name=eventTimeColumn" json:"eventTimeColumn,omitempty"`
	Format               *Format          `protobuf:"varint,8,opt,name=format,enum=otsprotocol.Format" json:"format,omitempty"`
	Schema               []*ParquetSchema `protobuf:"bytes,11,rep,name=schema" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *OSSTaskConfig) Reset()         { *m = OSSTaskConfig{} }
func (m *OSSTaskConfig) String() string { return proto.CompactTextString(m) }
func (*OSSTaskConfig) ProtoMessage()    {}
func (*OSSTaskConfig) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{1}
}
func (m *OSSTaskConfig) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_OSSTaskConfig.Unmarshal(m, b)
}
func (m *OSSTaskConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_OSSTaskConfig.Marshal(b, m, deterministic)
}
func (dst *OSSTaskConfig) XXX_Merge(src proto.Message) {
	xxx_messageInfo_OSSTaskConfig.Merge(dst, src)
}
func (m *OSSTaskConfig) XXX_Size() int {
	return xxx_messageInfo_OSSTaskConfig.Size(m)
}
func (m *OSSTaskConfig) XXX_DiscardUnknown() {
	xxx_messageInfo_OSSTaskConfig.DiscardUnknown(m)
}

var xxx_messageInfo_OSSTaskConfig proto.InternalMessageInfo

func (m *OSSTaskConfig) GetOssPrefix() string {
	if m != nil && m.OssPrefix != nil {
		return *m.OssPrefix
	}
	return ""
}

func (m *OSSTaskConfig) GetFormatter() TimeFormatter {
	if m != nil && m.Formatter != nil {
		return *m.Formatter
	}
	return TimeFormatter_YDMFormatter
}

func (m *OSSTaskConfig) GetOssDirtyPrefix() string {
	if m != nil && m.OssDirtyPrefix != nil {
		return *m.OssDirtyPrefix
	}
	return ""
}

func (m *OSSTaskConfig) GetOssBucket() string {
	if m != nil && m.OssBucket != nil {
		return *m.OssBucket
	}
	return ""
}

func (m *OSSTaskConfig) GetOssEndpoint() string {
	if m != nil && m.OssEndpoint != nil {
		return *m.OssEndpoint
	}
	return ""
}

func (m *OSSTaskConfig) GetOssStsRole() string {
	if m != nil && m.OssStsRole != nil {
		return *m.OssStsRole
	}
	return ""
}

func (m *OSSTaskConfig) GetEventTimeColumn() *EventColumn {
	if m != nil {
		return m.EventTimeColumn
	}
	return nil
}

func (m *OSSTaskConfig) GetFormat() Format {
	if m != nil && m.Format != nil {
		return *m.Format
	}
	return Format_Parquet
}

func (m *OSSTaskConfig) GetSchema() []*ParquetSchema {
	if m != nil {
		return m.Schema
	}
	return nil
}

type CreateDeliveryTaskResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CreateDeliveryTaskResponse) Reset()         { *m = CreateDeliveryTaskResponse{} }
func (m *CreateDeliveryTaskResponse) String() string { return proto.CompactTextString(m) }
func (*CreateDeliveryTaskResponse) ProtoMessage()    {}
func (*CreateDeliveryTaskResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{2}
}
func (m *CreateDeliveryTaskResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateDeliveryTaskResponse.Unmarshal(m, b)
}
func (m *CreateDeliveryTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateDeliveryTaskResponse.Marshal(b, m, deterministic)
}
func (dst *CreateDeliveryTaskResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateDeliveryTaskResponse.Merge(dst, src)
}
func (m *CreateDeliveryTaskResponse) XXX_Size() int {
	return xxx_messageInfo_CreateDeliveryTaskResponse.Size(m)
}
func (m *CreateDeliveryTaskResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateDeliveryTaskResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreateDeliveryTaskResponse proto.InternalMessageInfo

type DeleteDeliveryTaskRequest struct {
	TableName            *string  `protobuf:"bytes,1,opt,name=tableName" json:"tableName,omitempty"`
	TaskName             *string  `protobuf:"bytes,2,opt,name=taskName" json:"taskName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeleteDeliveryTaskRequest) Reset()         { *m = DeleteDeliveryTaskRequest{} }
func (m *DeleteDeliveryTaskRequest) String() string { return proto.CompactTextString(m) }
func (*DeleteDeliveryTaskRequest) ProtoMessage()    {}
func (*DeleteDeliveryTaskRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{3}
}
func (m *DeleteDeliveryTaskRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeleteDeliveryTaskRequest.Unmarshal(m, b)
}
func (m *DeleteDeliveryTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeleteDeliveryTaskRequest.Marshal(b, m, deterministic)
}
func (dst *DeleteDeliveryTaskRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeleteDeliveryTaskRequest.Merge(dst, src)
}
func (m *DeleteDeliveryTaskRequest) XXX_Size() int {
	return xxx_messageInfo_DeleteDeliveryTaskRequest.Size(m)
}
func (m *DeleteDeliveryTaskRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DeleteDeliveryTaskRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DeleteDeliveryTaskRequest proto.InternalMessageInfo

func (m *DeleteDeliveryTaskRequest) GetTableName() string {
	if m != nil && m.TableName != nil {
		return *m.TableName
	}
	return ""
}

func (m *DeleteDeliveryTaskRequest) GetTaskName() string {
	if m != nil && m.TaskName != nil {
		return *m.TaskName
	}
	return ""
}

type DeleteDeliveryTaskResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeleteDeliveryTaskResponse) Reset()         { *m = DeleteDeliveryTaskResponse{} }
func (m *DeleteDeliveryTaskResponse) String() string { return proto.CompactTextString(m) }
func (*DeleteDeliveryTaskResponse) ProtoMessage()    {}
func (*DeleteDeliveryTaskResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{4}
}
func (m *DeleteDeliveryTaskResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeleteDeliveryTaskResponse.Unmarshal(m, b)
}
func (m *DeleteDeliveryTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeleteDeliveryTaskResponse.Marshal(b, m, deterministic)
}
func (dst *DeleteDeliveryTaskResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeleteDeliveryTaskResponse.Merge(dst, src)
}
func (m *DeleteDeliveryTaskResponse) XXX_Size() int {
	return xxx_messageInfo_DeleteDeliveryTaskResponse.Size(m)
}
func (m *DeleteDeliveryTaskResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DeleteDeliveryTaskResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DeleteDeliveryTaskResponse proto.InternalMessageInfo

type DescribeDeliveryTaskRequest struct {
	TableName            *string  `protobuf:"bytes,1,opt,name=tableName" json:"tableName,omitempty"`
	TaskName             *string  `protobuf:"bytes,2,opt,name=taskName" json:"taskName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DescribeDeliveryTaskRequest) Reset()         { *m = DescribeDeliveryTaskRequest{} }
func (m *DescribeDeliveryTaskRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeDeliveryTaskRequest) ProtoMessage()    {}
func (*DescribeDeliveryTaskRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{5}
}
func (m *DescribeDeliveryTaskRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeDeliveryTaskRequest.Unmarshal(m, b)
}
func (m *DescribeDeliveryTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeDeliveryTaskRequest.Marshal(b, m, deterministic)
}
func (dst *DescribeDeliveryTaskRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeDeliveryTaskRequest.Merge(dst, src)
}
func (m *DescribeDeliveryTaskRequest) XXX_Size() int {
	return xxx_messageInfo_DescribeDeliveryTaskRequest.Size(m)
}
func (m *DescribeDeliveryTaskRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeDeliveryTaskRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeDeliveryTaskRequest proto.InternalMessageInfo

func (m *DescribeDeliveryTaskRequest) GetTableName() string {
	if m != nil && m.TableName != nil {
		return *m.TableName
	}
	return ""
}

func (m *DescribeDeliveryTaskRequest) GetTaskName() string {
	if m != nil && m.TaskName != nil {
		return *m.TaskName
	}
	return ""
}

type DescribeDeliveryTaskResponse struct {
	TaskConfig           *OSSTaskConfig    `protobuf:"bytes,1,opt,name=taskConfig" json:"taskConfig,omitempty"`
	TaskSyncStat         *TaskSyncStat     `protobuf:"bytes,2,opt,name=task_sync_stat,json=taskSyncStat" json:"task_sync_stat,omitempty"`
	TaskType             *DeliveryTaskType `protobuf:"varint,3,opt,name=taskType,enum=otsprotocol.DeliveryTaskType" json:"taskType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DescribeDeliveryTaskResponse) Reset()         { *m = DescribeDeliveryTaskResponse{} }
func (m *DescribeDeliveryTaskResponse) String() string { return proto.CompactTextString(m) }
func (*DescribeDeliveryTaskResponse) ProtoMessage()    {}
func (*DescribeDeliveryTaskResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{6}
}
func (m *DescribeDeliveryTaskResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeDeliveryTaskResponse.Unmarshal(m, b)
}
func (m *DescribeDeliveryTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeDeliveryTaskResponse.Marshal(b, m, deterministic)
}
func (dst *DescribeDeliveryTaskResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeDeliveryTaskResponse.Merge(dst, src)
}
func (m *DescribeDeliveryTaskResponse) XXX_Size() int {
	return xxx_messageInfo_DescribeDeliveryTaskResponse.Size(m)
}
func (m *DescribeDeliveryTaskResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeDeliveryTaskResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeDeliveryTaskResponse proto.InternalMessageInfo

func (m *DescribeDeliveryTaskResponse) GetTaskConfig() *OSSTaskConfig {
	if m != nil {
		return m.TaskConfig
	}
	return nil
}

func (m *DescribeDeliveryTaskResponse) GetTaskSyncStat() *TaskSyncStat {
	if m != nil {
		return m.TaskSyncStat
	}
	return nil
}

func (m *DescribeDeliveryTaskResponse) GetTaskType() DeliveryTaskType {
	if m != nil && m.TaskType != nil {
		return *m.TaskType
	}
	return DeliveryTaskType_BASE
}

type TaskSyncStat struct {
	TaskSyncPhase        *TaskSyncStat_TaskSyncPhase `protobuf:"varint,1,opt,name=task_sync_phase,json=taskSyncPhase,enum=otsprotocol.TaskSyncStat_TaskSyncPhase" json:"task_sync_phase,omitempty"`
	CurrentSyncTimestamp *int64                      `protobuf:"varint,2,opt,name=current_sync_timestamp,json=currentSyncTimestamp" json:"current_sync_timestamp,omitempty"`
	ErrorCode            *ErrorType                  `protobuf:"varint,3,opt,name=error_code,json=errorCode,enum=otsprotocol.ErrorType" json:"error_code,omitempty"`
	Detail               *string                     `protobuf:"bytes,4,opt,name=detail" json:"detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (m *TaskSyncStat) Reset()         { *m = TaskSyncStat{} }
func (m *TaskSyncStat) String() string { return proto.CompactTextString(m) }
func (*TaskSyncStat) ProtoMessage()    {}
func (*TaskSyncStat) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{7}
}
func (m *TaskSyncStat) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_TaskSyncStat.Unmarshal(m, b)
}
func (m *TaskSyncStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_TaskSyncStat.Marshal(b, m, deterministic)
}
func (dst *TaskSyncStat) XXX_Merge(src proto.Message) {
	xxx_messageInfo_TaskSyncStat.Merge(dst, src)
}
func (m *TaskSyncStat) XXX_Size() int {
	return xxx_messageInfo_TaskSyncStat.Size(m)
}
func (m *TaskSyncStat) XXX_DiscardUnknown() {
	xxx_messageInfo_TaskSyncStat.DiscardUnknown(m)
}

var xxx_messageInfo_TaskSyncStat proto.InternalMessageInfo

func (m *TaskSyncStat) GetTaskSyncPhase() TaskSyncStat_TaskSyncPhase {
	if m != nil && m.TaskSyncPhase != nil {
		return *m.TaskSyncPhase
	}
	return TaskSyncStat_INIT
}

func (m *TaskSyncStat) GetCurrentSyncTimestamp() int64 {
	if m != nil && m.CurrentSyncTimestamp != nil {
		return *m.CurrentSyncTimestamp
	}
	return 0
}

func (m *TaskSyncStat) GetErrorCode() ErrorType {
	if m != nil && m.ErrorCode != nil {
		return *m.ErrorCode
	}
	return ErrorType_UNAUTHORIZED
}

func (m *TaskSyncStat) GetDetail() string {
	if m != nil && m.Detail != nil {
		return *m.Detail
	}
	return ""
}

type UpdateDeliveryTaskRequest struct {
	Table                *string        `protobuf:"bytes,1,opt,name=table" json:"table,omitempty"`
	TaskName             *string        `protobuf:"bytes,2,opt,name=taskName" json:"taskName,omitempty"`
	TaskConfig           *OSSTaskConfig `protobuf:"bytes,5,opt,name=taskConfig" json:"taskConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *UpdateDeliveryTaskRequest) Reset()         { *m = UpdateDeliveryTaskRequest{} }
func (m *UpdateDeliveryTaskRequest) String() string { return proto.CompactTextString(m) }
func (*UpdateDeliveryTaskRequest) ProtoMessage()    {}
func (*UpdateDeliveryTaskRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{8}
}
func (m *UpdateDeliveryTaskRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdateDeliveryTaskRequest.Unmarshal(m, b)
}
func (m *UpdateDeliveryTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdateDeliveryTaskRequest.Marshal(b, m, deterministic)
}
func (dst *UpdateDeliveryTaskRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdateDeliveryTaskRequest.Merge(dst, src)
}
func (m *UpdateDeliveryTaskRequest) XXX_Size() int {
	return xxx_messageInfo_UpdateDeliveryTaskRequest.Size(m)
}
func (m *UpdateDeliveryTaskRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdateDeliveryTaskRequest.DiscardUnknown(m)
}

var xxx_messageInfo_UpdateDeliveryTaskRequest proto.InternalMessageInfo

func (m *UpdateDeliveryTaskRequest) GetTable() string {
	if m != nil && m.Table != nil {
		return *m.Table
	}
	return ""
}

func (m *UpdateDeliveryTaskRequest) GetTaskName() string {
	if m != nil && m.TaskName != nil {
		return *m.TaskName
	}
	return ""
}

func (m *UpdateDeliveryTaskRequest) GetTaskConfig() *OSSTaskConfig {
	if m != nil {
		return m.TaskConfig
	}
	return nil
}

type UpdateDeliveryTaskResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UpdateDeliveryTaskResponse) Reset()         { *m = UpdateDeliveryTaskResponse{} }
func (m *UpdateDeliveryTaskResponse) String() string { return proto.CompactTextString(m) }
func (*UpdateDeliveryTaskResponse) ProtoMessage()    {}
func (*UpdateDeliveryTaskResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{9}
}
func (m *UpdateDeliveryTaskResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdateDeliveryTaskResponse.Unmarshal(m, b)
}
func (m *UpdateDeliveryTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdateDeliveryTaskResponse.Marshal(b, m, deterministic)
}
func (dst *UpdateDeliveryTaskResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdateDeliveryTaskResponse.Merge(dst, src)
}
func (m *UpdateDeliveryTaskResponse) XXX_Size() int {
	return xxx_messageInfo_UpdateDeliveryTaskResponse.Size(m)
}
func (m *UpdateDeliveryTaskResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdateDeliveryTaskResponse.DiscardUnknown(m)
}

var xxx_messageInfo_UpdateDeliveryTaskResponse proto.InternalMessageInfo

type ListDeliveryTaskRequest struct {
	TableName            *string  `protobuf:"bytes,1,opt,name=tableName" json:"tableName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListDeliveryTaskRequest) Reset()         { *m = ListDeliveryTaskRequest{} }
func (m *ListDeliveryTaskRequest) String() string { return proto.CompactTextString(m) }
func (*ListDeliveryTaskRequest) ProtoMessage()    {}
func (*ListDeliveryTaskRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{10}
}
func (m *ListDeliveryTaskRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListDeliveryTaskRequest.Unmarshal(m, b)
}
func (m *ListDeliveryTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListDeliveryTaskRequest.Marshal(b, m, deterministic)
}
func (dst *ListDeliveryTaskRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListDeliveryTaskRequest.Merge(dst, src)
}
func (m *ListDeliveryTaskRequest) XXX_Size() int {
	return xxx_messageInfo_ListDeliveryTaskRequest.Size(m)
}
func (m *ListDeliveryTaskRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListDeliveryTaskRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListDeliveryTaskRequest proto.InternalMessageInfo

func (m *ListDeliveryTaskRequest) GetTableName() string {
	if m != nil && m.TableName != nil {
		return *m.TableName
	}
	return ""
}

type ListDeliveryTaskResponse struct {
	Tasks                []*DeliveryTaskInfo `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *ListDeliveryTaskResponse) Reset()         { *m = ListDeliveryTaskResponse{} }
func (m *ListDeliveryTaskResponse) String() string { return proto.CompactTextString(m) }
func (*ListDeliveryTaskResponse) ProtoMessage()    {}
func (*ListDeliveryTaskResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{11}
}
func (m *ListDeliveryTaskResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListDeliveryTaskResponse.Unmarshal(m, b)
}
func (m *ListDeliveryTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListDeliveryTaskResponse.Marshal(b, m, deterministic)
}
func (dst *ListDeliveryTaskResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListDeliveryTaskResponse.Merge(dst, src)
}
func (m *ListDeliveryTaskResponse) XXX_Size() int {
	return xxx_messageInfo_ListDeliveryTaskResponse.Size(m)
}
func (m *ListDeliveryTaskResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListDeliveryTaskResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListDeliveryTaskResponse proto.InternalMessageInfo

func (m *ListDeliveryTaskResponse) GetTasks() []*DeliveryTaskInfo {
	if m != nil {
		return m.Tasks
	}
	return nil
}

type DeliveryTaskInfo struct {
	TableName            *string           `protobuf:"bytes,1,opt,name=tableName" json:"tableName,omitempty"`
	TaskName             *string           `protobuf:"bytes,2,opt,name=taskName" json:"taskName,omitempty"`
	TaskType             *DeliveryTaskType `protobuf:"varint,3,opt,name=taskType,enum=otsprotocol.DeliveryTaskType" json:"taskType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DeliveryTaskInfo) Reset()         { *m = DeliveryTaskInfo{} }
func (m *DeliveryTaskInfo) String() string { return proto.CompactTextString(m) }
func (*DeliveryTaskInfo) ProtoMessage()    {}
func (*DeliveryTaskInfo) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{12}
}
func (m *DeliveryTaskInfo) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeliveryTaskInfo.Unmarshal(m, b)
}
func (m *DeliveryTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeliveryTaskInfo.Marshal(b, m, deterministic)
}
func (dst *DeliveryTaskInfo) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeliveryTaskInfo.Merge(dst, src)
}
func (m *DeliveryTaskInfo) XXX_Size() int {
	return xxx_messageInfo_DeliveryTaskInfo.Size(m)
}
func (m *DeliveryTaskInfo) XXX_DiscardUnknown() {
	xxx_messageInfo_DeliveryTaskInfo.DiscardUnknown(m)
}

var xxx_messageInfo_DeliveryTaskInfo proto.InternalMessageInfo

func (m *DeliveryTaskInfo) GetTableName() string {
	if m != nil && m.TableName != nil {
		return *m.TableName
	}
	return ""
}

func (m *DeliveryTaskInfo) GetTaskName() string {
	if m != nil && m.TaskName != nil {
		return *m.TaskName
	}
	return ""
}

func (m *DeliveryTaskInfo) GetTaskType() DeliveryTaskType {
	if m != nil && m.TaskType != nil {
		return *m.TaskType
	}
	return DeliveryTaskType_BASE
}

type EventColumn struct {
	ColumnName           *string                     `protobuf:"bytes,1,opt,name=columnName" json:"columnName,omitempty"`
	TimeFormat           *EventColumnEventTimeFormat `protobuf:"varint,2,opt,name=timeFormat,enum=otsprotocol.EventColumnEventTimeFormat" json:"timeFormat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (m *EventColumn) Reset()         { *m = EventColumn{} }
func (m *EventColumn) String() string { return proto.CompactTextString(m) }
func (*EventColumn) ProtoMessage()    {}
func (*EventColumn) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{13}
}
func (m *EventColumn) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_EventColumn.Unmarshal(m, b)
}
func (m *EventColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_EventColumn.Marshal(b, m, deterministic)
}
func (dst *EventColumn) XXX_Merge(src proto.Message) {
	xxx_messageInfo_EventColumn.Merge(dst, src)
}
func (m *EventColumn) XXX_Size() int {
	return xxx_messageInfo_EventColumn.Size(m)
}
func (m *EventColumn) XXX_DiscardUnknown() {
	xxx_messageInfo_EventColumn.DiscardUnknown(m)
}

var xxx_messageInfo_EventColumn proto.InternalMessageInfo

func (m *EventColumn) GetColumnName() string {
	if m != nil && m.ColumnName != nil {
		return *m.ColumnName
	}
	return ""
}

func (m *EventColumn) GetTimeFormat() EventColumnEventTimeFormat {
	if m != nil && m.TimeFormat != nil {
		return *m.TimeFormat
	}
	return EventColumn_RFC822
}

type ParquetSchema struct {
	ColumnName           *string                 `protobuf:"bytes,1,opt,name=columnName" json:"columnName,omitempty"`
	OssColumnName        *string                 `protobuf:"bytes,2,opt,name=ossColumnName" json:"ossColumnName,omitempty"`
	Type                 *ParquetSchema_DataType `protobuf:"varint,3,opt,name=type,enum=otsprotocol.ParquetSchema_DataType" json:"type,omitempty"`
	Encode               *Encoding               `protobuf:"varint,4,opt,name=encode,enum=otsprotocol.Encoding" json:"encode,omitempty"`
	TypeExtend           *string                 `protobuf:"bytes,5,opt,name=typeExtend" json:"typeExtend,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (m *ParquetSchema) Reset()         { *m = ParquetSchema{} }
func (m *ParquetSchema) String() string { return proto.CompactTextString(m) }
func (*ParquetSchema) ProtoMessage()    {}
func (*ParquetSchema) Descriptor() ([]byte, []int) {
	return fileDescriptor_delivery_4779036a5419baf4, []int{14}
}
func (m *ParquetSchema) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ParquetSchema.Unmarshal(m, b)
}
func (m *ParquetSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ParquetSchema.Marshal(b, m, deterministic)
}
func (dst *ParquetSchema) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ParquetSchema.Merge(dst, src)
}
func (m *ParquetSchema) XXX_Size() int {
	return xxx_messageInfo_ParquetSchema.Size(m)
}
func (m *ParquetSchema) XXX_DiscardUnknown() {
	xxx_messageInfo_ParquetSchema.DiscardUnknown(m)
}

var xxx_messageInfo_ParquetSchema proto.InternalMessageInfo

func (m *ParquetSchema) GetColumnName() string {
	if m != nil && m.ColumnName != nil {
		return *m.ColumnName
	}
	return ""
}

func (m *ParquetSchema) GetOssColumnName() string {
	if m != nil && m.OssColumnName != nil {
		return *m.OssColumnName
	}
	return ""
}

func (m *ParquetSchema) GetType() ParquetSchema_DataType {
	if m != nil && m.Type != nil {
		return *m.Type
	}
	return ParquetSchema_BOOL
}

func (m *ParquetSchema) GetEncode() Encoding {
	if m != nil && m.Encode != nil {
		return *m.Encode
	}
	return Encoding_PLAIN
}

func (m *ParquetSchema) GetTypeExtend() string {
	if m != nil && m.TypeExtend != nil {
		return *m.TypeExtend
	}
	return ""
}

func init() {
	proto.RegisterType((*CreateDeliveryTaskRequest)(nil), "otsprotocol.CreateDeliveryTaskRequest")
	proto.RegisterType((*OSSTaskConfig)(nil), "otsprotocol.OSSTaskConfig")
	proto.RegisterType((*CreateDeliveryTaskResponse)(nil), "otsprotocol.CreateDeliveryTaskResponse")
	proto.RegisterType((*DeleteDeliveryTaskRequest)(nil), "otsprotocol.DeleteDeliveryTaskRequest")
	proto.RegisterType((*DeleteDeliveryTaskResponse)(nil), "otsprotocol.DeleteDeliveryTaskResponse")
	proto.RegisterType((*DescribeDeliveryTaskRequest)(nil), "otsprotocol.DescribeDeliveryTaskRequest")
	proto.RegisterType((*DescribeDeliveryTaskResponse)(nil), "otsprotocol.DescribeDeliveryTaskResponse")
	proto.RegisterType((*TaskSyncStat)(nil), "otsprotocol.TaskSyncStat")
	proto.RegisterType((*UpdateDeliveryTaskRequest)(nil), "otsprotocol.UpdateDeliveryTaskRequest")
	proto.RegisterType((*UpdateDeliveryTaskResponse)(nil), "otsprotocol.UpdateDeliveryTaskResponse")
	proto.RegisterType((*ListDeliveryTaskRequest)(nil), "otsprotocol.ListDeliveryTaskRequest")
	proto.RegisterType((*ListDeliveryTaskResponse)(nil), "otsprotocol.ListDeliveryTaskResponse")
	proto.RegisterType((*DeliveryTaskInfo)(nil), "otsprotocol.DeliveryTaskInfo")
	proto.RegisterType((*EventColumn)(nil), "otsprotocol.EventColumn")
	proto.RegisterType((*ParquetSchema)(nil), "otsprotocol.ParquetSchema")
	proto.RegisterEnum("otsprotocol.DeliveryTaskType", DeliveryTaskType_name, DeliveryTaskType_value)
	proto.RegisterEnum("otsprotocol.Format", Format_name, Format_value)
	proto.RegisterEnum("otsprotocol.Encoding", Encoding_name, Encoding_value)
	proto.RegisterEnum("otsprotocol.TimeFormatter", TimeFormatter_name, TimeFormatter_value)
	proto.RegisterEnum("otsprotocol.ErrorType", ErrorType_name, ErrorType_value)
	proto.RegisterEnum("otsprotocol.TaskSyncStat_TaskSyncPhase", TaskSyncStat_TaskSyncPhase_name, TaskSyncStat_TaskSyncPhase_value)
	proto.RegisterEnum("otsprotocol.EventColumnEventTimeFormat", EventColumnEventTimeFormat_name, EventColumnEventTimeFormat_value)
	proto.RegisterEnum("otsprotocol.ParquetSchema_DataType", ParquetSchema_DataType_name, ParquetSchema_DataType_value)
}

func init() { proto.RegisterFile("delivery.proto", fileDescriptor_delivery_4779036a5419baf4) }

var fileDescriptor_delivery_4779036a5419baf4 = []byte{
	// 1105 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xcd, 0x6e, 0xdb, 0x46,
	0x10, 0x16, 0xf5, 0x67, 0x69, 0x64, 0xc9, 0x8b, 0x4d, 0x62, 0xcb, 0x8e, 0x5b, 0xb8, 0x6a, 0xd1,
	0x1a, 0x2e, 0x62, 0x34, 0x52, 0x9c, 0xd8, 0xbd, 0x14, 0x14, 0x49, 0xd5, 0x44, 0xa8, 0x1f, 0x2c,
	0xa9, 0x14, 0xee, 0x45, 0x60, 0xa4, 0x75, 0x42, 0x58, 0x22, 0x15, 0xee, 0x3a, 0xb5, 0x9f, 0xa0,
	0xe8, 0xb9, 0x7d, 0x9c, 0x9e, 0x7b, 0xea, 0xb9, 0xa7, 0x3e, 0x4c, 0xb1, 0x4b, 0x4a, 0x26, 0x15,
	0x1b, 0x85, 0x91, 0xdc, 0x76, 0xbe, 0xf9, 0xe6, 0x57, 0x33, 0x43, 0x41, 0x6d, 0x42, 0xa7, 0xde,
	0x7b, 0x1a, 0x5e, 0x1f, 0xce, 0xc3, 0x80, 0x07, 0xb8, 0x12, 0x70, 0x26, 0x5f, 0xe3, 0x60, 0xda,
	0xf8, 0x5b, 0x81, 0x6d, 0x2d, 0xa4, 0x2e, 0xa7, 0x7a, 0xcc, 0x72, 0x5c, 0x76, 0x41, 0xe8, 0xbb,
	0x4b, 0xca, 0x38, 0xde, 0x85, 0x32, 0x77, 0x5f, 0x4f, 0x69, 0xcf, 0x9d, 0xd1, 0xba, 0xb2, 0xa7,
	0xec, 0x97, 0xc9, 0x0d, 0x80, 0x77, 0xa0, 0xc4, 0x5d, 0x76, 0x21, 0x95, 0x59, 0xa9, 0x5c, 0xca,
	0xf8, 0x7b, 0x00, 0xf1, 0xd6, 0x02, 0xff, 0xdc, 0x7b, 0x53, 0xcf, 0xed, 0x29, 0xfb, 0x95, 0xe6,
	0xce, 0x61, 0x22, 0xf2, 0x61, 0xdf, 0xb6, 0x9d, 0x25, 0x83, 0x24, 0xd8, 0xf8, 0x24, 0xf2, 0xeb,
	0x5c, 0xcf, 0x69, 0x3d, 0xbf, 0xa7, 0xec, 0xd7, 0x9a, 0x9f, 0xa5, 0x2c, 0x93, 0x99, 0x0a, 0x12,
	0x59, 0xd2, 0x1b, 0x7f, 0xe4, 0xa0, 0x9a, 0x72, 0x2c, 0x4a, 0x08, 0x18, 0x1b, 0x84, 0xf4, 0xdc,
	0xbb, 0x5a, 0x94, 0xb0, 0x04, 0xf0, 0x31, 0x94, 0xcf, 0x83, 0x70, 0xe6, 0x72, 0x4e, 0x43, 0x59,
	0x43, 0x6d, 0x25, 0x4b, 0xc7, 0x9b, 0xd1, 0xce, 0x82, 0x41, 0x6e, 0xc8, 0xf8, 0x6b, 0xa8, 0x05,
	0x8c, 0xe9, 0x5e, 0xc8, 0xaf, 0x63, 0xe7, 0x39, 0xe9, 0x7c, 0x05, 0x8d, 0xe3, 0xb7, 0x2f, 0xc7,
	0x17, 0x94, 0xcb, 0x6a, 0xa2, 0xf8, 0x11, 0x80, 0xf7, 0xa0, 0x12, 0x30, 0x66, 0xf8, 0x93, 0x79,
	0xe0, 0xf9, 0xbc, 0x5e, 0x90, 0xfa, 0x24, 0x84, 0x3f, 0x07, 0x08, 0x18, 0xb3, 0x39, 0x23, 0xc1,
	0x94, 0xd6, 0x8b, 0x92, 0x90, 0x40, 0x70, 0x1b, 0x36, 0xe8, 0x7b, 0xea, 0x73, 0x91, 0xa8, 0x16,
	0x4c, 0x2f, 0x67, 0x7e, 0x7d, 0x4d, 0x76, 0xbb, 0x9e, 0xaa, 0xc3, 0x10, 0x9c, 0x48, 0x4f, 0x56,
	0x0d, 0xf0, 0xb7, 0x50, 0x8c, 0x0a, 0xab, 0x97, 0x64, 0x0b, 0x1e, 0xa4, 0x4c, 0xa3, 0xf2, 0x49,
	0x4c, 0xc1, 0x4d, 0x28, 0xb2, 0xf1, 0x5b, 0x3a, 0x73, 0xeb, 0x95, 0xbd, 0xdc, 0x07, 0xbf, 0xea,
	0xc0, 0x0d, 0xdf, 0x5d, 0x52, 0x6e, 0x4b, 0x06, 0x89, 0x99, 0x8d, 0x5d, 0xd8, 0xb9, 0x6d, 0xc8,
	0xd8, 0x3c, 0xf0, 0x19, 0x6d, 0x0c, 0x61, 0x5b, 0xa7, 0x53, 0xfa, 0x89, 0x47, 0x50, 0x04, 0xbd,
	0xcd, 0x6d, 0x1c, 0xf4, 0x27, 0x78, 0xac, 0x53, 0x36, 0x0e, 0xbd, 0xd7, 0x9f, 0x38, 0xec, 0x3f,
	0x0a, 0xec, 0xde, 0xee, 0x39, 0x8a, 0xbc, 0xb2, 0x1a, 0xca, 0xbd, 0x56, 0xe3, 0x07, 0xa8, 0x09,
	0x69, 0xc4, 0xae, 0xfd, 0xf1, 0x88, 0x71, 0x97, 0xcb, 0xf0, 0x95, 0xe6, 0x76, 0x7a, 0x68, 0x5d,
	0x76, 0x61, 0x5f, 0xfb, 0x63, 0x9b, 0xbb, 0x9c, 0xac, 0xf3, 0x84, 0x94, 0xda, 0xad, 0xdc, 0xfd,
	0x76, 0xeb, 0xf7, 0x2c, 0xac, 0x27, 0x3d, 0xe3, 0x3e, 0x6c, 0xdc, 0x24, 0x33, 0x7f, 0xeb, 0xb2,
	0xa8, 0x53, 0xb5, 0xe6, 0x37, 0x77, 0x66, 0xb3, 0x14, 0x06, 0x82, 0x4e, 0xaa, 0x3c, 0x29, 0xe2,
	0x67, 0xb0, 0x39, 0xbe, 0x0c, 0x43, 0xea, 0xf3, 0xc8, 0x27, 0xf7, 0x66, 0x94, 0x71, 0x77, 0x36,
	0x97, 0x55, 0xe6, 0xc8, 0xc3, 0x58, 0x2b, 0x2c, 0x9c, 0x85, 0x0e, 0x1f, 0x01, 0xd0, 0x30, 0x0c,
	0xc2, 0xd1, 0x38, 0x98, 0x2c, 0x8a, 0xda, 0x4c, 0x0f, 0xbf, 0x50, 0xcb, 0x6a, 0xca, 0x92, 0xa9,
	0x05, 0x13, 0x8a, 0x37, 0xa1, 0x38, 0xa1, 0xdc, 0xf5, 0xa6, 0xf1, 0x56, 0xc6, 0x52, 0xe3, 0x09,
	0x54, 0x53, 0x49, 0xe2, 0x12, 0xe4, 0xcd, 0x9e, 0xe9, 0xa0, 0x8c, 0x78, 0x75, 0x86, 0x96, 0x85,
	0x94, 0x08, 0xd3, 0x08, 0xca, 0x36, 0x7e, 0x53, 0x60, 0x7b, 0x38, 0x9f, 0xdc, 0x71, 0x40, 0x1f,
	0x42, 0x41, 0x4e, 0x4d, 0x3c, 0x42, 0x91, 0x70, 0x8f, 0xc3, 0x59, 0xb8, 0xcf, 0x74, 0x88, 0x89,
	0xbf, 0x2d, 0x95, 0x78, 0xe2, 0x5f, 0xc0, 0x96, 0xe5, 0x31, 0x7e, 0xef, 0x69, 0x6f, 0xf4, 0xa1,
	0xfe, 0xa1, 0x61, 0x3c, 0xcc, 0x2d, 0x51, 0x20, 0xbb, 0x60, 0x75, 0x45, 0x1e, 0x83, 0xbb, 0x87,
	0xc9, 0xf4, 0xcf, 0x03, 0x12, 0x71, 0x1b, 0xbf, 0x2a, 0x80, 0x56, 0x75, 0x1f, 0xf1, 0xad, 0xf9,
	0x88, 0x99, 0xfe, 0x4b, 0x81, 0x4a, 0xe2, 0x34, 0x8a, 0x6b, 0x3b, 0x96, 0xaf, 0x44, 0x16, 0x09,
	0x04, 0x9f, 0x02, 0xf0, 0xe5, 0x17, 0x21, 0xfe, 0x60, 0xec, 0xdf, 0x75, 0x68, 0x0f, 0x97, 0x77,
	0x36, 0x3e, 0xa1, 0x09, 0xdb, 0x46, 0x37, 0x71, 0xb7, 0x23, 0x08, 0x03, 0x14, 0x49, 0x47, 0x3b,
	0x6e, 0x36, 0x91, 0xb2, 0x78, 0x1f, 0x7d, 0x87, 0xb2, 0xb8, 0x02, 0x6b, 0xa4, 0xa3, 0x3d, 0x7d,
	0xda, 0x6c, 0xa1, 0x5c, 0x2c, 0xb4, 0x5a, 0xad, 0x13, 0x94, 0x17, 0x63, 0x38, 0xf4, 0xbd, 0x2b,
	0x54, 0x68, 0xfc, 0x99, 0x83, 0x6a, 0xea, 0xf6, 0xfe, 0x6f, 0x29, 0x5f, 0x41, 0x35, 0x60, 0x4c,
	0xbb, 0xa1, 0x44, 0x6d, 0x4d, 0x83, 0xf8, 0x05, 0xe4, 0xf9, 0x4d, 0x5f, 0xbf, 0xbc, 0xfb, 0xd6,
	0x1f, 0xea, 0x2e, 0x77, 0x65, 0x77, 0xa5, 0x01, 0x7e, 0x02, 0x45, 0xea, 0xcb, 0x8d, 0x8c, 0x3e,
	0xe1, 0x8f, 0xd2, 0x5d, 0x12, 0x2a, 0xcf, 0x7f, 0x43, 0x62, 0x92, 0xc8, 0x56, 0x98, 0x19, 0x57,
	0x9c, 0xfa, 0x93, 0xf8, 0x3b, 0x98, 0x40, 0x1a, 0xff, 0x2a, 0x50, 0x5a, 0x44, 0x10, 0x65, 0xb7,
	0xfb, 0x7d, 0x0b, 0x65, 0x70, 0x19, 0x0a, 0x66, 0xcf, 0x79, 0xfe, 0x2c, 0x5a, 0xc9, 0xa1, 0xd3,
	0x39, 0x46, 0x59, 0xd1, 0x3b, 0xbd, 0x3f, 0x6c, 0x5b, 0x06, 0xca, 0x09, 0x54, 0x57, 0x1d, 0x03,
	0xe5, 0x45, 0xe3, 0x74, 0x43, 0x33, 0xbb, 0xaa, 0x85, 0x0a, 0x78, 0x03, 0x2a, 0x8e, 0xd9, 0x35,
	0x46, 0x5d, 0xd3, 0xb2, 0x4c, 0x1b, 0x15, 0x13, 0x80, 0x46, 0xfa, 0x36, 0x5a, 0xc3, 0x0f, 0x01,
	0x09, 0xc0, 0x76, 0xd4, 0xee, 0x60, 0x41, 0x2b, 0xad, 0xa2, 0x92, 0x5b, 0x16, 0x41, 0x2c, 0xd3,
	0x76, 0x10, 0xe0, 0x35, 0xc8, 0x75, 0xd5, 0x01, 0xaa, 0xe0, 0x75, 0x28, 0x99, 0x3d, 0xc7, 0x20,
	0xaf, 0x54, 0x0b, 0xad, 0x8b, 0x34, 0x3b, 0x56, 0x5f, 0x75, 0x50, 0x35, 0xce, 0xb8, 0xd5, 0x44,
	0xb5, 0xf8, 0x79, 0xf2, 0x1c, 0x6d, 0x1c, 0xb4, 0xd2, 0x0b, 0xb1, 0xac, 0x52, 0xb5, 0x0d, 0x94,
	0x11, 0x5e, 0xcd, 0x9e, 0x86, 0x14, 0xe1, 0x55, 0x40, 0x23, 0x21, 0x65, 0x0f, 0x1e, 0x41, 0x31,
	0x9e, 0x9c, 0x0a, 0xac, 0xc5, 0x3f, 0x06, 0xca, 0x1c, 0xfc, 0x02, 0xa5, 0x45, 0x7b, 0x45, 0x88,
	0x81, 0xa5, 0x9a, 0x3d, 0x94, 0x11, 0xa9, 0xcb, 0xe7, 0x48, 0x37, 0x35, 0xc7, 0xec, 0xf7, 0x54,
	0x72, 0x86, 0x14, 0xbc, 0x05, 0x0f, 0x74, 0xc3, 0x72, 0xd4, 0x51, 0xdb, 0x14, 0xc8, 0x68, 0xa0,
	0x6a, 0x2f, 0x0d, 0x1d, 0x65, 0x05, 0x3d, 0x56, 0x9c, 0x39, 0xc6, 0x48, 0x25, 0x44, 0x3d, 0x43,
	0x39, 0xfc, 0x18, 0xb6, 0x22, 0xd4, 0x32, 0x7a, 0x3f, 0x3a, 0xa7, 0x49, 0x65, 0xfe, 0xe0, 0x0b,
	0xa8, 0xa6, 0xfe, 0x2e, 0x61, 0x04, 0xeb, 0x67, 0x7a, 0x77, 0x29, 0xa3, 0xcc, 0xc1, 0x11, 0x94,
	0x97, 0xc7, 0x58, 0xa8, 0x87, 0x3d, 0x75, 0xe8, 0x9c, 0xf6, 0x89, 0xf9, 0xb3, 0xa1, 0x23, 0x05,
	0x6f, 0x02, 0x36, 0x7b, 0xaf, 0x54, 0xcb, 0xd4, 0x47, 0x7d, 0xdb, 0x1e, 0xb5, 0x87, 0xda, 0x4b,
	0xc3, 0x41, 0xd9, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0xf9, 0xbd, 0x43, 0x43, 0xc3, 0x0a, 0x00,
	0x00,
}
