1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.thrift.generated.TIncrement

Java 类org.apache.hadoop.hbase.thrift.generated.TIncrement 实例源码

项目：ditb    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  Table table = null;
  try {
    table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(Throwables.getStackTraceAsString(e));
  } finally{
    closeTable(table);
  }
}
项目：LCIndex-HBase-0.94.16    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：HIndex    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：IRIndex    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：hbase    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  Table table = null;
  try {
    table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw getIOError(e);
  } finally{
    closeTable(table);
  }
}
项目：PyroDB    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：HBase-Research    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：hbase-0.94.8-qod    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：hbase-0.94.8-qod    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：DominoHBase    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：hindex    文件：ThriftServerRunner.java    
@Override
public void increment(TIncrement tincrement) throws IOError, TException {

  if (tincrement.getRow().length == 0 || tincrement.getTable().length == 0) {
    throw new TException("Must supply a table and a row key; can't increment");
  }

  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrement(tincrement);
    return;
  }

  try {
    HTable table = getTable(tincrement.getTable());
    Increment inc = ThriftUtilities.incrementFromThrift(tincrement);
    table.increment(inc);
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}
项目：ditb    文件：ThriftUtilities.java    
/**
 * From a {@link TIncrement} create an {@link Increment}.
 * @param tincrement the Thrift version of an increment
 * @return an increment that the {@link TIncrement} represented.
 */
public static Increment incrementFromThrift(TIncrement tincrement) {
  Increment inc = new Increment(tincrement.getRow());
  byte[][] famAndQf = KeyValue.parseColumn(tincrement.getColumn());
  if (famAndQf.length != 2) return null;
  inc.addColumn(famAndQf[0], famAndQf[1], tincrement.getAmmount());
  return inc;
}
项目：ditb    文件：IncrementCoalescer.java    
public boolean queueIncrement(TIncrement inc) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }
  return internalQueueTincrement(inc);
}
项目：ditb    文件：IncrementCoalescer.java    
public boolean queueIncrements(List<TIncrement> incs) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }

  for (TIncrement tinc : incs) {
    internalQueueTincrement(tinc);
  }
  return true;

}
项目：ditb    文件：IncrementCoalescer.java    
private boolean internalQueueTincrement(TIncrement inc) throws TException {
  byte[][] famAndQf = KeyValue.parseColumn(inc.getColumn());
  if (famAndQf.length != 2) return false;

  return internalQueueIncrement(inc.getTable(), inc.getRow(), famAndQf[0], famAndQf[1],
    inc.getAmmount());
}
项目：ditb    文件：ThriftServerRunner.java    
@Override
public void incrementRows(List<TIncrement> tincrements) throws IOError, TException {
  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrements(tincrements);
    return;
  }
  for (TIncrement tinc : tincrements) {
    increment(tinc);
  }
}
项目：ditb    文件：TestThriftServer.java    
public static void doTestIncrements(HBaseHandler handler) throws Exception {
  List<Mutation> mutations = new ArrayList<Mutation>(1);
  mutations.add(new Mutation(false, columnAAname, valueEname, true));
  mutations.add(new Mutation(false, columnAname, valueEname, true));
  handler.mutateRow(tableAname, rowAname, mutations, null);
  handler.mutateRow(tableAname, rowBname, mutations, null);

  List<TIncrement> increments = new ArrayList<TIncrement>();
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));

  int numIncrements = 60000;
  for (int i = 0; i < numIncrements; i++) {
    handler.increment(new TIncrement(tableAname, rowAname, columnAname, 2));
    handler.incrementRows(increments);
  }

  Thread.sleep(1000);
  long lv = handler.get(tableAname, rowAname, columnAname, null).get(0).value.getLong();
  // Wait on all increments being flushed
  while (handler.coalescer.getQueueSize() != 0) Threads.sleep(10);
  assertEquals((100 + (2 * numIncrements)), lv );


  lv = handler.get(tableAname, rowBname, columnAAname, null).get(0).value.getLong();
  assertEquals((100 + (3 * 7 * numIncrements)), lv);

  assertTrue(handler.coalescer.getSuccessfulCoalescings() > 0);

}
项目：LCIndex-HBase-0.94.16    文件：ThriftUtilities.java    
/**
 * From a {@link TIncrement} create an {@link Increment}.
 * @param tincrement the Thrift version of an increment
 * @return an increment that the {@link TIncrement} represented.
 */
