public class OTSProtocolBuilder extends Object
构造器和说明 |
---|
OTSProtocolBuilder() |
public static OtsInternalApi.PrimaryKeyType toPBPrimaryKeyType(PrimaryKeyType type)
public static OtsInternalApi.PrimaryKeyOption toPBPrimaryKeyOption(PrimaryKeyOption option)
public static OtsInternalApi.DefinedColumnType toPBDefinedColumnType(DefinedColumnType type)
public static OtsInternalApi.IndexType toPBIndexType(IndexType indexType)
public static OtsInternalApi.IndexUpdateMode toPBIndexUpdateMode(IndexUpdateMode indexUpdateMode)
public static OtsDelivery.EventColumn.eventTimeFormat toPBEventTimeFormat(EventTimeFormat eventTimeFormat)
public static OtsDelivery.TimeFormatter toPBTimeFormatter(TimeFormatter timeFormatter)
public static OtsDelivery.Format toPBFormat(OSSFileFormat format)
public static OtsDelivery.DeliveryTaskType toPBDeliveryTaskType(DeliveryTaskType deliveryTaskType)
public static OtsDelivery.ParquetSchema.DataType toPBDataType(DataType dataType)
public static OtsDelivery.Encoding toPBEncoding(OSSFileEncoding encoding)
public static OtsInternalApi.DefinedColumnSchema buildDefinedColumnSchema(DefinedColumnSchema definedColun)
public static OtsInternalApi.IndexMeta buildIndexMeta(IndexMeta indexMeta)
public static OtsInternalApi.TableMeta buildTableMeta(TableMeta tableMeta)
public static OtsInternalApi.GetRowRequest buildGetRowRequest(GetRowRequest request)
public static OtsInternalApi.PartitionRange buildPartitionRange(PrimaryKeyValue leftPoint, PrimaryKeyValue rightPoint)
public static void buildPartitionRanges(OtsInternalApi.CreateTableRequest.Builder builder, List<PrimaryKeyValue> splitPoints)
public static OtsInternalApi.CreateTableRequest.Builder getCreateTableRequestBuilder(CreateTableRequest createTableRequest)
public static OtsInternalApi.CreateTableRequest buildCreateTableRequest(CreateTableRequest createTableRequest)
public static OtsInternalApi.CreateTableRequest buildCreateTableExRequest(CreateTableRequestEx createTableRequestEx)
public static OtsInternalApi.DeleteTableRequest buildDeleteTableRequest(DeleteTableRequest req)
public static OtsDelivery.CreateDeliveryTaskRequest buildCreateDeliveryTaskRequest(CreateDeliveryTaskRequest req)
public static OtsDelivery.OSSTaskConfig buildOSSTaskConfig(OSSTaskConfig taskConfig)
public static OtsDelivery.EventColumn buildEventTimeColumn(EventColumn eventColumn)
public static OtsDelivery.DeleteDeliveryTaskRequest buildDeleteDeliveryTaskRequest(DeleteDeliveryTaskRequest req)
public static OtsDelivery.DescribeDeliveryTaskRequest buildDescribeDeliveryTaskRequest(DescribeDeliveryTaskRequest req)
public static OtsDelivery.ListDeliveryTaskRequest buildListDeliveryTaskRequest(ListDeliveryTaskRequest req)
public static OtsInternalApi.CreateIndexRequest buildCreateIndexRequest(CreateIndexRequest req)
public static OtsInternalApi.DropIndexRequest buildDeleteIndexRequest(DeleteIndexRequest req)
public static OtsInternalApi.AddDefinedColumnRequest buildAddDefinedColumnRequest(AddDefinedColumnRequest req)
public static OtsInternalApi.DeleteDefinedColumnRequest buildDeleteDefinedColumnRequest(DeleteDefinedColumnRequest req)
public static OtsInternalApi.RowExistenceExpectation toPBRowExistenceExpectation(RowExistenceExpectation rowExistenceExpectation)
public static OtsInternalApi.Condition buildCondition(Condition cond)
public static OtsInternalApi.ReturnContent buildReturnContent(ReturnType returnType, Set<String> returnColumnNames)
public static OtsInternalApi.DeleteRowRequest buildDeleteRowRequest(DeleteRowRequest request)
public static OtsInternalApi.PutRowRequest buildPutRowRequest(PutRowRequest request)
public static OtsInternalApi.ListTableRequest buildListTableRequest()
public static OtsInternalApi.DescribeTableRequest buildDescribeTableRequest(DescribeTableRequest req)
public static OtsInternalApi.UpdateRowRequest buildUpdateRowRequest(UpdateRowRequest request)
public static OtsInternalApi.Direction toPBDirection(Direction direction)
public static OtsInternalApi.ComputeSplitPointsBySizeRequest buildComputeSplitsBySizeRequest(ComputeSplitsBySizeRequest req)
public static OtsInternalApi.GetRangeRequest buildGetRangeRequest(GetRangeRequest request)
public static OtsInternalApi.BulkExportRequest buildBulkExportRequest(BulkExportRequest request)
public static OtsInternalApi.BatchGetRowRequest buildBatchGetRowRequest(Map<String,MultiRowQueryCriteria> criteriasGroupByTable)
public static OtsInternalApi.BatchWriteRowRequest buildBatchWriteRowRequest(BatchWriteRowRequest request)
public static OtsInternalApi.BulkImportRequest buildBulkImportRequest(BulkImportRequest request)
public static OtsInternalApi.UpdateTableRequest buildUpdateTableRequest(UpdateTableRequest updateTableRequest)
public static OtsFilter.LogicalOperator toLogicalOperator(CompositeColumnValueFilter.LogicOperator type)
public static OtsFilter.Filter toFilter(ColumnCondition f)
public static OtsFilter.Filter toFilter(Filter f)
public static OtsFilter.FilterType toFilterType(ColumnConditionType type)
public static OtsFilter.FilterType toFilterType(FilterType type)
public static com.google.protobuf.ByteString buildFilter(ColumnCondition filter)
public static com.google.protobuf.ByteString buildFilter(Filter filter)
public static com.google.protobuf.ByteString buildCompositeColumnValueFilter(CompositeColumnValueFilter filter)
public static com.google.protobuf.ByteString buildSingleColumnValueFilter(SingleColumnValueFilter filter)
public static com.google.protobuf.ByteString buildSingleColumnValueRegexFilter(SingleColumnValueRegexFilter filter)
public static com.google.protobuf.ByteString buildColumnPaginationFilter(ColumnPaginationFilter filter)
public static com.google.protobuf.Message buildListStreamRequest(ListStreamRequest request)
public static OtsInternalApi.DescribeStreamRequest buildDescribeStreamRequest(DescribeStreamRequest request)
public static OtsInternalApi.GetShardIteratorRequest buildGetShardIteratorRequest(GetShardIteratorRequest request)
public static OtsInternalApi.GetStreamRecordRequest buildGetStreamRecordRequest(GetStreamRecordRequest request)
public static OtsInternalApi.AbortTransactionRequest buildAbortTransactionRequest(AbortTransactionRequest request)
public static OtsInternalApi.StartLocalTransactionRequest buildStartLocalTransactionRequest(StartLocalTransactionRequest request)
public static OtsInternalApi.CommitTransactionRequest buildCommitTransactionRequest(CommitTransactionRequest request)
public static OtsInternalApi.ComputeSplitsRequest buildComputeSplitsRequest(ComputeSplitsRequest request)
public static OtsInternalApi.SQLQueryRequest buildSQLQueryRequest(SQLQueryRequest request)
Copyright © 2021. All Rights Reserved.