onyx.protocol.task-state — org.onyxplatform/onyx 0.14.6

PTaskStateMachine clj/s protocol

update-event! clj/s

(update-event! this f)

get-input-pipeline clj/s

(get-input-pipeline this)

next-epoch! clj/s

(next-epoch! this)

process-watermark! clj/s

(process-watermark! this watermark)

set-epoch! clj/s

(set-epoch! this epoch)

heartbeat! clj/s

(heartbeat! this)

get-output-pipeline clj/s

(get-output-pipeline this)

get-event clj/s

(get-event this)

advanced? clj/s

(advanced? this)

set-event! clj/s

(set-event! this new-event)

goto-recover! clj/s

(goto-recover! this)

advance clj/s

(advance this)

next-cycle! clj/s

(next-cycle! this)

log-state clj/s

(log-state this)

epoch clj/s

(epoch this)

set-min-epoch! clj/s

(set-min-epoch! this min-epoch)

set-context! clj/s

(set-context! this new-context)

replica-version clj/s

(replica-version this)

initial-sync-backoff clj/s

(initial-sync-backoff this)

watermark-flag? clj/s

(watermark-flag? this)

exec clj/s

(exec this)

get-coordinator clj/s

(get-coordinator this)

set-watermark-flag! clj/s

(set-watermark-flag! this flag)

min-epoch clj/s

(min-epoch this)

seal-checkpoints! clj/s

(seal-checkpoints! this)

(seal-checkpoints! this replica-version epoch)

set-messenger! clj/s

(set-messenger! this new-messenger)

start clj/s

(start this)

next-replica! clj/s

(next-replica! this replica)

set-coordinator! clj/s

(set-coordinator! this new-coordinator)

get-replica clj/s

(get-replica this)

get-context clj/s

(get-context this)

get-messenger clj/s

(get-messenger this)

get-state-store clj/s

(get-state-store this)

set-replica! clj/s

(set-replica! this new-replica)

get-watermark clj/s

(get-watermark this)

set-windows-state! clj/s

(set-windows-state! this new-windows-state)

killed? clj/s

(killed? this)

stop clj/s

(stop this scheduler-event)

sealed? clj/s

(sealed? this)

goto-next-iteration! clj/s

(goto-next-iteration! this)

set-sealed! clj/s

(set-sealed! this new-sealed?)

goto-next-batch! clj/s

(goto-next-batch! this)

set-state-store! clj/s

(set-state-store! this state-store)

new-iteration? clj/s

(new-iteration? this)

evict-peer! clj/s

(evict-peer! this peer-id)

get-windows-state clj/s

(get-windows-state this)

reset-event! clj/s

(reset-event! this)

get-lifecycle clj/s

(get-lifecycle this)