public abstract class CheckpointCommitter extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected String |
jobId |
protected static org.slf4j.Logger |
LOG |
protected String |
operatorId |
protected int |
subtaskId |
Constructor and Description |
---|
CheckpointCommitter() |
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
Closes the resource/connection to it.
|
abstract void |
commitCheckpoint(long checkpointID)
Mark the given checkpoint as completed in the resource.
|
abstract void |
createResource()
Creates/opens/connects to the resource that is used to store information.
|
abstract boolean |
isCheckpointCommitted(long checkpointID)
Checked the resource whether the given checkpoint was committed completely.
|
abstract void |
open()
Opens/connects to the resource, and possibly creates it beforehand.
|
void |
setJobId(String id)
Internally used to set the job ID after instantiation.
|
void |
setOperatorId(String id)
Internally used to set the operator ID after instantiation.
|
void |
setOperatorSubtaskId(int id)
Internally used to set the operator subtask ID after instantiation.
|
protected static final org.slf4j.Logger LOG
protected String jobId
protected String operatorId
protected int subtaskId
public void setJobId(String id) throws Exception
id
- Exception
public void setOperatorId(String id) throws Exception
id
- Exception
public void setOperatorSubtaskId(int id) throws Exception
id
- Exception
public abstract void open() throws Exception
Exception
public abstract void close() throws Exception
Exception
public abstract void createResource() throws Exception
Exception
public abstract void commitCheckpoint(long checkpointID) throws Exception
checkpointID
- Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.