feat: add substrait extension (#36)

* feat: add substrait extension Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * fix typo Signed-off-by: Ruihang Xia <waynestxia@gmail.com> --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
2023-05-18 14:31:14 +08:00
parent d32c9d5e98
commit e94a24873b
5 changed files with 649 additions and 0 deletions
@@ -0,0 +1,72 @@
+// Copyright 2023 Greptime Team
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+
+option go_package = "github.com/GreptimeTeam/greptime-proto/go/substrait_extension";
+
+package substrait_extension;
+
+message EmptyMetric {
+  // Start timestamp in millisecond
+  int64 start = 1;
+  // End timestamp in millisecond
+  int64 end = 2;
+  // Interval in millisecond
+  int64 interval = 3;
+}
+
+message InstantManipulate {
+  // Start timestamp in millisecond
+  int64 start = 1;
+  // End timestamp in millisecond
+  int64 end = 2;
+  // Interval in millisecond
+  int64 interval = 3;
+  // Look-back delta in millisecond
+  int64 lookback_delta = 4;
+  // Column name of time index column
+  string time_index = 5;
+  // Optional field column name for validating staleness
+  string field_index = 6;
+}
+
+message SeriesNormalize {
+  // Offset in millisecond
+  int64 offset = 1;
+  // Column name of time index column
+  string time_index = 2;
+  // Whether to filter out NaN value
+  bool filter_nan = 3;
+}
+
+message SeriesDivide {
+  // Names of tag columns
+  repeated string tag_columns = 1;
+}
+
+message RangeManipulate {
+  // Start timestamp in millisecond
+  int64 start = 1;
+  // End timestamp in millisecond
+  int64 end = 2;
+  // Interval in millisecond
+  int64 interval = 3;
+  // Range in millisecond
+  int64 range = 4;
+  // Column name of time index column
+  string time_index = 5;
+  // Names of tag columns
+  repeated string tag_columns = 6;
+}