Package com.databricks.jdbc.api.impl
Class DatabricksConnectionContext
- java.lang.Object
-
- com.databricks.jdbc.api.impl.DatabricksConnectionContext
-
- All Implemented Interfaces:
IDatabricksConnectionContext
public class DatabricksConnectionContext extends Object implements IDatabricksConnectionContext
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanacceptUndeterminedCertificateRevocation()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.booleancheckCertificateRevocation()booleanequals(Object obj)intgetAsyncExecPollInterval()StringgetAuthEndpoint()Returns the OAuth2 authorization endpoint URL for the authorization code flow.AuthFlowgetAuthFlow()AuthMechgetAuthMech()StringgetAuthScope()Returns the OAuth2 authentication scope used in the request.StringgetAzureTenantId()Returns the Azure tenant ID for the Azure Databricks workspace.StringgetAzureWorkspaceResourceId()StringgetCatalog()StringgetClientId()Map<String,String>getClientInfoProperties()StringgetClientSecret()DatabricksClientTypegetClientType()DatabricksClientTypegetClientTypeFromContext()StringgetClientUserAgent()Returns the userAgent string specific to client used to fetch results.com.databricks.sdk.core.utils.CloudgetCloud()com.databricks.sdk.core.ProxyConfig.ProxyAuthTypegetCloudFetchProxyAuthType()StringgetCloudFetchProxyHost()StringgetCloudFetchProxyPassword()intgetCloudFetchProxyPort()StringgetCloudFetchProxyUser()intgetCloudFetchThreadPoolSize()Returns the number of threads to be used for fetching data from cloud storageCompressionCodecgetCompressionCodec()IDatabricksComputeResourcegetComputeResource()Returns warehouse-Id as parsed from JDBC connection UrlStringgetConnectionURL()StringgetConnectionUuid()Returns a unique identifier for this connection context.StringgetCustomerUserAgent()Returns the userAgent string specified as part of the JDBC connection stringMap<String,String>getCustomHeaders()Returns the custom headers set in the JDBC connection string.intgetDefaultStringColumnLength()Returns maximum number of characters that can be contained in STRING columns.BooleangetDirectResultMode()StringgetEndpointURL()StringgetGcpAuthType()StringgetGoogleCredentials()StringgetGoogleServiceAccount()StringgetHostForOAuth()StringgetHostUrl()Returns host-Url for Databricks server as parsed from JDBC connection in formathttps://server:portintgetHttpConnectionPoolSize()Returns the size for HTTP connection poolStringgetHttpPath()intgetIdleHttpConnectionExpiry()StringgetJWTAlgorithm()Returns the algorithm used for signing the JWT (e.g., RS256, ES256).StringgetJWTKeyFile()Returns the file path to the JWT private key used for signing the JWT.StringgetJWTPassphrase()Returns the passphrase to decrypt the private key if the key is encrypted.StringgetKID()Returns the Key ID (KID) used in the JWT header, identifying the key.intgetLogFileCount()intgetLogFileSize()LogLevelgetLogLevel()StringgetLogPathString()intgetMaxBatchSize()Returns the maximum number of commands that can be executed in a single batch.StringgetNonProxyHosts()Returns the non-proxy hosts that should be excluded from proxying.StringgetNullableClientId()List<Integer>getOAuth2RedirectUrlPorts()Returns the list of OAuth2 redirect URL ports used for OAuth authentication.StringgetOAuthDiscoveryURL()Returns the discovery URL used to obtain the OAuth2 token and authorization endpoints.StringgetOAuthRefreshToken()Returns the OAuth2 refresh token used to obtain a new access token when the current one expires.List<String>getOAuthScopesForU2M()StringgetPassThroughAccessToken()Returns the pass through access tokencom.databricks.sdk.core.ProxyConfig.ProxyAuthTypegetProxyAuthType()StringgetProxyHost()StringgetProxyPassword()intgetProxyPort()StringgetProxyUser()intgetRateLimitRetryTimeout()intgetRowsFetchedPerBlock()Returns maximum number of rows that a query returns at a time.StringgetSchema()Map<String,String>getSessionConfigs()intgetSocketTimeout()Returns the socket timeout in seconds for HTTP connections.StringgetSSLTrustStore()Returns the SSL trust store file path used for SSL connections.StringgetSSLTrustStorePassword()Returns the SSL trust store password of the trust store file.StringgetSSLTrustStoreType()Returns the SSL trust store type of the trust store file.intgetTelemetryBatchSize()Returns the batch size for Telemetry logs processingintgetTemporarilyUnavailableRetryTimeout()StringgetToken()Returns the auth token (personal access token)StringgetTokenEndpoint()Returns the OAuth2 token endpoint URL for retrieving tokens.List<Integer>getUCIngestionRetriableHttpCodes()Returns the list of HTTP codes to retry for UC Volume IngestionintgetUCIngestionRetryTimeoutSeconds()Returns retry timeout in seconds for UC Volume IngestionBooleangetUseCloudFetchProxy()BooleangetUseEmptyMetadata()BooleangetUseProxy()BooleangetUseSystemProxy()StringgetVolumeOperationAllowedPaths()Returns allowlisted local file paths for UC Volume operationsinthashCode()booleanisAllPurposeCluster()booleanisComplexDatatypeSupportEnabled()Returns true if driver return complex data type java objects natively as opposed to stringbooleanisOAuthDiscoveryModeEnabled()Returns whether OAuth2 discovery mode is enabled, which fetches endpoints dynamically.booleanisPropertyPresent(DatabricksJdbcUrlParams urlParam)booleanisRequestTracingEnabled()Returns true if request tracing should be enabled.booleanisSqlExecHybridResultsEnabled()Returns true if driver should use hybrid results in SQL_EXEC API.booleanisTelemetryEnabled()Checks if Telemetry is enabledstatic IDatabricksConnectionContextparse(String url, Properties properties)Parses connection Url and properties into a Databricks specific connection contextvoidsetClientType(DatabricksClientType clientType)BooleanshouldEnableArrow()BooleanshouldRetryRateLimitError()BooleanshouldRetryTemporarilyUnavailableError()booleansupportManyParameters()booleanuseJWTAssertion()Returns whether JWT assertion should be used for OAuth2 authentication.
-
-
-
Method Detail
-
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
-
isPropertyPresent
public boolean isPropertyPresent(DatabricksJdbcUrlParams urlParam)
- Specified by:
isPropertyPresentin interfaceIDatabricksConnectionContext
-
getHostUrl
public String getHostUrl() throws DatabricksParsingException
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
-
getComputeResource
public IDatabricksComputeResource getComputeResource()
Description copied from interface:IDatabricksConnectionContextReturns warehouse-Id as parsed from JDBC connection Url- Specified by:
getComputeResourcein interfaceIDatabricksConnectionContext- Returns:
- warehouse-Id
-
getHttpPath
public String getHttpPath()
- Specified by:
getHttpPathin interfaceIDatabricksConnectionContext
-
getHostForOAuth
public String getHostForOAuth()
- Specified by:
getHostForOAuthin interfaceIDatabricksConnectionContext
-
getToken
public String getToken()
Description copied from interface:IDatabricksConnectionContextReturns the auth token (personal access token)- Specified by:
getTokenin interfaceIDatabricksConnectionContext- Returns:
- auth token
-
getPassThroughAccessToken
public String 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
public Boolean getDirectResultMode()
- Specified by:
getDirectResultModein interfaceIDatabricksConnectionContext
-
getCloud
public com.databricks.sdk.core.utils.Cloud getCloud() throws DatabricksParsingException- Specified by:
getCloudin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getGcpAuthType
public String getGcpAuthType() throws DatabricksParsingException
- Specified by:
getGcpAuthTypein interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getClientId
public String getClientId() throws DatabricksParsingException
- Specified by:
getClientIdin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getNullableClientId
public String getNullableClientId()
- Specified by:
getNullableClientIdin interfaceIDatabricksConnectionContext
-
getOAuthScopesForU2M
public List<String> getOAuthScopesForU2M() throws DatabricksParsingException
- Specified by:
getOAuthScopesForU2Min interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
getClientSecret
public String getClientSecret()
- Specified by:
getClientSecretin interfaceIDatabricksConnectionContext
-
getGoogleServiceAccount
public String getGoogleServiceAccount()
- Specified by:
getGoogleServiceAccountin interfaceIDatabricksConnectionContext
-
getGoogleCredentials
public String getGoogleCredentials()
- Specified by:
getGoogleCredentialsin interfaceIDatabricksConnectionContext
-
getAuthFlow
public AuthFlow getAuthFlow()
- Specified by:
getAuthFlowin interfaceIDatabricksConnectionContext
-
getAuthMech
public AuthMech getAuthMech()
- Specified by:
getAuthMechin interfaceIDatabricksConnectionContext
-
getLogLevel
public LogLevel getLogLevel()
- Specified by:
getLogLevelin interfaceIDatabricksConnectionContext
-
getLogPathString
public String getLogPathString()
- Specified by:
getLogPathStringin interfaceIDatabricksConnectionContext
-
getLogFileSize
public int getLogFileSize()
- Specified by:
getLogFileSizein interfaceIDatabricksConnectionContext
-
getLogFileCount
public int getLogFileCount()
- Specified by:
getLogFileCountin interfaceIDatabricksConnectionContext
-
getClientUserAgent
public String getClientUserAgent()
Description copied from interface:IDatabricksConnectionContextReturns the userAgent string specific to client used to fetch results.- Specified by:
getClientUserAgentin interfaceIDatabricksConnectionContext
-
getCustomerUserAgent
public String getCustomerUserAgent()
Description copied from interface:IDatabricksConnectionContextReturns the userAgent string specified as part of the JDBC connection string- Specified by:
getCustomerUserAgentin interfaceIDatabricksConnectionContext
-
getCompressionCodec
public CompressionCodec getCompressionCodec()
- Specified by:
getCompressionCodecin interfaceIDatabricksConnectionContext
-
getClientTypeFromContext
public DatabricksClientType getClientTypeFromContext()
-
getClientType
public DatabricksClientType getClientType()
- Specified by:
getClientTypein interfaceIDatabricksConnectionContext
-
setClientType
public void setClientType(DatabricksClientType clientType)
- 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
-
getCatalog
public String getCatalog()
- Specified by:
getCatalogin interfaceIDatabricksConnectionContext
-
getSchema
public String getSchema()
- Specified by:
getSchemain interfaceIDatabricksConnectionContext
-
getSessionConfigs
public Map<String,String> getSessionConfigs()
- Specified by:
getSessionConfigsin interfaceIDatabricksConnectionContext
-
getClientInfoProperties
public Map<String,String> getClientInfoProperties()
- Specified by:
getClientInfoPropertiesin interfaceIDatabricksConnectionContext
-
getCustomHeaders
public Map<String,String> 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
public String getProxyHost()
- Specified by:
getProxyHostin interfaceIDatabricksConnectionContext
-
getProxyPort
public int getProxyPort()
- Specified by:
getProxyPortin interfaceIDatabricksConnectionContext
-
getProxyUser
public String getProxyUser()
- Specified by:
getProxyUserin interfaceIDatabricksConnectionContext
-
getProxyPassword
public String getProxyPassword()
- Specified by:
getProxyPasswordin interfaceIDatabricksConnectionContext
-
getUseProxy
public Boolean getUseProxy()
- Specified by:
getUseProxyin interfaceIDatabricksConnectionContext
-
getProxyAuthType
public com.databricks.sdk.core.ProxyConfig.ProxyAuthType getProxyAuthType()
- Specified by:
getProxyAuthTypein interfaceIDatabricksConnectionContext
-
getUseSystemProxy
public Boolean getUseSystemProxy()
- Specified by:
getUseSystemProxyin interfaceIDatabricksConnectionContext
-
getUseCloudFetchProxy
public Boolean getUseCloudFetchProxy()
- Specified by:
getUseCloudFetchProxyin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyHost
public String getCloudFetchProxyHost()
- Specified by:
getCloudFetchProxyHostin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyPort
public int getCloudFetchProxyPort()
- Specified by:
getCloudFetchProxyPortin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyUser
public String getCloudFetchProxyUser()
- Specified by:
getCloudFetchProxyUserin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyPassword
public String getCloudFetchProxyPassword()
- Specified by:
getCloudFetchProxyPasswordin interfaceIDatabricksConnectionContext
-
getCloudFetchProxyAuthType
public com.databricks.sdk.core.ProxyConfig.ProxyAuthType getCloudFetchProxyAuthType()
- Specified by:
getCloudFetchProxyAuthTypein interfaceIDatabricksConnectionContext
-
shouldEnableArrow
public Boolean shouldEnableArrow()
- Specified by:
shouldEnableArrowin interfaceIDatabricksConnectionContext
-
getEndpointURL
public String getEndpointURL() throws DatabricksParsingException
- Specified by:
getEndpointURLin interfaceIDatabricksConnectionContext- Throws:
DatabricksParsingException
-
shouldRetryTemporarilyUnavailableError
public Boolean shouldRetryTemporarilyUnavailableError()
- Specified by:
shouldRetryTemporarilyUnavailableErrorin interfaceIDatabricksConnectionContext
-
shouldRetryRateLimitError
public Boolean shouldRetryRateLimitError()
- Specified by:
shouldRetryRateLimitErrorin interfaceIDatabricksConnectionContext
-
getTemporarilyUnavailableRetryTimeout
public int getTemporarilyUnavailableRetryTimeout()
- Specified by:
getTemporarilyUnavailableRetryTimeoutin 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
public String getConnectionURL()
- Specified by:
getConnectionURLin interfaceIDatabricksConnectionContext
-
checkCertificateRevocation
public boolean checkCertificateRevocation()
- Specified by:
checkCertificateRevocationin interfaceIDatabricksConnectionContext
-
acceptUndeterminedCertificateRevocation
public boolean acceptUndeterminedCertificateRevocation()
- Specified by:
acceptUndeterminedCertificateRevocationin interfaceIDatabricksConnectionContext
-
getJWTKeyFile
public String getJWTKeyFile()
Description copied from interface:IDatabricksConnectionContextReturns the file path to the JWT private key used for signing the JWT.- Specified by:
getJWTKeyFilein interfaceIDatabricksConnectionContext
-
getKID
public String getKID()
Description copied from interface:IDatabricksConnectionContextReturns the Key ID (KID) used in the JWT header, identifying the key.- Specified by:
getKIDin interfaceIDatabricksConnectionContext
-
getJWTPassphrase
public String getJWTPassphrase()
Description copied from interface:IDatabricksConnectionContextReturns the passphrase to decrypt the private key if the key is encrypted.- Specified by:
getJWTPassphrasein interfaceIDatabricksConnectionContext
-
getJWTAlgorithm
public String 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
public String getTokenEndpoint()
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 token endpoint URL for retrieving tokens.- Specified by:
getTokenEndpointin interfaceIDatabricksConnectionContext
-
getAuthEndpoint
public String 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
-
getOAuthDiscoveryURL
public String getOAuthDiscoveryURL()
Description copied from interface:IDatabricksConnectionContextReturns the discovery URL used to obtain the OAuth2 token and authorization endpoints.- Specified by:
getOAuthDiscoveryURLin interfaceIDatabricksConnectionContext
-
getAuthScope
public String getAuthScope()
Description copied from interface:IDatabricksConnectionContextReturns the OAuth2 authentication scope used in the request.- Specified by:
getAuthScopein interfaceIDatabricksConnectionContext
-
getOAuthRefreshToken
public String 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
public List<Integer> getOAuth2RedirectUrlPorts()
Description copied from interface:IDatabricksConnectionContextReturns the list of OAuth2 redirect URL ports used for OAuth authentication.- Specified by:
getOAuth2RedirectUrlPortsin interfaceIDatabricksConnectionContext
-
getUseEmptyMetadata
public Boolean getUseEmptyMetadata()
- Specified by:
getUseEmptyMetadatain interfaceIDatabricksConnectionContext
-
getNonProxyHosts
public String getNonProxyHosts()
Description copied from interface:IDatabricksConnectionContextReturns the non-proxy hosts that should be excluded from proxying.- Specified by:
getNonProxyHostsin interfaceIDatabricksConnectionContext
-
getSSLTrustStore
public String getSSLTrustStore()
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store file path used for SSL connections.- Specified by:
getSSLTrustStorein interfaceIDatabricksConnectionContext
-
getSSLTrustStorePassword
public String getSSLTrustStorePassword()
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store password of the trust store file.- Specified by:
getSSLTrustStorePasswordin interfaceIDatabricksConnectionContext
-
getSSLTrustStoreType
public String getSSLTrustStoreType()
Description copied from interface:IDatabricksConnectionContextReturns the SSL trust store type of the trust store file.- Specified by:
getSSLTrustStoreTypein 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
public String 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
public String 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
-
getAzureTenantId
public String 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
-
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
-
getUCIngestionRetriableHttpCodes
public List<Integer> 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
public String 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
-
-