public static Increment incrementFromThrift(TIncrement tincrement) {
  Increment inc = new Increment(tincrement.getRow());
  byte[][] famAndQf = KeyValue.parseColumn(tincrement.getColumn());
  if (famAndQf.length <1 ) return null;
  byte[] qual = famAndQf.length == 1 ? new byte[0]: famAndQf[1];
  inc.addColumn(famAndQf[0], qual, tincrement.getAmmount());
  return inc;
}
项目：LCIndex-HBase-0.94.16    文件：IncrementCoalescer.java    
public boolean queueIncrement(TIncrement inc) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }
  return internalQueueTincrement(inc);
}
项目：LCIndex-HBase-0.94.16    文件：IncrementCoalescer.java    
public boolean queueIncrements(List<TIncrement> incs) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }

  for (TIncrement tinc : incs) {
    internalQueueTincrement(tinc);
  }
  return true;

}
项目：LCIndex-HBase-0.94.16    文件：IncrementCoalescer.java    
private boolean internalQueueTincrement(TIncrement inc) throws TException {
  byte[][] famAndQf = KeyValue.parseColumn(inc.getColumn());
  if (famAndQf.length < 1) return false;
  byte[] qual = famAndQf.length == 1 ? new byte[0] : famAndQf[1];

  return internalQueueIncrement(inc.getTable(), inc.getRow(), famAndQf[0], qual,
    inc.getAmmount());

}
项目：LCIndex-HBase-0.94.16    文件：ThriftServerRunner.java    
@Override
public void incrementRows(List<TIncrement> tincrements) throws IOError, TException {
  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrements(tincrements);
    return;
  }
  for (TIncrement tinc : tincrements) {
    increment(tinc);
  }
}
项目：LCIndex-HBase-0.94.16    文件：TestThriftServer.java    
public static void doTestIncrements(HBaseHandler handler) throws Exception {
  List<Mutation> mutations = new ArrayList<Mutation>(1);
  mutations.add(new Mutation(false, columnAAname, valueEname, true));
  mutations.add(new Mutation(false, columnAname, valueEname, true));
  handler.mutateRow(tableAname, rowAname, mutations, null);
  handler.mutateRow(tableAname, rowBname, mutations, null);

  List<TIncrement> increments = new ArrayList<TIncrement>();
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));

  int numIncrements = 60000;
  for (int i = 0; i < numIncrements; i++) {
    handler.increment(new TIncrement(tableAname, rowAname, columnAname, 2));
    handler.incrementRows(increments);
  }

  Thread.sleep(1000);
  long lv = handler.get(tableAname, rowAname, columnAname, null).get(0).value.getLong();
  assertEquals((100 + (2 * numIncrements)), lv );


  lv = handler.get(tableAname, rowBname, columnAAname, null).get(0).value.getLong();
  assertEquals((100 + (3 * 7 * numIncrements)), lv);

  assertTrue(handler.coalescer.getSuccessfulCoalescings() > 0);

}
项目：HIndex    文件：ThriftUtilities.java    
/**
 * From a {@link TIncrement} create an {@link Increment}.
 * @param tincrement the Thrift version of an increment
 * @return an increment that the {@link TIncrement} represented.
 */
