本文整理汇总了Java中org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient类的典型用法代码示例。如果您正苦于以下问题：Java RowProcessorClient类的具体用法？Java RowProcessorClient怎么用？Java RowProcessorClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RowProcessorClient类属于org.apache.hadoop.hbase.client.coprocessor包，在下文中一共展示了RowProcessorClient类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testDoubleScan
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
@Test
public void testDoubleScan() throws Throwable {
prepareTestData();
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.FriendsOfFriendsProcessor processor =
new RowProcessorEndpoint.FriendsOfFriendsProcessor(ROW, A);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
ProcessResponse protoResult = service.process(null, request);
FriendsOfFriendsProcessorResponse response =
FriendsOfFriendsProcessorResponse.parseFrom(protoResult.getRowProcessorResult());
Set<String> result = new HashSet<String>();
result.addAll(response.getResultList());
Set<String> expected =
new HashSet<String>(Arrays.asList(new String[]{"d", "e", "f", "g"}));
Get get = new Get(ROW);
LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).listCells()));
assertEquals(expected, result);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:22，代码来源:TestRowProcessorEndpoint.java
示例2: testTimeout
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
@Test
public void testTimeout() throws Throwable {
prepareTestData();
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.TimeoutProcessor processor =
new RowProcessorEndpoint.TimeoutProcessor(ROW);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
boolean exceptionCaught = false;
try {
service.process(null, request);
} catch (Exception e) {
exceptionCaught = true;
}
assertTrue(exceptionCaught);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:18，代码来源:TestRowProcessorEndpoint.java
示例3: testDoubleScan
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
@Test
public void testDoubleScan() throws Throwable {
prepareTestData();
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.FriendsOfFriendsProcessor processor =
new RowProcessorEndpoint.FriendsOfFriendsProcessor(ROW, A);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
ProcessResponse protoResult = service.process(null, request);
FriendsOfFriendsProcessorResponse response =
FriendsOfFriendsProcessorResponse.parseFrom(protoResult.getRowProcessorResult());
Set<String> result = new HashSet<>();
result.addAll(response.getResultList());
Set<String> expected = new HashSet<>(Arrays.asList(new String[]{"d", "e", "f", "g"}));
Get get = new Get(ROW);
LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).listCells()));
assertEquals(expected, result);
}
开发者ID:apache，项目名称:hbase，代码行数:21，代码来源:TestRowProcessorEndpoint.java
示例4: testDoubleScan
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
@Test
public void testDoubleScan() throws Throwable {
prepareTestData();
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.FriendsOfFriendsProcessor processor =
new RowProcessorEndpoint.FriendsOfFriendsProcessor(ROW, A);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);
RowProcessorResult protoResult = service.process(null, request);
FriendsOfFriendsProcessorResponse response =
FriendsOfFriendsProcessorResponse.parseFrom(protoResult.getRowProcessorResult());
Set<String> result = new HashSet<String>();
result.addAll(response.getResultList());
Set<String> expected =
new HashSet<String>(Arrays.asList(new String[]{"d", "e", "f", "g"}));
Get get = new Get(ROW);
LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).list()));
assertEquals(expected, result);
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:22，代码来源:TestRowProcessorEndpoint.java
示例5: testTimeout
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
@Test
public void testTimeout() throws Throwable {
prepareTestData();
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.TimeoutProcessor processor =
new RowProcessorEndpoint.TimeoutProcessor(ROW);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);
boolean exceptionCaught = false;
try {
service.process(null, request);
} catch (Exception e) {
exceptionCaught = true;
}
assertTrue(exceptionCaught);
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:18，代码来源:TestRowProcessorEndpoint.java
示例6: incrementCounter
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private int incrementCounter(Table table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.IncrementCounterProcessor processor =
new RowProcessorEndpoint.IncrementCounterProcessor(ROW);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
ProcessResponse protoResult = service.process(null, request);
IncCounterProcessorResponse response = IncCounterProcessorResponse
.parseFrom(protoResult.getRowProcessorResult());
Integer result = response.getResponse();
return result;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:14，代码来源:TestRowProcessorEndpoint.java
示例7: swapRows
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private void swapRows(Table table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.RowSwapProcessor processor =
new RowProcessorEndpoint.RowSwapProcessor(ROW, ROW2);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
service.process(null, request);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:10，代码来源:TestRowProcessorEndpoint.java
示例8: incrementCounter
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private int incrementCounter(HTable table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.IncrementCounterProcessor processor =
new RowProcessorEndpoint.IncrementCounterProcessor(ROW);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
ProcessResponse protoResult = service.process(null, request);
IncCounterProcessorResponse response = IncCounterProcessorResponse
.parseFrom(protoResult.getRowProcessorResult());
Integer result = response.getResponse();
return result;
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:14，代码来源:TestRowProcessorEndpoint.java
示例9: swapRows
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private void swapRows(HTable table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.RowSwapProcessor processor =
new RowProcessorEndpoint.RowSwapProcessor(ROW, ROW2);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
ProcessRequest request = RowProcessorClient.getRowProcessorPB(processor);
service.process(null, request);
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:10，代码来源:TestRowProcessorEndpoint.java
示例10: incrementCounter
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private int incrementCounter(HTable table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.IncrementCounterProcessor processor =
new RowProcessorEndpoint.IncrementCounterProcessor(ROW);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);
RowProcessorResult protoResult = service.process(null, request);
IncCounterProcessorResponse response = IncCounterProcessorResponse
.parseFrom(protoResult.getRowProcessorResult());
Integer result = response.getResponse();
return result;
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:14，代码来源:TestRowProcessorEndpoint.java
示例11: swapRows
import org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient; //导入依赖的package包/类
private void swapRows(HTable table) throws Throwable {
CoprocessorRpcChannel channel = table.coprocessorService(ROW);
RowProcessorEndpoint.RowSwapProcessor processor =
new RowProcessorEndpoint.RowSwapProcessor(ROW, ROW2);
RowProcessorService.BlockingInterface service =
RowProcessorService.newBlockingStub(channel);
RowProcessorRequest request = RowProcessorClient.getRowProcessorPB(processor);
service.process(null, request);
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:10，代码来源:TestRowProcessorEndpoint.java
注：本文中的org.apache.hadoop.hbase.client.coprocessor.RowProcessorClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论