feat: add interval column type (#74)

* feat: add interval column type

* chore: add empty line
This commit is contained in:
Zou Wei
2023-08-03 11:50:19 +08:00
committed by GitHub
parent eeae2d0dfa
commit 940694cfd0
10 changed files with 2557 additions and 127 deletions
+168 -47
View File
@@ -127,40 +127,106 @@ func (x *Column) GetDatatype() ColumnDataType {
return ColumnDataType_BOOLEAN
}
type IntervalMonthDayNano struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Months int32 `protobuf:"varint,1,opt,name=months,proto3" json:"months,omitempty"`
Days int32 `protobuf:"varint,2,opt,name=days,proto3" json:"days,omitempty"`
Nanoseconds int64 `protobuf:"varint,3,opt,name=nanoseconds,proto3" json:"nanoseconds,omitempty"`
}
func (x *IntervalMonthDayNano) Reset() {
*x = IntervalMonthDayNano{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_column_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *IntervalMonthDayNano) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*IntervalMonthDayNano) ProtoMessage() {}
func (x *IntervalMonthDayNano) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_column_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)
}
// Deprecated: Use IntervalMonthDayNano.ProtoReflect.Descriptor instead.
func (*IntervalMonthDayNano) Descriptor() ([]byte, []int) {
return file_greptime_v1_column_proto_rawDescGZIP(), []int{1}
}
func (x *IntervalMonthDayNano) GetMonths() int32 {
if x != nil {
return x.Months
}
return 0
}
func (x *IntervalMonthDayNano) GetDays() int32 {
if x != nil {
return x.Days
}
return 0
}
func (x *IntervalMonthDayNano) GetNanoseconds() int64 {
if x != nil {
return x.Nanoseconds
}
return 0
}
type Column_Values struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
I8Values []int32 `protobuf:"varint,1,rep,packed,name=i8_values,json=i8Values,proto3" json:"i8_values,omitempty"`
I16Values []int32 `protobuf:"varint,2,rep,packed,name=i16_values,json=i16Values,proto3" json:"i16_values,omitempty"`
I32Values []int32 `protobuf:"varint,3,rep,packed,name=i32_values,json=i32Values,proto3" json:"i32_values,omitempty"`
I64Values []int64 `protobuf:"varint,4,rep,packed,name=i64_values,json=i64Values,proto3" json:"i64_values,omitempty"`
U8Values []uint32 `protobuf:"varint,5,rep,packed,name=u8_values,json=u8Values,proto3" json:"u8_values,omitempty"`
U16Values []uint32 `protobuf:"varint,6,rep,packed,name=u16_values,json=u16Values,proto3" json:"u16_values,omitempty"`
U32Values []uint32 `protobuf:"varint,7,rep,packed,name=u32_values,json=u32Values,proto3" json:"u32_values,omitempty"`
U64Values []uint64 `protobuf:"varint,8,rep,packed,name=u64_values,json=u64Values,proto3" json:"u64_values,omitempty"`
F32Values []float32 `protobuf:"fixed32,9,rep,packed,name=f32_values,json=f32Values,proto3" json:"f32_values,omitempty"`
F64Values []float64 `protobuf:"fixed64,10,rep,packed,name=f64_values,json=f64Values,proto3" json:"f64_values,omitempty"`
BoolValues []bool `protobuf:"varint,11,rep,packed,name=bool_values,json=boolValues,proto3" json:"bool_values,omitempty"`
BinaryValues [][]byte `protobuf:"bytes,12,rep,name=binary_values,json=binaryValues,proto3" json:"binary_values,omitempty"`
StringValues []string `protobuf:"bytes,13,rep,name=string_values,json=stringValues,proto3" json:"string_values,omitempty"`
DateValues []int32 `protobuf:"varint,14,rep,packed,name=date_values,json=dateValues,proto3" json:"date_values,omitempty"`
DatetimeValues []int64 `protobuf:"varint,15,rep,packed,name=datetime_values,json=datetimeValues,proto3" json:"datetime_values,omitempty"`
TsSecondValues []int64 `protobuf:"varint,16,rep,packed,name=ts_second_values,json=tsSecondValues,proto3" json:"ts_second_values,omitempty"`
TsMillisecondValues []int64 `protobuf:"varint,17,rep,packed,name=ts_millisecond_values,json=tsMillisecondValues,proto3" json:"ts_millisecond_values,omitempty"`
TsMicrosecondValues []int64 `protobuf:"varint,18,rep,packed,name=ts_microsecond_values,json=tsMicrosecondValues,proto3" json:"ts_microsecond_values,omitempty"`
TsNanosecondValues []int64 `protobuf:"varint,19,rep,packed,name=ts_nanosecond_values,json=tsNanosecondValues,proto3" json:"ts_nanosecond_values,omitempty"`
TimeSecondValues []int64 `protobuf:"varint,20,rep,packed,name=time_second_values,json=timeSecondValues,proto3" json:"time_second_values,omitempty"`
TimeMillisecondValues []int64 `protobuf:"varint,21,rep,packed,name=time_millisecond_values,json=timeMillisecondValues,proto3" json:"time_millisecond_values,omitempty"`
TimeMicrosecondValues []int64 `protobuf:"varint,22,rep,packed,name=time_microsecond_values,json=timeMicrosecondValues,proto3" json:"time_microsecond_values,omitempty"`
TimeNanosecondValues []int64 `protobuf:"varint,23,rep,packed,name=time_nanosecond_values,json=timeNanosecondValues,proto3" json:"time_nanosecond_values,omitempty"`
I8Values []int32 `protobuf:"varint,1,rep,packed,name=i8_values,json=i8Values,proto3" json:"i8_values,omitempty"`
I16Values []int32 `protobuf:"varint,2,rep,packed,name=i16_values,json=i16Values,proto3" json:"i16_values,omitempty"`
I32Values []int32 `protobuf:"varint,3,rep,packed,name=i32_values,json=i32Values,proto3" json:"i32_values,omitempty"`
I64Values []int64 `protobuf:"varint,4,rep,packed,name=i64_values,json=i64Values,proto3" json:"i64_values,omitempty"`
U8Values []uint32 `protobuf:"varint,5,rep,packed,name=u8_values,json=u8Values,proto3" json:"u8_values,omitempty"`
U16Values []uint32 `protobuf:"varint,6,rep,packed,name=u16_values,json=u16Values,proto3" json:"u16_values,omitempty"`
U32Values []uint32 `protobuf:"varint,7,rep,packed,name=u32_values,json=u32Values,proto3" json:"u32_values,omitempty"`
U64Values []uint64 `protobuf:"varint,8,rep,packed,name=u64_values,json=u64Values,proto3" json:"u64_values,omitempty"`
F32Values []float32 `protobuf:"fixed32,9,rep,packed,name=f32_values,json=f32Values,proto3" json:"f32_values,omitempty"`
F64Values []float64 `protobuf:"fixed64,10,rep,packed,name=f64_values,json=f64Values,proto3" json:"f64_values,omitempty"`
BoolValues []bool `protobuf:"varint,11,rep,packed,name=bool_values,json=boolValues,proto3" json:"bool_values,omitempty"`
BinaryValues [][]byte `protobuf:"bytes,12,rep,name=binary_values,json=binaryValues,proto3" json:"binary_values,omitempty"`
StringValues []string `protobuf:"bytes,13,rep,name=string_values,json=stringValues,proto3" json:"string_values,omitempty"`
DateValues []int32 `protobuf:"varint,14,rep,packed,name=date_values,json=dateValues,proto3" json:"date_values,omitempty"`
DatetimeValues []int64 `protobuf:"varint,15,rep,packed,name=datetime_values,json=datetimeValues,proto3" json:"datetime_values,omitempty"`
TsSecondValues []int64 `protobuf:"varint,16,rep,packed,name=ts_second_values,json=tsSecondValues,proto3" json:"ts_second_values,omitempty"`
TsMillisecondValues []int64 `protobuf:"varint,17,rep,packed,name=ts_millisecond_values,json=tsMillisecondValues,proto3" json:"ts_millisecond_values,omitempty"`
TsMicrosecondValues []int64 `protobuf:"varint,18,rep,packed,name=ts_microsecond_values,json=tsMicrosecondValues,proto3" json:"ts_microsecond_values,omitempty"`
TsNanosecondValues []int64 `protobuf:"varint,19,rep,packed,name=ts_nanosecond_values,json=tsNanosecondValues,proto3" json:"ts_nanosecond_values,omitempty"`
TimeSecondValues []int64 `protobuf:"varint,20,rep,packed,name=time_second_values,json=timeSecondValues,proto3" json:"time_second_values,omitempty"`
TimeMillisecondValues []int64 `protobuf:"varint,21,rep,packed,name=time_millisecond_values,json=timeMillisecondValues,proto3" json:"time_millisecond_values,omitempty"`
TimeMicrosecondValues []int64 `protobuf:"varint,22,rep,packed,name=time_microsecond_values,json=timeMicrosecondValues,proto3" json:"time_microsecond_values,omitempty"`
TimeNanosecondValues []int64 `protobuf:"varint,23,rep,packed,name=time_nanosecond_values,json=timeNanosecondValues,proto3" json:"time_nanosecond_values,omitempty"`
IntervalYearMonthValues []int32 `protobuf:"varint,24,rep,packed,name=interval_year_month_values,json=intervalYearMonthValues,proto3" json:"interval_year_month_values,omitempty"`
IntervalDayTimeValues []int64 `protobuf:"varint,25,rep,packed,name=interval_day_time_values,json=intervalDayTimeValues,proto3" json:"interval_day_time_values,omitempty"`
IntervalMonthDayNanoValues []*IntervalMonthDayNano `protobuf:"bytes,26,rep,name=interval_month_day_nano_values,json=intervalMonthDayNanoValues,proto3" json:"interval_month_day_nano_values,omitempty"`
}
func (x *Column_Values) Reset() {
*x = Column_Values{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_column_proto_msgTypes[1]
mi := &file_greptime_v1_column_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -173,7 +239,7 @@ func (x *Column_Values) String() string {
func (*Column_Values) ProtoMessage() {}
func (x *Column_Values) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_column_proto_msgTypes[1]
mi := &file_greptime_v1_column_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -350,6 +416,27 @@ func (x *Column_Values) GetTimeNanosecondValues() []int64 {
return nil
}
func (x *Column_Values) GetIntervalYearMonthValues() []int32 {
if x != nil {
return x.IntervalYearMonthValues
}
return nil
}
func (x *Column_Values) GetIntervalDayTimeValues() []int64 {
if x != nil {
return x.IntervalDayTimeValues
}
return nil
}
func (x *Column_Values) GetIntervalMonthDayNanoValues() []*IntervalMonthDayNano {
if x != nil {
return x.IntervalMonthDayNanoValues
}
return nil
}
var File_greptime_v1_column_proto protoreflect.FileDescriptor
var file_greptime_v1_column_proto_rawDesc = []byte{
@@ -357,7 +444,7 @@ var file_greptime_v1_column_proto_rawDesc = []byte{
0x6c, 0x75, 0x6d, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0b, 0x67, 0x72, 0x65, 0x70,
0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x18, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2f, 0x76, 0x31, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x22, 0xfd, 0x08, 0x0a, 0x06, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x1f, 0x0a, 0x0b,
0x6f, 0x22, 0xda, 0x0a, 0x0a, 0x06, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x1f, 0x0a, 0x0b,
0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x3e, 0x0a,
0x0d, 0x73, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02,
@@ -372,7 +459,7 @@ var file_greptime_v1_column_proto_rawDesc = []byte{
0x0a, 0x08, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e,
0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43,
0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x52, 0x08, 0x64,
0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x1a, 0x87, 0x07, 0x0a, 0x06, 0x56, 0x61, 0x6c, 0x75,
0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x1a, 0xe4, 0x08, 0x0a, 0x06, 0x56, 0x61, 0x6c, 0x75,
0x65, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x69, 0x38, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18,
0x01, 0x20, 0x03, 0x28, 0x05, 0x52, 0x08, 0x69, 0x38, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12,
0x1d, 0x0a, 0x0a, 0x69, 0x31, 0x36, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x02, 0x20,
@@ -429,12 +516,32 @@ var file_greptime_v1_column_proto_rawDesc = []byte{
0x69, 0x6d, 0x65, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x5f, 0x76,
0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x17, 0x20, 0x03, 0x28, 0x03, 0x52, 0x14, 0x74, 0x69, 0x6d,
0x65, 0x4e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65,
0x73, 0x42, 0x50, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65,
0x2e, 0x76, 0x31, 0x42, 0x07, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x5a, 0x35, 0x67, 0x69,
0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65,
0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x73, 0x12, 0x3b, 0x0a, 0x1a, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x5f, 0x79, 0x65,
0x61, 0x72, 0x5f, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18,
0x18, 0x20, 0x03, 0x28, 0x05, 0x52, 0x17, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x59,
0x65, 0x61, 0x72, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x37,
0x0a, 0x18, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x5f, 0x64, 0x61, 0x79, 0x5f, 0x74,
0x69, 0x6d, 0x65, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x19, 0x20, 0x03, 0x28, 0x03,
0x52, 0x15, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x44, 0x61, 0x79, 0x54, 0x69, 0x6d,
0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x12, 0x65, 0x0a, 0x1e, 0x69, 0x6e, 0x74, 0x65, 0x72,
0x76, 0x61, 0x6c, 0x5f, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x5f, 0x64, 0x61, 0x79, 0x5f, 0x6e, 0x61,
0x6e, 0x6f, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x1a, 0x20, 0x03, 0x28, 0x0b, 0x32,
0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x49, 0x6e,
0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x44, 0x61, 0x79, 0x4e, 0x61,
0x6e, 0x6f, 0x52, 0x1a, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x4d, 0x6f, 0x6e, 0x74,
0x68, 0x44, 0x61, 0x79, 0x4e, 0x61, 0x6e, 0x6f, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x22, 0x64,
0x0a, 0x14, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x44,
0x61, 0x79, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73,
0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73, 0x12, 0x12,
0x0a, 0x04, 0x64, 0x61, 0x79, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x64, 0x61,
0x79, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64,
0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63,
0x6f, 0x6e, 0x64, 0x73, 0x42, 0x50, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x07, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x5a,
0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70,
0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74,
0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
@@ -449,22 +556,24 @@ func file_greptime_v1_column_proto_rawDescGZIP() []byte {
return file_greptime_v1_column_proto_rawDescData
}
var file_greptime_v1_column_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
var file_greptime_v1_column_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
var file_greptime_v1_column_proto_goTypes = []interface{}{
(*Column)(nil), // 0: greptime.v1.Column
(*Column_Values)(nil), // 1: greptime.v1.Column.Values
(SemanticType)(0), // 2: greptime.v1.SemanticType
(ColumnDataType)(0), // 3: greptime.v1.ColumnDataType
(*Column)(nil), // 0: greptime.v1.Column
(*IntervalMonthDayNano)(nil), // 1: greptime.v1.IntervalMonthDayNano
(*Column_Values)(nil), // 2: greptime.v1.Column.Values
(SemanticType)(0), // 3: greptime.v1.SemanticType
(ColumnDataType)(0), // 4: greptime.v1.ColumnDataType
}
var file_greptime_v1_column_proto_depIdxs = []int32{
2, // 0: greptime.v1.Column.semantic_type:type_name -> greptime.v1.SemanticType
1, // 1: greptime.v1.Column.values:type_name -> greptime.v1.Column.Values
3, // 2: greptime.v1.Column.datatype:type_name -> greptime.v1.ColumnDataType
3, // [3:3] is the sub-list for method output_type
3, // [3:3] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
3, // 0: greptime.v1.Column.semantic_type:type_name -> greptime.v1.SemanticType
2, // 1: greptime.v1.Column.values:type_name -> greptime.v1.Column.Values
4, // 2: greptime.v1.Column.datatype:type_name -> greptime.v1.ColumnDataType
1, // 3: greptime.v1.Column.Values.interval_month_day_nano_values:type_name -> greptime.v1.IntervalMonthDayNano
4, // [4:4] is the sub-list for method output_type
4, // [4:4] is the sub-list for method input_type
4, // [4:4] is the sub-list for extension type_name
4, // [4:4] is the sub-list for extension extendee
0, // [0:4] is the sub-list for field type_name
}
func init() { file_greptime_v1_column_proto_init() }
@@ -487,6 +596,18 @@ func file_greptime_v1_column_proto_init() {
}
}
file_greptime_v1_column_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*IntervalMonthDayNano); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_greptime_v1_column_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Column_Values); i {
case 0:
return &v.state
@@ -505,7 +626,7 @@ func file_greptime_v1_column_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_greptime_v1_column_proto_rawDesc,
NumEnums: 0,
NumMessages: 2,
NumMessages: 3,
NumExtensions: 0,
NumServices: 0,
},
+67 -53
View File
@@ -86,29 +86,32 @@ func (SemanticType) EnumDescriptor() ([]byte, []int) {
type ColumnDataType int32
const (
ColumnDataType_BOOLEAN ColumnDataType = 0
ColumnDataType_INT8 ColumnDataType = 1
ColumnDataType_INT16 ColumnDataType = 2
ColumnDataType_INT32 ColumnDataType = 3
ColumnDataType_INT64 ColumnDataType = 4
ColumnDataType_UINT8 ColumnDataType = 5
ColumnDataType_UINT16 ColumnDataType = 6
ColumnDataType_UINT32 ColumnDataType = 7
ColumnDataType_UINT64 ColumnDataType = 8
ColumnDataType_FLOAT32 ColumnDataType = 9
ColumnDataType_FLOAT64 ColumnDataType = 10
ColumnDataType_BINARY ColumnDataType = 11
ColumnDataType_STRING ColumnDataType = 12
ColumnDataType_DATE ColumnDataType = 13
ColumnDataType_DATETIME ColumnDataType = 14
ColumnDataType_TIMESTAMP_SECOND ColumnDataType = 15
ColumnDataType_TIMESTAMP_MILLISECOND ColumnDataType = 16
ColumnDataType_TIMESTAMP_MICROSECOND ColumnDataType = 17
ColumnDataType_TIMESTAMP_NANOSECOND ColumnDataType = 18
ColumnDataType_TIME_SECOND ColumnDataType = 19
ColumnDataType_TIME_MILLISECOND ColumnDataType = 20
ColumnDataType_TIME_MICROSECOND ColumnDataType = 21
ColumnDataType_TIME_NANOSECOND ColumnDataType = 22
ColumnDataType_BOOLEAN ColumnDataType = 0
ColumnDataType_INT8 ColumnDataType = 1
ColumnDataType_INT16 ColumnDataType = 2
ColumnDataType_INT32 ColumnDataType = 3
ColumnDataType_INT64 ColumnDataType = 4
ColumnDataType_UINT8 ColumnDataType = 5
ColumnDataType_UINT16 ColumnDataType = 6
ColumnDataType_UINT32 ColumnDataType = 7
ColumnDataType_UINT64 ColumnDataType = 8
ColumnDataType_FLOAT32 ColumnDataType = 9
ColumnDataType_FLOAT64 ColumnDataType = 10
ColumnDataType_BINARY ColumnDataType = 11
ColumnDataType_STRING ColumnDataType = 12
ColumnDataType_DATE ColumnDataType = 13
ColumnDataType_DATETIME ColumnDataType = 14
ColumnDataType_TIMESTAMP_SECOND ColumnDataType = 15
ColumnDataType_TIMESTAMP_MILLISECOND ColumnDataType = 16
ColumnDataType_TIMESTAMP_MICROSECOND ColumnDataType = 17
ColumnDataType_TIMESTAMP_NANOSECOND ColumnDataType = 18
ColumnDataType_TIME_SECOND ColumnDataType = 19
ColumnDataType_TIME_MILLISECOND ColumnDataType = 20
ColumnDataType_TIME_MICROSECOND ColumnDataType = 21
ColumnDataType_TIME_NANOSECOND ColumnDataType = 22
ColumnDataType_INTERVAL_YEAR_MONTH ColumnDataType = 23
ColumnDataType_INTERVAL_DAY_TIME ColumnDataType = 24
ColumnDataType_INTERVAL_MONTH_DAY_NANO ColumnDataType = 25
)
// Enum value maps for ColumnDataType.
@@ -137,31 +140,37 @@ var (
20: "TIME_MILLISECOND",
21: "TIME_MICROSECOND",
22: "TIME_NANOSECOND",
23: "INTERVAL_YEAR_MONTH",
24: "INTERVAL_DAY_TIME",
25: "INTERVAL_MONTH_DAY_NANO",
}
ColumnDataType_value = map[string]int32{
"BOOLEAN": 0,
"INT8": 1,
"INT16": 2,
"INT32": 3,
"INT64": 4,
"UINT8": 5,
"UINT16": 6,
"UINT32": 7,
"UINT64": 8,
"FLOAT32": 9,
"FLOAT64": 10,
"BINARY": 11,
"STRING": 12,
"DATE": 13,
"DATETIME": 14,
"TIMESTAMP_SECOND": 15,
"TIMESTAMP_MILLISECOND": 16,
"TIMESTAMP_MICROSECOND": 17,
"TIMESTAMP_NANOSECOND": 18,
"TIME_SECOND": 19,
"TIME_MILLISECOND": 20,
"TIME_MICROSECOND": 21,
"TIME_NANOSECOND": 22,
"BOOLEAN": 0,
"INT8": 1,
"INT16": 2,
"INT32": 3,
"INT64": 4,
"UINT8": 5,
"UINT16": 6,
"UINT32": 7,
"UINT64": 8,
"FLOAT32": 9,
"FLOAT64": 10,
"BINARY": 11,
"STRING": 12,
"DATE": 13,
"DATETIME": 14,
"TIMESTAMP_SECOND": 15,
"TIMESTAMP_MILLISECOND": 16,
"TIMESTAMP_MICROSECOND": 17,
"TIMESTAMP_NANOSECOND": 18,
"TIME_SECOND": 19,
"TIME_MILLISECOND": 20,
"TIME_MICROSECOND": 21,
"TIME_NANOSECOND": 22,
"INTERVAL_YEAR_MONTH": 23,
"INTERVAL_DAY_TIME": 24,
"INTERVAL_MONTH_DAY_NANO": 25,
}
)
@@ -799,7 +808,7 @@ var file_greptime_v1_common_proto_rawDesc = []byte{
0x61, 0x69, 0x6e, 0x74, 0x2a, 0x31, 0x0a, 0x0c, 0x53, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63,
0x54, 0x79, 0x70, 0x65, 0x12, 0x07, 0x0a, 0x03, 0x54, 0x41, 0x47, 0x10, 0x00, 0x12, 0x09, 0x0a,
0x05, 0x46, 0x49, 0x45, 0x4c, 0x44, 0x10, 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x54, 0x49, 0x4d, 0x45,
0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x02, 0x2a, 0xf9, 0x02, 0x0a, 0x0e, 0x43, 0x6f, 0x6c, 0x75,
0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x02, 0x2a, 0xc6, 0x03, 0x0a, 0x0e, 0x43, 0x6f, 0x6c, 0x75,
0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x42, 0x4f,
0x4f, 0x4c, 0x45, 0x41, 0x4e, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x49, 0x4e, 0x54, 0x38, 0x10,
0x01, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x31, 0x36, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05,
@@ -823,12 +832,17 @@ var file_greptime_v1_common_proto_rawDesc = []byte{
0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x14, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x49, 0x4d, 0x45,
0x5f, 0x4d, 0x49, 0x43, 0x52, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x15, 0x12, 0x13,
0x0a, 0x0f, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e,
0x44, 0x10, 0x16, 0x42, 0x4f, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x06, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x5a, 0x35, 0x67,
0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x44, 0x10, 0x16, 0x12, 0x17, 0x0a, 0x13, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f,
0x59, 0x45, 0x41, 0x52, 0x5f, 0x4d, 0x4f, 0x4e, 0x54, 0x48, 0x10, 0x17, 0x12, 0x15, 0x0a, 0x11,
0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f, 0x44, 0x41, 0x59, 0x5f, 0x54, 0x49, 0x4d,
0x45, 0x10, 0x18, 0x12, 0x1b, 0x0a, 0x17, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f,
0x4d, 0x4f, 0x4e, 0x54, 0x48, 0x5f, 0x44, 0x41, 0x59, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x10, 0x19,
0x42, 0x4f, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
0x76, 0x31, 0x42, 0x06, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68,
0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54,
0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76,
0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (