Uses of Class
org.apache.hadoop.hbase.coprocessor.ColumnInterpreter

Packages that use ColumnInterpreter

Package	Description
org.apache.hadoop.hbase.client.coprocessor	Provides client classes for invoking Coprocessor RPC protocols Overview Example Usage
org.apache.hadoop.hbase.coprocessor	Table of Contents

Uses of ColumnInterpreter in org.apache.hadoop.hbase.client.coprocessor

Subclasses of ColumnInterpreter in org.apache.hadoop.hbase.client.coprocessor

Modifier and Type	Class and Description
class	BigDecimalColumnInterpreter ColumnInterpreter for doing Aggregation's with BigDecimal columns.
class	DoubleColumnInterpreter a concrete column interpreter implementation.
class	LongColumnInterpreter a concrete column interpreter implementation.

Methods in org.apache.hadoop.hbase.client.coprocessor with parameters of type ColumnInterpreter

Modifier and Type	Method and Description
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double>	AsyncAggregationClient.avg(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> double	AggregationClient.avg(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handle for calling the average method for a given cf-cq combination.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> double	AggregationClient.avg(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handle for calling the average method for a given cf-cq combination.
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> void	AsyncAggregationClient.findMedian(CompletableFuture<R> future, AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan, NavigableMap<byte[],S> sumByRegion)
private <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> Pair<S,Long>	AggregationClient.getAvgArgs(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It computes average while fetching sum and row count from all the corresponding regions.
private <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> Pair<S,Long>	AggregationClient.getAvgArgs(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It computes average while fetching sum and row count from all the corresponding regions.
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AsyncAggregationClient.getCellValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp, int firstPartIndex)
private <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> Pair<NavigableMap<byte[],List<S>>,List<S>>	AggregationClient.getMedianArgs(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It helps locate the region with median for a given column whose weight is specified in an optional column.
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> S	AsyncAggregationClient.getPromotedValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp, int firstPartIndex)
private <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> Pair<List<S>,Long>	AggregationClient.getStdArgs(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It computes a global standard deviation for a given column and its value.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.max(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.max(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the maximum value of a column for a given column family for the given range.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.max(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the maximum value of a column for a given column family for the given range.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.median(AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.median(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handler for calling the median method for a given cf-cq combination.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.median(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handler for calling the median method for a given cf-cq combination.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	AsyncAggregationClient.min(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.min(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the minimum value of a column for a given column family for the given range.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	AggregationClient.min(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the minimum value of a column for a given column family for the given range.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Long>	AsyncAggregationClient.rowCount(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> long	AggregationClient.rowCount(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the row count, by summing up the individual results obtained from regions.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> long	AggregationClient.rowCount(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It gives the row count, by summing up the individual results obtained from regions.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double>	AsyncAggregationClient.std(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> double	AggregationClient.std(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handle for calling the std method for a given cf-cq combination.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> double	AggregationClient.std(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) This is the client side interface/handle for calling the std method for a given cf-cq combination.
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<S>	AsyncAggregationClient.sum(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> S	AggregationClient.sum(Table table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It sums up the value returned from various regions.
<R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> S	AggregationClient.sum(TableName tableName, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan) It sums up the value returned from various regions.
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<NavigableMap<byte[],S>>	AsyncAggregationClient.sumByRegion(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
(package private) static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest	AggregationHelper.validateArgAndGetPB(Scan scan, ColumnInterpreter<R,S,P,Q,T> ci, boolean canFamilyBeAbsent)

Uses of ColumnInterpreter in org.apache.hadoop.hbase.coprocessor

Methods in org.apache.hadoop.hbase.coprocessor that return ColumnInterpreter

Modifier and Type	Method and Description
(package private) ColumnInterpreter<T,S,P,Q,R>	AggregateImplementation.constructColumnInterpreterFromRequest(org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest request)