org.apache.hadoop.hbase.client

Class MultiResponse

java.lang.Object

org.apache.hadoop.hbase.client.AbstractResponse

org.apache.hadoop.hbase.client.MultiResponse

@InterfaceAudience.Private
public class MultiResponse
extends AbstractResponse

A container for Result objects, grouped by regionName.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	MultiResponse.RegionResult

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.AbstractResponse

AbstractResponse.ResponseType

Field Summary

Fields

Modifier and Type	Field and Description
private Map<byte[],Throwable>	exceptions The server can send us a failure for the region itself, instead of individual failure.
private Map<byte[],MultiResponse.RegionResult>	results

Constructor Summary

Constructors

Constructor and Description
MultiResponse()

Method Summary

Modifier and Type	Method and Description
void	add(byte[] regionName, int originalIndex, Object resOrEx) Add the pair to the container, grouped by the regionName
void	addException(byte[] regionName, Throwable ie)
void	addStatistic(byte[] regionName, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionLoadStats stat)
Throwable	getException(byte[] regionName)
Map<byte[],Throwable>	getExceptions()
private MultiResponse.RegionResult	getResult(byte[] region)
Map<byte[],MultiResponse.RegionResult>	getResults()
int	size()
AbstractResponse.ResponseType	type()

Methods inherited from class java.lang.Object

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

Field Detail

results

private Map<byte[],MultiResponse.RegionResult> results

exceptions

private Map<byte[],Throwable> exceptions

The server can send us a failure for the region itself, instead of individual failure. It's a part of the protobuf definition.

Constructor Detail

MultiResponse

public MultiResponse()

Method Detail

size

public int size()

Returns:

Number of pairs in this container

add

public void add(byte[] regionName,
                int originalIndex,
                Object resOrEx)

Add the pair to the container, grouped by the regionName

Parameters:

regionName -

originalIndex - the original index of the Action (request).

resOrEx - the result or error; will be empty for successful Put and Delete actions.

addException

public void addException(byte[] regionName,
                         Throwable ie)

getException

public Throwable getException(byte[] regionName)

Returns:

the exception for the region, if any. Null otherwise.

getExceptions

public Map<byte[],Throwable> getExceptions()

addStatistic

public void addStatistic(byte[] regionName,
                         org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionLoadStats stat)

getResult

private MultiResponse.RegionResult getResult(byte[] region)

getResults

public Map<byte[],MultiResponse.RegionResult> getResults()

type

public AbstractResponse.ResponseType type()

Specified by:

type in class AbstractResponse