ModelBridgeInternal Class

  • Reference
Package:
com.azure.cosmos.models
Maven Artifact:
com.azure:azure-cosmos:4.58.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 CosmosItemResponse<T> createCosmosAsyncItemResponse(ResourceResponse<Document> response, Class<T> classType, ItemDeserializer itemDeserializer)
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 com.azure.cosmos.implementation.InternalObjectNode getInternalObjectNode(CosmosItemResponse<T> cosmosItemResponse)
static com.azure.cosmos.implementation.JsonSerializable getJsonSerializable(T t)
static int getPayloadLength(CosmosItemResponse<T> cosmosItemResponse)
static com.azure.cosmos.implementation.query.QueryInfo.QueryPlanDiagnosticsContext getQueryPlanDiagnosticsContext(FeedResponse<T> feedResponse)
static com.azure.cosmos.implementation.Resource getResource(T t)
static T instantiateByObjectNode(ObjectNode objectNode, Class<T> c)
static boolean noChanges(RxDocumentServiceResponse rsp)
static boolean noChanges(FeedResponse<T> page)
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 void setFeedResponseContinuationToken(String continuationToken, FeedResponse<T> response)
static void setProperty(JsonSerializable jsonSerializable, String propertyName, T value)
static FeedResponse<T> toChangeFeedResponsePage(RxDocumentServiceResponse response, Function<JsonNode,T> factoryMethod, Class<T> cls)
static FeedResponse<T> toFeedResponsePage(RxDocumentServiceResponse response, Function<JsonNode,T> factoryMethod, Class<T> cls)
static FeedResponse<T> toFeedResponsePage(List<T> results, Map<String,String> headers, boolean noChanges)
static T toObjectFromJsonSerializable(JsonSerializable jsonSerializable, Class<T> c)
static CosmosBulkOperationResponse<TContext> createCosmosBulkOperationResponse(CosmosItemOperation operation, CosmosBulkItemResponse response, TContext batchContext)
static CosmosBulkOperationResponse<TContext> createCosmosBulkOperationResponse(CosmosItemOperation operation, Exception exception, TContext batchContext)
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 CosmosItemResponse<Object> createCosmosAsyncItemResponseWithObjectType(ResourceResponse<Document> response)
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 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 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 String getAltLink(Resource resource)
static Boolean getBooleanFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
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 Double getDoubleFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
static CosmosChangeFeedRequestOptions getEffectiveChangeFeedRequestOptions(CosmosChangeFeedRequestOptions cosmosChangeFeedRequestOptions, CosmosPagedFluxOptions pagedFlexOptions)
static Integer getIntFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
static Map<String,Object> getMapFromJsonSerializable(JsonSerializable jsonSerializable)
static Integer getMaxItemCountFromQueryRequestOptions(CosmosQueryRequestOptions options)
static boolean getNoChangesFromFeedResponse(FeedResponse<?> response)
static com.azure.cosmos.implementation.routing.PartitionKeyInternal getNonePartitionKey(PartitionKeyDefinition partitionKeyDefinition)
static Object getObjectByPathFromJsonSerializable(JsonSerializable jsonSerializable, List<String> propertyNames)
static Object getObjectFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
static com.fasterxml.jackson.databind.node.ObjectNode getObjectNodeFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
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 Object getPartitionKeyObject(PartitionKey right)
static String getPartitionKeyRangeIdInternal(CosmosQueryRequestOptions options)

