diff --git a/common_spec_types.go b/common_spec_types.go index fa91f0d..a48127b 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