com.aliyun.openservices.ots.model
类 OTSProtocolHelper

java.lang.Object
  com.aliyun.openservices.ots.model.OTSProtocolHelper

public class OTSProtocolHelper
extends Object

构造方法摘要

OTSProtocolHelper()

方法摘要

static byte[]	buildAbortTransaction(String transactionId)
static byte[]	buildBatchModifyRowRequest(String tableName, Collection<RowChange> rowChanges, String transactionId)
static OtsProtocol.Column	buildColumn(String name, ColumnValue value)
static OtsProtocol.Column	buildColumn(String name, PrimaryKeyValue value)
static OtsProtocol.ColumnSchema	buildColumnSchema(String name, ColumnType type)
static OtsProtocol.ColumnSchema	buildColumnSchema(String name, PrimaryKeyType type)
static OtsProtocol.ColumnValue	buildColumnValue(ColumnValue column)
static OtsProtocol.ColumnValue	buildColumnValue(PartitionKeyValue partKey)
static OtsProtocol.ColumnValue	buildColumnValue(PrimaryKeyValue primaryKey)
static byte[]	buildCommitTransaction(String transactionId)
static byte[]	buildCreateTableGroupRequest(String tableGroupName, PartitionKeyType pkType)
static byte[]	buildCreateTableRequest(TableMeta tableMeta)
static OtsProtocol.DeleteRowParameter	buildDeleteRowParameter(String tableName, RowDeleteChange rowChange)
static byte[]	buildDeleteRowRequest(String tableName, RowDeleteChange rowChange, String transactionId)
static byte[]	buildDeleteTableGroupRequest(String tableGroupName)
static byte[]	buildDeleteTableRequest(String tableName)
static OtsProtocol.GetRowParameter	buildGetRowParameter(SingleRowQueryCriteria criteria)
static byte[]	buildGetRowRequest(SingleRowQueryCriteria criteria, String transactionId)
static byte[]	buildGetRowsByRangeRequest(RangeRowQueryCriteria criteria, String transactionId, String nextToken)
static byte[]	buildGetTableMetaRequest(String tableName)
static byte[]	buildMultiDeleteRowRequest(List<MultiDeleteRowItem> rowChanges)
static byte[]	buildMultiGetRowRequest(List<SingleRowQueryCriteria> criterias)
static byte[]	buildMultiPutRowRequest(List<MultiPutRowItem> rowChanges)
static OtsProtocol.PutRowParameter	buildPutRowParameter(String tableName, RowPutChange rowChange)
static byte[]	buildPutRowRequest(String tableName, RowPutChange rowChange, String transactionId)
static OtsProtocol.ColumnValue	buildRangeKeyValue(PrimaryKeyValue value)
static OtsProtocol.Row	buildRow(Map<String,PrimaryKeyValue> primaryKeys, Map<String,ColumnValue> attributeColumns)
static OtsProtocol.RowDeleteChange	buildRowDeleteChange(RowDeleteChange rowChange)
static OtsProtocol.RowPutChange	buildRowPutChange(RowPutChange rowChange)
static byte[]	buildStartTransactionRequest(String entityName, PartitionKeyValue pkValue)
static OtsProtocol.TableMeta	buildTableMeta(TableMeta tableMeta)
static OtsProtocol.ViewMeta	buildViewMeta(ViewMeta viewMeta)
static Row	parseGetRowResponse(OtsProtocol.GetRowResponse response)
static RowListing	parseGetRowsByRangeResponse(OtsProtocol.GetRowsByRangeResponse response)
static TableMeta	parseGetTableMetaResponse(OtsProtocol.GetTableMetaResponse response)
static List<RowOperationStatus>	parseMultiDeleteRowResponse(OtsProtocol.MultiDeleteRowResponse response, com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)
static List<MultiGetRowItem>	parseMultiGetRowResponse(OtsProtocol.MultiGetRowResponse response, com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)
static List<RowOperationStatus>	parseMultiPutRowResponse(OtsProtocol.MultiPutRowResponse response, com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)
static Row	parseRow(OtsProtocol.Row pbRow)
static ColumnType	toColumnType(OtsProtocol.ColumnType type)
static ColumnValue	toColumnValue(OtsProtocol.ColumnValue value)
static OtsProtocol.ColumnType	toPBColumnType(ColumnType colType)
static OtsProtocol.ColumnType	toPBColumnType(PartitionKeyType pkType)
static OtsProtocol.ColumnType	toPBColumnType(PrimaryKeyType pkType)
static PrimaryKeyType	toPrimaryKeyType(OtsProtocol.ColumnType type)
static PrimaryKeyValue	toPrimaryKeyValue(OtsProtocol.ColumnValue value)

从类 java.lang.Object 继承的方法

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

构造方法详细信息

OTSProtocolHelper

public OTSProtocolHelper()

方法详细信息

toPBColumnType

public static OtsProtocol.ColumnType toPBColumnType(PartitionKeyType pkType)

toPBColumnType

public static OtsProtocol.ColumnType toPBColumnType(PrimaryKeyType pkType)

toPrimaryKeyType

public static PrimaryKeyType toPrimaryKeyType(OtsProtocol.ColumnType type)

toPBColumnType

public static OtsProtocol.ColumnType toPBColumnType(ColumnType colType)

toColumnType

public static ColumnType toColumnType(OtsProtocol.ColumnType type)

buildColumnValue

