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) |
Modifier and Type | Method and Description |
---|---|
InProgressFileWriter<IN,BucketID> |
RowWiseBucketWriter.openNew(BucketID bucketId,
RecoverableFsDataOutputStream stream,
Path path,
long creationTime) |
InProgressFileWriter<IN,BucketID> |
BulkBucketWriter.openNew(BucketID bucketId,
RecoverableFsDataOutputStream stream,
Path path,
long creationTime) |
InProgressFileWriter<IN,BucketID> |
RowWiseBucketWriter.resumeFrom(BucketID bucketId,
RecoverableFsDataOutputStream stream,
RecoverableWriter.ResumeRecoverable resumable,
long creationTime) |
InProgressFileWriter<IN,BucketID> |
BulkBucketWriter.resumeFrom(BucketID bucketId,
RecoverableFsDataOutputStream stream,
RecoverableWriter.ResumeRecoverable resumable,
long creationTime) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.