1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.thrift2.generated.TDurability

Java 类org.apache.hadoop.hbase.thrift2.generated.TDurability 实例源码

项目：ditb    文件：ThriftUtilities.java    
private static Durability durabilityFromThrift(TDurability tDurability) {
  switch (tDurability.getValue()) {
    case 1: return Durability.SKIP_WAL;
    case 2: return Durability.ASYNC_WAL;
    case 3: return Durability.SYNC_WAL;
    case 4: return Durability.FSYNC_WAL;
    default: return null;
  }
}
项目：HIndex    文件：ThriftUtilities.java    
private static Durability durabilityFromThrift(TDurability tDurability) {
  switch (tDurability.getValue()) {
    case 1: return Durability.SKIP_WAL;
    case 2: return Durability.ASYNC_WAL;
    case 3: return Durability.SYNC_WAL;
    case 4: return Durability.FSYNC_WAL;
    default: return null;
  }
}
项目：hbase    文件：ThriftUtilities.java    
private static Durability durabilityFromThrift(TDurability tDurability) {
  switch (tDurability.getValue()) {
    case 1: return Durability.SKIP_WAL;
    case 2: return Durability.ASYNC_WAL;
    case 3: return Durability.SYNC_WAL;
    case 4: return Durability.FSYNC_WAL;
    default: return null;
  }
}
项目：PyroDB    文件：ThriftUtilities.java    
private static Durability durabilityFromThrift(TDurability tDurability) {
  switch (tDurability.getValue()) {
    case 1: return Durability.SKIP_WAL;
    case 2: return Durability.ASYNC_WAL;
    case 3: return Durability.SYNC_WAL;
    case 4: return Durability.FSYNC_WAL;
    default: return null;
  }
}
项目：ditb    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 *
 * @throws Exception
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = "testDurability".getBytes();
  List<TColumnValue> columnValues = new ArrayList<TColumnValue>();
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<TColumnIncrement>();
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));
  tDelete.setDurability(TDurability.SKIP_WAL);
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.ASYNC_WAL);

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SYNC_WAL);

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.FSYNC_WAL);

  TPut tPut = new TPut(wrap(rowName), columnValues);
  tPut.setDurability(TDurability.SKIP_WAL);
  Put put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.ASYNC_WAL);

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SYNC_WAL);

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.FSYNC_WAL);

  TIncrement tIncrement = new TIncrement(wrap(rowName), incrementColumns);

  tIncrement.setDurability(TDurability.SKIP_WAL);
  Increment increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SKIP_WAL);

  tIncrement.setDurability(TDurability.ASYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.ASYNC_WAL);

  tIncrement.setDurability(TDurability.SYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SYNC_WAL);

  tIncrement.setDurability(TDurability.FSYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.FSYNC_WAL);
}
项目：LCIndex-HBase-0.94.16    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 *
 * @throws Exception
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = "testDurability".getBytes();
  List<TColumnValue> columnValues = new ArrayList<TColumnValue>();
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<TColumnIncrement>();
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));

  //if not setting writeToWal, check for default value
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to true, durability should be CF default
  tDelete.setWriteToWal(true);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to false, durability should be SKIP_WAL
  tDelete.setWriteToWal(false);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);


  tDelete.setDurability(TDurability.SKIP_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.ASYNC_WAL);

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SYNC_WAL);

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.FSYNC_WAL);

  TPut tPut = new TPut(wrap(rowName), columnValues);

  //if not setting writeToWal, check for default value
  Put put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to true, durability should be CF default
  tPut.setWriteToWal(true);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to false, durability should be SKIP_WAL
  tPut.setWriteToWal(false);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.SKIP_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.ASYNC_WAL);

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SYNC_WAL);

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.FSYNC_WAL);
}
项目：HIndex    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 *
 * @throws Exception
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = "testDurability".getBytes();
  List<TColumnValue> columnValues = new ArrayList<TColumnValue>();
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<TColumnIncrement>();
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));
  tDelete.setDurability(TDurability.SKIP_WAL);
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.ASYNC_WAL);

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SYNC_WAL);

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.FSYNC_WAL);

  TPut tPut = new TPut(wrap(rowName), columnValues);
  tPut.setDurability(TDurability.SKIP_WAL);
  Put put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.ASYNC_WAL);

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SYNC_WAL);

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.FSYNC_WAL);

  TIncrement tIncrement = new TIncrement(wrap(rowName), incrementColumns);

  tIncrement.setDurability(TDurability.SKIP_WAL);
  Increment increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SKIP_WAL);

  tIncrement.setDurability(TDurability.ASYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.ASYNC_WAL);

  tIncrement.setDurability(TDurability.SYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SYNC_WAL);

  tIncrement.setDurability(TDurability.FSYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.FSYNC_WAL);
}
项目：IRIndex    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 *
 * @throws Exception
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = "testDurability".getBytes();
  List<TColumnValue> columnValues = new ArrayList<TColumnValue>();
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<TColumnIncrement>();
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));

  //if not setting writeToWal, check for default value
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to true, durability should be CF default
  tDelete.setWriteToWal(true);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to false, durability should be SKIP_WAL
  tDelete.setWriteToWal(false);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);


  tDelete.setDurability(TDurability.SKIP_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.ASYNC_WAL);

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SYNC_WAL);

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.FSYNC_WAL);

  TPut tPut = new TPut(wrap(rowName), columnValues);

  //if not setting writeToWal, check for default value
  Put put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to true, durability should be CF default
  tPut.setWriteToWal(true);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.USE_DEFAULT);

  //if setting writeToWal to false, durability should be SKIP_WAL
  tPut.setWriteToWal(false);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.SKIP_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.ASYNC_WAL);

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SYNC_WAL);

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.FSYNC_WAL);
}
项目：hbase    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = Bytes.toBytes("testDurability");
  List<TColumnValue> columnValues = new ArrayList<>(1);
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<>(1);
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));
  tDelete.setDurability(TDurability.SKIP_WAL);
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(Durability.SKIP_WAL, delete.getDurability());

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(Durability.ASYNC_WAL, delete.getDurability());

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(Durability.SYNC_WAL, delete.getDurability());

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(Durability.FSYNC_WAL, delete.getDurability());

  TPut tPut = new TPut(wrap(rowName), columnValues);
  tPut.setDurability(TDurability.SKIP_WAL);
  Put put = putFromThrift(tPut);
  assertEquals(Durability.SKIP_WAL, put.getDurability());

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(Durability.ASYNC_WAL, put.getDurability());

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(Durability.SYNC_WAL, put.getDurability());

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(Durability.FSYNC_WAL, put.getDurability());

  TIncrement tIncrement = new TIncrement(wrap(rowName), incrementColumns);

  tIncrement.setDurability(TDurability.SKIP_WAL);
  Increment increment = incrementFromThrift(tIncrement);
  assertEquals(Durability.SKIP_WAL, increment.getDurability());

  tIncrement.setDurability(TDurability.ASYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(Durability.ASYNC_WAL, increment.getDurability());

  tIncrement.setDurability(TDurability.SYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(Durability.SYNC_WAL, increment.getDurability());

  tIncrement.setDurability(TDurability.FSYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(Durability.FSYNC_WAL, increment.getDurability());
}
项目：PyroDB    文件：TestThriftHBaseServiceHandler.java    
/**
 * Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility
 * functions to get Put , Delete and Increment respectively. Use getDurability to make sure
 * the returned objects have the appropriate durability setting.
 *
 * @throws Exception
 */
@Test
public void testDurability() throws Exception {
  byte[] rowName = "testDurability".getBytes();
  List<TColumnValue> columnValues = new ArrayList<TColumnValue>();
  columnValues.add(new TColumnValue(wrap(familyAname), wrap(qualifierAname), wrap(valueAname)));

  List<TColumnIncrement> incrementColumns = new ArrayList<TColumnIncrement>();
  incrementColumns.add(new TColumnIncrement(wrap(familyAname), wrap(qualifierAname)));

  TDelete tDelete = new TDelete(wrap(rowName));
  tDelete.setDurability(TDurability.SKIP_WAL);
  Delete delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SKIP_WAL);

  tDelete.setDurability(TDurability.ASYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.ASYNC_WAL);

  tDelete.setDurability(TDurability.SYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.SYNC_WAL);

  tDelete.setDurability(TDurability.FSYNC_WAL);
  delete = deleteFromThrift(tDelete);
  assertEquals(delete.getDurability(), Durability.FSYNC_WAL);

  TPut tPut = new TPut(wrap(rowName), columnValues);
  tPut.setDurability(TDurability.SKIP_WAL);
  Put put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SKIP_WAL);

  tPut.setDurability(TDurability.ASYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.ASYNC_WAL);

  tPut.setDurability(TDurability.SYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.SYNC_WAL);

  tPut.setDurability(TDurability.FSYNC_WAL);
  put = putFromThrift(tPut);
  assertEquals(put.getDurability(), Durability.FSYNC_WAL);

  TIncrement tIncrement = new TIncrement(wrap(rowName), incrementColumns);

  tIncrement.setDurability(TDurability.SKIP_WAL);
  Increment increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SKIP_WAL);

  tIncrement.setDurability(TDurability.ASYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.ASYNC_WAL);

  tIncrement.setDurability(TDurability.SYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.SYNC_WAL);

  tIncrement.setDurability(TDurability.FSYNC_WAL);
  increment = incrementFromThrift(tIncrement);
  assertEquals(increment.getDurability(), Durability.FSYNC_WAL);
}