Uses of Interface
com.databricks.jdbc.api.internal.IDatabricksConnectionContext
Packages that use IDatabricksConnectionContext
Package
Description
-
Uses of IDatabricksConnectionContext in com.databricks.jdbc.api.impl
Classes in com.databricks.jdbc.api.impl that implement IDatabricksConnectionContextMethods in com.databricks.jdbc.api.impl that return IDatabricksConnectionContextModifier and TypeMethodDescriptionstatic IDatabricksConnectionContextCreates an instance ofIDatabricksConnectionContextfrom the given URL, user and passwordstatic IDatabricksConnectionContextDatabricksConnectionContextFactory.create(String url, Properties properties) Creates an instance ofIDatabricksConnectionContextfrom the given URL and properties.static IDatabricksConnectionContextDatabricksConnectionContextFactory.createWithoutError(String url, Properties properties) DatabricksConnection.getConnectionContext()DatabricksSession.getConnectionContext()static IDatabricksConnectionContextDatabricksConnectionContext.parse(String url, Properties properties) Parses connection Url and properties into a Databricks specific connection contextConstructors in com.databricks.jdbc.api.impl with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDatabricksConnection(IDatabricksConnectionContext connectionContext) Creates an instance of Databricks connection for given connection context.DatabricksConnection(IDatabricksConnectionContext connectionContext, IDatabricksClient testDatabricksClient) DatabricksResultSetMetaData(StatementId statementId, TGetResultSetMetadataResp resultManifest, long rows, long chunkCount, List<String> arrowMetadata, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for a Thrift-based result set.DatabricksResultSetMetaData(StatementId statementId, ResultManifest resultManifest, boolean usesExternalLinks, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for a SEA result set.DatabricksResultSetMetaData(StatementId statementId, List<String> columnNames, List<String> columnDataTypes, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for metadata result set obtained from DESCRIBE QUERY Works for both SEA and Thrift flows as result set obtained from DESCRIBE QUERY is already parsed.DatabricksSession(IDatabricksConnectionContext connectionContext) Creates an instance of Databricks session for given connection contextDatabricksSession(IDatabricksConnectionContext connectionContext, IDatabricksClient testDatabricksClient) Constructor method to be used for mocking in a test case. -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.api.impl.volume
Methods in com.databricks.jdbc.api.impl.volume with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionstatic IDatabricksVolumeClientDatabricksVolumeClientFactory.getVolumeClient(IDatabricksConnectionContext connectionContext) Creates an instance of the DBFVolumeClient from the given connectionContext.Constructors in com.databricks.jdbc.api.impl.volume with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDBFSVolumeClient(IDatabricksConnectionContext connectionContext) VolumeUploadCallback(IDatabricksHttpClient httpClient, CompletableFuture<VolumePutResult> uploadFuture, DBFSVolumeClient.UploadRequest request, Semaphore semaphore, VolumeUploadCallback.UrlGenerator urlGenerator, Function<Integer, Long> retryDelayCalculator, IDatabricksConnectionContext connectionContext) Constructor for the callback. -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.api.internal
Methods in com.databricks.jdbc.api.internal that return IDatabricksConnectionContextModifier and TypeMethodDescriptionIDatabricksConnectionInternal.getConnectionContext()Returns the connection context associated with the connection.IDatabricksSession.getConnectionContext()Returns the associated connection context for the session -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.auth
Constructors in com.databricks.jdbc.auth with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionAzureExternalBrowserProvider(IDatabricksConnectionContext connectionContext, int availablePort) Constructor for Azure OAuth provider.AzureMSICredentialProvider(IDatabricksConnectionContext connectionContext) Constructs a new AzureMSICredentialProvider.DatabricksTokenFederationProvider(IDatabricksConnectionContext connectionContext, com.databricks.sdk.core.CredentialsProvider credentialsProvider) OAuthRefreshCredentialsProvider(IDatabricksConnectionContext context, com.databricks.sdk.core.DatabricksConfig databricksConfig) PrivateKeyClientCredentialProvider(IDatabricksConnectionContext connectionContext, com.databricks.sdk.core.DatabricksConfig databricksConfig) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.common
Methods in com.databricks.jdbc.common with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionDatabricksClientConfiguratorManager.getConfigurator(IDatabricksConnectionContext context) DatabricksClientConfiguratorManager.getConfiguratorOnlyIfExists(IDatabricksConnectionContext context) Returns the client configurator if it exists, otherwise returns null.voidDatabricksClientConfiguratorManager.removeInstance(IDatabricksConnectionContext context) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.common.safe
Methods in com.databricks.jdbc.common.safe with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionDatabricksDriverFeatureFlagsContextFactory.getInstance(IDatabricksConnectionContext context) Gets or creates a DatabricksDriverFeatureFlagsContext instance for the given computestatic voidDatabricksDriverFeatureFlagsContextFactory.removeInstance(IDatabricksConnectionContext connectionContext) Removes the DatabricksDriverFeatureFlagsContext instance for the given compute.Constructors in com.databricks.jdbc.common.safe with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDatabricksDriverFeatureFlagsContext(IDatabricksConnectionContext connectionContext) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.common.util
Methods in com.databricks.jdbc.common.util that return IDatabricksConnectionContextModifier and TypeMethodDescriptionstatic IDatabricksConnectionContextDatabricksThreadContextHolder.getConnectionContext()Methods in com.databricks.jdbc.common.util with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionstatic int[]DatabricksTypeUtil.getBasePrecisionAndScale(int columnType, IDatabricksConnectionContext ctx) static intVolumeRetryUtil.getRetryTimeoutSeconds(IDatabricksConnectionContext connectionContext) Get the retry timeout in seconds.static StringDatabricksAuthUtil.getTokenEndpoint(com.databricks.sdk.core.DatabricksConfig databricksConfig, IDatabricksConnectionContext connectionContext) static booleanVolumeRetryUtil.isRetryableHttpCode(int statusCode, IDatabricksConnectionContext connectionContext) Check if the given HTTP status code is retryable.static <T,R> List <R> JdbcThreadUtils.parallelFlatMap(Collection<T> items, IDatabricksConnectionContext connectionContext, int maxThreads, int timeoutSeconds, Function<T, Collection<R>> task, ExecutorService executor) Executes tasks in parallel, collecting and flattening all results, utilizing a provided executor service (which can be null, in which case a new one will be created).static <T,R> List <R> JdbcThreadUtils.parallelMap(Collection<T> items, IDatabricksConnectionContext connectionContext, int maxThreads, int timeoutSeconds, Function<T, R> task, ExecutorService executor) Executes tasks concurrently with appropriate context management, utilizing a provided executor service (which can be null, in which case a new one will be created).static voidDatabricksThreadContextHolder.setConnectionContext(IDatabricksConnectionContext context) static voidDriverUtil.setUpLogging(IDatabricksConnectionContext connectionContext) static voidUserAgentManager.setUserAgent(IDatabricksConnectionContext connectionContext) Set the user agent for the Databricks JDBC driver.static booleanVolumeRetryUtil.shouldRetry(int attempt, long retryStartTime, IDatabricksConnectionContext connectionContext) Check if we should retry based on attempt count and elapsed time. -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.dbclient
Methods in com.databricks.jdbc.dbclient that return IDatabricksConnectionContext -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.dbclient.impl.common
Methods in com.databricks.jdbc.dbclient.impl.common with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionstatic org.apache.http.config.Registry<org.apache.http.conn.socket.ConnectionSocketFactory> ConfiguratorUtils.createConnectionSocketFactoryRegistry(IDatabricksConnectionContext connectionContext) Creates a registry of connection socket factories based on the connection context.static org.apache.http.impl.conn.PoolingHttpClientConnectionManagerConfiguratorUtils.getBaseConnectionManager(IDatabricksConnectionContext connectionContext) Creates and configures the connection manager based on the connection context.static KeyStoreConfiguratorUtils.loadKeystoreOrNull(IDatabricksConnectionContext connectionContext) Loads a key store from the path specified in the connection context.static KeyStoreConfiguratorUtils.loadTruststoreOrNull(IDatabricksConnectionContext connectionContext) Loads a trust store from the path specified in the connection context.Constructors in com.databricks.jdbc.dbclient.impl.common with parameters of type IDatabricksConnectionContext -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.dbclient.impl.http
Methods in com.databricks.jdbc.dbclient.impl.http with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionDatabricksHttpClientFactory.getClient(IDatabricksConnectionContext context) DatabricksHttpClientFactory.getClient(IDatabricksConnectionContext context, HttpClientType type) voidDatabricksHttpClientFactory.removeClient(IDatabricksConnectionContext context) voidDatabricksHttpClientFactory.removeClient(IDatabricksConnectionContext context, HttpClientType type) Constructors in com.databricks.jdbc.dbclient.impl.http with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDatabricksHttpRetryHandler(IDatabricksConnectionContext connectionContext) UCVolumeHttpRetryHandler(IDatabricksConnectionContext connectionContext) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.dbclient.impl.sqlexec
Methods in com.databricks.jdbc.dbclient.impl.sqlexec that return IDatabricksConnectionContextConstructors in com.databricks.jdbc.dbclient.impl.sqlexec with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDatabricksSdkClient(IDatabricksConnectionContext connectionContext) DatabricksSdkClient(IDatabricksConnectionContext connectionContext, com.databricks.sdk.service.sql.StatementExecutionService statementExecutionService, com.databricks.sdk.core.ApiClient apiClient) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.dbclient.impl.thrift
Methods in com.databricks.jdbc.dbclient.impl.thrift that return IDatabricksConnectionContextConstructors in com.databricks.jdbc.dbclient.impl.thrift with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionDatabricksHttpTTransport(IDatabricksHttpClient httpClient, String url, com.databricks.sdk.core.DatabricksConfig databricksConfig, IDatabricksConnectionContext connectionContext) DatabricksThriftServiceClient(IDatabricksConnectionContext connectionContext) -
Uses of IDatabricksConnectionContext in com.databricks.jdbc.telemetry
Methods in com.databricks.jdbc.telemetry with parameters of type IDatabricksConnectionContextModifier and TypeMethodDescriptionvoidTelemetryClientFactory.closeTelemetryClient(IDatabricksConnectionContext connectionContext) static voidTelemetryHelper.exportFailureLog(IDatabricksConnectionContext connectionContext, String errorName, String errorMessage) static voidTelemetryHelper.exportFailureLog(IDatabricksConnectionContext connectionContext, String errorName, String errorMessage, String statementId, Long chunkIndex) static com.databricks.sdk.core.DatabricksConfigTelemetryHelper.getDatabricksConfigSafely(IDatabricksConnectionContext context) TelemetryClientFactory.getTelemetryClient(IDatabricksConnectionContext connectionContext) static booleanTelemetryHelper.isTelemetryAllowedForConnection(IDatabricksConnectionContext context) static voidTelemetryHelper.updateTelemetryAppName(IDatabricksConnectionContext connectionContext, String clientInfoAppName) Sets/updates client app name in telemetryConstructors in com.databricks.jdbc.telemetry with parameters of type IDatabricksConnectionContextModifierConstructorDescriptionTelemetryClient(IDatabricksConnectionContext connectionContext, ExecutorService executorService) TelemetryClient(IDatabricksConnectionContext connectionContext, ExecutorService executorService, com.databricks.sdk.core.DatabricksConfig config) TelemetryPushClient(boolean isAuthenticated, IDatabricksConnectionContext connectionContext, com.databricks.sdk.core.DatabricksConfig databricksConfig)