public class OTSProtocolHelper extends Object
构造器和说明 |
---|
OTSProtocolHelper() |
public static OtsProtocol2.ColumnType toPBColumnType(PrimaryKeyType pkType)
public static PrimaryKeyType toPrimaryKeyType(OtsProtocol2.ColumnType type)
public static OtsProtocol2.ColumnType toPBColumnType(ColumnType colType)
public static ColumnType toColumnType(OtsProtocol2.ColumnType type)
public static OtsProtocol2.ColumnValue buildColumnValue(PrimaryKeyValue primaryKey)
public static PrimaryKeyValue toPrimaryKeyValue(OtsProtocol2.ColumnValue value)
public static OtsProtocol2.ColumnValue buildColumnValue(ColumnValue column)
public static ColumnValue toColumnValue(OtsProtocol2.ColumnValue value)
public static OtsProtocol2.RowExistenceExpectation toPBRowExistenceExpectation(RowExistenceExpectation rowExistenceExpectation)
public static OtsProtocol2.ColumnConditionType toPBColumnConditionType(ColumnConditionType cct)
public static OtsProtocol2.ColumnCondition buildColumnCondition(ColumnCondition cc)
public static OtsProtocol2.Condition buildCondition(Condition cond)
public static OtsProtocol2.Column buildColumn(String name, PrimaryKeyValue value)
public static OtsProtocol2.Column buildColumn(String name, ColumnValue value)
public static OtsProtocol2.ColumnSchema buildColumnSchema(String name, PrimaryKeyType type)
public static OtsProtocol2.TableMeta buildTableMeta(TableMeta tableMeta)
public static OtsProtocol2.GetRowRequest buildGetRowRequest(SingleRowQueryCriteria criteria)
public static OtsProtocol2.Row buildRow(Map<String,PrimaryKeyValue> primaryKey, Map<String,ColumnValue> attributeColumns)
public static OtsProtocol2.CreateTableRequest buildCreateTableRequest(CreateTableRequest request)
public static OtsProtocol2.DeleteTableRequest buildDeleteTableRequest(String tableName)
public static OtsProtocol2.DeleteRowRequest buildDeleteRowRequest(RowDeleteChange rowChange)
public static OtsProtocol2.PutRowRequest buildPutRowRequest(RowPutChange rowChange)
public static ReservedThroughputDetails parseCapacityUnitDetails(OtsProtocol2.ReservedThroughputDetails capacityUnitDetails)
public static TableMeta parseTableMeta(OtsProtocol2.TableMeta meta)
public static Row parseRow(OtsProtocol2.Row pbRow)
public static Row parseGetRowResponse(OtsProtocol2.GetRowResponse response)
public static OtsProtocol2.ListTableRequest buildListTableRequest()
public static OtsProtocol2.DescribeTableRequest buildDescribeTableRequest(String tableName)
public static OtsProtocol2.UpdateTableRequest buildUpdateTableRequest(UpdateTableRequest request)
public static OtsProtocol2.UpdateRowRequest buildUpdateRowRequest(RowUpdateChange rowChange)
public static OtsProtocol2.Direction toPBDirection(Direction direction)
public static OtsProtocol2.Column buildRangeColumn(String name, PrimaryKeyValue value)
public static OtsProtocol2.GetRangeRequest buildGetRangeRequest(RangeRowQueryCriteria criteria)
public static OtsProtocol2.BatchGetRowRequest buildBatchGetRowRequest(Map<String,MultiRowQueryCriteria> criteriasGroupByTable)
public static OtsProtocol2.BatchWriteRowRequest buildBatchWriteRowRequest(BatchWriteRowRequest request)
public static ConsumedCapacity parseConsumedCapacity(OtsProtocol2.ConsumedCapacity consumed)
public static BatchGetRowResult.RowStatus parseBatchGetRowStatus(String tableName, OtsProtocol2.RowInBatchGetRowResponse status, int index)
public static BatchWriteRowResult.RowStatus parseBatchWriteRowStatus(String tableName, OtsProtocol2.RowInBatchWriteRowResponse status, int index)
Copyright © 2016. All Rights Reserved.