Package | Description |
---|---|
org.apache.flink.core.fs | |
org.apache.flink.core.fs.local | |
org.apache.flink.fs.s3.common.writer | |
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 | Class and Description |
---|---|
class |
S3RecoverableFsDataOutputStream
A RecoverableFsDataOutputStream to S3 that is based on a recoverable multipart upload.
|
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
S3RecoverableWriter.open(Path path) |
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.