Java 类org.apache.hadoop.hbase.client.coprocessor.Batch.Callback 实例源码

项目：ditb 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[],R> coprocessorService(final Class<T> service,
    byte[] startKey, byte[] endKey, final Batch.Call<T,R> callable)
    throws ServiceException, Throwable {
  final Map<byte[],R> results =  Collections.synchronizedMap(
      new TreeMap<byte[], R>(Bytes.BYTES_COMPARATOR));
  coprocessorService(service, startKey, endKey, callable, new Batch.Callback<R>() {
    @Override
    public void update(byte[] region, byte[] row, R value) {
      if (region != null) {
        results.put(region, value);
      }
    }
  });
  return results;
}

项目：ditb 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {

        @Override
        public void update(byte[] region, byte[] row, R result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：ditb 文件：TestAsyncProcess.java

@Test
public void testSubmitWithCB() throws Exception {
  ClusterConnection hc = createHConnection();
  final AtomicInteger updateCalled = new AtomicInteger(0);
  Batch.Callback<Object> cb = new Batch.Callback<Object>() {
    @Override
    public void update(byte[] region, byte[] row, Object result) {
      updateCalled.incrementAndGet();
    }
  };
  AsyncProcess ap = new MyAsyncProcess(hc, conf);

  List<Put> puts = new ArrayList<Put>();
  puts.add(createPut(1, true));

  final AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, cb, false);
  Assert.assertTrue(puts.isEmpty());
  ars.waitUntilDone();
  Assert.assertEquals(updateCalled.get(), 1);
}

项目：pbase 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[],R> coprocessorService(final Class<T> service,
    byte[] startKey, byte[] endKey, final Batch.Call<T,R> callable)
    throws ServiceException, Throwable {
  final Map<byte[],R> results =  Collections.synchronizedMap(
      new TreeMap<byte[], R>(Bytes.BYTES_COMPARATOR));
  coprocessorService(service, startKey, endKey, callable, new Batch.Callback<R>() {
    @Override
    public void update(byte[] region, byte[] row, R value) {
      if (region != null) {
        results.put(region, value);
      }
    }
  });
  return results;
}

项目：pbase 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {

        @Override
        public void update(byte[] region, byte[] row, R result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：pbase 文件：TestAsyncProcess.java

@Test
public void testSubmitWithCB() throws Exception {
  ClusterConnection hc = createHConnection();
  final AtomicInteger updateCalled = new AtomicInteger(0);
  Batch.Callback<Object> cb = new Batch.Callback<Object>() {
    @Override
    public void update(byte[] region, byte[] row, Object result) {
      updateCalled.incrementAndGet();
    }
  };
  AsyncProcess ap = new MyAsyncProcess(hc, conf);

  List<Put> puts = new ArrayList<Put>();
  puts.add(createPut(1, true));

  final AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, cb, false);
  Assert.assertTrue(puts.isEmpty());
  ars.waitUntilDone();
  Assert.assertEquals(updateCalled.get(), 1);
}

项目：HIndex 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[],R> coprocessorService(final Class<T> service,
    byte[] startKey, byte[] endKey, final Batch.Call<T,R> callable)
    throws ServiceException, Throwable {
  final Map<byte[],R> results =  Collections.synchronizedMap(
      new TreeMap<byte[], R>(Bytes.BYTES_COMPARATOR));
  coprocessorService(service, startKey, endKey, callable, new Batch.Callback<R>() {
    public void update(byte[] region, byte[] row, R value) {
      if (region != null) {
        results.put(region, value);
      }
    }
  });
  return results;
}

项目：HIndex 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {

        @Override
        public void update(byte[] region, byte[] row, R result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：hbase 文件：HTable.java

public static <R> void doBatchWithCallback(List<? extends Row> actions, Object[] results,
  Callback<R> callback, ClusterConnection connection, ExecutorService pool, TableName tableName)
  throws InterruptedIOException, RetriesExhaustedWithDetailsException {
  int operationTimeout = connection.getConnectionConfiguration().getOperationTimeout();
  int writeTimeout = connection.getConfiguration().getInt(HConstants.HBASE_RPC_WRITE_TIMEOUT_KEY,
      connection.getConfiguration().getInt(HConstants.HBASE_RPC_TIMEOUT_KEY,
          HConstants.DEFAULT_HBASE_RPC_TIMEOUT));
  AsyncProcessTask<R> task = AsyncProcessTask.newBuilder(callback)
          .setPool(pool)
          .setTableName(tableName)
          .setRowAccess(actions)
          .setResults(results)
          .setOperationTimeout(operationTimeout)
          .setRpcTimeout(writeTimeout)
          .setSubmittedRows(AsyncProcessTask.SubmittedRows.ALL)
          .build();
  AsyncRequestFuture ars = connection.getAsyncProcess().submit(task);
  ars.waitUntilDone();
  if (ars.hasError()) {
    throw ars.getErrors();
  }
}

项目：hbase 文件：HTable.java

@Override
public <T extends Service, R> Map<byte[],R> coprocessorService(final Class<T> service,
    byte[] startKey, byte[] endKey, final Batch.Call<T,R> callable)
    throws ServiceException, Throwable {
  final Map<byte[],R> results =  Collections.synchronizedMap(
      new TreeMap<byte[], R>(Bytes.BYTES_COMPARATOR));
  coprocessorService(service, startKey, endKey, callable, new Batch.Callback<R>() {
    @Override
    public void update(byte[] region, byte[] row, R value) {
      if (region != null) {
        results.put(region, value);
      }
    }
  });
  return results;
}

项目：hbase 文件：HTable.java

@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {
    @Override
    public void update(byte[] region, byte[] row, R result) {
      if (region != null) {
        results.put(region, result);
      }
    }
  });
  return results;
}

项目：CSBT 文件：TestCrossSiteCoprocessor.java

private Map<byte[], SumResponse> sumInBatch(final CrossSiteHTable table,
    final String[] clusterNames, final byte[] family, final byte[] qualifier, final byte[] start,
    final byte[] end) throws ServiceException, Throwable {
  ColumnAggregationProtos.SumRequest.Builder builder = ColumnAggregationProtos.SumRequest
      .newBuilder();
  builder.setFamily(HBaseZeroCopyByteString.wrap(family));
  if (qualifier != null && qualifier.length > 0) {
    builder.setQualifier(HBaseZeroCopyByteString.wrap(qualifier));
  }
  final Map<byte[], ColumnAggregationProtos.SumResponse> results = Collections
      .synchronizedMap(new TreeMap<byte[], ColumnAggregationProtos.SumResponse>(
          Bytes.BYTES_COMPARATOR));
  table.batchCoprocessorService(ColumnAggregationProtos.ColumnAggregationService.getDescriptor()
      .findMethodByName("sum"), builder.build(), start, end, clusterNames,
      ColumnAggregationProtos.SumResponse.getDefaultInstance(),
      new Callback<ColumnAggregationProtos.SumResponse>() {

        @Override
        public void update(byte[] region, byte[] row, ColumnAggregationProtos.SumResponse result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：CSBT 文件：CrossSiteHTable.java

@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {

        @Override
        public void update(byte[] region, byte[] row, R result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：PyroDB 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <T extends Service, R> Map<byte[],R> coprocessorService(final Class<T> service,
    byte[] startKey, byte[] endKey, final Batch.Call<T,R> callable)
    throws ServiceException, Throwable {
  final Map<byte[],R> results =  Collections.synchronizedMap(
      new TreeMap<byte[], R>(Bytes.BYTES_COMPARATOR));
  coprocessorService(service, startKey, endKey, callable, new Batch.Callback<R>() {
    public void update(byte[] region, byte[] row, R value) {
      if (region != null) {
        results.put(region, value);
      }
    }
  });
  return results;
}

项目：PyroDB 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <R extends Message> Map<byte[], R> batchCoprocessorService(
    Descriptors.MethodDescriptor methodDescriptor, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype) throws ServiceException, Throwable {
  final Map<byte[], R> results = Collections.synchronizedMap(new TreeMap<byte[], R>(
      Bytes.BYTES_COMPARATOR));
  batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
      new Callback<R>() {

        @Override
        public void update(byte[] region, byte[] row, R result) {
          if (region != null) {
            results.put(region, result);
          }
        }
      });
  return results;
}

项目：PyroDB 文件：TestAsyncProcess.java

@Test
public void testSubmitWithCB() throws Exception {
  ClusterConnection hc = createHConnection();
  final AtomicInteger updateCalled = new AtomicInteger(0);
  Batch.Callback<Object> cb = new Batch.Callback<Object>() {
    public void update(byte[] region, byte[] row, Object result) {
      updateCalled.incrementAndGet();
    }
  };
  AsyncProcess ap = new MyAsyncProcess(hc, conf);

  List<Put> puts = new ArrayList<Put>();
  puts.add(createPut(1, true));

  final AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, cb, false);
  Assert.assertTrue(puts.isEmpty());
  ars.waitUntilDone();
  Assert.assertEquals(updateCalled.get(), 1);
}

项目：ditb 文件：HTableWrapper.java

@Override
public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
    Message request, byte[] startKey, byte[] endKey, R responsePrototype, Callback<R> callback)
    throws ServiceException, Throwable {
  table.batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype,
    callback);
}

项目：ditb 文件：HTable.java

/**
 * {@inheritDoc}
 */
@Override
public <R> void batchCallback(
    final List<? extends Row> actions, final Object[] results, final Batch.Callback<R> callback)
    throws IOException, InterruptedException {
  connection.processBatchCallback(actions, tableName, pool, results, callback);
}

项目：ditb 文件：HTable.java

/**
 * {@inheritDoc}
 * @deprecated If any exception is thrown by one of the actions, there is no way to
 * retrieve the partially executed results. Use
 * {@link #batchCallback(List, Object[], org.apache.hadoop.hbase.client.coprocessor.Batch.Callback)}
 * instead.
 */
@Deprecated
@Override
public <R> Object[] batchCallback(
  final List<? extends Row> actions, final Batch.Callback<R> callback) throws IOException,
    InterruptedException {
  Object[] results = new Object[actions.size()];
  batchCallback(actions, results, callback);
  return results;
}

项目：ditb 文件：HTablePool.java

@Override
public <T extends Service, R> void coprocessorService(Class<T> service,
    byte[] startKey, byte[] endKey, Batch.Call<T, R> callable, Callback<R> callback)
    throws ServiceException, Throwable {
  checkState();
  table.coprocessorService(service, startKey, endKey, callable, callback);
}

项目：ditb 文件：HTablePool.java

@Override
public <R> void batchCallback(List<? extends Row> actions,
    Object[] results, Callback<R> callback) throws IOException,
    InterruptedException {
  checkState();
  table.batchCallback(actions, results, callback);
}

项目：ditb 文件：HTablePool.java

@Override
public <R extends Message> void batchCoprocessorService(
    Descriptors.MethodDescriptor method, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype, Callback<R> callback)
    throws ServiceException, Throwable {
  checkState();
  table.batchCoprocessorService(method, request, startKey, endKey, responsePrototype, callback);
}

项目：ditb 文件：TestAsyncProcess.java

@Override
protected <Res> AsyncRequestFutureImpl<Res> createAsyncRequestFuture(TableName tableName,
    List<Action<Row>> actions, long nonceGroup, ExecutorService pool,
    Batch.Callback<Res> callback, Object[] results, boolean needResults) {
  // Test HTable has tableName of null, so pass DUMMY_TABLE
  AsyncRequestFutureImpl<Res> r = super.createAsyncRequestFuture(
      DUMMY_TABLE, actions, nonceGroup, pool, callback, results, needResults);
  allReqs.add(r);
  callsCt.incrementAndGet();
  return r;
}

项目：ditb 文件：TestAsyncProcess.java

@Override
public <Res> AsyncRequestFuture submit(TableName tableName, List<? extends Row> rows,
    boolean atLeastOne, Callback<Res> callback, boolean needResults)
        throws InterruptedIOException {
  // We use results in tests to check things, so override to always save them.
  return super.submit(DUMMY_TABLE, rows, atLeastOne, callback, true);
}

项目：ditb 文件：RemoteHTable.java

@Override
public <R extends Message> void batchCoprocessorService(
    Descriptors.MethodDescriptor method, Message request,
    byte[] startKey, byte[] endKey, R responsePrototype, Callback<R> callback)
    throws ServiceException, Throwable {
  throw new UnsupportedOperationException("batchCoprocessorService not implemented");
}

项目：hbase.mcc 文件：HTableMultiCluster.java

public <R extends Message> void batchCoprocessorService(
        MethodDescriptor methodDescriptor, Message request, byte[] startKey,
        byte[] endKey, R responsePrototype, Callback<R> callback)
        throws ServiceException, Throwable {
  // TODO Auto-generated method stub

}

项目：hbase.mcc 文件：HConnectionMultiCluster.java

@Deprecated
public <R> void processBatchCallback(List<? extends Row> list,
    byte[] tableName, ExecutorService pool, Object[] results,
    Callback<R> callback) throws IOException, InterruptedException {
  primaryConnection.processBatchCallback(list, tableName, pool, results, callback);

}

项目：ColumnManagerForHBase 文件：MTable.java

@Override
@Deprecated
public <R> Object[] batchCallback(List<? extends Row> actions, Callback<R> callback)
        throws IOException, InterruptedException {
  Object[] results = new Object[actions.size()];
  batchCallback(actions, results, callback);
  return results;
}

项目：gora-boot 文件：HBaseTableConnection.java

@Override
public <R> void
    batchCallback(List<? extends Row> actions, Object[] results, Callback<R> callback)
        throws IOException, InterruptedException {
  getTable().batchCallback(actions, results, callback);

}

项目：gora-boot 文件：HBaseTableConnection.java

@Override
public <R extends Message> void batchCoprocessorService(MethodDescriptor methodDescriptor,
    Message request, byte[] startKey, byte[] endKey, R responsePrototype, Callback<R> callback)
    throws Throwable {
  getTable().batchCoprocessorService(methodDescriptor, request, startKey, endKey, responsePrototype, callback);

}