Examples of tachyon.thrift.ClientBlockInfo$ClientBlockInfoStandardScheme

tachyon.thrift.ClientBlockInfo


  @Test
  public void readTest() throws InvalidPathException, FileAlreadyExistException, IOException {
    final int length = 10;
    int fileId = TestUtils.createByteFile(mTFS, "/testFile", WriteType.MUST_CACHE, length);
    ClientBlockInfo block = mTFS.getFileBlocks(fileId).get(0);
    DataServerMessage recvMsg = request(block);
    assertValid(recvMsg, length, block.getBlockId(), 0, length);
  }

View Full Code Here


  @Test
  public void readTooLarge() throws IOException {
    final int length = 20;
    int fileId = TestUtils.createByteFile(mTFS, "/readTooLarge", WriteType.MUST_CACHE, length);
    ClientBlockInfo block = mTFS.getFileBlocks(fileId).get(0);
    DataServerMessage recvMsg = request(block, 0, length * 2);
    assertError(recvMsg, block.blockId);
  }

View Full Code Here


  @Test
  public void tooLargeOffset() throws IOException {
    final int length = 10;
    int fileId = TestUtils.createByteFile(mTFS, "/readTooLarge", WriteType.MUST_CACHE, length);
    ClientBlockInfo block = mTFS.getFileBlocks(fileId).get(0);
    DataServerMessage recvMsg = request(block, length * 2, 1);
    assertError(recvMsg, block.blockId);
  }

View Full Code Here

   * @param blockIndex The index of the block in the file.
   * @return filename on local file system or null if file not present on local file system.
   * @throws IOException
   */
  public String getLocalFilename(int blockIndex) throws IOException {
    ClientBlockInfo blockInfo = getClientBlockInfo(blockIndex);


    String rootFolder = mTachyonFS.getLocalDataFolder();
    if (rootFolder != null) {
      String localFileName = CommonUtils.concat(rootFolder, blockInfo.getBlockId());
      File file = new File(localFileName);
      if (file.exists()) {
        return localFileName;
      }
    }

View Full Code Here

    }
    if (len < 0 && len != -1) {
      throw new IOException("Length can not be negative except -1: " + len);
    }


    ClientBlockInfo info = getClientBlockInfo(blockIndex);
    long blockId = info.blockId;


    int blockLockId = mTachyonFS.getBlockLockId();
    if (!mTachyonFS.lockBlock(blockId, blockLockId)) {
      return null;

View Full Code Here

  }


  @Override
  public ClientBlockInfo user_getClientBlockInfo(long blockId) throws FileDoesNotExistException,
      BlockInfoException, TException {
    ClientBlockInfo ret = null;
    try {
      ret = mMasterInfo.getClientBlockInfo(blockId);
    } catch (IOException e) {
      throw new FileDoesNotExistException(e.getMessage());
    }

View Full Code Here

0 1

TOP

Related Classes of tachyon.thrift.ClientBlockInfo$ClientBlockInfoStandardScheme

org.apache.thrift.protocol.TTupleProtocol

tachyon.client.TachyonFile

tachyon.client.TachyonFileTest

tachyon.hadoop.AbstractTFS

tachyon.master.BlockInfo

tachyon.master.BlockInfoTest

tachyon.master.MasterInfo

tachyon.master.MasterServiceHandler

tachyon.worker.DataServerTest

java.util.BitSet

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.