Downgrade stl lib

project.clj

@@ -43,6 +43,7 @@
                                net.sourceforge.nekohtml/nekohtml
                                ring/ring-core]]
                  [com.draines/postal "2.0.2"]                         ; SMTP library
+                 [com.github.brandtg/stl-java "0.1.1"]                ; STL decomposition
                  [com.google.apis/google-api-services-analytics       ; Google Analytics Java Client Library
                   "v3-rev139-1.22.0"]
                  [com.google.apis/google-api-services-bigquery        ; Google BigQuery Java Client Library
@@ -87,9 +88,6 @@
                  [ring/ring-jetty-adapter "1.6.0"]                    ; Ring adapter using Jetty webserver (used to run a Ring server for unit tests)
                  [ring/ring-json "0.4.0"]                             ; Ring middleware for reading/writing JSON automatically
                  [stencil "0.5.0"]                                    ; Mustache templates for Clojure
-                 [tide "0.3.0-SNAPSHOT"                               ; Various algorithms for working with timeseries
-                  :exclusions [com.github.davidmoten/fastdtw
-                               org.slf4j/slf4j-simple]]
                  [toucan "1.0.3"                                      ; Model layer, hydration, and DB utilities
                   :exclusions [honeysql]]]
   :repositories [["bintray" "https://dl.bintray.com/crate/crate"]]    ; Repo for Crate JDBC driver

src/metabase/fingerprinting/fingerprinters.clj

@@ -13,10 +13,10 @@
             [medley.core :as m]
             [metabase.fingerprinting
              [histogram :as h]
-             [costs :as costs]]
+             [costs :as costs]
+             [stl :as stl]]
             [metabase.util :as u]            ;;;; temp!
-            [redux.core :as redux]
-            [tide.stl :as stl])
+            [redux.core :as redux])
   (:import com.clearspring.analytics.stream.cardinality.HyperLogLogPlus))
 
 (def ^:private ^:const percentiles (range 0 1 0.1))
@@ -329,10 +329,7 @@
                  :week  52
                  :day   365)]
     (when (>= (count ts) (* 2 period))
-      (select-keys (stl/decompose period {:periodic? true
-                                          :robust?   true}
-                                  ts)
-                   [:trend :seasonal :residual]))))
+      (select-keys (stl/decompose period ts) [:trend :seasonal :residual]))))
 
 (defmethod fingerprinter [DateTime Num]
   [{:keys [max-cost resolution query]} field]

src/metabase/fingerprinting/stl.clj

+(ns metabase.fingerprinting.stl
+  "Seasonal-Trend Decomposition
+  https://www.wessa.net/download/stl.pdf"
+  (:import com.github.brandtg.stl.StlDecomposition))
+
+(def ^:private setters
+  {:inner-loop-passes           (memfn setNumberOfInnerLoopPasses n)
+   :robustness-iterations       (memfn setNumberOfRobustnessIterations n)
+   :trend-bandwidth             (memfn setTrendComponentBandwidth bw)
+   :seasonal-bandwidth          (memfn setSeasonalComponentBandwidth bw)
+   :loess-robustness-iterations (memfn setLoessRobustnessIterations n)
+   :periodic?                   (memfn setPeriodic periodic?)})
+
+(defn decompose
+  "Decompose time series into trend, seasonal component, and residual."
+  ([period ts]
+   (decompose period {} ts))
+  ([period opts ts]
+   (let [xs            (map first ts)
+         ys            (map second ts)
+         preprocess    (if-let [transform (:transform opts)]
+                         (partial map transform)
+                         identity)
+         postprocess   (if-let [transform (:reverse-transform opts)]
+                         (partial map transform)
+                         vec)
+         decomposer    (StlDecomposition. period)
+         _             (reduce-kv (fn [config k v]
+                                    (when-let [setter (setters k)]
+                                      (setter config v))
+                                    config)
+                                  (.getConfig decomposer)
+                                  (merge {:inner-loop-passes 100}
+                                         opts))
+         decomposition (.decompose decomposer xs (preprocess ys))]
+     {:trend    (postprocess (.getTrend decomposition))
+      :seasonal (postprocess (.getSeasonal decomposition))
+      :residual (postprocess (.getRemainder decomposition))
+      :xs       xs
+      :ys       ys})))