org.apache.hadoop.hbase.client.coprocessor

Class AsyncAggregationClient.AbstractAggregationCallback<T>

java.lang.Object

org.apache.hadoop.hbase.client.coprocessor.AsyncAggregationClient.AbstractAggregationCallback<T>

All Implemented Interfaces:

AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>

Enclosing class:

AsyncAggregationClient

private abstract static class AsyncAggregationClient.AbstractAggregationCallback<T>
extends Object
implements AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	finished
private CompletableFuture<T>	future

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractAggregationCallback(CompletableFuture<T> future)

Method Summary

Modifier and Type	Method and Description
protected abstract void	aggregate(RegionInfo region, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp)
private void	completeExceptionally(Throwable error)
protected abstract T	getFinalResult()
void	onComplete() Indicate that all responses of the regions have been notified by calling AsyncTable.CoprocessorCallback.onRegionComplete(RegionInfo, Object) or AsyncTable.CoprocessorCallback.onRegionError(RegionInfo, Throwable).
void	onError(Throwable error) Indicate that we got an error which does not belong to any regions.
void	onRegionComplete(RegionInfo region, org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp)
void	onRegionError(RegionInfo region, Throwable error)

Methods inherited from class java.lang.Object

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

Field Detail

future

private final CompletableFuture<T> future

finished

protected boolean finished

Constructor Detail

AbstractAggregationCallback

protected AbstractAggregationCallback(CompletableFuture<T> future)

Method Detail

completeExceptionally

private void completeExceptionally(Throwable error)

onRegionError

public void onRegionError(RegionInfo region,
                          Throwable error)

Specified by:

onRegionError in interface AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>

Parameters:

region - the region that the error belongs to

error - the response error of the coprocessor call

onError

public void onError(Throwable error)

Description copied from interface: AsyncTable.CoprocessorCallback

Indicate that we got an error which does not belong to any regions. Usually a locating error.

Specified by:

onError in interface AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>

aggregate

protected abstract void aggregate(RegionInfo region,
                                  org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp)
                           throws IOException

Throws:

IOException

onRegionComplete

public void onRegionComplete(RegionInfo region,
                             org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse resp)

Specified by:

onRegionComplete in interface AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>

Parameters:

region - the region that the response belongs to

resp - the response of the coprocessor call

getFinalResult

protected abstract T getFinalResult()

onComplete

public void onComplete()

Description copied from interface: AsyncTable.CoprocessorCallback

Indicate that all responses of the regions have been notified by calling AsyncTable.CoprocessorCallback.onRegionComplete(RegionInfo, Object) or AsyncTable.CoprocessorCallback.onRegionError(RegionInfo, Throwable).

Specified by:

onComplete in interface AsyncTable.CoprocessorCallback<org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse>