|
@@ -1128,6 +1128,13 @@ public class SequenceFile {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /** flush all currently written data to the file system */
|
|
|
+ public void syncFs() throws IOException {
|
|
|
+ if (out != null) {
|
|
|
+ out.sync(); // flush contents to file system
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
/** Returns the configuration of this file. */
|
|
|
Configuration getConf() { return conf; }
|
|
|
|