@Test public void createFileTest() throws IOException { int fileId = mTfs.createFile("/root/testFile1"); Assert.assertEquals(3, fileId); fileId = mTfs.createFile("/root/testFile2"); Assert.assertEquals(4, fileId); fileId = mTfs.createFile("/root/testFile3"); Assert.assertEquals(5, fileId); }
public synchronized int createFile(String path) throws IOException { return createFile(path, UserConf.get().DEFAULT_BLOCK_SIZE_BYTE); }
TachyonFS { public synchronized int createFile(String path) throws IOException { return createFile(path, UserConf.get().DEFAULT_BLOCK_SIZE_BYTE); } }
TachyonFS { public synchronized int createFile(String path) throws IOException { return createFile(path, UserConf.get().DEFAULT_BLOCK_SIZE_BYTE); } private  TachyonFS(InetSocketAddress masterAddress, boolean zookeeperMode); }
TachyonFS { public synchronized int createFile(String path) throws IOException { return createFile(path, UserConf.get().DEFAULT_BLOCK_SIZE_BYTE); } private  TachyonFS(InetSocketAddress masterAddress, boolean zookeeperMode); static synchronized TachyonFS get(String tachyonPath); synchronized void cacheBlock(long blockId); synchronized void close(); synchronized int createDependency(List<String> parents, List<String> children,
      String commandPrefix, List<ByteBuffer> data, String comment, String framework,
      String frameworkVersion, int dependencyType, long childrenBlockSizeByte); synchronized int createFile(String path); synchronized int createFile(String path, long blockSizeByte); synchronized int createFile(String path, String underfsPath); synchronized int createRawTable(String path, int columns); synchronized int createRawTable(String path, int columns, ByteBuffer metadata); synchronized boolean delete(int fid, boolean recursive); synchronized boolean delete(String path, boolean recursive); synchronized boolean exist(String path); synchronized long getBlockId(int fId, int blockIndex); int getBlockLockId(); synchronized long getBlockSizeByte(int fId); synchronized ClientBlockInfo getClientBlockInfo(int fId, int blockIndex); synchronized ClientDependencyInfo getClientDependencyInfo(int did); synchronized long getCreationTimeMs(int fId); synchronized TachyonFile getFile(int fid); synchronized TachyonFile getFile(int fid, boolean useCachedMetadata); synchronized TachyonFile getFile(String path); synchronized TachyonFile getFile(String path, boolean useCachedMetadata); synchronized List<Long> getFileBlockIdList(int fId); synchronized List<ClientBlockInfo> getFileBlocks(int fid); synchronized List<String> getFileHosts(int fileId); synchronized int getFileId(String path); synchronized List<NetAddress> getFileNetAddresses(int fileId); synchronized List<List<String>> getFilesHosts(List<Integer> fileIds); synchronized List<List<NetAddress>> getFilesNetAddresses(List<Integer> fileIds); synchronized int getNumberOfFiles(String path); synchronized RawTable getRawTable(int id); synchronized RawTable getRawTable(String path); synchronized String getUnderfsAddress(); synchronized List<ClientWorkerInfo> getWorkersInfo(); synchronized boolean hasLocalWorker(); synchronized boolean isConnected(); synchronized List<Integer> listFiles(String path, boolean recursive); synchronized List<ClientFileInfo> listStatus(String path); synchronized List<String> ls(String path, boolean recursive); synchronized boolean mkdir(String path); synchronized void outOfMemoryForPinFile(int fid); synchronized void releaseSpace(long releaseSpaceBytes); synchronized boolean rename(int fId, String path); synchronized boolean rename(String srcPath, String dstPath); synchronized void reportLostFile(int fileId); synchronized void requestFilesInDependency(int depId); synchronized boolean requestSpace(long requestSpaceBytes); @Override String toString(); synchronized void setPinned(int fid, boolean pinned); synchronized void pinFile(int fid); synchronized void unpinFile(int fid); synchronized boolean isPinned(int fid, boolean useCachedMetadata); synchronized void updateRawTableMetadata(int id, ByteBuffer metadata); }
TachyonFS { public synchronized int createFile(String path) throws IOException { return createFile(path, UserConf.get().DEFAULT_BLOCK_SIZE_BYTE); } private  TachyonFS(InetSocketAddress masterAddress, boolean zookeeperMode); static synchronized TachyonFS get(String tachyonPath); synchronized void cacheBlock(long blockId); synchronized void close(); synchronized int createDependency(List<String> parents, List<String> children,
      String commandPrefix, List<ByteBuffer> data, String comment, String framework,
      String frameworkVersion, int dependencyType, long childrenBlockSizeByte); synchronized int createFile(String path); synchronized int createFile(String path, long blockSizeByte); synchronized int createFile(String path, String underfsPath); synchronized int createRawTable(String path, int columns); synchronized int createRawTable(String path, int columns, ByteBuffer metadata); synchronized boolean delete(int fid, boolean recursive); synchronized boolean delete(String path, boolean recursive); synchronized boolean exist(String path); synchronized long getBlockId(int fId, int blockIndex); int getBlockLockId(); synchronized long getBlockSizeByte(int fId); synchronized ClientBlockInfo getClientBlockInfo(int fId, int blockIndex); synchronized ClientDependencyInfo getClientDependencyInfo(int did); synchronized long getCreationTimeMs(int fId); synchronized TachyonFile getFile(int fid); synchronized TachyonFile getFile(int fid, boolean useCachedMetadata); synchronized TachyonFile getFile(String path); synchronized TachyonFile getFile(String path, boolean useCachedMetadata); synchronized List<Long> getFileBlockIdList(int fId); synchronized List<ClientBlockInfo> getFileBlocks(int fid); synchronized List<String> getFileHosts(int fileId); synchronized int getFileId(String path); synchronized List<NetAddress> getFileNetAddresses(int fileId); synchronized List<List<String>> getFilesHosts(List<Integer> fileIds); synchronized List<List<NetAddress>> getFilesNetAddresses(List<Integer> fileIds); synchronized int getNumberOfFiles(String path); synchronized RawTable getRawTable(int id); synchronized RawTable getRawTable(String path); synchronized String getUnderfsAddress(); synchronized List<ClientWorkerInfo> getWorkersInfo(); synchronized boolean hasLocalWorker(); synchronized boolean isConnected(); synchronized List<Integer> listFiles(String path, boolean recursive); synchronized List<ClientFileInfo> listStatus(String path); synchronized List<String> ls(String path, boolean recursive); synchronized boolean mkdir(String path); synchronized void outOfMemoryForPinFile(int fid); synchronized void releaseSpace(long releaseSpaceBytes); synchronized boolean rename(int fId, String path); synchronized boolean rename(String srcPath, String dstPath); synchronized void reportLostFile(int fileId); synchronized void requestFilesInDependency(int depId); synchronized boolean requestSpace(long requestSpaceBytes); @Override String toString(); synchronized void setPinned(int fid, boolean pinned); synchronized void pinFile(int fid); synchronized void unpinFile(int fid); synchronized boolean isPinned(int fid, boolean useCachedMetadata); synchronized void updateRawTableMetadata(int id, ByteBuffer metadata);  }