Package | Description |
---|---|
org.apache.flink.core.fs | |
org.apache.flink.core.fs.local | |
org.apache.flink.fs.s3.common | |
org.apache.flink.fs.s3.common.writer | |
org.apache.flink.runtime.fs.hdfs |
Modifier and Type | Method and Description |
---|---|
RecoverableWriter |
SafetyNetWrapperFileSystem.createRecoverableWriter() |
RecoverableWriter |
FileSystem.createRecoverableWriter()
Creates a new
RecoverableWriter . |
Modifier and Type | Class and Description |
---|---|
class |
LocalRecoverableWriter
A
RecoverableWriter for the LocalFileSystem . |
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() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.