@InterfaceAudience.Private public class ThriftUtilities extends Object
Modifier and Type | Method and Description |
---|---|
static Append |
appendFromThrift(TAppend append) |
static CompareOperator |
compareOpFromThrift(TCompareOp tCompareOp) |
static TDelete |
deleteFromHBase(Delete in) |
static Delete |
deleteFromThrift(TDelete in)
|
static List<Delete> |
deletesFromThrift(List<TDelete> in)
|
static Get |
getFromThrift(TGet in)
|
static List<Get> |
getsFromThrift(List<TGet> in)
|
static Increment |
incrementFromThrift(TIncrement in) |
static Put |
putFromThrift(TPut in)
|
static List<Put> |
putsFromThrift(List<TPut> in)
|
static THRegionLocation |
regionLocationFromHBase(HRegionLocation hrl) |
static List<THRegionLocation> |
regionLocationsFromHBase(List<HRegionLocation> locations) |
static TResult |
resultFromHBase(Result in)
|
static List<TResult> |
resultsFromHBase(Result[] in)
|
static RowMutations |
rowMutationsFromThrift(TRowMutations in)
Creates a
RowMutations (HBase) from a TRowMutations (Thrift) |
static Scan |
scanFromThrift(TScan in) |
public static Get getFromThrift(TGet in) throws IOException
in
- the TGet
to convertGet
objectIOException
- if an invalid time range or max version parameter is givenpublic static List<Get> getsFromThrift(List<TGet> in) throws IOException
in
- list of TGet
s to convertGet
objectsIOException
- if an invalid time range or max version parameter is givengetFromThrift(TGet)
public static TResult resultFromHBase(Result in)
in
- the Result
to convertnull
public static List<TResult> resultsFromHBase(Result[] in)
in
- array of Result
s to convertTResult
sresultFromHBase(Result)
public static Put putFromThrift(TPut in)
in
- the TPut
to convertPut
public static List<Put> putsFromThrift(List<TPut> in)
in
- list of TPut
s to convertPut
sputFromThrift(TPut)
public static Delete deleteFromThrift(TDelete in)
in
- the TDelete
to convertDelete
public static List<Delete> deletesFromThrift(List<TDelete> in)
in
- list of TDelete
s to convertDelete
sdeleteFromThrift(TDelete)
public static RowMutations rowMutationsFromThrift(TRowMutations in) throws IOException
RowMutations
(HBase) from a TRowMutations
(Thrift)in
- the TRowMutations
to convertRowMutations
IOException
public static Scan scanFromThrift(TScan in) throws IOException
IOException
public static Increment incrementFromThrift(TIncrement in) throws IOException
IOException
public static Append appendFromThrift(TAppend append) throws IOException
IOException
public static THRegionLocation regionLocationFromHBase(HRegionLocation hrl)
public static List<THRegionLocation> regionLocationsFromHBase(List<HRegionLocation> locations)
public static CompareOperator compareOpFromThrift(TCompareOp tCompareOp)
Copyright © 2007–2019 Cloudera. All rights reserved.