本文整理汇总了Java中org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos类的典型用法代码示例。如果您正苦于以下问题：Java ColumnAggregationWithErrorsProtos类的具体用法？Java ColumnAggregationWithErrorsProtos怎么用？Java ColumnAggregationWithErrorsProtos使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ColumnAggregationWithErrorsProtos类属于org.apache.hadoop.hbase.coprocessor.protobuf.generated包，在下文中一共展示了ColumnAggregationWithErrorsProtos类的3个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testAggregationWithErrors
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos; //导入依赖的package包/类
@Test
public void testAggregationWithErrors() throws Throwable {
Table table = new HTable(util.getConfiguration(), TEST_TABLE);
final Map<byte[], ColumnAggregationWithErrorsProtos.SumResponse> results =
Collections.synchronizedMap(
new TreeMap<byte[], ColumnAggregationWithErrorsProtos.SumResponse>(
Bytes.BYTES_COMPARATOR
));
ColumnAggregationWithErrorsProtos.SumRequest.Builder builder =
ColumnAggregationWithErrorsProtos.SumRequest
.newBuilder();
builder.setFamily(ByteStringer.wrap(TEST_FAMILY));
if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
builder.setQualifier(ByteStringer.wrap(TEST_QUALIFIER));
}
boolean hasError = false;
try {
table.batchCoprocessorService(
ColumnAggregationWithErrorsProtos.ColumnAggregationServiceWithErrors.getDescriptor()
.findMethodByName("sum"),
builder.build(), ROWS[0], ROWS[ROWS.length - 1],
ColumnAggregationWithErrorsProtos.SumResponse.getDefaultInstance(),
new Batch.Callback<ColumnAggregationWithErrorsProtos.SumResponse>() {
@Override
public void update(byte[] region, byte[] row,
ColumnAggregationWithErrorsProtos.SumResponse result) {
results.put(region, result);
}
});
} catch (Throwable t) {
LOG.info("Exceptions in coprocessor service", t);
hasError = true;
}
int sumResult = 0;
int expectedResult = 0;
for (Map.Entry<byte[], ColumnAggregationWithErrorsProtos.SumResponse> e : results.entrySet()) {
LOG.info("Got value " + e.getValue().getSum() + " for region "
+ Bytes.toStringBinary(e.getKey()));
sumResult += e.getValue().getSum();
}
for (int i = 0; i < rowSeperator2; i++) {
expectedResult += i;
}
assertEquals("Invalid result", expectedResult, sumResult);
assertTrue(hasError);
table.close();
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:51，代码来源:TestBatchCoprocessorEndpoint.java
示例2: testAggregationWithErrors
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos; //导入依赖的package包/类
@Test
public void testAggregationWithErrors() throws Throwable {
HTable table = new HTable(util.getConfiguration(), TEST_TABLE);
final Map<byte[], ColumnAggregationWithErrorsProtos.SumResponse> results =
Collections.synchronizedMap(
new TreeMap<byte[], ColumnAggregationWithErrorsProtos.SumResponse>(
Bytes.BYTES_COMPARATOR
));
ColumnAggregationWithErrorsProtos.SumRequest.Builder builder =
ColumnAggregationWithErrorsProtos.SumRequest
.newBuilder();
builder.setFamily(HBaseZeroCopyByteString.wrap(TEST_FAMILY));
if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
builder.setQualifier(HBaseZeroCopyByteString.wrap(TEST_QUALIFIER));
}
boolean hasError = false;
try {
table.batchCoprocessorService(
ColumnAggregationWithErrorsProtos.ColumnAggregationServiceWithErrors.getDescriptor()
.findMethodByName("sum"),
builder.build(), ROWS[0], ROWS[ROWS.length - 1],
ColumnAggregationWithErrorsProtos.SumResponse.getDefaultInstance(),
new Batch.Callback<ColumnAggregationWithErrorsProtos.SumResponse>() {
@Override
public void update(byte[] region, byte[] row,
ColumnAggregationWithErrorsProtos.SumResponse result) {
results.put(region, result);
}
});
} catch (Throwable t) {
LOG.info("Exceptions in coprocessor service", t);
hasError = true;
}
int sumResult = 0;
int expectedResult = 0;
for (Map.Entry<byte[], ColumnAggregationWithErrorsProtos.SumResponse> e : results.entrySet()) {
LOG.info("Got value " + e.getValue().getSum() + " for region "
+ Bytes.toStringBinary(e.getKey()));
sumResult += e.getValue().getSum();
}
for (int i = 0; i < rowSeperator2; i++) {
expectedResult += i;
}
assertEquals("Invalid result", expectedResult, sumResult);
assertTrue(hasError);
table.close();
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:51，代码来源:TestBatchCoprocessorEndpoint.java
示例3: testAggregationWithErrors
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos; //导入依赖的package包/类
@Test
public void testAggregationWithErrors() throws Throwable {
Table table = util.getConnection().getTable(TEST_TABLE);
final Map<byte[], ColumnAggregationWithErrorsSumResponse> results =
Collections.synchronizedMap(
new TreeMap<byte[], ColumnAggregationWithErrorsSumResponse>(
Bytes.BYTES_COMPARATOR
));
ColumnAggregationWithErrorsSumRequest.Builder builder =
ColumnAggregationWithErrorsSumRequest
.newBuilder();
builder.setFamily(ByteString.copyFrom(TEST_FAMILY));
if (TEST_QUALIFIER != null && TEST_QUALIFIER.length > 0) {
builder.setQualifier(ByteString.copyFrom(TEST_QUALIFIER));
}
boolean hasError = false;
try {
table.batchCoprocessorService(
ColumnAggregationWithErrorsProtos.ColumnAggregationServiceWithErrors.getDescriptor()
.findMethodByName("sum"),
builder.build(), ROWS[0], ROWS[ROWS.length - 1],
ColumnAggregationWithErrorsSumResponse.getDefaultInstance(),
new Batch.Callback<ColumnAggregationWithErrorsSumResponse>() {
@Override
public void update(byte[] region, byte[] row,
ColumnAggregationWithErrorsSumResponse result) {
results.put(region, result);
}
});
} catch (Throwable t) {
LOG.info("Exceptions in coprocessor service", t);
hasError = true;
}
int sumResult = 0;
int expectedResult = 0;
for (Map.Entry<byte[], ColumnAggregationWithErrorsSumResponse> e : results.entrySet()) {
LOG.info("Got value " + e.getValue().getSum() + " for region "
+ Bytes.toStringBinary(e.getKey()));
sumResult += e.getValue().getSum();
}
for (int i = 0; i < rowSeperator2; i++) {
expectedResult += i;
}
assertEquals("Invalid result", expectedResult, sumResult);
assertTrue(hasError);
table.close();
}
开发者ID:apache，项目名称:hbase，代码行数:51，代码来源:TestBatchCoprocessorEndpoint.java
注：本文中的org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论