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 |
---|---|
abstract RecoverableWriter.ResumeRecoverable |
RecoverableFsDataOutputStream.persist()
Ensures all data so far is persistent (similar to
FSDataOutputStream.sync() ) and returns
a handle to recover the stream at the current position. |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
RecoverableWriter.getResumeRecoverableSerializer()
The serializer for the ResumeRecoverable types created in this writer.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
LocalRecoverableWriter.getResumeRecoverableSerializer() |
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
LocalRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable) |
Modifier and Type | Method and Description |
---|---|
SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> |
HadoopRecoverableWriter.getResumeRecoverableSerializer() |
Modifier and Type | Method and Description |
---|---|
RecoverableFsDataOutputStream |
HadoopRecoverableWriter.recover(RecoverableWriter.ResumeRecoverable recoverable) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.