Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.protobuf.generated |
Modifier and Type | Method and Description |
---|---|
void |
AggregateImplementation.getAvg(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives a Pair with first object as Sum and second object as row count,
computed for a given combination of column qualifier and column family in
the given row range as defined in the Scan object.
|
void |
AggregateImplementation.getMax(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives the maximum for a given combination of column qualifier and column
family, in the given row range as defined in the Scan object.
|
void |
AggregateImplementation.getMedian(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives a List containing sum of values and sum of weights.
|
void |
AggregateImplementation.getMin(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives the minimum for a given combination of column qualifier and column
family, in the given row range as defined in the Scan object.
|
void |
AggregateImplementation.getRowNum(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives the row count for the given column family and column qualifier, in
the given row range as defined in the Scan object.
|
void |
AggregateImplementation.getStd(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives a Pair with first object a List containing Sum and sum of squares,
and the second object as row count.
|
void |
AggregateImplementation.getSum(RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
Gives the sum for a given combination of column qualifier and column
family, in the given row range as defined in the Scan object.
|
Modifier and Type | Method and Description |
---|---|
AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.Builder.build() |
AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.Builder.buildPartial() |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.getDefaultInstance() |
AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.getDefaultInstanceForType() |
AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.Builder.getDefaultInstanceForType() |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseDelimitedFrom(java.io.InputStream input) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(com.google.protobuf.ByteString data) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(com.google.protobuf.CodedInputStream input) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AggregateProtos.AggregateRequest |
AggregateProtos.AggregateRequest.parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getAvg(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getAvg(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetAvg(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getAvg(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetAvg(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getAvg(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getMax(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getMax(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMax(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getMax(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMax(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getMax(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getMedian(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getMedian(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMedian(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getMedian(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMedian(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getMedian(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getMin(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getMin(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMin(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getMin(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetMin(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getMin(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getRowNum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getRowNum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetRowNum(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getRowNum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetRowNum(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getRowNum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getStd(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getStd(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetStd(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getStd(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetStd(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getStd(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
AggregateProtos.AggregateResponse |
AggregateProtos.AggregateService.BlockingInterface.getSum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request) |
abstract void |
AggregateProtos.AggregateService.getSum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetSum(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Interface.getSum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done)
rpc GetSum(.hbase.pb.AggregateRequest) returns (.hbase.pb.AggregateResponse); |
void |
AggregateProtos.AggregateService.Stub.getSum(com.google.protobuf.RpcController controller,
AggregateProtos.AggregateRequest request,
<any> done) |
static AggregateProtos.AggregateRequest.Builder |
AggregateProtos.AggregateRequest.newBuilder(AggregateProtos.AggregateRequest prototype) |