public static Increment incrementFromThrift(TIncrement tincrement) {
  Increment inc = new Increment(tincrement.getRow());
  byte[][] famAndQf = KeyValue.parseColumn(tincrement.getColumn());
  if (famAndQf.length != 2) return null;
  inc.addColumn(famAndQf[0], famAndQf[1], tincrement.getAmmount());
  return inc;
}
项目：HIndex    文件：IncrementCoalescer.java    
public boolean queueIncrement(TIncrement inc) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }
  return internalQueueTincrement(inc);
}
项目：HIndex    文件：IncrementCoalescer.java    
public boolean queueIncrements(List<TIncrement> incs) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }

  for (TIncrement tinc : incs) {
    internalQueueTincrement(tinc);
  }
  return true;

}
项目：HIndex    文件：IncrementCoalescer.java    
private boolean internalQueueTincrement(TIncrement inc) throws TException {
  byte[][] famAndQf = KeyValue.parseColumn(inc.getColumn());
  if (famAndQf.length != 2) return false;

  return internalQueueIncrement(inc.getTable(), inc.getRow(), famAndQf[0], famAndQf[1],
    inc.getAmmount());
}
项目：HIndex    文件：ThriftServerRunner.java    
@Override
public void incrementRows(List<TIncrement> tincrements) throws IOError, TException {
  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrements(tincrements);
    return;
  }
  for (TIncrement tinc : tincrements) {
    increment(tinc);
  }
}
项目：HIndex    文件：TestThriftServer.java    
public static void doTestIncrements(HBaseHandler handler) throws Exception {
  List<Mutation> mutations = new ArrayList<Mutation>(1);
  mutations.add(new Mutation(false, columnAAname, valueEname, true));
  mutations.add(new Mutation(false, columnAname, valueEname, true));
  handler.mutateRow(tableAname, rowAname, mutations, null);
  handler.mutateRow(tableAname, rowBname, mutations, null);

  List<TIncrement> increments = new ArrayList<TIncrement>();
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));

  int numIncrements = 60000;
  for (int i = 0; i < numIncrements; i++) {
    handler.increment(new TIncrement(tableAname, rowAname, columnAname, 2));
    handler.incrementRows(increments);
  }

  Thread.sleep(1000);
  long lv = handler.get(tableAname, rowAname, columnAname, null).get(0).value.getLong();
  // Wait on all increments being flushed
  while (handler.coalescer.getQueueSize() != 0) Threads.sleep(10);
  assertEquals((100 + (2 * numIncrements)), lv );


  lv = handler.get(tableAname, rowBname, columnAAname, null).get(0).value.getLong();
  assertEquals((100 + (3 * 7 * numIncrements)), lv);

  assertTrue(handler.coalescer.getSuccessfulCoalescings() > 0);

}
项目：IRIndex    文件：ThriftUtilities.java    
/**
 * From a {@link TIncrement} create an {@link Increment}.
 * @param tincrement the Thrift version of an increment
 * @return an increment that the {@link TIncrement} represented.
 */
