Class DatabricksConnectionContext
java.lang.Object
com.databricks.jdbc.api.impl.DatabricksConnectionContext
- All Implemented Interfaces:
IDatabricksConnectionContext
-
Method Summary
Modifier and TypeMethodDescriptionbooleanbooleanReturns whether self-signed certificates are allowed for SSL connections.buildPropertiesMap(String connectionParamString, Properties properties) Builds a map of properties from the given connection parameter string and properties object.booleanbooleanbooleanbooleanReturns whether telemetry is enabled for all connectionsReturns the application name using JDBC ConnectionintReturns the OAuth2 authorization endpoint URL for the authorization code flow.Returns the OAuth2 authentication scope used in the request.Returns the Azure tenant ID for the Azure Databricks workspace.intReturns the timeout in seconds for waiting for a chunk to be ready.Returns the userAgent string specific to client used to fetch results.com.databricks.sdk.core.utils.CloudgetCloud()com.databricks.sdk.core.ProxyConfig.ProxyAuthTypeintdoubleReturns the minimum expected download speed threshold in MB/s for CloudFetch operationsintReturns the number of threads to be used for fetching data from cloud storageReturns warehouse-Id as parsed from JDBC connection UrlReturns a unique identifier for this connection context.Returns the userAgent string specified as part of the JDBC connection stringReturns the custom headers set in the JDBC connection string.intReturns maximum number of characters that can be contained in STRING columns.booleanbooleanReturns the value of the enableMultipleCatalogSupport connection property.booleanReturns the value of the EnableSQLValidationForIsValid connection property.getHost()Returns just the host parsed from JDBC connection.Returns host-Url for Databricks server as parsed from JDBC connection in formathttps://server:portintReturns the size for HTTP connection poolReturns the HTTP connection request timeout in secondsintReturns the maximum number of HTTP connections per routeOAuth Client Id for identity federation which is used in exchanging the access token with Databricks in-house tokenintbooleanReturns whether transaction-related method calls should be ignoredReturns the algorithm used for signing the JWT (e.g., RS256, ES256).Returns the file path to the JWT private key used for signing the JWT.Returns the passphrase to decrypt the private key if the key is encrypted.getKID()Returns the Key ID (KID) used in the JWT header, identifying the key.intintintReturns the maximum number of commands that can be executed in a single batch.intReturns the non-proxy hosts that should be excluded from proxying.Returns the list of OAuth2 redirect URL ports used for OAuth authentication.Returns the discovery URL used to obtain the OAuth2 token and authorization endpoints.Returns the OAuth2 refresh token used to obtain a new access token when the current one expires.Returns the OAuth scopes to request for the user-to-machine (U2M) authorization flow.Returns the pass through access tokencom.databricks.sdk.core.ProxyConfig.ProxyAuthTypeintintintReturns maximum number of rows that a query returns at a time.intReturns the socket timeout in seconds for HTTP connections.Returns the SSL key store file path used for SSL connections.Returns the SSL key store password of the key store file.Returns the SSL key store provider for the key store.Returns the SSL key store type of the key store file.Returns the SSL trust store file path used for SSL connections.Returns the SSL trust store password of the trust store file.Returns the SSL trust store provider for the trust store.Returns the SSL trust store type of the trust store file.intReturns the batch size for Telemetry logs processingintReturns the flush interval in milliseconds for telemetryintgetToken()Returns the auth token (personal access token)Returns the passphrase used for encrypting/decrypting token cacheReturns the OAuth2 token endpoint URL for retrieving tokens.Returns the list of HTTP codes to retry for UC Volume IngestionintReturns retry timeout in seconds for UC Volume IngestionReturns allowlisted local file paths for UC Volume operationsinthashCode()booleanbooleanReturns whether batched INSERT optimization is enabledbooleanReturns true if driver return complex data type java objects natively as opposed to stringbooleanReturns whether OAuth2 discovery mode is enabled, which fetches endpoints dynamically.booleanisPropertyPresent(DatabricksJdbcUrlParams urlParam) booleanReturns true if request tracing should be enabled.booleanReturns true if driver should use direct results in SQL_EXEC API.booleanReturns true if driver should use hybrid results in SQL_EXEC API.booleanReturns whether circuit breaker is enabled for telemetrybooleanChecks if Telemetry is enabledbooleanReturns whether token caching is enabled for OAuth authenticationstatic IDatabricksConnectionContextparse(String url, Properties properties) Parses connection Url and properties into a Databricks specific connection contextvoidsetClientType(DatabricksClientType clientType) booleanbooleanReturns whether JWT assertion should be used for OAuth2 authentication.booleanReturns whether the system property trust store should be used for SSL certificate validation.
-
Method Details
-
buildPropertiesMap
public static com.google.common.collect.ImmutableMap<String,String> buildPropertiesMap(String connectionParamString, Properties properties) Builds a map of properties from the given connection parameter string and properties object.- Parameters:
connectionParamString- the connection parameter stringproperties- the properties object- Returns:
- an immutable map of properties
-
parse
public static IDatabricksConnectionContext parse(String url, Properties properties) throws DatabricksSQLException Parses connection Url and properties into a Databricks specific connection context- Parameters:
url- Databricks server connection Urlproperties- connection properties- Returns:
- a connection context
- Throws:
DatabricksSQLException
-
hashCode
-
equals
-
isPropertyPresent
- Specified by:
isPropertyPresentin interfaceIDatabricksConnectionContext
-
getHostUrl
Description copied from interface:IDatabricksConnectionContextReturns host-Url for Databricks server as parsed from JDBC connection in formathttps://server:port- Specified by:
getHostUrlin interfaceIDatabricksConnectionContext- Returns:
- Databricks host-Url
- Throws:
DatabricksParsingException
-
getHost
Description copied from interface:IDatabricksConnectionContextReturns just the host parsed from JDBC connection. Note : this is not the url.- Specified by:
getHostin interfaceIDatabricksConnectionContext- Returns:
- Databricks host
-
getComputeResource
Description copied from interface:IDatabricksConnectionContextReturns warehouse-Id as parsed from JDBC connection Url- Specified by:
getComputeResourcein interfaceIDatabricksConnectionContext- Returns:
- warehouse-Id
-
getHttpPath
- Specified by:
getHttpPathin interfaceIDatabricksConnectionContext
-
getEnableSQLValidationForIsValid
public boolean getEnableSQLValidationForIsValid()Description copied from interface:IDatabricksConnectionContextReturns the value of the EnableSQLValidationForIsValid connection property.- Specified by:
getEnableSQLValidationForIsValidin interfaceIDatabricksConnectionContext
-
getEnableMultipleCatalogSupport
public boolean getEnableMultipleCatalogSupport()Description copied from interface:IDatabricksConnectionContextReturns the value of the enableMultipleCatalogSupport connection property.- Specified by:
getEnableMultipleCatalogSupportin interfaceIDatabricksConnectionContext
-
getHostForOAuth
- Specified by:
getHostForOAuthin interfaceIDatabricksConnectionContext
-
getToken
Description copied from interface:IDatabricksConnectionContextReturns the auth token (personal access token)- Specified by:
getTokenin interfaceIDatabricksConnectionContext- Returns:
- auth token
-
getPassThroughAccessToken
Description copied from interface:IDatabricksConnectionContextReturns the pass through access token- Specified by:
getPassThroughAccessTokenin interfaceIDatabricksConnectionContext- Returns:
- access token
-
getAsyncExecPollInterval
public int getAsyncExecPollInterval()- Specified by:
getAsyncExecPollIntervalin interfaceIDatabricksConnectionContext
-
getDirectResultMode
- Specified by:
getDirectResultModein interfaceIDatabricksConnectionContext
-
getCloud
- Specified by:
getCloudin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getGcpAuthType
- Specified by:
getGcpAuthTypein interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getClientId
- Specified by:
getClientIdin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getNullableClientId
- Specified by:
getNullableClientIdin interfaceIDatabricksConnectionContext
-
getOAuthScopesForU2M
Description copied from interface:IDatabricksConnectionContextReturns the OAuth scopes to request for the user-to-machine (U2M) authorization flow.If an explicit auth scope is provided via connection parameters, this returns a singleton list containing that scope. On AWS and GCP, this returns the SQL scope and offline access scope. On Azure, this returns
nullbecause the default scope is set by the Databricks SDK.- Specified by:
getOAuthScopesForU2Min interfaceIDatabricksConnectionContext- Returns:
- a list of OAuth scopes to request, or
nullon Azure to use the SDK default - Throws:
DatabricksParsingException- if connection parameters cannot be parsed
-
getClientSecret
- Specified by:
getClientSecretin interfaceIDatabricksConnectionContext
-
getGoogleServiceAccount
- Specified by:
getGoogleServiceAccountin interfaceIDatabricksConnectionContext
-
getGoogleCredentials
- Specified by:
getGoogleCredentialsin interfaceIDatabricksConnectionContext
-
getAuthFlow
- Specified by:
getAuthFlowin interfaceIDatabricksConnectionContext
-
getAuthMech
- Specified by:
getAuthMechin interfaceIDatabricksConnectionContext
-
getLogLevel
- Specified by:
getLogLevelin interfaceIDatabricksConnectionContext
-
getLogPathString
- Specified by:
getLogPathStringin interfaceIDatabricksConnectionContext
-
getLogFileSize
public int getLogFileSize()- Specified by:
getLogFileSizein interfaceIDatabricksConnectionContext
-
getLogFileCount
public int getLogFileCount()- Specified by:
getLogFileCountin interfaceIDatabricksConnectionContext
-
getClientUserAgent
Description copied from interface:IDatabricksConnectionContextReturns the userAgent string specific to client used to fetch results.- Specified by:
getClientUserAgentin interfaceIDatabricksConnectionContext
-
getCustomerUserAgent
Description copied from interface:IDatabricksConnectionContextReturns the userAgent string specified as part of the JDBC connection string- Specified by:
getCustomerUserAgentin interfaceIDatabricksConnectionContext
-
getCompressionCodec
- Specified by:
getCompressionCodecin interfaceIDatabricksConnectionContext
-
getClientTypeFromContext
-
getClientType
- Specified by:
getClientTypein interfaceIDatabricksConnectionContext
-
setClientType
- Specified by:
setClientTypein interfaceIDatabricksConnectionContext
-
getCloudFetchThreadPoolSize
public int getCloudFetchThreadPoolSize()Description copied from interface:IDatabricksConnectionContextReturns the number of threads to be used for fetching data from cloud storage- Specified by:
getCloudFetchThreadPoolSizein interfaceIDatabricksConnectionContext
-
getCloudFetchSpeedThreshold
public double getCloudFetchSpeedThreshold()Description copied from interface:IDatabricksConnectionContextReturns the minimum expected download speed threshold in MB/s for CloudFetch operations- Specified by:
getCloudFetchSpeedThresholdin interfaceIDatabricksConnectionContext
-
getCatalog
- Specified by:
getCatalogin interfaceIDatabricksConnectionContext
-
getSchema
- Specified by:
getSchemain interfaceIDatabricksConnectionContext
-
getSessionConfigs
- Specified by:
getSessionConfigsin interfaceIDatabricksConnectionContext
-
getClientInfoProperties
- Specified by:
getClientInfoPropertiesin interfaceIDatabricksConnectionContext
-
getCustomHeaders
Description copied from interface:IDatabricksConnectionContextReturns the custom headers set in the JDBC connection string.- Specified by:
getCustomHeadersin interfaceIDatabricksConnectionContext- Returns:
- Map of custom headers
-
isAllPurposeCluster
public boolean isAllPurposeCluster()- Specified by:
isAllPurposeClusterin interfaceIDatabricksConnectionContext
-
getProxyHost
- Specified by:
getProxyHostin interfaceIDatabricksConnectionContext
-
getProxyPort
public int getProxyPort()- Specified by:
getProxyPortin interfaceIDatabricksConnectionContext
-
getProxyUser
- Specified by:
getProxyUserin interfaceIDatabricksConnectionContext
-
getProxyPassword
- Specified by:
getProxyPasswordin interfaceIDatabricksConnectionContext
-
getUseProxy
- Specified by:
getUseProxyin interfaceIDatabricksConnectionContext
-
getProxyAuthType
public com.databricks.sdk.core.ProxyConfig.ProxyAuthType getProxyAuthType()- Specified by:
getProxyAuthTypein interfaceIDatabricksConnectionContext
-
getUseSystemProxy
- Specified by:
getUseSystemProxyin interfaceIDatabricksConnectionContext
-
getUseCloudFetchProxy
- Specified by:
getUseCloudFetchProxyin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyHost
- Specified by:
getCloudFetchProxyHostin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyPort
public int getCloudFetchProxyPort()- Specified by:
getCloudFetchProxyPortin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyUser
- Specified by:
getCloudFetchProxyUserin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyPassword
- Specified by:
getCloudFetchProxyPasswordin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyAuthType
public com.databricks.sdk.core.ProxyConfig.ProxyAuthType getCloudFetchProxyAuthType()- Specified by:
getCloudFetchProxyAuthTypein interfaceIDatabricksConnectionContext
-
shouldEnableArrow
- Specified by:
shouldEnableArrowin interfaceIDatabricksConnectionContext
-
getEndpointURL
- Specified by:
getEndpointURLin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
shouldRetryRateLimitError
- Specified by:
shouldRetryRateLimitErrorin interfaceIDatabricksConnectionContext
-
getRateLimitRetryTimeout
public int getRateLimitRetryTimeout()- Specified by:
getRateLimitRetryTimeoutin interfaceIDatabricksConnectionContext
-
getIdleHttpConnectionExpiry
public int getIdleHttpConnectionExpiry()- Specified by:
getIdleHttpConnectionExpiryin interfaceIDatabricksConnectionContext
-
supportManyParameters
public boolean supportManyParameters()- Specified by:
supportManyParametersin interfaceIDatabricksConnectionContext
-
getConnectionURL
- Specified by:
getConnectionURLin interfaceIDatabricksConnectionContext
-
checkCertificateRevocation
public boolean checkCertificateRevocation()- Specified by:
checkCertificateRevocationin interfaceIDatabricksConnectionContext
-
acceptUndeterminedCertificateRevocation
public boolean acceptUndeterminedCertificateRevocation()- Specified by:
acceptUndeterminedCertificateRevocationin interfaceIDatabricksConnectionContext
-
getJWTKeyFile
Description copied from interface:IDatabricksConnectionContextReturns the file path to the JWT private key used for signing the JWT.- Specified by:
getJWTKeyFilein interfaceIDatabricksConnectionContext
-
getKID
Description copied from interface:IDatabricksConnectionContextReturns the Key ID (KID) used in the JWT header, identifying the key.- Specified by:
getKIDin interfaceIDatabricksConnectionContext
-
getJWTPassphrase
Description copied from interface:IDatabricksConnectionContextReturns the passphrase to decrypt the private key if the key is encrypted.- Specified by:
getJWTPassphrasein interfaceIDatabricksConnectionContext
-
getJWTAlgorithm
Description copied from interface:IDatabricksConnectionContextReturns the algorithm used for signing the JWT (e.g., RS256, ES256).- Specified by:
getJWTAlgorithmin interfaceIDatabricksConnectionContext
-
useJWTAssertion
public boolean useJWTAssertion()Description copied from interface:IDatabricksConnectionContextReturns whether JWT assertion should be used for OAuth2 authentication.- Specified by:
useJWTAssertionin interfaceIDatabricksConnectionContext
-
getTokenEndpoint
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 token endpoint URL for retrieving tokens.- Specified by:
getTokenEndpointin interfaceIDatabricksConnectionContext
-
getAuthEndpoint
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 authorization endpoint URL for the authorization code flow.- Specified by:
getAuthEndpointin interfaceIDatabricksConnectionContext
-
isOAuthDiscoveryModeEnabled
public boolean isOAuthDiscoveryModeEnabled()Description copied from interface:IDatabricksConnectionContextReturns whether OAuth2 discovery mode is enabled, which fetches endpoints dynamically.- Specified by:
isOAuthDiscoveryModeEnabledin interfaceIDatabricksConnectionContext
-
getIdentityFederationClientId
Description copied from interface:IDatabricksConnectionContextOAuth Client Id for identity federation which is used in exchanging the access token with Databricks in-house token- Specified by:
getIdentityFederationClientIdin interfaceIDatabricksConnectionContext
-
getOAuthDiscoveryURL
Description copied from interface:IDatabricksConnectionContextReturns the discovery URL used to obtain the OAuth2 token and authorization endpoints.- Specified by:
getOAuthDiscoveryURLin interfaceIDatabricksConnectionContext
-
getAuthScope
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 authentication scope used in the request.- Specified by:
getAuthScopein interfaceIDatabricksConnectionContext
-
getOAuthRefreshToken
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 refresh token used to obtain a new access token when the current one expires.- Specified by:
getOAuthRefreshTokenin interfaceIDatabricksConnectionContext
-
getOAuth2RedirectUrlPorts
Description copied from interface:IDatabricksConnectionContextReturns the list of OAuth2 redirect URL ports used for OAuth authentication.- Specified by:
getOAuth2RedirectUrlPortsin interfaceIDatabricksConnectionContext
-
getUseEmptyMetadata
- Specified by:
getUseEmptyMetadatain interfaceIDatabricksConnectionContext
-
getNonProxyHosts
Description copied from interface:IDatabricksConnectionContextReturns the non-proxy hosts that should be excluded from proxying.- Specified by:
getNonProxyHostsin interfaceIDatabricksConnectionContext
-
getSSLTrustStore
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store file path used for SSL connections.- Specified by:
getSSLTrustStorein interfaceIDatabricksConnectionContext
-
getSSLTrustStorePassword
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store password of the trust store file.- Specified by:
getSSLTrustStorePasswordin interfaceIDatabricksConnectionContext
-
getSSLTrustStoreType
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store type of the trust store file.- Specified by:
getSSLTrustStoreTypein interfaceIDatabricksConnectionContext
-
getSSLTrustStoreProvider
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store provider for the trust store.- Specified by:
getSSLTrustStoreProviderin interfaceIDatabricksConnectionContext
-
getSSLKeyStore
Description copied from interface:IDatabricksConnectionContextReturns the SSL key store file path used for SSL connections.- Specified by:
getSSLKeyStorein interfaceIDatabricksConnectionContext
-
getSSLKeyStorePassword
Description copied from interface:IDatabricksConnectionContextReturns the SSL key store password of the key store file.- Specified by:
getSSLKeyStorePasswordin interfaceIDatabricksConnectionContext
-
getSSLKeyStoreType
Description copied from interface:IDatabricksConnectionContextReturns the SSL key store type of the key store file.- Specified by:
getSSLKeyStoreTypein interfaceIDatabricksConnectionContext
-
getSSLKeyStoreProvider
Description copied from interface:IDatabricksConnectionContextReturns the SSL key store provider for the key store.- Specified by:
getSSLKeyStoreProviderin interfaceIDatabricksConnectionContext
-
getMaxBatchSize
public int getMaxBatchSize()Description copied from interface:IDatabricksConnectionContextReturns the maximum number of commands that can be executed in a single batch.- Specified by:
getMaxBatchSizein interfaceIDatabricksConnectionContext
-
getConnectionUuid
Description copied from interface:IDatabricksConnectionContextReturns a unique identifier for this connection context.This UUID is generated when the connection context is instantiated and serves as a unique internal identifier for each JDBC connection.
- Specified by:
getConnectionUuidin interfaceIDatabricksConnectionContext
-
getTelemetryBatchSize
public int getTelemetryBatchSize()Description copied from interface:IDatabricksConnectionContextReturns the batch size for Telemetry logs processing- Specified by:
getTelemetryBatchSizein interfaceIDatabricksConnectionContext
-
isTelemetryEnabled
public boolean isTelemetryEnabled()Description copied from interface:IDatabricksConnectionContextChecks if Telemetry is enabled- Specified by:
isTelemetryEnabledin interfaceIDatabricksConnectionContext
-
getVolumeOperationAllowedPaths
Description copied from interface:IDatabricksConnectionContextReturns allowlisted local file paths for UC Volume operations- Specified by:
getVolumeOperationAllowedPathsin interfaceIDatabricksConnectionContext
-
isSqlExecHybridResultsEnabled
public boolean isSqlExecHybridResultsEnabled()Description copied from interface:IDatabricksConnectionContextReturns true if driver should use hybrid results in SQL_EXEC API.- Specified by:
isSqlExecHybridResultsEnabledin interfaceIDatabricksConnectionContext
-
isSqlExecDirectResultsEnabled
public boolean isSqlExecDirectResultsEnabled()Description copied from interface:IDatabricksConnectionContextReturns true if driver should use direct results in SQL_EXEC API.- Specified by:
isSqlExecDirectResultsEnabledin interfaceIDatabricksConnectionContext
-
getAzureTenantId
Description copied from interface:IDatabricksConnectionContextReturns the Azure tenant ID for the Azure Databricks workspace.- Specified by:
getAzureTenantIdin interfaceIDatabricksConnectionContext
-
getDefaultStringColumnLength
public int getDefaultStringColumnLength()Description copied from interface:IDatabricksConnectionContextReturns maximum number of characters that can be contained in STRING columns.- Specified by:
getDefaultStringColumnLengthin interfaceIDatabricksConnectionContext
-
getMaxDBFSConcurrentPresignedRequests
public int getMaxDBFSConcurrentPresignedRequests()- Specified by:
getMaxDBFSConcurrentPresignedRequestsin interfaceIDatabricksConnectionContext
-
isComplexDatatypeSupportEnabled
public boolean isComplexDatatypeSupportEnabled()Description copied from interface:IDatabricksConnectionContextReturns true if driver return complex data type java objects natively as opposed to string- Specified by:
isComplexDatatypeSupportEnabledin interfaceIDatabricksConnectionContext
-
isRequestTracingEnabled
public boolean isRequestTracingEnabled()Description copied from interface:IDatabricksConnectionContextReturns true if request tracing should be enabled.- Specified by:
isRequestTracingEnabledin interfaceIDatabricksConnectionContext
-
getHttpConnectionPoolSize
public int getHttpConnectionPoolSize()Description copied from interface:IDatabricksConnectionContextReturns the size for HTTP connection pool- Specified by:
getHttpConnectionPoolSizein interfaceIDatabricksConnectionContext
-
allowSelfSignedCerts
public boolean allowSelfSignedCerts()Description copied from interface:IDatabricksConnectionContextReturns whether self-signed certificates are allowed for SSL connections.When true, the driver will accept any certificate, including self-signed certificates. This option is insecure and should only be used in non-production environments.
- Specified by:
allowSelfSignedCertsin interfaceIDatabricksConnectionContext- Returns:
- true if self-signed certificates are allowed, false otherwise
-
useSystemTrustStore
public boolean useSystemTrustStore()Description copied from interface:IDatabricksConnectionContextReturns whether the system property trust store should be used for SSL certificate validation.When true, the driver will use either:
- The trust store specified by the Java system property
javax.net.ssl.trustStoreif set - Or the JDK's default trust store (cacerts) if no system property is set
When false, the driver will:
- Use the custom trust store specified by the SSLTrustStore parameter if provided
- Or use the JDK's default trust store (cacerts) but ignore any javax.net.ssl.trustStore system property
- Specified by:
useSystemTrustStorein interfaceIDatabricksConnectionContext- Returns:
- true if the system property trust store should be used, false otherwise
- The trust store specified by the Java system property
-
getUCIngestionRetriableHttpCodes
Description copied from interface:IDatabricksConnectionContextReturns the list of HTTP codes to retry for UC Volume Ingestion- Specified by:
getUCIngestionRetriableHttpCodesin interfaceIDatabricksConnectionContext
-
getUCIngestionRetryTimeoutSeconds
public int getUCIngestionRetryTimeoutSeconds()Description copied from interface:IDatabricksConnectionContextReturns retry timeout in seconds for UC Volume Ingestion- Specified by:
getUCIngestionRetryTimeoutSecondsin interfaceIDatabricksConnectionContext
-
getAzureWorkspaceResourceId
- Specified by:
getAzureWorkspaceResourceIdin interfaceIDatabricksConnectionContext
-
getRowsFetchedPerBlock
public int getRowsFetchedPerBlock()Description copied from interface:IDatabricksConnectionContextReturns maximum number of rows that a query returns at a time.- Specified by:
getRowsFetchedPerBlockin interfaceIDatabricksConnectionContext
-
getSocketTimeout
public int getSocketTimeout()Returns the socket timeout in seconds for HTTP connections.- Specified by:
getSocketTimeoutin interfaceIDatabricksConnectionContext
-
getTokenCachePassPhrase
Description copied from interface:IDatabricksConnectionContextReturns the passphrase used for encrypting/decrypting token cache- Specified by:
getTokenCachePassPhrasein interfaceIDatabricksConnectionContext
-
isTokenCacheEnabled
public boolean isTokenCacheEnabled()Description copied from interface:IDatabricksConnectionContextReturns whether token caching is enabled for OAuth authentication- Specified by:
isTokenCacheEnabledin interfaceIDatabricksConnectionContext
-
getApplicationName
Description copied from interface:IDatabricksConnectionContextReturns the application name using JDBC Connection- Specified by:
getApplicationNamein interfaceIDatabricksConnectionContext
-
getChunkReadyTimeoutSeconds
public int getChunkReadyTimeoutSeconds()Returns the timeout in seconds for waiting for a chunk to be ready.- Specified by:
getChunkReadyTimeoutSecondsin interfaceIDatabricksConnectionContext
-
isTelemetryCircuitBreakerEnabled
public boolean isTelemetryCircuitBreakerEnabled()Description copied from interface:IDatabricksConnectionContextReturns whether circuit breaker is enabled for telemetry- Specified by:
isTelemetryCircuitBreakerEnabledin interfaceIDatabricksConnectionContext
-
getHttpMaxConnectionsPerRoute
public int getHttpMaxConnectionsPerRoute()Description copied from interface:IDatabricksConnectionContextReturns the maximum number of HTTP connections per route- Specified by:
getHttpMaxConnectionsPerRoutein interfaceIDatabricksConnectionContext
-
getHttpConnectionRequestTimeout
Description copied from interface:IDatabricksConnectionContextReturns the HTTP connection request timeout in seconds- Specified by:
getHttpConnectionRequestTimeoutin interfaceIDatabricksConnectionContext
-
enableShowCommandsForGetFunctions
public boolean enableShowCommandsForGetFunctions()- Specified by:
enableShowCommandsForGetFunctionsin interfaceIDatabricksConnectionContext
-
getEnableMetricViewMetadata
public boolean getEnableMetricViewMetadata()- Specified by:
getEnableMetricViewMetadatain interfaceIDatabricksConnectionContext
-
forceEnableTelemetry
public boolean forceEnableTelemetry()Description copied from interface:IDatabricksConnectionContextReturns whether telemetry is enabled for all connections- Specified by:
forceEnableTelemetryin interfaceIDatabricksConnectionContext
-
getTelemetryFlushIntervalInMilliseconds
public int getTelemetryFlushIntervalInMilliseconds()Description copied from interface:IDatabricksConnectionContextReturns the flush interval in milliseconds for telemetry- Specified by:
getTelemetryFlushIntervalInMillisecondsin interfaceIDatabricksConnectionContext
-
isBatchedInsertsEnabled
public boolean isBatchedInsertsEnabled()Description copied from interface:IDatabricksConnectionContextReturns whether batched INSERT optimization is enabled- Specified by:
isBatchedInsertsEnabledin interfaceIDatabricksConnectionContext
-
getIgnoreTransactions
public boolean getIgnoreTransactions()Description copied from interface:IDatabricksConnectionContextReturns whether transaction-related method calls should be ignored- Specified by:
getIgnoreTransactionsin interfaceIDatabricksConnectionContext
-