onyx.peer.resume-point — org.onyxplatform/onyx 0.14.5-SNAPSHOT

coordinates->input-resume-point clj

(coordinates->input-resume-point {:keys [onyx.core/task-id onyx.core/job-id
                                         onyx.core/resume-point
                                         onyx.core/tenancy-id]
                                  :as event}
                                 latest-coordinates)

coordinates->output-resume-point clj

(coordinates->output-resume-point {:keys [onyx.core/task-id onyx.core/job-id
                                          onyx.core/resume-point
                                          onyx.core/tenancy-id]
                                   :as event}
                                  latest-coordinates)

coordinates->windows-resume-point clj

(coordinates->windows-resume-point
  {:keys [onyx.core/windows onyx.core/task-id onyx.core/job-id
          onyx.core/resume-point onyx.core/tenancy-id]
   :as event}
  latest-coordinates)

read-checkpoint clj

(read-checkpoint {:keys [onyx.core/storage onyx.core/monitoring] :as event}
                 checkpoint-type
                 {:keys [tenancy-id job-id task-id replica-version epoch]
                  :as coordinates}
                 slot-id)

recover-input clj

(recover-input {:keys [onyx.core/slot-id] :as event} recover-coordinates)

recover-output clj

(recover-output event recover-coordinates)

recover-windows clj

(recover-windows {:keys [onyx.core/windows onyx.core/triggers onyx.core/task-id
                         onyx.core/slot-id onyx.core/task-map]
                  :as event}
                 state-store
                 recover-coordinates)

resume-point->coordinates clj

(resume-point->coordinates resume-point)

state-reindex clj

(state-reindex old-state-indices new-state-indices)

windows-to-fetch clj

(windows-to-fetch {:keys [onyx.core/slot-id] :as event} resume-point task-id)