public static Increment incrementFromThrift(TIncrement tincrement) {
  Increment inc = new Increment(tincrement.getRow());
  byte[][] famAndQf = KeyValue.parseColumn(tincrement.getColumn());
  if (famAndQf.length <1 ) return null;
  byte[] qual = famAndQf.length == 1 ? new byte[0]: famAndQf[1];
  inc.addColumn(famAndQf[0], qual, tincrement.getAmmount());
  return inc;
}
项目：IRIndex    文件：IncrementCoalescer.java    
public boolean queueIncrement(TIncrement inc) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }
  return internalQueueTincrement(inc);
}
项目：IRIndex    文件：IncrementCoalescer.java    
public boolean queueIncrements(List<TIncrement> incs) throws TException {
  if (!canQueue()) {
    failedIncrements.incrementAndGet();
    return false;
  }

  for (TIncrement tinc : incs) {
    internalQueueTincrement(tinc);
  }
  return true;

}
项目：IRIndex    文件：IncrementCoalescer.java    
private boolean internalQueueTincrement(TIncrement inc) throws TException {
  byte[][] famAndQf = KeyValue.parseColumn(inc.getColumn());
  if (famAndQf.length < 1) return false;
  byte[] qual = famAndQf.length == 1 ? new byte[0] : famAndQf[1];

  return internalQueueIncrement(inc.getTable(), inc.getRow(), famAndQf[0], qual,
    inc.getAmmount());

}
项目：IRIndex    文件：ThriftServerRunner.java    
@Override
public void incrementRows(List<TIncrement> tincrements) throws IOError, TException {
  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrements(tincrements);
    return;
  }
  for (TIncrement tinc : tincrements) {
    increment(tinc);
  }
}
项目：IRIndex    文件：TestThriftServer.java    
public static void doTestIncrements(HBaseHandler handler) throws Exception {
  List<Mutation> mutations = new ArrayList<Mutation>(1);
  mutations.add(new Mutation(false, columnAAname, valueEname, true));
  mutations.add(new Mutation(false, columnAname, valueEname, true));
  handler.mutateRow(tableAname, rowAname, mutations, null);
  handler.mutateRow(tableAname, rowBname, mutations, null);

  List<TIncrement> increments = new ArrayList<TIncrement>();
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));
  increments.add(new TIncrement(tableAname, rowBname, columnAAname, 7));

  int numIncrements = 60000;
  for (int i = 0; i < numIncrements; i++) {
    handler.increment(new TIncrement(tableAname, rowAname, columnAname, 2));
    handler.incrementRows(increments);
  }

  Thread.sleep(1000);
  long lv = handler.get(tableAname, rowAname, columnAname, null).get(0).value.getLong();
  assertEquals((100 + (2 * numIncrements)), lv );


  lv = handler.get(tableAname, rowBname, columnAAname, null).get(0).value.getLong();
  assertEquals((100 + (3 * 7 * numIncrements)), lv);

  assertTrue(handler.coalescer.getSuccessfulCoalescings() > 0);

}
项目：hbase    文件：ThriftUtilities.java    
/**
 * From a {@link TIncrement} create an {@link Increment}.
 * @param tincrement the Thrift version of an increment
 * @return an increment that the {@link TIncrement} represented.
 */
public static Increment incrementFromThrift(TIncrement tincrement) {
  Increment inc = new Increment(tincrement.getRow());
  byte[][] famAndQf = CellUtil.parseColumn(tincrement.getColumn());

  if (famAndQf.length != 2) {
    return null;
  }

  inc.addColumn(famAndQf[0], famAndQf[1], tincrement.getAmmount());
  return inc;
}
项目：hbase    文件：IncrementCoalescer.java    
public boolean queueIncrement(TIncrement inc) throws TException {
  if (!canQueue()) {
    failedIncrements.increment();
    return false;
  }
  return internalQueueTincrement(inc);
}
项目：hbase    文件：IncrementCoalescer.java    
public boolean queueIncrements(List<TIncrement> incs) throws TException {
  if (!canQueue()) {
    failedIncrements.increment();
    return false;
  }

  for (TIncrement tinc : incs) {
    internalQueueTincrement(tinc);
  }

  return true;
}
项目：hbase    文件：IncrementCoalescer.java    
private boolean internalQueueTincrement(TIncrement inc) throws TException {
  byte[][] famAndQf = CellUtil.parseColumn(inc.getColumn());

  if (famAndQf.length != 2) {
    return false;
  }

  return internalQueueIncrement(inc.getTable(), inc.getRow(), famAndQf[0], famAndQf[1],
    inc.getAmmount());
}
项目：hbase    文件：ThriftServerRunner.java    
@Override
public void incrementRows(List<TIncrement> tincrements) throws IOError, TException {
  if (conf.getBoolean(COALESCE_INC_KEY, false)) {
    this.coalescer.queueIncrements(tincrements);
    return;
  }
  for (TIncrement tinc : tincrements) {
    increment(tinc);
  }
}