org.apache.hadoop.hbase.thrift2

Class ThriftUtilities

java.lang.Object

org.apache.hadoop.hbase.thrift2.ThriftUtilities

@InterfaceAudience.Private
public class ThriftUtilities
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private static Cell[]	EMPTY_CELL_ARRAY
private static Result	EMPTY_RESULT
private static Result	EMPTY_RESULT_STALE

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 org.apache.hadoop.hbase.thrift2.generated.TAppend	appendFromHBase(Append in)
static Append	appendFromThrift(org.apache.hadoop.hbase.thrift2.generated.TAppend append)
static org.apache.hadoop.hbase.thrift2.generated.TBloomFilterType	bloomFilterFromHBase(BloomType in)
static BloomType	bloomFilterFromThrift(org.apache.hadoop.hbase.thrift2.generated.TBloomFilterType in)
static org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor	columnFamilyDescriptorFromHBase(ColumnFamilyDescriptor in)
static ColumnFamilyDescriptor	columnFamilyDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor in)
static org.apache.hadoop.hbase.thrift2.generated.TCompareOp	compareOpFromHBase(CompareOperator compareOp)
static CompareOperator	compareOpFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompareOp tCompareOp)
static org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm	compressionAlgorithmFromHBase(Compression.Algorithm in)
static Compression.Algorithm	compressionAlgorithmFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm in)
private static org.apache.hadoop.hbase.thrift2.generated.TConsistency	consistencyFromHBase(Consistency consistency)
private static Consistency	consistencyFromThrift(org.apache.hadoop.hbase.thrift2.generated.TConsistency tConsistency)
static org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding	dataBlockEncodingFromHBase(DataBlockEncoding in)
static DataBlockEncoding	dataBlockEncodingFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding in)
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<org.apache.hadoop.hbase.thrift2.generated.TDelete>	deletesFromHBase(List<Delete> in)
static List<Delete>	deletesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TDelete> in) Converts multiple TDeletes (Thrift) into a list of Deletes (HBase).
static org.apache.hadoop.hbase.thrift2.generated.TDeleteType	deleteTypeFromHBase(Cell.Type type)
private static org.apache.hadoop.hbase.thrift2.generated.TDurability	durabilityFromHBase(Durability durability)
private static Durability	durabilityFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDurability tDurability)
static byte[]	filterFromHBase(Filter filter)
static Filter	filterFromThrift(byte[] filterBytes)
static org.apache.hadoop.hbase.thrift2.generated.TGet	getFromHBase(Get in)
static Get	getFromThrift(org.apache.hadoop.hbase.thrift2.generated.TGet in) Creates a Get (HBase) from a TGet (Thrift).
static List<org.apache.hadoop.hbase.thrift2.generated.TGet>	getsFromHBase(List<Get> in)
static List<Get>	getsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TGet> in) Converts multiple TGets (Thrift) into a list of Gets (HBase).
static HTableDescriptor	hTableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in)
static HTableDescriptor[]	hTableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in)
static org.apache.hadoop.hbase.thrift2.generated.TIncrement	incrementFromHBase(Increment in)
static Increment	incrementFromThrift(org.apache.hadoop.hbase.thrift2.generated.TIncrement in)
static org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCells	keepDeletedCellsFromHBase(KeepDeletedCells in)
static KeepDeletedCells	keepDeletedCellsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCells in)
static org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor	namespaceDescriptorFromHBase(NamespaceDescriptor in)
static NamespaceDescriptor	namespaceDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor in)
static List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor>	namespaceDescriptorsFromHBase(NamespaceDescriptor[] in)
static NamespaceDescriptor[]	namespaceDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor> in)
static org.apache.hadoop.hbase.thrift2.generated.TPut	putFromHBase(Put in)
static Put	putFromThrift(org.apache.hadoop.hbase.thrift2.generated.TPut in) Creates a Put (HBase) from a TPut (Thrift)
static List<org.apache.hadoop.hbase.thrift2.generated.TPut>	putsFromHBase(List<Put> in)
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 org.apache.hadoop.hbase.thrift2.generated.TReadType	readTypeFromHBase(Scan.ReadType readType)
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 Result	resultFromThrift(org.apache.hadoop.hbase.thrift2.generated.TResult in)
static List<org.apache.hadoop.hbase.thrift2.generated.TResult>	resultsFromHBase(Result[] in) Converts multiple Results (HBase) into a list of TResults (Thrift).
static Result[]	resultsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TResult> in)
static org.apache.hadoop.hbase.thrift2.generated.TRowMutations	rowMutationsFromHBase(RowMutations in)
static RowMutations	rowMutationsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TRowMutations in) Creates a RowMutations (HBase) from a TRowMutations (Thrift)
static org.apache.hadoop.hbase.thrift2.generated.TScan	scanFromHBase(Scan in)
static Scan	scanFromThrift(org.apache.hadoop.hbase.thrift2.generated.TScan in)
static List<ByteBuffer>	splitKeyFromHBase(byte[][] in)
static byte[][]	splitKeyFromThrift(List<ByteBuffer> in)
static org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor	tableDescriptorFromHBase(TableDescriptor in)
static TableDescriptor	tableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in)
static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor>	tableDescriptorsFromHBase(List<TableDescriptor> in)
static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor>	tableDescriptorsFromHBase(TableDescriptor[] in)
static List<TableDescriptor>	tableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in)
static org.apache.hadoop.hbase.thrift2.generated.TTableName	tableNameFromHBase(TableName table)
static TableName	tableNameFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableName tableName)
static TableName[]	tableNamesArrayFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNames)
static List<org.apache.hadoop.hbase.thrift2.generated.TTableName>	tableNamesFromHBase(List<TableName> in)
static List<org.apache.hadoop.hbase.thrift2.generated.TTableName>	tableNamesFromHBase(TableName[] in)
static List<TableName>	tableNamesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNames)
static Cell	toCell(ExtendedCellBuilder cellBuilder, byte[] row, org.apache.hadoop.hbase.thrift2.generated.TColumnValue columnValue)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_CELL_ARRAY

