public interface CheckpointService
Modifier and Type | Interface and Description |
---|---|
static interface |
CheckpointService.CheckpointReadChannel |
static interface |
CheckpointService.CheckpointWriteChannel |
Modifier and Type | Method and Description |
---|---|
void |
abort(CheckpointService.CheckpointWriteChannel channel)
Dual to commit, it aborts the current checkpoint.
|
CheckpointID |
commit(CheckpointService.CheckpointWriteChannel channel)
Used to finalize and existing checkpoint.
|
CheckpointService.CheckpointWriteChannel |
create()
This method creates a checkpoint and provide a channel to write to it.
|
boolean |
delete(CheckpointID checkpointId)
It discards an existing checkpoint identified by its CheckpointID.
|
CheckpointService.CheckpointReadChannel |
open(CheckpointID checkpointId)
Given a CheckpointID returns a reading channel.
|
CheckpointService.CheckpointWriteChannel create() throws IOException, InterruptedException
IOException
InterruptedException
CheckpointID commit(CheckpointService.CheckpointWriteChannel channel) throws IOException, InterruptedException
channel
- the CheckpointWriteChannel to commitIOException
InterruptedException
void abort(CheckpointService.CheckpointWriteChannel channel) throws IOException, InterruptedException
channel
- the CheckpointWriteChannel to abortIOException
InterruptedException
CheckpointService.CheckpointReadChannel open(CheckpointID checkpointId) throws IOException, InterruptedException
checkpointId
- CheckpointID for the checkpoint to be openedIOException
InterruptedException
boolean delete(CheckpointID checkpointId) throws IOException, InterruptedException
checkpointId
- CheckpointID for the checkpoint to be deletedIOException
InterruptedException
Copyright © 2015 The Apache Software Foundation. All rights reserved.