org.apache.hadoop.hbase.thrift2

Class ThriftUtilities

java.lang.Object

org.apache.hadoop.hbase.thrift2.ThriftUtilities

@InterfaceAudience.Private
public class ThriftUtilities
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ThriftUtilities()

Method Summary

Modifier and Type	Method and Description
private static void	addAttributes(OperationWithAttributes op, Map<ByteBuffer,ByteBuffer> attributes) Adds all the attributes into the Operation object
static Append	appendFromThrift(org.apache.hadoop.hbase.thrift2.generated.TAppend append)
static CompareOperator	compareOpFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompareOp tCompareOp)
static org.apache.hadoop.hbase.thrift2.generated.TDelete	deleteFromHBase(Delete in)
static Delete	deleteFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDelete in) Creates a Delete (HBase) from a TDelete (Thrift).
static List<Delete>	deletesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TDelete> in) Converts multiple TDeletes (Thrift) into a list of Deletes (HBase).
private static Durability	durabilityFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDurability tDurability)
static Get	getFromThrift(org.apache.hadoop.hbase.thrift2.generated.TGet in) Creates a Get (HBase) from a TGet (Thrift).
static List<Get>	getsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TGet> in) Converts multiple TGets (Thrift) into a list of Gets (HBase).
static Increment	incrementFromThrift(org.apache.hadoop.hbase.thrift2.generated.TIncrement in)
static Put	putFromThrift(org.apache.hadoop.hbase.thrift2.generated.TPut in) Creates a Put (HBase) from a TPut (Thrift)
static List<Put>	putsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TPut> in) Converts multiple TPuts (Thrift) into a list of Puts (HBase).
private static Scan.ReadType	readTypeFromThrift(org.apache.hadoop.hbase.thrift2.generated.TReadType tReadType)
static org.apache.hadoop.hbase.thrift2.generated.THRegionLocation	regionLocationFromHBase(HRegionLocation hrl)
static List<org.apache.hadoop.hbase.thrift2.generated.THRegionLocation>	regionLocationsFromHBase(List<HRegionLocation> locations)
static org.apache.hadoop.hbase.thrift2.generated.TResult	resultFromHBase(Result in) Creates a TResult (Thrift) from a Result (HBase).
static List<org.apache.hadoop.hbase.thrift2.generated.TResult>	resultsFromHBase(Result[] in) Converts multiple Results (HBase) into a list of TResults (Thrift).
static RowMutations	rowMutationsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TRowMutations in) Creates a RowMutations (HBase) from a TRowMutations (Thrift)
static Scan	scanFromThrift(org.apache.hadoop.hbase.thrift2.generated.TScan in)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThriftUtilities

private ThriftUtilities()

Method Detail

getFromThrift

public static Get getFromThrift(org.apache.hadoop.hbase.thrift2.generated.TGet in)
                         throws IOException

Creates a Get (HBase) from a TGet (Thrift). This ignores any timestamps set on TColumn objects.

Parameters:

in - the TGet to convert

Returns:

Get object

Throws:

IOException - if an invalid time range or max version parameter is given

getsFromThrift

public static List<Get> getsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TGet> in)
                                throws IOException

Converts multiple TGets (Thrift) into a list of Gets (HBase).

Parameters:

in - list of TGets to convert

Returns:

list of Get objects

Throws:

IOException - if an invalid time range or max version parameter is given

See Also:

getFromThrift(TGet)

resultFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TResult resultFromHBase(Result in)

Creates a TResult (Thrift) from a Result (HBase).

Parameters:

in - the Result to convert

Returns:

converted result, returns an empty result if the input is null

resultsFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TResult> resultsFromHBase(Result[] in)

Converts multiple Results (HBase) into a list of TResults (Thrift).

Parameters:

in - array of Results to convert

Returns:

list of converted TResults

See Also:

resultFromHBase(Result)

putFromThrift

public static Put putFromThrift(org.apache.hadoop.hbase.thrift2.generated.TPut in)

Creates a Put (HBase) from a TPut (Thrift)

Parameters:

in - the TPut to convert

Returns:

converted Put

putsFromThrift

public static List<Put> putsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TPut> in)

Converts multiple TPuts (Thrift) into a list of Puts (HBase).

Parameters:

in - list of TPuts to convert

Returns:

list of converted Puts

See Also:

putFromThrift(TPut)

deleteFromThrift

public static Delete deleteFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDelete in)

Creates a Delete (HBase) from a TDelete (Thrift).

Parameters:

in - the TDelete to convert

Returns:

converted Delete

deletesFromThrift

public static List<Delete> deletesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TDelete> in)

Converts multiple TDeletes (Thrift) into a list of Deletes (HBase).

Parameters:

in - list of TDeletes to convert

Returns:

list of converted Deletes

See Also:

deleteFromThrift(TDelete)

deleteFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TDelete deleteFromHBase(Delete in)

rowMutationsFromThrift

public static RowMutations rowMutationsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TRowMutations in)
                                           throws IOException

Creates a RowMutations (HBase) from a TRowMutations (Thrift)

Parameters:

in - the TRowMutations to convert

Returns:

converted RowMutations

Throws:

IOException

scanFromThrift

public static Scan scanFromThrift(org.apache.hadoop.hbase.thrift2.generated.TScan in)
                           throws IOException

Throws:

IOException

incrementFromThrift

public static Increment incrementFromThrift(org.apache.hadoop.hbase.thrift2.generated.TIncrement in)
                                     throws IOException

Throws:

IOException

appendFromThrift

public static Append appendFromThrift(org.apache.hadoop.hbase.thrift2.generated.TAppend append)
                               throws IOException

Throws:

IOException

regionLocationFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.THRegionLocation regionLocationFromHBase(HRegionLocation hrl)

regionLocationsFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.THRegionLocation> regionLocationsFromHBase(List<HRegionLocation> locations)

addAttributes

private static void addAttributes(OperationWithAttributes op,
                                  Map<ByteBuffer,ByteBuffer> attributes)

Adds all the attributes into the Operation object

durabilityFromThrift

private static Durability durabilityFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDurability tDurability)

compareOpFromThrift

public static CompareOperator compareOpFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompareOp tCompareOp)

readTypeFromThrift

private static Scan.ReadType readTypeFromThrift(org.apache.hadoop.hbase.thrift2.generated.TReadType tReadType)