ModelBridgeInternal Class

Package:

com.azure.cosmos.models

Maven Artifact:

com.azure:azure-cosmos:4.80.0

• 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

Method Summary

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 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 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

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Method Details

addCosmosBatchResultInResponse

public static void addCosmosBatchResultInResponse(CosmosBatchResponse cosmosBatchResponse, List<CosmosBatchOperationResult> 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<String,String> 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<TContext> <TContext>createCosmosBulkOperationResponse(CosmosItemOperation operation, CosmosBulkItemResponse response, TContext batchContext)

Parameters:

operation

response

batchContext

createCosmosBulkOperationResponse

public static CosmosBulkOperationResponse<TContext> <TContext>createCosmosBulkOperationResponse(CosmosItemOperation operation, Exception exception, TContext batchContext)

Parameters:

operation

exception

batchContext

createCosmosClientEncryptionKeyResponse

public static CosmosClientEncryptionKeyResponse createCosmosClientEncryptionKeyResponse(ResourceResponse<ClientEncryptionKey> response)

Parameters:

response

createCosmosConflictResponse

public static CosmosConflictResponse createCosmosConflictResponse(ResourceResponse<Conflict> response)

Parameters:

response

createCosmosContainerResponse

public static CosmosContainerResponse createCosmosContainerResponse(ResourceResponse<DocumentCollection> response)

Parameters:

response

createCosmosDatabaseResponse

public static CosmosDatabaseResponse createCosmosDatabaseResponse(ResourceResponse<Database> 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<Permission> response)

Parameters:

response

createCosmosStoredProcedureProperties

public static CosmosStoredProcedureProperties createCosmosStoredProcedureProperties(String jsonString)

Parameters:

jsonString

createCosmosStoredProcedureResponse

public static CosmosStoredProcedureResponse createCosmosStoredProcedureResponse(ResourceResponse<StoredProcedure> response)

Parameters:

response

createCosmosStoredProcedureResponse

public static CosmosStoredProcedureResponse createCosmosStoredProcedureResponse(StoredProcedureResponse response)

Parameters:

response

createCosmosTriggerResponse

public static CosmosTriggerResponse createCosmosTriggerResponse(ResourceResponse<Trigger> response)

Parameters:

response

createCosmosUserDefinedFunctionResponse

public static CosmosUserDefinedFunctionResponse createCosmosUserDefinedFunctionResponse(ResourceResponse<UserDefinedFunction> response)

Parameters:

response

createCosmosUserResponse

public static CosmosUserResponse createCosmosUserResponse(ResourceResponse<User> response)

Parameters:

response

createFeedResponse

public static FeedResponse<T> <T>createFeedResponse(List<T> results, Map<String,String> headers)

Parameters:

results

headers

createFeedResponseWithQueryMetrics

public static FeedResponse<T> <T>createFeedResponseWithQueryMetrics(List<T> results, Map<String,String> headers, ConcurrentMap<String,QueryMetrics> 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<Offer> offerResourceResponse)

Parameters:

offerResourceResponse

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<CosmosClientEncryptionKeyProperties> getClientEncryptionKeyPropertiesList(List<ClientEncryptionKey> results)

Parameters:

results

getConsistencyLevel

public static ConsistencyLevel getConsistencyLevel(CosmosItemRequestOptions options)

Parameters:

options

getCosmosConflictPropertiesFromV2Results

public static List<CosmosConflictProperties> getCosmosConflictPropertiesFromV2Results(List<Conflict> results)

Parameters:

results

getCosmosContainerPropertiesFromV2Results

public static List<CosmosContainerProperties> getCosmosContainerPropertiesFromV2Results(List<DocumentCollection> results)

Parameters:

results

getCosmosDatabasePropertiesFromV2Results

public static List<CosmosDatabaseProperties> getCosmosDatabasePropertiesFromV2Results(List<Database> results)

Parameters:

results

getCosmosPermissionPropertiesFromResults

public static List<CosmosPermissionProperties> getCosmosPermissionPropertiesFromResults(List<Permission> results)

Parameters:

results

getCosmosStoredProcedurePropertiesFromV2Results

public static List<CosmosStoredProcedureProperties> getCosmosStoredProcedurePropertiesFromV2Results(List<StoredProcedure> results)

Parameters:

results

getCosmosTriggerPropertiesFromV2Results

public static List<CosmosTriggerProperties> getCosmosTriggerPropertiesFromV2Results(List<Trigger> results)

Parameters:

results

getCosmosUserDefinedFunctionPropertiesFromV2Results

public static List<CosmosUserDefinedFunctionProperties> getCosmosUserDefinedFunctionPropertiesFromV2Results(List<UserDefinedFunction> results)

Parameters:

results

getCosmosUserPropertiesFromV2Results

public static List<CosmosUserProperties> getCosmosUserPropertiesFromV2Results(List<User> results)

Parameters:

results

getEffectiveChangeFeedRequestOptions

public static CosmosChangeFeedRequestOptions getEffectiveChangeFeedRequestOptions(CosmosChangeFeedRequestOptions cosmosChangeFeedRequestOptions, CosmosPagedFluxOptions pagedFlexOptions)

Parameters:

cosmosChangeFeedRequestOptions

pagedFlexOptions

getInternalObjectNode

public static InternalObjectNode <T>getInternalObjectNode(CosmosItemResponse<T> cosmosItemResponse)

Parameters:

cosmosItemResponse

getJsonSerializable

public static JsonSerializable <T>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<PatchOperation> getPatchOperationsFromCosmosPatch(CosmosPatchOperations cosmosPatchOperations)

Parameters:

cosmosPatchOperations

getPayloadLength

public static int <T>getPayloadLength(CosmosItemResponse<T> 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<String,Object> getPropertiesFromChangeFeedRequestOptions(CosmosChangeFeedRequestOptions options)

Parameters:

options

getQueryPlanDiagnosticsContext

public static QueryInfo.QueryPlanDiagnosticsContext <T>getQueryPlanDiagnosticsContext(FeedResponse<T> feedResponse)

Parameters:

feedResponse

getRequestContinuationFromQueryRequestOptions

public static String getRequestContinuationFromQueryRequestOptions(CosmosQueryRequestOptions options)

Parameters:

options

getResource

public static Resource <T>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 <T>instantiateByObjectNode(ObjectNode objectNode, Class<T> c)

Parameters:

objectNode

c

isV2

public static boolean isV2(PartitionKeyDefinition pkd)

Parameters:

pkd

noChanges

public static boolean <T>noChanges(FeedResponse<T> page)

Parameters:

page

partitionKeyfromJsonString

public static PartitionKey partitionKeyfromJsonString(String jsonString)

Parameters:

jsonString

populatePropertyBag

public static void <T>populatePropertyBag(T t)

Parameters:

t

queryMetrics

public static ConcurrentMap<String,QueryMetrics> <T>queryMetrics(FeedResponse<T> feedResponse)

Parameters:

feedResponse

queryMetricsMap

public static ConcurrentMap<String,QueryMetrics> <T>queryMetricsMap(FeedResponse<T> 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 <T>setFeedResponseContinuationToken(String continuationToken, FeedResponse<T> 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<String,Object> 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<T> <T>toFeedResponsePage(List<T> results, Map<String,String> 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