public static OtsProtocol.ColumnValue buildColumnValue(PartitionKeyValue partKey)

buildColumnValue

public static OtsProtocol.ColumnValue buildColumnValue(PrimaryKeyValue primaryKey)

buildRangeKeyValue

public static OtsProtocol.ColumnValue buildRangeKeyValue(PrimaryKeyValue value)

toPrimaryKeyValue

public static PrimaryKeyValue toPrimaryKeyValue(OtsProtocol.ColumnValue value)

buildColumnValue

public static OtsProtocol.ColumnValue buildColumnValue(ColumnValue column)

toColumnValue

public static ColumnValue toColumnValue(OtsProtocol.ColumnValue value)

buildColumn

public static OtsProtocol.Column buildColumn(String name,
                                             PrimaryKeyValue value)

buildColumn

public static OtsProtocol.Column buildColumn(String name,
                                             ColumnValue value)

buildColumnSchema

public static OtsProtocol.ColumnSchema buildColumnSchema(String name,
                                                         PrimaryKeyType type)

buildColumnSchema

public static OtsProtocol.ColumnSchema buildColumnSchema(String name,
                                                         ColumnType type)

buildViewMeta

public static OtsProtocol.ViewMeta buildViewMeta(ViewMeta viewMeta)

buildTableMeta

public static OtsProtocol.TableMeta buildTableMeta(TableMeta tableMeta)

buildGetRowParameter

public static OtsProtocol.GetRowParameter buildGetRowParameter(SingleRowQueryCriteria criteria)

buildRow

public static OtsProtocol.Row buildRow(Map<String,PrimaryKeyValue> primaryKeys,
                                       Map<String,ColumnValue> attributeColumns)

buildRowPutChange

public static OtsProtocol.RowPutChange buildRowPutChange(RowPutChange rowChange)

buildRowDeleteChange

public static OtsProtocol.RowDeleteChange buildRowDeleteChange(RowDeleteChange rowChange)

buildPutRowParameter

public static OtsProtocol.PutRowParameter buildPutRowParameter(String tableName,
                                                               RowPutChange rowChange)

buildDeleteRowParameter

public static OtsProtocol.DeleteRowParameter buildDeleteRowParameter(String tableName,
                                                                     RowDeleteChange rowChange)

buildCreateTableGroupRequest

public static byte[] buildCreateTableGroupRequest(String tableGroupName,
                                                  PartitionKeyType pkType)

buildDeleteTableGroupRequest

public static byte[] buildDeleteTableGroupRequest(String tableGroupName)

buildCreateTableRequest

public static byte[] buildCreateTableRequest(TableMeta tableMeta)

buildGetTableMetaRequest

public static byte[] buildGetTableMetaRequest(String tableName)

buildDeleteTableRequest

public static byte[] buildDeleteTableRequest(String tableName)

buildGetRowRequest

public static byte[] buildGetRowRequest(SingleRowQueryCriteria criteria,
                                        String transactionId)

buildGetRowsByRangeRequest

public static byte[] buildGetRowsByRangeRequest(RangeRowQueryCriteria criteria,
                                                String transactionId,
                                                String nextToken)

buildMultiGetRowRequest

public static byte[] buildMultiGetRowRequest(List<SingleRowQueryCriteria> criterias)

buildDeleteRowRequest

public static byte[] buildDeleteRowRequest(String tableName,
                                           RowDeleteChange rowChange,
                                           String transactionId)

buildMultiDeleteRowRequest

public static byte[] buildMultiDeleteRowRequest(List<MultiDeleteRowItem> rowChanges)

buildBatchModifyRowRequest

public static byte[] buildBatchModifyRowRequest(String tableName,
                                                Collection<RowChange> rowChanges,
                                                String transactionId)

buildPutRowRequest

public static byte[] buildPutRowRequest(String tableName,
                                        RowPutChange rowChange,
                                        String transactionId)

buildMultiPutRowRequest

public static byte[] buildMultiPutRowRequest(List<MultiPutRowItem> rowChanges)

buildStartTransactionRequest

public static byte[] buildStartTransactionRequest(String entityName,
                                                  PartitionKeyValue pkValue)

buildCommitTransaction

public static byte[] buildCommitTransaction(String transactionId)

buildAbortTransaction

public static byte[] buildAbortTransaction(String transactionId)

parseGetTableMetaResponse

public static TableMeta parseGetTableMetaResponse(OtsProtocol.GetTableMetaResponse response)

parseRow

public static Row parseRow(OtsProtocol.Row pbRow)

parseGetRowResponse

public static Row parseGetRowResponse(OtsProtocol.GetRowResponse response)

parseGetRowsByRangeResponse

public static RowListing parseGetRowsByRangeResponse(OtsProtocol.GetRowsByRangeResponse response)

parseMultiGetRowResponse

public static List<MultiGetRowItem> parseMultiGetRowResponse(OtsProtocol.MultiGetRowResponse response,
                                                             com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)

parseMultiPutRowResponse

public static List<RowOperationStatus> parseMultiPutRowResponse(OtsProtocol.MultiPutRowResponse response,
                                                                com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)

parseMultiDeleteRowResponse

public static List<RowOperationStatus> parseMultiDeleteRowResponse(OtsProtocol.MultiDeleteRowResponse response,
                                                                   com.aliyun.openservices.ots.internal.model.RequestMeta requestMeta)