public class FSCheckpointService extends Object implements CheckpointService
CheckpointService.CheckpointReadChannel, CheckpointService.CheckpointWriteChannel
Constructor and Description |
---|
FSCheckpointService(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path base,
CheckpointNamingService namingPolicy,
short replication) |
Modifier and Type | Method and Description |
---|---|
void |
abort(CheckpointService.CheckpointWriteChannel ch)
Aborts the current checkpoint.
|
CheckpointID |
commit(CheckpointService.CheckpointWriteChannel ch)
Closes an existing checkpoint for writes and returns the CheckpointID that can be later
used to get the read-only access to this checkpoint.
|
CheckpointService.CheckpointWriteChannel |
create()
Creates a checkpoint and provides a channel to write to it.
|
boolean |
delete(CheckpointID id)
Discards an existing checkpoint identified by its CheckpointID.
|
CheckpointService.CheckpointReadChannel |
open(CheckpointID id)
Returns a reading channel to a checkpoint identified by the CheckpointID.
|
public FSCheckpointService(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path base, CheckpointNamingService namingPolicy, short replication)
public CheckpointService.CheckpointWriteChannel create() throws IOException
CheckpointService
commit
is called.
This makes enforcing atomicity of writes easy.create
in interface CheckpointService
IOException
public CheckpointService.CheckpointReadChannel open(CheckpointID id) throws IOException, InterruptedException
CheckpointService
open
in interface CheckpointService
id
- CheckpointID for the checkpoint to be openedIOException
InterruptedException
public CheckpointID commit(CheckpointService.CheckpointWriteChannel ch) throws IOException, InterruptedException
CheckpointService
commit
in interface CheckpointService
ch
- the CheckpointWriteChannel to commitIOException
InterruptedException
public void abort(CheckpointService.CheckpointWriteChannel ch) throws IOException
CheckpointService
abort
in interface CheckpointService
ch
- the CheckpointWriteChannel to abortIOException
public boolean delete(CheckpointID id) throws IOException, InterruptedException
CheckpointService
delete
in interface CheckpointService
id
- CheckpointID for the checkpoint to be deletedIOException
InterruptedException
Copyright © 2017 The Apache Software Foundation. All rights reserved.