• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java Callback类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java PlatformLogger类代码示例发布时间:2022-05-21
下一篇:
Java TextVertexInputFormat类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap