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