(catalog->type-task-names catalog type-pred)
(coerce-uuid uuid)
(find-dupes coll)
(fixed-windows-dont-define-slide job w)
(global-windows-dont-define-range-or-slide job w)
(helpful-validate schema value job)
(min-and-max-peers-sane job entry)
(min-max-n-peers-mutually-exclusive job entry)
(no-duplicate-entries {:keys [catalog :as job]})
(print-schema-errors! job t)
(range-and-slide-units-compatible job w)
(session-windows-define-a-timeout job w)
(session-windows-dont-define-range-or-slide job w)
(session-windows-must-store-extents job {:keys [window/storage-strategy] :as w})
(sliding-windows-define-range-and-slide job w)
(trigger-id-unique-per-window job triggers)
(trigger-names-a-window window-ids t)
(using-all-clause? flow-conditions)
(validate-all-position {:keys [flow-conditions]})
(validate-auto-short-circuit {:keys [flow-conditions] :as job})
(validate-catalog {:keys [catalog] :as job})
(validate-env-config env-config)
(validate-flow-conditions {:keys [flow-conditions workflow] :as job})
(validate-flow-connections {:keys [workflow flow-conditions] :as job})
(validate-flow-pred-all-kws {:keys [flow-conditions] :as job})
(validate-flow-structure {:keys [flow-conditions] :as job})
(validate-java-version)
(validate-job job)
(validate-job-schema job)
(validate-lifecycle-calls m)
(validate-lifecycles {:keys [lifecycles catalog] :as job})
(validate-none-position {:keys [flow-conditions]})
(validate-peer-client-config peer-client-config)
(validate-peer-config peer-config)
(validate-refinement-calls m)
(validate-resume-point {:keys [workflow catalog windows resume-point] :as job})
(validate-short-circuit {:keys [flow-conditions]})
(validate-state-aggregation-calls m)
(validate-trigger-calls m)
(validate-triggers {:keys [windows triggers catalog] :as job})
(validate-windows {:keys [windows catalog] :as job})
(validate-workflow job)
(validate-workflow-graph {:keys [catalog workflow] :as job})
(validate-workflow-inputs g input-tasks)
(validate-workflow-intermediates workflow g intermediate-tasks)
(validate-workflow-names {:keys [workflow catalog]})
(validate-workflow-no-dupes {:keys [workflow] :as job})
(validate-workflow-reducers {:keys [windows triggers]} g reduce-tasks)
(window-ids-unique {:keys [windows] :as job})
(window-incremental-extents-incompatible job
{:keys [window/storage-strategy]
:as w})
(window-key-where-required job w)
(window-names-a-task tasks {:keys [window/task] :as w})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close