public interface CheckpointIDCounter
Modifier and Type | Method and Description |
---|---|
long |
getAndIncrement()
Atomically increments the current checkpoint ID.
|
void |
setCount(long newId)
Sets the current checkpoint ID.
|
void |
shutdown(JobStatus jobStatus)
Shuts the
CheckpointIDCounter service. |
void |
start()
Starts the
CheckpointIDCounter service down. |
void start() throws Exception
CheckpointIDCounter
service down.Exception
void shutdown(JobStatus jobStatus) throws Exception
CheckpointIDCounter
service.
The job status is forwarded and used to decide whether state should actually be discarded or kept.
jobStatus
- Job state on shut downException
long getAndIncrement() throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.