databricks-sql-python API reference
129 public APIs from databricks-sql-python (databricks/databricks-sql-python) — 73 classes, 3 functions, 53 methods. Signatures extracted by static analysis of the actual source.
Repository: databricks/databricks-sql-python
| Kind | Count |
|---|---|
| Classes | 73 |
| Functions | 3 |
| Methods | 53 |
API list
func
src.databricks.sql.auth.auth_utils.decode_token(access_token:str) -> Optional[Dict]Decode a JWT token without verification to extract claims.
func
src.databricks.sql.auth.auth_utils.is_same_host(url1:str, url2:str) -> boolCheck if two URLs have the same host.
class
src.databricks.sql.auth.oauth.TokenA class to represent a token.
method
src.databricks.sql.auth.token_federation.Token.is_expired() -> boolCheck if the token is expired.
method
src.databricks.sql.auth.token_federation.Token.to_dict() -> Dict[str, str]Convert token to dictionary format.
class
src.databricks.sql.backend.kernel.result_set.KernelResultSetStreaming ``ResultSet`` over a kernel handle.
class
src.databricks.sql.backend.sea.models.base.ChunkInfoInformation about a chunk in the result set.
class
src.databricks.sql.backend.sea.models.base.ExternalLinkExternal link information for result data.
class
src.databricks.sql.backend.sea.models.base.ResultDataResult data from a statement execution.
class
src.databricks.sql.backend.sea.models.base.ResultManifestManifest information for a result set.
class
src.databricks.sql.backend.sea.models.base.ServiceErrorError information returned by the SEA API.
class
src.databricks.sql.backend.sea.models.base.StatementStatusStatus information for a statement execution.
class
src.databricks.sql.backend.sea.queue.JsonQueueQueue implementation for JSON_ARRAY format data.
method
src.databricks.sql.backend.sea.queue.JsonQueue.next_n_rows(num_rows:int) -> List[List[str]]Get the next n rows from the data array.
method
src.databricks.sql.backend.sea.queue.JsonQueue.remaining_rows() -> List[List[str]]Get all remaining rows from the data array.
class
src.databricks.sql.backend.sea.result_set.SeaResultSetResultSet implementation for SEA backend.
method
src.databricks.sql.backend.sea.result_set.SeaResultSet.fetchmany_arrow(size:int) -> 'pyarrow.Table'Fetch the next set of rows as an Arrow table.
method
src.databricks.sql.backend.sea.result_set.SeaResultSet.fetchmany_json(size:int) -> List[List[str]]Fetch the next set of rows as a columnar table.
class
src.databricks.sql.backend.sea.utils.constants.MetadataCommandsSQL commands used in the SEA backend.
class
src.databricks.sql.backend.sea.utils.constants.ResultCompressionEnum for result compression values.
class
src.databricks.sql.backend.sea.utils.constants.ResultDispositionEnum for result disposition values.
class
src.databricks.sql.backend.sea.utils.constants.ResultFormatEnum for result format values.
class
src.databricks.sql.backend.sea.utils.constants.WaitTimeoutEnum for wait timeout values.
class
src.databricks.sql.backend.sea.utils.filters.ResultSetFilterA general-purpose filter for result sets.
method
src.databricks.sql.backend.sea.utils.http_client.SeaHttpClient.using_proxy() -> boolCheck if proxy is being used.
class
src.databricks.sql.backend.types.BackendTypeEnum representing the type of backend
method
src.databricks.sql.backend.types.CommandState.from_sea_state(state:str) -> Optional['CommandState']Map SEA state string to CommandState enum.
class
src.databricks.sql.backend.types.ExecuteResponseResponse from executing a SQL command.
method
src.databricks.sql.client.Connection.autocommit() -> boolGet auto-commit mode for this connection.
method
src.databricks.sql.client.Connection.commit() -> NoneCommit the current transaction.
method
src.databricks.sql.client.Connection.get_session_id_hex()Get the session ID in hex format
method
src.databricks.sql.client.Connection.get_transaction_isolation() -> strGet the transaction isolation level.
method
src.databricks.sql.client.Connection.rollback() -> NoneRollback the current transaction.
method
src.databricks.sql.client.Connection.set_transaction_isolation(level:str) -> NoneSet transaction isolation level.
method
src.databricks.sql.client.Cursor.cancel() -> NoneCancel a running command.
method
src.databricks.sql.client.Cursor.catalogs() -> 'Cursor'Get all available catalogs.
method
src.databricks.sql.client.Cursor.close() -> NoneClose cursor
method
src.databricks.sql.client.Cursor.setinputsizes(sizes)Does nothing by default
method
src.databricks.sql.client.Cursor.setoutputsize(size, column=None)Does nothing by default
class
src.databricks.sql.cloudfetch.downloader.DownloadedFileClass for the result file and metadata.
class
src.databricks.sql.exc.CursorAlreadyClosedErrorThrown if CancelOperation receives a code 404.
class
src.databricks.sql.exc.ErrorBase class for DB-API2.0 exceptions.
class
src.databricks.sql.exc.NonRecoverableNetworkErrorThrown if an HTTP code 501 is received
class
src.databricks.sql.exc.RequestErrorThrown if there was a error during request to the server.
class
src.databricks.sql.exc.SessionAlreadyClosedErrorThrown if CloseSession receives a code 404.
class
src.databricks.sql.exc.TransactionErrorException raised for transaction-specific errors.
method
src.databricks.sql.result_set.ResultSet.close() -> NoneClose the result set.
method
src.databricks.sql.result_set.ResultSet.fetchall() -> List[Row]Fetch all remaining rows of a query result.
method
src.databricks.sql.result_set.ResultSet.fetchall_arrow() -> 'pyarrow.Table'Fetch all remaining rows as an Arrow table.
method
src.databricks.sql.result_set.ResultSet.fetchmany(size:int) -> List[Row]Fetch the next set of rows of a query result.
method
src.databricks.sql.result_set.ResultSet.fetchmany_arrow(size:int) -> 'pyarrow.Table'Fetch the next set of rows as an Arrow table.
method
src.databricks.sql.result_set.ResultSet.fetchone() -> Optional[Row]Fetch the next row of a query result set.
class
src.databricks.sql.result_set.ThriftResultSetResultSet implementation for the Thrift backend.
method
src.databricks.sql.session.Session.close() -> NoneClose the underlying session.
method
src.databricks.sql.session.Session.get_autocommit() -> boolGet the cached autocommit state for this session.
method
src.databricks.sql.session.Session.guid() -> AnyGet the raw session ID (backend-specific)
method
src.databricks.sql.session.Session.guid_hex() -> strGet the session ID in hex format
method
src.databricks.sql.session.Session.session_id() -> SessionIdGet the normalized session ID
method
src.databricks.sql.session.Session.set_autocommit(value:bool) -> NoneUpdate the cached autocommit state for this session.
class
src.databricks.sql.telemetry.models.event.SqlExecutionEventRepresents a SQL query execution event.
class
src.databricks.sql.telemetry.telemetry_push_client.ITelemetryPushClientInterface for telemetry push clients.
method
src.databricks.sql.telemetry.telemetry_push_client.ITelemetryPushClient.request(method:HttpMethod, url:str, headers:Optional[Dict[str, str]]=None, **kwargs) -> BaseHTTPResponseMake an HTTP request.
class
src.databricks.sql.telemetry.utils.BaseTelemetryClientBase class for telemetry clients.
class
src.databricks.sql.telemetry.utils.EnumEncoderCustom JSON encoder to handle Enum values.
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CancelDelegationToken_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CancelDelegationToken_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CancelOperation_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CancelOperation_resultAttributes: - success
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.CancelDelegationToken(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.CancelOperation(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.CloseOperation(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.CloseSession(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.ExecuteStatement(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.FetchResults(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetCatalogs(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetColumns(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetCrossReference(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetDelegationToken(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetFunctions(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetInfo(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetOperationStatus(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetPrimaryKeys(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetResultSetMetadata(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetSchemas(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetTableTypes(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetTables(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.GetTypeInfo(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.OpenSession(req)Parameters: - req
method
src.databricks.sql.thrift_api.TCLIService.TCLIService.Client.RenewDelegationToken(req)Parameters: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CloseOperation_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CloseOperation_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CloseSession_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.CloseSession_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.ExecuteStatement_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.ExecuteStatement_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.FetchResults_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.FetchResults_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetCatalogs_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetCatalogs_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetColumns_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetColumns_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetCrossReference_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetCrossReference_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetDelegationToken_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetDelegationToken_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetFunctions_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetFunctions_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetInfo_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetInfo_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetOperationStatus_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetOperationStatus_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetPrimaryKeys_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetPrimaryKeys_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetResultSetMetadata_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetResultSetMetadata_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetSchemas_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetSchemas_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTableTypes_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTableTypes_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTables_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTables_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTypeInfo_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.GetTypeInfo_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.OpenSession_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.OpenSession_resultAttributes: - success
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.RenewDelegationToken_argsAttributes: - req
class
src.databricks.sql.thrift_api.TCLIService.TCLIService.RenewDelegationToken_resultAttributes: - success
class
src.databricks.sql.types.RowA row in a query result.
func
src.databricks.sql.utils.escape_value(value:str) -> strEscape special characters in tag values.
About this data
These signatures were extracted from the public source of databricks/databricks-sql-python
using Python's ast module. Argument names, default values,
type annotations and return types are taken verbatim from the code.
Implementation bodies are never stored. See
how it works for details.