本文整理汇总了Java中org.apache.hadoop.hbase.client.coprocessor.Batch.Callback类的典型用法代码示例。如果您正苦于以下问题：Java Callback类的具体用法？Java Callback怎么用？Java Callback使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Callback类属于org.apache.hadoop.hbase.client.coprocessor.Batch包，在下文中一共展示了Callback类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: coprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
/**
* {@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;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:20，代码来源:HTable.java
示例2: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
/**
* {@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;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:22，代码来源:HTable.java
示例3: testSubmitWithCB
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:21，代码来源:TestAsyncProcess.java
示例4: coprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
/**
* {@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;
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:19，代码来源:HTable.java
示例5: doBatchWithCallback
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
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();
}
}
开发者ID:apache，项目名称:hbase，代码行数:23，代码来源:HTable.java
示例6: coprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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;
}
开发者ID:apache，项目名称:hbase，代码行数:17，代码来源:HTable.java
示例7: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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;
}
开发者ID:apache，项目名称:hbase，代码行数:18，代码来源:HTable.java
示例8: sumInBatch
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
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;
}
开发者ID:intel-hadoop，项目名称:CSBT，代码行数:27，代码来源:TestCrossSiteCoprocessor.java
示例9: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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;
}
开发者ID:intel-hadoop，项目名称:CSBT，代码行数:19，代码来源:CrossSiteHTable.java
示例10: testSubmitWithCB
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:shenli-uiuc，项目名称:PyroDB，代码行数:20，代码来源:TestAsyncProcess.java
示例11: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:HTableWrapper.java
示例12: batchCallback
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
/**
* {@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:10，代码来源:HTable.java
示例13: coprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:HTablePool.java
示例14: batchCallback
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@Override
public <R> void batchCallback(List<? extends Row> actions,
Object[] results, Callback<R> callback) throws IOException,
InterruptedException {
checkState();
table.batchCallback(actions, results, callback);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:HTablePool.java
示例15: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:9，代码来源:HTablePool.java
示例16: createAsyncRequestFuture
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:12，代码来源:TestAsyncProcess.java
示例17: submit
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:TestAsyncProcess.java
示例18: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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");
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:RemoteHTable.java
示例19: batchCoprocessorService
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
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
}
开发者ID:cloudera-labs，项目名称:hbase.mcc，代码行数:8，代码来源:HTableMultiCluster.java
示例20: processBatchCallback
import org.apache.hadoop.hbase.client.coprocessor.Batch.Callback; //导入依赖的package包/类
@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);
}
开发者ID:cloudera-labs，项目名称:hbase.mcc，代码行数:8，代码来源:HConnectionMultiCluster.java
注：本文中的org.apache.hadoop.hbase.client.coprocessor.Batch.Callback类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论