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 |
---|---|
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 | 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.