org.apache.hadoop.hbase.client.coprocessor

Class AsyncAggregationClient

java.lang.Object

org.apache.hadoop.hbase.client.coprocessor.AsyncAggregationClient

@InterfaceAudience.Public
public final class AsyncAggregationClient
extends Object

This client class is for invoking the aggregate functions deployed on the Region Server side via the AggregateService. This class will implement the supporting functionality for summing/processing the individual results obtained from the AggregateService for each region.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	AsyncAggregationClient.AbstractAggregationCallback<T>

Constructor Summary

Constructors

Modifier	Constructor and Description
private	AsyncAggregationClient()

Method Summary

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>	avg(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> void	findMedian(CompletableFuture<R> future, AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan, NavigableMap<byte[],S> sumByRegion)
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R	getCellValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp, int firstPartIndex)
private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> S	getPromotedValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp, int firstPartIndex)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	max(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	median(AsyncTable<AdvancedScanResultConsumer> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R>	min(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
private static byte[]	nullToEmpty(byte[] b)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Long>	rowCount(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double>	std(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<S>	sum(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)
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>>	sumByRegion(AsyncTable<?> table, ColumnInterpreter<R,S,P,Q,T> ci, Scan scan)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncAggregationClient

private AsyncAggregationClient()

Method Detail

getCellValueFromProto

private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> R getCellValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                               org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp,
                                                                                                                                                               int firstPartIndex)
                                                                                                                                                        throws IOException

Throws:

IOException

getPromotedValueFromProto

private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> S getPromotedValueFromProto(ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                   org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp,
                                                                                                                                                                   int firstPartIndex)
                                                                                                                                                            throws IOException

Throws:

IOException

nullToEmpty

private static byte[] nullToEmpty(byte[] b)

max

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R> max(AsyncTable<?> table,
                                                                                                                                                               ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                               Scan scan)

min

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R> min(AsyncTable<?> table,
                                                                                                                                                               ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                               Scan scan)

rowCount

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Long> rowCount(AsyncTable<?> table,
                                                                                                                                                                       ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                       Scan scan)

sum

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<S> sum(AsyncTable<?> table,
                                                                                                                                                               ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                               Scan scan)

avg

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double> avg(AsyncTable<?> table,
                                                                                                                                                                    ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                    Scan scan)

std

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<Double> std(AsyncTable<?> table,
                                                                                                                                                                    ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                    Scan scan)

sumByRegion

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>> sumByRegion(AsyncTable<?> table,
                                                                                                                                                                                             ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                                             Scan scan)

findMedian

private static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> void findMedian(CompletableFuture<R> future,
                                                                                                                                                       AsyncTable<AdvancedScanResultConsumer> table,
                                                                                                                                                       ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                       Scan scan,
                                                                                                                                                       NavigableMap<byte[],S> sumByRegion)

median

public static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> CompletableFuture<R> median(AsyncTable<AdvancedScanResultConsumer> table,
                                                                                                                                                                  ColumnInterpreter<R,S,P,Q,T> ci,
                                                                                                                                                                  Scan scan)