onyx.static.validation — org.onyxplatform/onyx 0.14.6

catalog->type-task-names clj/s

(catalog->type-task-names catalog type-pred)

coerce-uuid clj/s

(coerce-uuid uuid)

find-dupes clj/s

(find-dupes coll)

fixed-windows-dont-define-slide clj/s

(fixed-windows-dont-define-slide job w)

global-windows-dont-define-range-or-slide clj/s

(global-windows-dont-define-range-or-slide job w)

helpful-validate clj/s

(helpful-validate schema value job)

min-and-max-peers-sane clj/s

(min-and-max-peers-sane job entry)

min-max-n-peers-mutually-exclusive clj/s

(min-max-n-peers-mutually-exclusive job entry)

no-duplicate-entries clj/s

(no-duplicate-entries {:keys [catalog :as job]})

print-schema-errors! clj/s

(print-schema-errors! job t)

range-and-slide-units-compatible clj/s

(range-and-slide-units-compatible job w)

session-windows-define-a-timeout clj/s

(session-windows-define-a-timeout job w)

session-windows-dont-define-range-or-slide clj/s

(session-windows-dont-define-range-or-slide job w)

session-windows-must-store-extents clj/s

(session-windows-must-store-extents job {:keys [window/storage-strategy] :as w})

sliding-windows-define-range-and-slide clj/s

(sliding-windows-define-range-and-slide job w)

trigger-id-unique-per-window clj/s

(trigger-id-unique-per-window job triggers)

trigger-names-a-window clj/s

(trigger-names-a-window window-ids t)

using-all-clause? clj/s

(using-all-clause? flow-conditions)

validate-all-position clj/s

(validate-all-position {:keys [flow-conditions]})

validate-auto-short-circuit clj/s

(validate-auto-short-circuit {:keys [flow-conditions] :as job})

validate-catalog clj/s

(validate-catalog {:keys [catalog] :as job})

validate-env-config clj/s

(validate-env-config env-config)

validate-flow-conditions clj/s

(validate-flow-conditions {:keys [flow-conditions workflow] :as job})

validate-flow-connections clj/s

(validate-flow-connections {:keys [workflow flow-conditions] :as job})

validate-flow-pred-all-kws clj/s

(validate-flow-pred-all-kws {:keys [flow-conditions] :as job})

validate-flow-structure clj/s

(validate-flow-structure {:keys [flow-conditions] :as job})

validate-java-version clj

(validate-java-version)

validate-job clj/s

(validate-job job)

validate-job-schema clj/s

(validate-job-schema job)

validate-lifecycle-calls clj/s

(validate-lifecycle-calls m)

validate-lifecycles clj/s

(validate-lifecycles {:keys [lifecycles catalog] :as job})

validate-none-position clj/s

(validate-none-position {:keys [flow-conditions]})

validate-peer-client-config clj/s

(validate-peer-client-config peer-client-config)

validate-peer-config clj/s

(validate-peer-config peer-config)

validate-refinement-calls clj/s

(validate-refinement-calls m)

validate-resume-point clj/s

(validate-resume-point {:keys [workflow catalog windows resume-point] :as job})

validate-short-circuit clj/s

(validate-short-circuit {:keys [flow-conditions]})

validate-state-aggregation-calls clj/s

(validate-state-aggregation-calls m)

validate-trigger-calls clj/s

(validate-trigger-calls m)

validate-triggers clj/s

(validate-triggers {:keys [windows triggers catalog] :as job})

validate-windows clj/s

(validate-windows {:keys [windows catalog] :as job})

validate-workflow clj/s

(validate-workflow job)

validate-workflow-graph clj/s

(validate-workflow-graph {:keys [catalog workflow] :as job})

validate-workflow-inputs clj/s

(validate-workflow-inputs g input-tasks)

validate-workflow-intermediates clj/s

(validate-workflow-intermediates workflow g intermediate-tasks)

validate-workflow-names clj/s

(validate-workflow-names {:keys [workflow catalog]})

validate-workflow-no-dupes clj/s

(validate-workflow-no-dupes {:keys [workflow] :as job})

validate-workflow-reducers clj/s

(validate-workflow-reducers {:keys [windows triggers]} g reduce-tasks)

window-ids-unique clj/s

(window-ids-unique {:keys [windows] :as job})

window-incremental-extents-incompatible clj/s

(window-incremental-extents-incompatible job
                                         {:keys [window/storage-strategy]
                                          :as w})

window-key-where-required clj/s

(window-key-where-required job w)

window-names-a-task clj/s

(window-names-a-task tasks {:keys [window/task] :as w})