From 57aaf3a55102ae86ea963dbabe11c4c24136ee9b Mon Sep 17 00:00:00 2001 From: vzaytsev Date: Tue, 2 Jan 2024 16:05:02 -0500 Subject: [PATCH 1/2] add fields for druid input source --- common_spec_types.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/common_spec_types.go b/common_spec_types.go index fa91f0d..dd5618e 100644 --- a/common_spec_types.go +++ b/common_spec_types.go @@ -332,6 +332,12 @@ type InputSource struct { // SqlInputSource. SQLs []string `json:"sqls,omitempty"` Database *Database `json:"database,omitempty"` + + // Druid input source + Datasource string `json:"dataSource,omitempty"` + // ISO-8601 interval, which defines the time range to fetch the data over. + Interval string `json:"interval,omitempty"` + Metrics []string `json:"metrics,omitempty"` } // TransformSpec is responsible for transforming druid input data From fe28ed65334bb2e2253f7935d6d18440e3a85580 Mon Sep 17 00:00:00 2001 From: Victor Zaytsev <94850767+vzaytsev1981@users.noreply.github.com> Date: Wed, 3 Jan 2024 08:00:27 -0500 Subject: [PATCH 2/2] Update common_spec_types.go MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Luboš Pokorný --- common_spec_types.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common_spec_types.go b/common_spec_types.go index dd5618e..a48127b 100644 --- a/common_spec_types.go +++ b/common_spec_types.go @@ -333,7 +333,7 @@ type InputSource struct { SQLs []string `json:"sqls,omitempty"` Database *Database `json:"database,omitempty"` - // Druid input source + // Druid input source. Datasource string `json:"dataSource,omitempty"` // ISO-8601 interval, which defines the time range to fetch the data over. Interval string `json:"interval,omitempty"`