public class ColumnAggregationEndpoint extends ColumnAggregationProtos.ColumnAggregationService implements Coprocessor, CoprocessorService
ColumnAggregationProtos.ColumnAggregationService.BlockingInterface, ColumnAggregationProtos.ColumnAggregationService.Interface, ColumnAggregationProtos.ColumnAggregationService.Stub
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
ColumnAggregationEndpoint() |
Modifier and Type | Method and Description |
---|---|
Service |
getService() |
void |
start(CoprocessorEnvironment env) |
void |
stop(CoprocessorEnvironment env) |
void |
sum(RpcController controller,
ColumnAggregationProtos.SumRequest request,
<any> done)
rpc sum(.SumRequest) returns (.SumResponse); |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public Service getService()
getService
in interface CoprocessorService
public void start(CoprocessorEnvironment env) throws java.io.IOException
start
in interface Coprocessor
java.io.IOException
public void stop(CoprocessorEnvironment env) throws java.io.IOException
stop
in interface Coprocessor
java.io.IOException
public void sum(RpcController controller, ColumnAggregationProtos.SumRequest request, <any> done)
ColumnAggregationProtos.ColumnAggregationService
rpc sum(.SumRequest) returns (.SumResponse);
sum
in class ColumnAggregationProtos.ColumnAggregationService