RecoverableStreamWrapper (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.state.filesystem.MetadataOutputStreamWrapper
- - org.apache.flink.runtime.state.filesystem.RecoverableStreamWrapper

```
@Internal
public class RecoverableStreamWrapper
extends MetadataOutputStreamWrapper
```
Implementation of MetadataOutputStreamWrapper encapsulates the RecoverableFsDataOutputStream for FsCheckpointMetadataOutputStream.

Constructor Summary

Constructors
Constructor Description

RecoverableStreamWrapper(RecoverableFsDataOutputStream out)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cleanup()`
`void`	`closeAction()`
`void`	`closeForCommitAction()`
`FSDataOutputStream`	`getOutput()`

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

Constructor Detail

RecoverableStreamWrapper

public RecoverableStreamWrapper(RecoverableFsDataOutputStream out)

Method Detail

getOutput
```
public FSDataOutputStream getOutput()
```

closeForCommitAction

public void closeForCommitAction()
                          throws IOException

Throws:: IOException

closeAction

public void closeAction()
                 throws IOException

Throws:: IOException

cleanup

public void cleanup()
             throws IOException

Throws:: IOException