diff --git a/go.mod b/go.mod index 9f8a47b..837c226 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/GreptimeTeam/greptimedb-ingester-go go 1.20 require ( - github.com/GreptimeTeam/greptime-proto v0.4.3 + github.com/GreptimeTeam/greptime-proto v0.7.0 github.com/stoewer/go-strcase v1.3.0 github.com/stretchr/testify v1.8.4 google.golang.org/grpc v1.56.3 diff --git a/go.sum b/go.sum index ede9a26..a0aa005 100644 --- a/go.sum +++ b/go.sum @@ -5,6 +5,8 @@ github.com/GreptimeTeam/greptime-proto v0.4.2 h1:oX6N1v6+bYQDrh/QM+JmMHqEWjlxAVo github.com/GreptimeTeam/greptime-proto v0.4.2/go.mod h1:jk5XBR9qIbSBiDF2Gix1KALyIMCVktcpx91AayOWxmE= github.com/GreptimeTeam/greptime-proto v0.4.3 h1:qJC2j03AfP2YbfVrBBlB6t+Sd1RvMG6zKVtGUwtj7N0= github.com/GreptimeTeam/greptime-proto v0.4.3/go.mod h1:jk5XBR9qIbSBiDF2Gix1KALyIMCVktcpx91AayOWxmE= +github.com/GreptimeTeam/greptime-proto v0.7.0 h1:WHBjAu+NWDFcbZgW9kPtksxEKEAeqYemP1HY63QuO48= +github.com/GreptimeTeam/greptime-proto v0.7.0/go.mod h1:jk5XBR9qIbSBiDF2Gix1KALyIMCVktcpx91AayOWxmE= github.com/Microsoft/go-winio v0.6.0 h1:slsWYD/zyx7lCXoZVlvQrj0hPTM1HI4+v1sIda2yDvg= github.com/Microsoft/go-winio v0.6.0/go.mod h1:cTAf44im0RAYeL23bpB+fzCyDH2MJiz2BO69KH/soAE= github.com/Nvveen/Gotty v0.0.0-20120604004816-cd527374f1e5 h1:TngWCqHvy9oXAN6lEVMRuU21PR1EtLVZJmdB18Gu3Rw= diff --git a/schema/field.go b/schema/field.go index ab90848..d8c2579 100644 --- a/schema/field.go +++ b/schema/field.go @@ -250,12 +250,6 @@ func parseValue(typ gpb.ColumnDataType, val reflect.Value) (*gpb.Value, error) { gpb.ColumnDataType_INTERVAL_MONTH_DAY_NANO: return nil, fmt.Errorf("INTERVAL not implemented yet for %#v", val) - case gpb.ColumnDataType_DURATION_SECOND, - gpb.ColumnDataType_DURATION_MILLISECOND, - gpb.ColumnDataType_DURATION_MICROSECOND, - gpb.ColumnDataType_DURATION_NANOSECOND: - return nil, fmt.Errorf("DURATION not supported for %#v", val) - // TODO(yuanbohan): support decimal 128 case gpb.ColumnDataType_DECIMAL128: return nil, fmt.Errorf("DECIMAL 128 not supported for %#v", val) diff --git a/table/cell/cell.go b/table/cell/cell.go index fc6ed4e..372ae49 100644 --- a/table/cell/cell.go +++ b/table/cell/cell.go @@ -82,12 +82,6 @@ func (c Cell) Build() (*gpb.Value, error) { gpb.ColumnDataType_INTERVAL_MONTH_DAY_NANO: return nil, fmt.Errorf("INTERVAL not implemented yet for %#v", c.Val) - case gpb.ColumnDataType_DURATION_SECOND, - gpb.ColumnDataType_DURATION_MILLISECOND, - gpb.ColumnDataType_DURATION_MICROSECOND, - gpb.ColumnDataType_DURATION_NANOSECOND: - return nil, fmt.Errorf("DURATION not supported for %#v", c.Val) - // TODO(yuanbohan): support decimal 128 case gpb.ColumnDataType_DECIMAL128: return nil, fmt.Errorf("DECIMAL 128 not supported for %#v", c.Val) diff --git a/table/types/types.go b/table/types/types.go index 43df35e..fa31fb4 100644 --- a/table/types/types.go +++ b/table/types/types.go @@ -83,10 +83,6 @@ const ( // INTERVAL_YEAR_MONTH ColumnType = 23 // INTERVAL_DAY_TIME ColumnType = 24 // INTERVAL_MONTH_DAY_NANO ColumnType = 25 - // DURATION_SECOND ColumnType = 26 - // DURATION_MILLISECOND ColumnType = 27 - // DURATION_MICROSECOND ColumnType = 28 - // DURATION_NANOSECOND ColumnType = 29 // DECIMAL128 ColumnType = 30 // the following types are not from protocol buffer