Package | Description |
---|---|
org.apache.flink.core.fs | |
org.apache.flink.core.fs.local | |
org.apache.flink.runtime.fs.hdfs |
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
RecoverableWriter.open(Path path)
Opens a new recoverable stream to write to the given path.
|
RecoverableFsDataOutputStream |
RecoverableWriter.recover(RecoverableWriter.ResumeRecoverable resumable)
Resumes a recoverable stream consistently at the point indicated by the given ResumeRecoverable.
|
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
LocalRecoverableWriter.open(Path filePath) |
RecoverableFsDataOutputStream |
LocalRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable) |
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
HadoopRecoverableWriter.open(Path filePath) |
RecoverableFsDataOutputStream |
HadoopRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.