@Test public void AddBlockTest() throws Exception { mTfs.createFile("/xyz", 64); TachyonFile file = mTfs.getFile("/xyz"); OutputStream os = file.getOutStream(WriteType.MUST_CACHE); for (int k = 0; k < 1000; k ++) { os.write(k); } os.close(); ClientFileInfo fInfo = mLocalTachyonCluster.getMasterInfo().getClientFileInfo("/xyz"); mLocalTachyonCluster.stopTFS(); AddBlockTestUtil(fInfo); String editLogPath = mLocalTachyonCluster.getEditLogPath(); UnderFileSystem.get(editLogPath).delete(editLogPath, true); AddBlockTestUtil(fInfo); }
public void close() { if (mEditLog != null) { mEditLog.close(); } }
Journal { public void close() { if (mEditLog != null) { mEditLog.close(); } } }
Journal { public void close() { if (mEditLog != null) { mEditLog.close(); } } Journal(String folder, String imageFileName, String editLogFileName); }
Journal { public void close() { if (mEditLog != null) { mEditLog.close(); } } Journal(String folder, String imageFileName, String editLogFileName); void close(); void createEditLog(long startingTransactionId); void createImage(MasterInfo info); void createImage(MasterInfo info, String imagePath); EditLog getEditLog(); long getImageModTimeMs(); long loadEditLog(MasterInfo info); void loadImage(MasterInfo info); void loadSingleLogFile(MasterInfo info, String path); void setMaxLogSize(int size); }
Journal { public void close() { if (mEditLog != null) { mEditLog.close(); } } Journal(String folder, String imageFileName, String editLogFileName); void close(); void createEditLog(long startingTransactionId); void createImage(MasterInfo info); void createImage(MasterInfo info, String imagePath); EditLog getEditLog(); long getImageModTimeMs(); long loadEditLog(MasterInfo info); void loadImage(MasterInfo info); void loadSingleLogFile(MasterInfo info, String path); void setMaxLogSize(int size);  }