Modifier and Type | Method and Description |
---|---|
RecoverableWriter |
FileSystem.createRecoverableWriter()
Creates a new
RecoverableWriter . |
RecoverableWriter |
SafetyNetWrapperFileSystem.createRecoverableWriter() |
Modifier and Type | Class and Description |
---|---|
class |
LocalRecoverableWriter
A
RecoverableWriter for the LocalFileSystem . |
Modifier and Type | Class and Description |
---|---|
class |
GSRecoverableWriter
The recoverable writer implementation for Google storage.
|
Modifier and Type | Method and Description |
---|---|
RecoverableWriter |
FlinkOSSFileSystem.createRecoverableWriter() |
Modifier and Type | Class and Description |
---|---|
class |
OSSRecoverableWriter
An implementation of the
RecoverableWriter against OSS. |
Modifier and Type | Method and Description |
---|---|
RecoverableWriter |
FlinkS3FileSystem.createRecoverableWriter() |
Modifier and Type | Class and Description |
---|---|
class |
S3RecoverableWriter
An implementation of the
RecoverableWriter against S3. |
Modifier and Type | Class and Description |
---|---|
class |
HadoopRecoverableWriter
An implementation of the
RecoverableWriter for Hadoop's file system abstraction. |
Modifier and Type | Method and Description |
---|---|
RecoverableWriter |
HadoopFileSystem.createRecoverableWriter() |
Constructor and Description |
---|
BulkBucketWriter(RecoverableWriter recoverableWriter,
BulkWriter.Factory<IN> writerFactory) |
RowWiseBucketWriter(RecoverableWriter recoverableWriter,
Encoder<IN> encoder) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.