ModelBridgeInternal Class
- java.lang.Object
- com.azure.cosmos.models.ModelBridgeInternal
public final class ModelBridgeInternal
DO NOT USE. This is meant to be used only internally as a bridge access to classes in com.azure.cosmos.model package
Modifier and Type |
Method and Description |
static
void
|
addCosmosBatchResultInResponse(CosmosBatchResponse cosmosBatchResponse, List<CosmosBatchOperationResult> cosmosBatchOperationResults)
|
static
void
|
addQueryInfoToFeedResponse(FeedResponse<?> feedResponse, QueryInfo queryInfo)
|
static
void
|
addQueryPlanDiagnosticsContextToFeedResponse(FeedResponse<?> feedResponse, QueryInfo.QueryPlanDiagnosticsContext queryPlanDiagnosticsContext)
|
static
CosmosItemRequestOptions
|
clone(CosmosItemRequestOptions options)
|
static
CosmosChangeFeedRequestOptions
|
createChangeFeedRequestOptionsForChangeFeedState(ChangeFeedState state)
|
static
CosmosBatchResponse
|
createCosmosBatchResponse(int responseStatusCode, int responseSubStatusCode, String errorMessage, Map<String,String> responseHeaders, CosmosDiagnostics cosmosDiagnostics)
|
static
CosmosBatchOperationResult
|
createCosmosBatchResult(String eTag, double requestCharge, ObjectNode resourceObject, int statusCode, Duration retryAfter, int subStatusCode, CosmosItemOperation cosmosItemOperation)
|
static
CosmosBulkItemResponse
|
createCosmosBulkItemResponse(CosmosBatchOperationResult result, CosmosBatchResponse response)
|
static
CosmosBulkOperationResponse<TContext>
|
createCosmosBulkOperationResponse(CosmosItemOperation operation, CosmosBulkItemResponse response, TContext batchContext)
|
static
CosmosBulkOperationResponse<TContext>
|
createCosmosBulkOperationResponse(CosmosItemOperation operation, Exception exception, TContext batchContext)
|
static
CosmosClientEncryptionKeyResponse
|
createCosmosClientEncryptionKeyResponse(ResourceResponse<ClientEncryptionKey> response)
|
static
CosmosConflictResponse
|
createCosmosConflictResponse(ResourceResponse<Conflict> response)
|
static
CosmosContainerResponse
|
createCosmosContainerResponse(ResourceResponse<DocumentCollection> response)
|
static
CosmosDatabaseResponse
|
createCosmosDatabaseResponse(ResourceResponse<Database> response)
|
static
CosmosItemRequestOptions
|
createCosmosItemRequestOptions(PartitionKey partitionKey)
|
static
CosmosPermissionProperties
|
createCosmosPermissionProperties(String jsonString)
|
static
CosmosPermissionResponse
|
createCosmosPermissionResponse(ResourceResponse<Permission> response)
|
static
CosmosStoredProcedureProperties
|
createCosmosStoredProcedureProperties(String jsonString)
|
static
CosmosStoredProcedureResponse
|
createCosmosStoredProcedureResponse(ResourceResponse<StoredProcedure> response)
|
static
CosmosStoredProcedureResponse
|
createCosmosStoredProcedureResponse(StoredProcedureResponse response)
|
static
CosmosTriggerResponse
|
createCosmosTriggerResponse(ResourceResponse<Trigger> response)
|
static
CosmosUserDefinedFunctionResponse
|
createCosmosUserDefinedFunctionResponse(ResourceResponse<UserDefinedFunction> response)
|
static
CosmosUserResponse
|
createCosmosUserResponse(ResourceResponse<User> response)
|
static
FeedResponse<T>
|
createFeedResponse(List<T> results, Map<String,String> headers)
|
static
FeedResponse<T>
|
createFeedResponseWithQueryMetrics(List<T> results, Map<String,String> headers, ConcurrentMap<String,QueryMetrics> queryMetricsMap, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext, boolean useEtagAsContinuation, boolean isNoChanges)
|
static
IndexingPolicy
|
createIndexingPolicy(Index[] indexes)
|
static
ThroughputResponse
|
createThroughputRespose(ResourceResponse<Offer> offerResourceResponse)
|
static
CosmosChangeFeedRequestOptions
|
disableSplitHandling(CosmosChangeFeedRequestOptions requestOptions)
|
static
com.azure.cosmos.implementation.CosmosResourceType
|
fromServiceSerializedFormat(String cosmosResourceType)
|
static
com.azure.cosmos.implementation.changefeed.common.ChangeFeedState
|
getChangeFeedContinuationState(CosmosChangeFeedRequestOptions requestOptions)
|
static
boolean
|
getChangeFeedIsSplitHandlingDisabled(CosmosChangeFeedRequestOptions requestOptions)
|
static
com.azure.cosmos.implementation.changefeed.common.ChangeFeedMode
|
getChangeFeedMode(CosmosChangeFeedRequestOptions requestOptions)
|
static
com.azure.cosmos.implementation.changefeed.common.ChangeFeedStartFromInternal
|
getChangeFeedStartFromSettings(CosmosChangeFeedRequestOptions requestOptions)
|
static
com.azure.cosmos.implementation.ClientEncryptionKey
|
getClientEncryptionKey(CosmosClientEncryptionKeyProperties cosmosClientEncryptionKeyProperties)
|
static
List<CosmosClientEncryptionKeyProperties>
|
getClientEncryptionKeyPropertiesList(List<ClientEncryptionKey> results)
|
static
ConsistencyLevel
|
getConsistencyLevel(CosmosItemRequestOptions options)
|
static
List<CosmosConflictProperties>
|
getCosmosConflictPropertiesFromV2Results(List<Conflict> results)
|
static
List<CosmosContainerProperties>
|
getCosmosContainerPropertiesFromV2Results(List<DocumentCollection> results)
|
static
List<CosmosDatabaseProperties>
|
getCosmosDatabasePropertiesFromV2Results(List<Database> results)
|
static
List<CosmosPermissionProperties>
|
getCosmosPermissionPropertiesFromResults(List<Permission> results)
|
static
List<CosmosStoredProcedureProperties>
|
getCosmosStoredProcedurePropertiesFromV2Results(List<StoredProcedure> results)
|
static
List<CosmosTriggerProperties>
|
getCosmosTriggerPropertiesFromV2Results(List<Trigger> results)
|
static
List<CosmosUserDefinedFunctionProperties>
|
getCosmosUserDefinedFunctionPropertiesFromV2Results(List<UserDefinedFunction> results)
|
static
List<CosmosUserProperties>
|
getCosmosUserPropertiesFromV2Results(List<User> results)
|
static
CosmosChangeFeedRequestOptions
|
getEffectiveChangeFeedRequestOptions(CosmosChangeFeedRequestOptions cosmosChangeFeedRequestOptions, CosmosPagedFluxOptions pagedFlexOptions)
|
static
com.azure.cosmos.implementation.InternalObjectNode
|
getInternalObjectNode(CosmosItemResponse<T> cosmosItemResponse)
|
static
com.azure.cosmos.implementation.JsonSerializable
|
getJsonSerializable(T t)
|
static
Integer
|
getMaxItemCountFromQueryRequestOptions(CosmosQueryRequestOptions options)
|
static
boolean
|
getNoChangesFromFeedResponse(FeedResponse<?> response)
|
static
com.azure.cosmos.implementation.routing.PartitionKeyInternal
|
getNonePartitionKey(PartitionKeyDefinition partitionKeyDefinition)
|
static
com.azure.cosmos.implementation.Offer
|
getOfferFromThroughputProperties(ThroughputProperties properties)
|
static
String
|
getOperationValueForCosmosItemOperationType(CosmosItemOperationType cosmosItemOperationType)
|
static
com.azure.cosmos.implementation.routing.PartitionKeyInternal
|
getPartitionKeyInternal(PartitionKey partitionKey)
|
static
String
|
getPartitionKeyRangeIdInternal(CosmosQueryRequestOptions options)
Gets the partitionKeyRangeId.
|
static
List<com.azure.cosmos.implementation.patch.PatchOperation>
|
getPatchOperationsFromCosmosPatch(CosmosPatchOperations cosmosPatchOperations)
|
static
int
|
getPayloadLength(CosmosItemResponse<T> cosmosItemResponse)
|
static
com.azure.cosmos.implementation.Permission
|
getPermission(CosmosPermissionProperties permissionProperties)
|
static
com.azure.cosmos.implementation.Permission
|
getPermission(CosmosPermissionProperties permissionProperties, String databaseName)
|
static
Map<String,Object>
|
getPropertiesFromChangeFeedRequestOptions(CosmosChangeFeedRequestOptions options)
|
static
Map<String,Object>
|
getPropertiesFromQueryRequestOptions(CosmosQueryRequestOptions options)
|
static
com.azure.cosmos.implementation.query.QueryInfo.QueryPlanDiagnosticsContext
|
getQueryPlanDiagnosticsContext(FeedResponse<T> feedResponse)
|
static
String
|
getRequestContinuationFromQueryRequestOptions(CosmosQueryRequestOptions options)
|
static
com.azure.cosmos.implementation.Resource
|
getResource(T t)
|
static
com.azure.cosmos.implementation.DocumentCollection
|
getV2Collection(CosmosContainerProperties containerProperties)
|
static
com.azure.cosmos.implementation.User
|
getV2User(CosmosUserProperties cosmosUserProperties)
|
static
void
|
initializeAllAccessors()
|
static
T
|
instantiateByObjectNode(ObjectNode objectNode, Class<T> c)
|
static
boolean
|
isV2(PartitionKeyDefinition pkd)
|
static
boolean
|
noChanges(FeedResponse<T> page)
|
static
PartitionKey
|
partitionKeyfromJsonString(String jsonString)
|
static
void
|
populatePropertyBag(T t)
|
static
ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics>
|
queryMetrics(FeedResponse<T> feedResponse)
|
static
ConcurrentMap<String,com.azure.cosmos.implementation.QueryMetrics>
|
queryMetricsMap(FeedResponse<T> feedResponse)
|
static
ByteBuffer
|
serializeJsonToByteBuffer(SqlQuerySpec sqlQuerySpec)
|
static
void
|
setChangeFeedRequestOptionsContinuation(String eTag, CosmosChangeFeedRequestOptions options)
|
static
void
|
setFeedResponseContinuationToken(String continuationToken, FeedResponse<T> response)
|
static
CosmosItemRequestOptions
|
setPartitionKey(CosmosItemRequestOptions cosmosItemRequestOptions, PartitionKey partitionKey)
|
static
CosmosQueryRequestOptions
|
setPartitionKeyRangeIdInternal(CosmosQueryRequestOptions options, String partitionKeyRangeId)
Sets the PartitionKeyRangeId.
|
static
void
|
setQueryRequestOptionsContinuationToken(CosmosQueryRequestOptions cosmosQueryRequestOptions, String continuationToken)
|
static
void
|
setQueryRequestOptionsContinuationTokenAndMaxItemCount(CosmosQueryRequestOptions options, String continuationToken, Integer maxItemCount)
|
static
void
|
setQueryRequestOptionsMaxItemCount(CosmosQueryRequestOptions cosmosQueryRequestOptions, Integer maxItemCount)
|
static
CosmosQueryRequestOptions
|
setQueryRequestOptionsProperties(CosmosQueryRequestOptions options, Map<String,Object> properties)
|
static
CosmosContainerRequestOptions
|
setThroughputProperties(CosmosContainerRequestOptions containerRequestOptions, ThroughputProperties throughputProperties)
|
static
CosmosDatabaseRequestOptions
|
setThroughputProperties(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions, ThroughputProperties throughputProperties)
|
static
com.azure.cosmos.implementation.DatabaseAccount
|
toDatabaseAccount(RxDocumentServiceResponse response)
|
static
FeedResponse<T>
|
toFeedResponsePage(List<T> results, Map<String,String> headers, boolean noChanges)
|
static
String
|
toLower(RequestVerb verb)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosBatchRequestOptions cosmosBatchRequestOptions)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosConflictRequestOptions cosmosConflictRequestOptions)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosContainerRequestOptions cosmosContainerRequestOptions)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosPermissionRequestOptions cosmosPermissionRequestOptions)
|
static
com.azure.cosmos.implementation.RequestOptions
|
toRequestOptions(CosmosStoredProcedureRequestOptions cosmosStoredProcedureRequestOptions)
|
static
com.azure.cosmos.implementation.Offer
|
updateOfferFromProperties(Offer offer, ThroughputProperties properties)
|
Methods inherited from java.lang.Object
addCosmosBatchResultInResponse
public static void addCosmosBatchResultInResponse(CosmosBatchResponse cosmosBatchResponse, List cosmosBatchOperationResults)
Parameters:
cosmosBatchResponse
cosmosBatchOperationResults
addQueryInfoToFeedResponse
public static void addQueryInfoToFeedResponse(FeedResponse feedResponse, QueryInfo queryInfo)
Parameters:
feedResponse
queryInfo
addQueryPlanDiagnosticsContextToFeedResponse
public static void addQueryPlanDiagnosticsContextToFeedResponse(FeedResponse feedResponse, QueryInfo.QueryPlanDiagnosticsContext queryPlanDiagnosticsContext)
Parameters:
feedResponse
queryPlanDiagnosticsContext
clone
public static CosmosItemRequestOptions clone(CosmosItemRequestOptions options)
Parameters:
options
createChangeFeedRequestOptionsForChangeFeedState
public static CosmosChangeFeedRequestOptions createChangeFeedRequestOptionsForChangeFeedState(ChangeFeedState state)
Parameters:
state
createCosmosBatchResponse
public static CosmosBatchResponse createCosmosBatchResponse(int responseStatusCode, int responseSubStatusCode, String errorMessage, Map responseHeaders, CosmosDiagnostics cosmosDiagnostics)
Parameters:
responseStatusCode
responseSubStatusCode
errorMessage
responseHeaders
cosmosDiagnostics
createCosmosBatchResult
public static CosmosBatchOperationResult createCosmosBatchResult(String eTag, double requestCharge, ObjectNode resourceObject, int statusCode, Duration retryAfter, int subStatusCode, CosmosItemOperation cosmosItemOperation)
Parameters:
eTag
requestCharge
resourceObject
statusCode
retryAfter
subStatusCode
cosmosItemOperation
createCosmosBulkItemResponse
public static CosmosBulkItemResponse createCosmosBulkItemResponse(CosmosBatchOperationResult result, CosmosBatchResponse response)
Parameters:
result
response
createCosmosBulkOperationResponse
public static CosmosBulkOperationResponse createCosmosBulkOperationResponse(CosmosItemOperation operation, CosmosBulkItemResponse response, TContext batchContext)
Parameters:
operation
response
batchContext
createCosmosBulkOperationResponse
public static CosmosBulkOperationResponse createCosmosBulkOperationResponse(CosmosItemOperation operation, Exception exception, TContext batchContext)
Parameters:
operation
exception
batchContext
createCosmosClientEncryptionKeyResponse
public static CosmosClientEncryptionKeyResponse createCosmosClientEncryptionKeyResponse(ResourceResponse response)
Parameters:
response
createCosmosConflictResponse
public static CosmosConflictResponse createCosmosConflictResponse(ResourceResponse response)
Parameters:
response
createCosmosContainerResponse
public static CosmosContainerResponse createCosmosContainerResponse(ResourceResponse response)
Parameters:
response
createCosmosDatabaseResponse
public static CosmosDatabaseResponse createCosmosDatabaseResponse(ResourceResponse response)
Parameters:
response
createCosmosItemRequestOptions
public static CosmosItemRequestOptions createCosmosItemRequestOptions(PartitionKey partitionKey)
Parameters:
partitionKey
createCosmosPermissionProperties
public static CosmosPermissionProperties createCosmosPermissionProperties(String jsonString)
Parameters:
jsonString
createCosmosPermissionResponse
public static CosmosPermissionResponse createCosmosPermissionResponse(ResourceResponse response)
Parameters:
response
createCosmosStoredProcedureProperties
public static CosmosStoredProcedureProperties createCosmosStoredProcedureProperties(String jsonString)
Parameters:
jsonString
createCosmosStoredProcedureResponse
public static CosmosStoredProcedureResponse createCosmosStoredProcedureResponse(ResourceResponse response)
Parameters:
response
createCosmosStoredProcedureResponse
public static CosmosStoredProcedureResponse createCosmosStoredProcedureResponse(StoredProcedureResponse response)
Parameters:
response
createCosmosTriggerResponse
public static CosmosTriggerResponse createCosmosTriggerResponse(ResourceResponse response)
Parameters:
response
createCosmosUserDefinedFunctionResponse
public static CosmosUserDefinedFunctionResponse createCosmosUserDefinedFunctionResponse(ResourceResponse response)
Parameters:
response
createCosmosUserResponse
public static CosmosUserResponse createCosmosUserResponse(ResourceResponse response)
Parameters:
response
createFeedResponse
public static FeedResponse createFeedResponse(List results, Map headers)
Parameters:
results
headers
createFeedResponseWithQueryMetrics
public static FeedResponse createFeedResponseWithQueryMetrics(List results, Map headers, ConcurrentMap queryMetricsMap, QueryInfo.QueryPlanDiagnosticsContext diagnosticsContext, boolean useEtagAsContinuation, boolean isNoChanges)
Parameters:
results
headers
queryMetricsMap
diagnosticsContext
useEtagAsContinuation
isNoChanges
createIndexingPolicy
public static IndexingPolicy createIndexingPolicy(Index[] indexes)
Parameters:
indexes
createThroughputRespose
public static ThroughputResponse createThroughputRespose(ResourceResponse offerResourceResponse)
Parameters:
offerResourceResponse
disableSplitHandling
public static CosmosChangeFeedRequestOptions disableSplitHandling(CosmosChangeFeedRequestOptions requestOptions)
Parameters:
requestOptions
fromServiceSerializedFormat
public static CosmosResourceType fromServiceSerializedFormat(String cosmosResourceType)
Parameters:
cosmosResourceType
getChangeFeedContinuationState
public static ChangeFeedState getChangeFeedContinuationState(CosmosChangeFeedRequestOptions requestOptions)
Parameters:
requestOptions
getChangeFeedIsSplitHandlingDisabled
public static boolean getChangeFeedIsSplitHandlingDisabled(CosmosChangeFeedRequestOptions requestOptions)
Parameters:
requestOptions
getChangeFeedMode
public static ChangeFeedMode getChangeFeedMode(CosmosChangeFeedRequestOptions requestOptions)
Parameters:
requestOptions
getChangeFeedStartFromSettings
public static ChangeFeedStartFromInternal getChangeFeedStartFromSettings(CosmosChangeFeedRequestOptions requestOptions)
Parameters:
requestOptions
getClientEncryptionKey
public static ClientEncryptionKey getClientEncryptionKey(CosmosClientEncryptionKeyProperties cosmosClientEncryptionKeyProperties)
Parameters:
cosmosClientEncryptionKeyProperties
getClientEncryptionKeyPropertiesList
public static List getClientEncryptionKeyPropertiesList(List results)
Parameters:
results
getConsistencyLevel
public static ConsistencyLevel getConsistencyLevel(CosmosItemRequestOptions options)
Parameters:
options
getCosmosConflictPropertiesFromV2Results
public static List getCosmosConflictPropertiesFromV2Results(List results)
Parameters:
results
getCosmosContainerPropertiesFromV2Results
public static List getCosmosContainerPropertiesFromV2Results(List results)
Parameters:
results
getCosmosDatabasePropertiesFromV2Results
public static List getCosmosDatabasePropertiesFromV2Results(List results)
Parameters:
results
getCosmosPermissionPropertiesFromResults
public static List getCosmosPermissionPropertiesFromResults(List results)
Parameters:
results
getCosmosStoredProcedurePropertiesFromV2Results
public static List getCosmosStoredProcedurePropertiesFromV2Results(List results)
Parameters:
results
getCosmosTriggerPropertiesFromV2Results
public static List getCosmosTriggerPropertiesFromV2Results(List results)
Parameters:
results
getCosmosUserDefinedFunctionPropertiesFromV2Results
public static List getCosmosUserDefinedFunctionPropertiesFromV2Results(List results)
Parameters:
results
getCosmosUserPropertiesFromV2Results
public static List getCosmosUserPropertiesFromV2Results(List results)
Parameters:
results
getEffectiveChangeFeedRequestOptions
public static CosmosChangeFeedRequestOptions getEffectiveChangeFeedRequestOptions(CosmosChangeFeedRequestOptions cosmosChangeFeedRequestOptions, CosmosPagedFluxOptions pagedFlexOptions)
Parameters:
cosmosChangeFeedRequestOptions
pagedFlexOptions
getInternalObjectNode
public static InternalObjectNode getInternalObjectNode(CosmosItemResponse cosmosItemResponse)
Parameters:
cosmosItemResponse
getJsonSerializable
public static JsonSerializable getJsonSerializable(T t)
Parameters:
t
getMaxItemCountFromQueryRequestOptions
public static Integer getMaxItemCountFromQueryRequestOptions(CosmosQueryRequestOptions options)
Parameters:
options
getNoChangesFromFeedResponse
public static boolean getNoChangesFromFeedResponse(FeedResponse response)
Parameters:
response
getNonePartitionKey
public static PartitionKeyInternal getNonePartitionKey(PartitionKeyDefinition partitionKeyDefinition)
Parameters:
partitionKeyDefinition
getOfferFromThroughputProperties
public static Offer getOfferFromThroughputProperties(ThroughputProperties properties)
Parameters:
properties
getOperationValueForCosmosItemOperationType
public static String getOperationValueForCosmosItemOperationType(CosmosItemOperationType cosmosItemOperationType)
Parameters:
cosmosItemOperationType
getPartitionKeyInternal
public static PartitionKeyInternal getPartitionKeyInternal(PartitionKey partitionKey)
Parameters:
partitionKey
getPartitionKeyRangeIdInternal
public static String getPartitionKeyRangeIdInternal(CosmosQueryRequestOptions options)
Gets the partitionKeyRangeId.
Parameters:
options
- the query request options
Returns:
the partitionKeyRangeId.
getPatchOperationsFromCosmosPatch
public static List getPatchOperationsFromCosmosPatch(CosmosPatchOperations cosmosPatchOperations)
Parameters:
cosmosPatchOperations
getPayloadLength
public static int getPayloadLength(CosmosItemResponse cosmosItemResponse)
Parameters:
cosmosItemResponse
getPermission
public static Permission getPermission(CosmosPermissionProperties permissionProperties)
Parameters:
permissionProperties
getPermission
public static Permission getPermission(CosmosPermissionProperties permissionProperties, String databaseName)
Parameters:
permissionProperties
databaseName
getPropertiesFromChangeFeedRequestOptions
public static Map getPropertiesFromChangeFeedRequestOptions(CosmosChangeFeedRequestOptions options)
Parameters:
options
getPropertiesFromQueryRequestOptions
public static Map getPropertiesFromQueryRequestOptions(CosmosQueryRequestOptions options)
Parameters:
options
getQueryPlanDiagnosticsContext
public static QueryInfo.QueryPlanDiagnosticsContext getQueryPlanDiagnosticsContext(FeedResponse feedResponse)
Parameters:
feedResponse
getRequestContinuationFromQueryRequestOptions
public static String getRequestContinuationFromQueryRequestOptions(CosmosQueryRequestOptions options)
Parameters:
options
getResource
public static Resource getResource(T t)
Parameters:
t
getV2Collection
public static DocumentCollection getV2Collection(CosmosContainerProperties containerProperties)
Parameters:
containerProperties
getV2User
public static User getV2User(CosmosUserProperties cosmosUserProperties)
Parameters:
cosmosUserProperties
initializeAllAccessors
public static void initializeAllAccessors()
instantiateByObjectNode
public static T instantiateByObjectNode(ObjectNode objectNode, Class c)
Parameters:
objectNode
c
isV2
public static boolean isV2(PartitionKeyDefinition pkd)
Parameters:
pkd
noChanges
public static boolean noChanges(FeedResponse page)
Parameters:
page
partitionKeyfromJsonString
public static PartitionKey partitionKeyfromJsonString(String jsonString)
Parameters:
jsonString
populatePropertyBag
public static void populatePropertyBag(T t)
Parameters:
t
queryMetrics
public static ConcurrentMap queryMetrics(FeedResponse feedResponse)
Parameters:
feedResponse
queryMetricsMap
public static ConcurrentMap queryMetricsMap(FeedResponse feedResponse)
Parameters:
feedResponse
serializeJsonToByteBuffer
public static ByteBuffer serializeJsonToByteBuffer(SqlQuerySpec sqlQuerySpec)
Parameters:
sqlQuerySpec
setChangeFeedRequestOptionsContinuation
public static void setChangeFeedRequestOptionsContinuation(String eTag, CosmosChangeFeedRequestOptions options)
Parameters:
eTag
options
setFeedResponseContinuationToken
public static void setFeedResponseContinuationToken(String continuationToken, FeedResponse response)
Parameters:
continuationToken
response
setPartitionKey
public static CosmosItemRequestOptions setPartitionKey(CosmosItemRequestOptions cosmosItemRequestOptions, PartitionKey partitionKey)
Parameters:
cosmosItemRequestOptions
partitionKey
setPartitionKeyRangeIdInternal
public static CosmosQueryRequestOptions setPartitionKeyRangeIdInternal(CosmosQueryRequestOptions options, String partitionKeyRangeId)
Sets the PartitionKeyRangeId.
Parameters:
options
- the query request options
partitionKeyRangeId
- the partition key range id
Returns:
the partitionKeyRangeId.
setQueryRequestOptionsContinuationToken
public static void setQueryRequestOptionsContinuationToken(CosmosQueryRequestOptions cosmosQueryRequestOptions, String continuationToken)
Parameters:
cosmosQueryRequestOptions
continuationToken
setQueryRequestOptionsContinuationTokenAndMaxItemCount
public static void setQueryRequestOptionsContinuationTokenAndMaxItemCount(CosmosQueryRequestOptions options, String continuationToken, Integer maxItemCount)
Parameters:
options
continuationToken
maxItemCount
setQueryRequestOptionsMaxItemCount
public static void setQueryRequestOptionsMaxItemCount(CosmosQueryRequestOptions cosmosQueryRequestOptions, Integer maxItemCount)
Parameters:
cosmosQueryRequestOptions
maxItemCount
setQueryRequestOptionsProperties
public static CosmosQueryRequestOptions setQueryRequestOptionsProperties(CosmosQueryRequestOptions options, Map properties)
Parameters:
options
properties
setThroughputProperties
public static CosmosContainerRequestOptions setThroughputProperties(CosmosContainerRequestOptions containerRequestOptions, ThroughputProperties throughputProperties)
Parameters:
containerRequestOptions
throughputProperties
setThroughputProperties
public static CosmosDatabaseRequestOptions setThroughputProperties(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions, ThroughputProperties throughputProperties)
Parameters:
cosmosDatabaseRequestOptions
throughputProperties
toDatabaseAccount
public static DatabaseAccount toDatabaseAccount(RxDocumentServiceResponse response)
Parameters:
response
toFeedResponsePage
public static FeedResponse toFeedResponsePage(List results, Map headers, boolean noChanges)
Parameters:
results
headers
noChanges
toLower
public static String toLower(RequestVerb verb)
Parameters:
verb
toRequestOptions
public static RequestOptions toRequestOptions(CosmosBatchRequestOptions cosmosBatchRequestOptions)
Parameters:
cosmosBatchRequestOptions
toRequestOptions
public static RequestOptions toRequestOptions(CosmosConflictRequestOptions cosmosConflictRequestOptions)
Parameters:
cosmosConflictRequestOptions
toRequestOptions
public static RequestOptions toRequestOptions(CosmosContainerRequestOptions cosmosContainerRequestOptions)
Parameters:
cosmosContainerRequestOptions
toRequestOptions
public static RequestOptions toRequestOptions(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions)
Parameters:
cosmosDatabaseRequestOptions
toRequestOptions
public static RequestOptions toRequestOptions(CosmosPermissionRequestOptions cosmosPermissionRequestOptions)
Parameters:
cosmosPermissionRequestOptions
toRequestOptions
public static RequestOptions toRequestOptions(CosmosStoredProcedureRequestOptions cosmosStoredProcedureRequestOptions)
Parameters:
cosmosStoredProcedureRequestOptions
updateOfferFromProperties
public static Offer updateOfferFromProperties(Offer offer, ThroughputProperties properties)
Parameters:
offer
properties
Applies to
Azure SDK for Java
Latest