Gets the partitionKeyRangeId.
static List<com.azure.cosmos.implementation.patch.PatchOperation> getPatchOperationsFromCosmosPatch(CosmosPatchOperations cosmosPatchOperations)
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.fasterxml.jackson.databind.node.ObjectNode getPropertyBagFromJsonSerializable(JsonSerializable jsonSerializable)
static String getRequestContinuationFromQueryRequestOptions(CosmosQueryRequestOptions options)
static String getStringFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
static com.azure.cosmos.implementation.DocumentCollection getV2Collection(CosmosContainerProperties containerProperties)
static com.azure.cosmos.implementation.User getV2User(CosmosUserProperties cosmosUserProperties)
static Object getValue(JsonNode value)
static void initializeAllAccessors()
static boolean isV2(PartitionKeyDefinition pkd)
static PartitionKey partitionKeyfromJsonString(String jsonString)
static void removeFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)
static ByteBuffer serializeJsonToByteBuffer(JsonSerializable jsonSerializable)
static ByteBuffer serializeJsonToByteBuffer(JsonSerializable jsonSerializable, ObjectMapper objectMapper)
static ByteBuffer serializeJsonToByteBuffer(SqlQuerySpec sqlQuerySpec)
static void setAltLink(Resource resource, String altLink)
static void setChangeFeedRequestOptionsContinuation(String eTag, CosmosChangeFeedRequestOptions options)
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 void setResourceId(Resource resource, String resourceId)
static void setResourceSelfLink(Resource resource, String selfLink)
static CosmosContainerRequestOptions setThroughputProperties(CosmosContainerRequestOptions containerRequestOptions, ThroughputProperties throughputProperties)
static CosmosDatabaseRequestOptions setThroughputProperties(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions, ThroughputProperties throughputProperties)
static void setTimestamp(Resource resource, Instant date)
static com.azure.cosmos.implementation.DatabaseAccount toDatabaseAccount(RxDocumentServiceResponse response)
static String toJsonFromJsonSerializable(JsonSerializable jsonSerializable)
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(CosmosItemRequestOptions cosmosItemRequestOptions)
static com.azure.cosmos.implementation.RequestOptions toRequestOptions(CosmosPatchItemRequestOptions cosmosPatchItemRequestOptions)
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

createCosmosAsyncItemResponse

public static CosmosItemResponse createCosmosAsyncItemResponse(ResourceResponse response, Class classType, ItemDeserializer itemDeserializer)

Parameters:

response
classType
itemDeserializer

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

getInternalObjectNode

public static InternalObjectNode getInternalObjectNode(CosmosItemResponse cosmosItemResponse)

Parameters:

cosmosItemResponse

getJsonSerializable

public static JsonSerializable getJsonSerializable(T t)

Parameters:

t

getPayloadLength

public static int getPayloadLength(CosmosItemResponse cosmosItemResponse)

Parameters:

cosmosItemResponse

getQueryPlanDiagnosticsContext

public static QueryInfo.QueryPlanDiagnosticsContext getQueryPlanDiagnosticsContext(FeedResponse feedResponse)

Parameters:

feedResponse

getResource

public static Resource getResource(T t)

Parameters:

t

instantiateByObjectNode

public static T instantiateByObjectNode(ObjectNode objectNode, Class c)

Parameters:

objectNode
c

noChanges

public static boolean noChanges(RxDocumentServiceResponse rsp)

Parameters:

rsp

noChanges

public static boolean noChanges(FeedResponse page)

Parameters:

page

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

setFeedResponseContinuationToken

public static void setFeedResponseContinuationToken(String continuationToken, FeedResponse response)

Parameters:

continuationToken
response

setProperty

public static void setProperty(JsonSerializable jsonSerializable, String propertyName, T value)

Parameters:

jsonSerializable
propertyName
value

toChangeFeedResponsePage

public static FeedResponse toChangeFeedResponsePage(RxDocumentServiceResponse response, Function factoryMethod, Class cls)

Parameters:

response
factoryMethod
cls

toFeedResponsePage

public static FeedResponse toFeedResponsePage(RxDocumentServiceResponse response, Function factoryMethod, Class cls)

Parameters:

response
factoryMethod
cls

toFeedResponsePage

public static FeedResponse toFeedResponsePage(List results, Map headers, boolean noChanges)

Parameters:

results
headers
noChanges

toObjectFromJsonSerializable

public static T toObjectFromJsonSerializable(JsonSerializable jsonSerializable, Class c)

Parameters:

jsonSerializable
c

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

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

createCosmosAsyncItemResponseWithObjectType

public static CosmosItemResponse createCosmosAsyncItemResponseWithObjectType(ResourceResponse response)

Parameters:

response

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

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

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

getAltLink

public static String getAltLink(Resource resource)

Parameters:

resource

getBooleanFromJsonSerializable

public static Boolean getBooleanFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

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

getDoubleFromJsonSerializable

public static Double getDoubleFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

getEffectiveChangeFeedRequestOptions

public static CosmosChangeFeedRequestOptions getEffectiveChangeFeedRequestOptions(CosmosChangeFeedRequestOptions cosmosChangeFeedRequestOptions, CosmosPagedFluxOptions pagedFlexOptions)

