FsCheckpointStateToolset (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.state.filesystem.FsCheckpointStateToolset

All Implemented Interfaces:

CheckpointStateToolset
```
public class FsCheckpointStateToolset
extends Object
implements CheckpointStateToolset
```
An implementation of CheckpointStateToolset that does file based duplicating with as PathsCopyingFileSystem.

Constructor Summary

Constructors
Constructor Description

FsCheckpointStateToolset(Path basePath, PathsCopyingFileSystem fs)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`canFastDuplicate(StreamStateHandle stateHandle)`	Tells if we can duplicate the given `StreamStateHandle`.
`List<StreamStateHandle>`	`duplicate(List<StreamStateHandle> stateHandles)`	Duplicates `StreamStateHandles` into the path embedded inside of the class.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FsCheckpointStateToolset
```
public FsCheckpointStateToolset(Path basePath,
                                PathsCopyingFileSystem fs)
```
- Method Detail
  - canFastDuplicate
```
public boolean canFastDuplicate(StreamStateHandle stateHandle)
                         throws IOException
```
    Description copied from interface: CheckpointStateToolset
    
    Tells if we can duplicate the given StreamStateHandle.
    This should be a rather cheap operation, preferably not involving any remote accesses.
    
    Specified by:
    
    canFastDuplicate in interface CheckpointStateToolset
    
    Parameters:
    
    stateHandle - The handle to duplicate
    
    Returns:
    
    true, if we can perform the duplication
    
    Throws:
    
    IOException
  - duplicate
```
public List<StreamStateHandle> duplicate(List<StreamStateHandle> stateHandles)
                                  throws IOException
```
    Description copied from interface: CheckpointStateToolset
    
    Duplicates StreamStateHandles into the path embedded inside of the class.
    You should first check if you can duplicate with CheckpointStateToolset.canFastDuplicate(StreamStateHandle).
    
    Specified by:
    
    duplicate in interface CheckpointStateToolset
    
    Parameters:
    
    stateHandles - The handles to duplicate
    
    Returns:
    
    The duplicated handles
    
    Throws:
    
    IOException