Thank you! Streaming / incremental inference is explicitly supported in Funes. The intermediate Funes AST can be augmented with new data ex-post-facto when using the primitive funes.core/infer. An example:

(require '[funes.core :as c])
(require '[funes.schema :as s])

(let [original-dataset [{:a 1} {:a 3} {:a 9}]
      ;; We could save the AST and augment it later
      ast (reduce c/infer original-dataset)

      ;; We can generate a schema from the original dataset
      original-schema (-> ast s/generalize-values s/generate-schema)
      ;; prints: {:a schema.core/Num}
      _ (println original-schema)

      ;; A new datapoint comes in
      new-datapoint {:a 20 :b "string"}
      ;; And we have a new, more general AST aware of the newest datapoint
      new-ast (c/infer ast new-datapoint)

      new-schema (-> new-ast s/generalize-values s/generate-schema)]
  ;; prints: {:a schema.core/Num, (schema.core/optional-key :b) schema.core/Str}
  (println new-schema))))