Parameters:

cosmosChangeFeedRequestOptions
pagedFlexOptions

getIntFromJsonSerializable

public static Integer getIntFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

getMapFromJsonSerializable

public static Map getMapFromJsonSerializable(JsonSerializable jsonSerializable)

Parameters:

jsonSerializable

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

getObjectByPathFromJsonSerializable

public static Object getObjectByPathFromJsonSerializable(JsonSerializable jsonSerializable, List propertyNames)

Parameters:

jsonSerializable
propertyNames

getObjectFromJsonSerializable

public static Object getObjectFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

getObjectNodeFromJsonSerializable

public static ObjectNode getObjectNodeFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

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

getPartitionKeyObject

public static Object getPartitionKeyObject(PartitionKey right)

Parameters:

right

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

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

getPropertyBagFromJsonSerializable

public static ObjectNode getPropertyBagFromJsonSerializable(JsonSerializable jsonSerializable)

Parameters:

jsonSerializable

getRequestContinuationFromQueryRequestOptions

public static String getRequestContinuationFromQueryRequestOptions(CosmosQueryRequestOptions options)

Parameters:

options

getStringFromJsonSerializable

public static String getStringFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

getV2Collection

public static DocumentCollection getV2Collection(CosmosContainerProperties containerProperties)

Parameters:

containerProperties

getV2User

public static User getV2User(CosmosUserProperties cosmosUserProperties)

Parameters:

cosmosUserProperties

getValue

public static Object getValue(JsonNode value)

Parameters:

value

initializeAllAccessors

public static void initializeAllAccessors()

isV2

public static boolean isV2(PartitionKeyDefinition pkd)

Parameters:

pkd

partitionKeyfromJsonString

public static PartitionKey partitionKeyfromJsonString(String jsonString)

Parameters:

jsonString

removeFromJsonSerializable

public static void removeFromJsonSerializable(JsonSerializable jsonSerializable, String propertyName)

Parameters:

jsonSerializable
propertyName

serializeJsonToByteBuffer

public static ByteBuffer serializeJsonToByteBuffer(JsonSerializable jsonSerializable)

Parameters:

jsonSerializable

serializeJsonToByteBuffer

public static ByteBuffer serializeJsonToByteBuffer(JsonSerializable jsonSerializable, ObjectMapper objectMapper)

Parameters:

jsonSerializable
objectMapper

serializeJsonToByteBuffer

public static ByteBuffer serializeJsonToByteBuffer(SqlQuerySpec sqlQuerySpec)

Parameters:

sqlQuerySpec

setAltLink

public static void setAltLink(Resource resource, String altLink)

Parameters:

resource
altLink

setChangeFeedRequestOptionsContinuation

public static void setChangeFeedRequestOptionsContinuation(String eTag, CosmosChangeFeedRequestOptions options)

Parameters:

eTag
options

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

setResourceId

public static void setResourceId(Resource resource, String resourceId)

Parameters:

resource
resourceId

setResourceSelfLink

public static void setResourceSelfLink(Resource resource, String selfLink)

Parameters:

resource
selfLink

setThroughputProperties

public static CosmosContainerRequestOptions setThroughputProperties(CosmosContainerRequestOptions containerRequestOptions, ThroughputProperties throughputProperties)

Parameters:

containerRequestOptions
throughputProperties

setThroughputProperties

public static CosmosDatabaseRequestOptions setThroughputProperties(CosmosDatabaseRequestOptions cosmosDatabaseRequestOptions, ThroughputProperties throughputProperties)

Parameters:

cosmosDatabaseRequestOptions
throughputProperties

setTimestamp

public static void setTimestamp(Resource resource, Instant date)

Parameters:

resource
date

toDatabaseAccount

public static DatabaseAccount toDatabaseAccount(RxDocumentServiceResponse response)

Parameters:

response

toJsonFromJsonSerializable

public static String toJsonFromJsonSerializable(JsonSerializable jsonSerializable)

Parameters:

jsonSerializable

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(CosmosItemRequestOptions cosmosItemRequestOptions)

Parameters:

cosmosItemRequestOptions

toRequestOptions

public static RequestOptions toRequestOptions(CosmosPatchItemRequestOptions cosmosPatchItemRequestOptions)

Parameters:

cosmosPatchItemRequestOptions

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