|
@@ -1193,6 +1193,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; }
|
|
|
|