Package org.apache.hadoop.hbase.thrift2
Class ThriftUtilities
java.lang.Object
org.apache.hadoop.hbase.thrift2.ThriftUtilities
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final ExtendedCell[]private static final Resultprivate static final Result -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static voidaddAttributes(OperationWithAttributes op, Map<ByteBuffer, ByteBuffer> attributes) Adds all the attributes into the Operation objectstatic org.apache.hadoop.hbase.thrift2.generated.TAppendstatic AppendappendFromThrift(org.apache.hadoop.hbase.thrift2.generated.TAppend append) static org.apache.hadoop.hbase.thrift2.generated.TBloomFilterTypestatic BloomTypebloomFilterFromThrift(org.apache.hadoop.hbase.thrift2.generated.TBloomFilterType in) static org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptorstatic ColumnFamilyDescriptorcolumnFamilyDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor in) static org.apache.hadoop.hbase.thrift2.generated.TCompareOperatorcompareOpFromHBase(CompareOperator compareOp) static CompareOperatorcompareOpFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompareOperator tCompareOp) static org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithmstatic Compression.AlgorithmcompressionAlgorithmFromThrift(org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm in) private static org.apache.hadoop.hbase.thrift2.generated.TConsistencyconsistencyFromHBase(Consistency consistency) private static ConsistencyconsistencyFromThrift(org.apache.hadoop.hbase.thrift2.generated.TConsistency tConsistency) static org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncodingstatic DataBlockEncodingdataBlockEncodingFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding in) static org.apache.hadoop.hbase.thrift2.generated.TDeletestatic DeletedeleteFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDelete in) Creates aDelete(HBase) from aTDelete(Thrift).static List<org.apache.hadoop.hbase.thrift2.generated.TDelete>deletesFromHBase(List<Delete> in) deletesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TDelete> in) Converts multipleTDeletes (Thrift) into a list ofDeletes (HBase).static org.apache.hadoop.hbase.thrift2.generated.TDeleteTypedeleteTypeFromHBase(Cell.Type type) private static org.apache.hadoop.hbase.thrift2.generated.TDurabilitydurabilityFromHBase(Durability durability) private static DurabilitydurabilityFromThrift(org.apache.hadoop.hbase.thrift2.generated.TDurability tDurability) static byte[]filterFromHBase(Filter filter) static FilterfilterFromThrift(byte[] filterBytes) private static LogQueryFilter.FilterByOperatorgetFilterByFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tLogQueryFilter) static org.apache.hadoop.hbase.thrift2.generated.TGetgetFromHBase(Get in) static GetgetFromThrift(org.apache.hadoop.hbase.thrift2.generated.TGet in) Creates aGet(HBase) from aTGet(Thrift).private static LogQueryFilter.TypegetLogTypeFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tSlowLogQueryFilter) static Set<org.apache.hadoop.hbase.thrift2.generated.TServerName>getServerNamesFromHBase(Set<ServerName> serverNames) static Set<ServerName>getServerNamesFromThrift(Set<org.apache.hadoop.hbase.thrift2.generated.TServerName> tServerNames) static List<org.apache.hadoop.hbase.thrift2.generated.TGet>getsFromHBase(List<Get> in) getsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TGet> in) Converts multipleTGets (Thrift) into a list ofGets (HBase).static org.apache.hadoop.hbase.thrift2.generated.TLogQueryFiltergetSlowLogQueryFromHBase(LogQueryFilter logQueryFilter) static LogQueryFiltergetSlowLogQueryFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tLogQueryFilter) static List<org.apache.hadoop.hbase.thrift2.generated.TOnlineLogRecord>getSlowLogRecordsFromHBase(List<OnlineLogRecord> onlineLogRecords) static List<OnlineLogRecord>getSlowLogRecordsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TOnlineLogRecord> tOnlineLogRecords) private static org.apache.hadoop.hbase.thrift2.generated.TFilterByOperatorgetTFilterByFromHBase(LogQueryFilter logQueryFilter) private static org.apache.hadoop.hbase.thrift2.generated.TLogTypegettLogTypeFromHBase(LogQueryFilter logQueryFilter) static org.apache.hadoop.hbase.thrift2.generated.TIncrementstatic IncrementincrementFromThrift(org.apache.hadoop.hbase.thrift2.generated.TIncrement in) static org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCellsstatic KeepDeletedCellskeepDeletedCellsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TKeepDeletedCells in) static org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptorstatic NamespaceDescriptornamespaceDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor in) static List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor>static NamespaceDescriptor[]namespaceDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TNamespaceDescriptor> in) static Permission.Action[]permissionActionsFromString(String permission_actions) static org.apache.hadoop.hbase.thrift2.generated.TPutputFromHBase(Put in) static PutputFromThrift(org.apache.hadoop.hbase.thrift2.generated.TPut in) Creates aPut(HBase) from aTPut(Thrift)static List<org.apache.hadoop.hbase.thrift2.generated.TPut>putsFromHBase(List<Put> in) putsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TPut> in) Converts multipleTPuts (Thrift) into a list ofPuts (HBase).private static org.apache.hadoop.hbase.thrift2.generated.TReadTypereadTypeFromHBase(Scan.ReadType readType) private static Scan.ReadTypereadTypeFromThrift(org.apache.hadoop.hbase.thrift2.generated.TReadType tReadType) static org.apache.hadoop.hbase.thrift2.generated.THRegionLocationstatic List<org.apache.hadoop.hbase.thrift2.generated.THRegionLocation>regionLocationsFromHBase(List<HRegionLocation> locations) static org.apache.hadoop.hbase.thrift2.generated.TResultCreates aTResult(Thrift) from aResult(HBase).static ResultresultFromThrift(org.apache.hadoop.hbase.thrift2.generated.TResult in) static List<org.apache.hadoop.hbase.thrift2.generated.TResult>resultsFromHBase(Result[] in) Converts multipleResults (HBase) into a list ofTResults (Thrift).static Result[]resultsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TResult> in) static org.apache.hadoop.hbase.thrift2.generated.TRowMutationsstatic RowMutationsrowMutationsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TRowMutations in) Creates aRowMutations(HBase) from aTRowMutations(Thrift)static org.apache.hadoop.hbase.thrift2.generated.TScanscanFromHBase(Scan in) static ScanscanFromThrift(org.apache.hadoop.hbase.thrift2.generated.TScan in) static List<ByteBuffer>splitKeyFromHBase(byte[][] in) static byte[][]static org.apache.hadoop.hbase.thrift2.generated.TTableDescriptorstatic TableDescriptortableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in) static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor>static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor>static List<TableDescriptor>tableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in) static org.apache.hadoop.hbase.thrift2.generated.TTableNametableNameFromHBase(TableName table) static TableNametableNameFromThrift(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>static List<org.apache.hadoop.hbase.thrift2.generated.TTableName>tableNamesFromHBase(TableName[] in) tableNamesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableName> tableNames) static CelltoCell(ExtendedCellBuilder cellBuilder, byte[] row, org.apache.hadoop.hbase.thrift2.generated.TColumnValue columnValue)
-
Field Details
-
EMPTY_CELL_ARRAY
-
EMPTY_RESULT
-
EMPTY_RESULT_STALE
-
-
Constructor Details
-
ThriftUtilities
private ThriftUtilities()
-
-
Method Details
-
getFromThrift
public static Get getFromThrift(org.apache.hadoop.hbase.thrift2.generated.TGet in) throws IOException - Parameters:
in- theTGetto convert- Returns:
Getobject- 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 multipleTGets (Thrift) into a list ofGets (HBase).- Parameters:
in- list ofTGets to convert- Returns:
- list of
Getobjects - Throws:
IOException- if an invalid time range or max version parameter is given- See Also:
-
resultFromHBase
Creates aTResult(Thrift) from aResult(HBase).- Parameters:
in- theResultto convert- Returns:
- converted result, returns an empty result if the input is
null
-
resultsFromHBase
Converts multipleResults (HBase) into a list ofTResults (Thrift).- Parameters:
in- array ofResults to convert- Returns:
- list of converted
TResults - See Also:
-
putFromThrift
Creates aPut(HBase) from aTPut(Thrift)- Parameters:
in- theTPutto convert- Returns:
- converted
Put
-
putsFromThrift
Converts multipleTPuts (Thrift) into a list ofPuts (HBase).- Parameters:
in- list ofTPuts to convert- Returns:
- list of converted
Puts - See Also:
-
deleteFromThrift
Creates aDelete(HBase) from aTDelete(Thrift).- Parameters:
in- theTDeleteto convert- Returns:
- converted
Delete
-
deletesFromThrift
public static List<Delete> deletesFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TDelete> in) Converts multipleTDeletes (Thrift) into a list ofDeletes (HBase).- Parameters:
in- list ofTDeletes to convert- Returns:
- list of converted
Deletes - See Also:
-
deleteTypeFromHBase
public static org.apache.hadoop.hbase.thrift2.generated.TDeleteType deleteTypeFromHBase(Cell.Type type) -
deleteFromHBase
-
rowMutationsFromThrift
public static RowMutations rowMutationsFromThrift(org.apache.hadoop.hbase.thrift2.generated.TRowMutations in) throws IOException Creates aRowMutations(HBase) from aTRowMutations(Thrift)- Parameters:
in- theTRowMutationsto convert- Returns:
- converted
RowMutations - Throws:
IOException
-
scanFromThrift
public static Scan scanFromThrift(org.apache.hadoop.hbase.thrift2.generated.TScan in) throws IOException - Throws:
IOException
-
filterFromHBase
- Throws:
IOException
-
filterFromThrift
- 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.TCompareOperator 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
-
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) -
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
-
toCell
public static Cell toCell(ExtendedCellBuilder cellBuilder, byte[] row, org.apache.hadoop.hbase.thrift2.generated.TColumnValue columnValue) -
resultFromThrift
-
putFromHBase
-
putsFromHBase
-
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.TCompareOperator compareOpFromHBase(CompareOperator compareOp) -
splitKeyFromHBase
-
resultsFromThrift
public static Result[] resultsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TResult> in) -
getsFromHBase
-
getServerNamesFromHBase
public static Set<org.apache.hadoop.hbase.thrift2.generated.TServerName> getServerNamesFromHBase(Set<ServerName> serverNames) -
getServerNamesFromThrift
public static Set<ServerName> getServerNamesFromThrift(Set<org.apache.hadoop.hbase.thrift2.generated.TServerName> tServerNames) -
getSlowLogQueryFromHBase
public static org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter getSlowLogQueryFromHBase(LogQueryFilter logQueryFilter) -
gettLogTypeFromHBase
private static org.apache.hadoop.hbase.thrift2.generated.TLogType gettLogTypeFromHBase(LogQueryFilter logQueryFilter) -
getTFilterByFromHBase
private static org.apache.hadoop.hbase.thrift2.generated.TFilterByOperator getTFilterByFromHBase(LogQueryFilter logQueryFilter) -
getSlowLogQueryFromThrift
public static LogQueryFilter getSlowLogQueryFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tLogQueryFilter) -
getLogTypeFromThrift
private static LogQueryFilter.Type getLogTypeFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tSlowLogQueryFilter) -
getFilterByFromThrift
private static LogQueryFilter.FilterByOperator getFilterByFromThrift(org.apache.hadoop.hbase.thrift2.generated.TLogQueryFilter tLogQueryFilter) -
getSlowLogRecordsFromHBase
public static List<org.apache.hadoop.hbase.thrift2.generated.TOnlineLogRecord> getSlowLogRecordsFromHBase(List<OnlineLogRecord> onlineLogRecords) -
getSlowLogRecordsFromThrift
public static List<OnlineLogRecord> getSlowLogRecordsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TOnlineLogRecord> tOnlineLogRecords) -
permissionActionsFromString
-