private static final Cell[] EMPTY_CELL_ARRAY

EMPTY_RESULT

private static final Result EMPTY_RESULT

EMPTY_RESULT_STALE

private static final Result EMPTY_RESULT_STALE

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)

deleteTypeFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TDeleteType deleteTypeFromHBase(Cell.Type type)

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

filterFromHBase

public static byte[] filterFromHBase(Filter filter)
                              throws IOException

Throws:

IOException

filterFromThrift

public static Filter filterFromThrift(byte[] filterBytes)
                               throws IOException

Throws:

IOException

scanFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TScan scanFromHBase(Scan 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)

readTypeFromHBase

private static org.apache.hadoop.hbase.thrift2.generated.TReadType readTypeFromHBase(Scan.ReadType readType)

consistencyFromThrift

private static Consistency consistencyFromThrift(org.apache.hadoop.hbase.thrift2.generated.TConsistency tConsistency)

tableNameFromThrift

public static TableName tableNameFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableName tableName)

tableNamesArrayFromThrift

public static TableName[] tableNamesArrayFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNames)

tableNamesFromThrift

public static List<TableName> tableNamesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNames)

tableNameFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TTableName tableNameFromHBase(TableName table)

tableNamesFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNamesFromHBase(List<TableName> in)

tableNamesFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNamesFromHBase(TableName[] in)

splitKeyFromThrift

public static byte[][] splitKeyFromThrift(List<ByteBuffer> in)

bloomFilterFromThrift

public static BloomType bloomFilterFromThrift(org.apache.hadoop.hbase.thrift2.generated.TBloomFilterType in)

compressionAlgorithmFromThrift

public static Compression.Algorithm compressionAlgorithmFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm in)

dataBlockEncodingFromThrift

public static DataBlockEncoding dataBlockEncodingFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding in)

keepDeletedCellsFromThrift

public static KeepDeletedCells keepDeletedCellsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCells in)

columnFamilyDescriptorFromThrift

public static ColumnFamilyDescriptor columnFamilyDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor in)

namespaceDescriptorFromThrift

public static NamespaceDescriptor namespaceDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor in)

namespaceDescriptorFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor namespaceDescriptorFromHBase(NamespaceDescriptor in)

namespaceDescriptorsFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor> namespaceDescriptorsFromHBase(NamespaceDescriptor[] in)

tableDescriptorFromThrift

public static TableDescriptor tableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in)

hTableDescriptorFromThrift

public static HTableDescriptor hTableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in)

hTableDescriptorsFromThrift

public static HTableDescriptor[] hTableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in)

tableDescriptorsFromThrift

public static List<TableDescriptor> tableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in)

durabilityFromHBase

private static org.apache.hadoop.hbase.thrift2.generated.TDurability durabilityFromHBase(Durability durability)

tableDescriptorFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor tableDescriptorFromHBase(TableDescriptor in)

tableDescriptorsFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> tableDescriptorsFromHBase(List<TableDescriptor> in)

tableDescriptorsFromHBase

public static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> tableDescriptorsFromHBase(TableDescriptor[] in)

bloomFilterFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TBloomFilterType bloomFilterFromHBase(BloomType in)

compressionAlgorithmFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm compressionAlgorithmFromHBase(Compression.Algorithm in)

dataBlockEncodingFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding dataBlockEncodingFromHBase(DataBlockEncoding in)

keepDeletedCellsFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCells keepDeletedCellsFromHBase(KeepDeletedCells in)

columnFamilyDescriptorFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor columnFamilyDescriptorFromHBase(ColumnFamilyDescriptor in)

consistencyFromHBase

private static org.apache.hadoop.hbase.thrift2.generated.TConsistency consistencyFromHBase(Consistency consistency)

getFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TGet getFromHBase(Get in)

toCell

public static Cell toCell(ExtendedCellBuilder cellBuilder,
                          byte[] row,
                          org.apache.hadoop.hbase.thrift2.generated.TColumnValue columnValue)

resultFromThrift

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

putFromHBase

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

putsFromHBase

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

namespaceDescriptorsFromThrift

public static NamespaceDescriptor[] namespaceDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor> in)

deletesFromHBase

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

appendFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TAppend appendFromHBase(Append in)
                                                                         throws IOException

Throws:

IOException

incrementFromHBase

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

Throws:

IOException

rowMutationsFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TRowMutations rowMutationsFromHBase(RowMutations in)

compareOpFromHBase

public static org.apache.hadoop.hbase.thrift2.generated.TCompareOp compareOpFromHBase(CompareOperator compareOp)

splitKeyFromHBase

public static List<ByteBuffer> splitKeyFromHBase(byte[][] in)

resultsFromThrift

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

getsFromHBase

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