Package index • brickster

Authentication

db_host(): Generate/Fetch Databricks Host

db_token(): Fetch Databricks Token

db_wsid(): Fetch Databricks Workspace ID

db_read_netrc(): Read .netrc File

db_current_user(): Get Current User Info

db_current_workspace_id(): Detect Current Workspace ID

db_current_cloud(): Detect Current Workspaces Cloud

Clusters

db_cluster_action(): Cluster Action Helper Function

db_cluster_create(): Create a Cluster

db_cluster_delete(): Delete/Terminate a Cluster

db_cluster_edit(): Edit a Cluster

db_cluster_events(): List Cluster Activity Events

db_cluster_get(): Get Details of a Cluster

db_cluster_list(): List Clusters

db_cluster_list_node_types(): List Available Cluster Node Types

db_cluster_list_zones(): List Availability Zones (AWS Only)

db_cluster_perm_delete(): Permanently Delete a Cluster

db_cluster_pin(): Pin a Cluster

db_cluster_resize(): Resize a Cluster

db_cluster_restart(): Restart a Cluster

db_cluster_runtime_versions(): List Available Databricks Runtime Versions

db_cluster_start(): Start a Cluster

db_cluster_terminate(): Delete/Terminate a Cluster

db_cluster_unpin(): Unpin a Cluster

get_and_start_cluster(): Get and Start Cluster

get_latest_dbr(): Get Latest Databricks Runtime (DBR)

aws_attributes(): AWS Attributes

gcp_attributes(): GCP Attributes

azure_attributes(): Azure Attributes

cluster_autoscale(): Cluster Autoscale

dbfs_storage_info(): DBFS Storage Information

file_storage_info(): File Storage Information

s3_storage_info(): S3 Storage Info

cluster_log_conf(): Cluster Log Configuration

docker_image(): Docker Image

init_script_info(): Init Script Info

access_control_request(): Access Control Request

access_control_req_user(): Access Control Request For User

access_control_req_group(): Access Control Request for Group

Cluster Libraries

db_libs_all_cluster_statuses(): Get Status of All Libraries on All Clusters

db_libs_cluster_status(): Get Status of Libraries on Cluster

db_libs_install(): Install Library on Cluster

db_libs_uninstall(): Uninstall Library on Cluster

wait_for_lib_installs(): Wait for Libraries to Install on Databricks Cluster

Databricks Notebook Helpers

in_databricks_nb(): Detect if running within Databricks Notebook

DBFS

db_dbfs_add_block(): DBFS Add Block

db_dbfs_close(): DBFS Close

db_dbfs_create(): DBFS Create

db_dbfs_delete(): DBFS Delete

db_dbfs_get_status(): DBFS Get Status

db_dbfs_list(): DBFS List

db_dbfs_mkdirs(): DBFS mkdirs

db_dbfs_move(): DBFS Move

db_dbfs_put(): DBFS Put

db_dbfs_read(): DBFS Read

Volume FileSystem

db_volume_delete(): Volume FileSystem Delete

db_volume_dir_create(): Volume FileSystem Create Directory

db_volume_dir_delete(): Volume FileSystem Delete Directory

db_volume_dir_exists(): Volume FileSystem Check Directory Exists

db_volume_file_exists(): Volume FileSystem File Status

db_volume_list(): Volume FileSystem List Directory Contents

db_volume_read(): Volume FileSystem Read

db_volume_write(): Volume FileSystem Write

Execution Contexts

db_context_command_cancel(): Cancel a Command

db_context_command_run(): Run a Command

db_context_command_status(): Get Information About a Command

db_context_create(): Create an Execution Context

db_context_destroy(): Delete an Execution Context

db_context_status(): Get Information About an Execution Context

Jobs

db_jobs_create(): Create Job

db_jobs_delete(): Delete a Job

db_jobs_get(): Get Job Details

db_jobs_list(): List Jobs

db_jobs_reset(): Overwrite All Settings For A Job

db_jobs_run_now(): Trigger A New Job Run

db_jobs_runs_cancel(): Cancel Job Run

db_jobs_runs_delete(): Delete Job Run

db_jobs_runs_export(): Export Job Run Output

db_jobs_runs_get(): Get Job Run Details

db_jobs_runs_get_output(): Get Job Run Output

db_jobs_runs_list(): List Job Runs

db_jobs_runs_submit(): Create And Trigger A One-Time Run

db_jobs_update(): Partially Update A Job

job_tasks(): Job Tasks

job_task(): Job Task

notebook_task(): Notebook Task

spark_jar_task(): Spark Jar Task

spark_python_task(): Spark Python Task

spark_submit_task(): Spark Submit Task

pipeline_task(): Pipeline Task

python_wheel_task(): Python Wheel Task

new_cluster(): New Cluster

libraries(): Libraries

lib_cran(): Cran Library (R)

lib_egg(): Egg Library (Python)

lib_jar(): Jar Library (Scala)

lib_maven(): Maven Library (Scala)

lib_pypi(): PyPi Library (Python)

lib_whl(): Wheel Library (Python)

email_notifications(): Email Notifications

cron_schedule(): Cron Schedule

git_source(): Git Source for Job Notebook Tasks

Mlflow Model Registry

db_mlflow_model_approve_transition_req(): Approve Model Version Stage Transition Request

db_mlflow_model_delete_transition_req(): Delete a Model Version Stage Transition Request

db_mlflow_model_open_transition_reqs(): Get All Open Stage Transition Requests for the Model Version

db_mlflow_model_reject_transition_req(): Reject Model Version Stage Transition Request

db_mlflow_model_transition_req(): Make a Model Version Stage Transition Request

db_mlflow_model_transition_stage(): Transition a Model Version's Stage

db_mlflow_model_version_comment(): Make a Comment on a Model Version

db_mlflow_model_version_comment_delete(): Delete a Comment on a Model Version

db_mlflow_model_version_comment_edit(): Edit a Comment on a Model Version

db_mlflow_registered_model_details(): Get Registered Model Details

R Library Management

add_lib_path(): Add Library Path

remove_lib_path(): Remove Library Path

Repos

db_repo_create(): Create Repo

db_repo_delete(): Delete Repo

db_repo_get(): Get Repo

db_repo_get_all(): Get All Repos

db_repo_update(): Update Repo

Secrets

db_secrets_delete(): Delete Secret in Secret Scope

db_secrets_list(): List Secrets in Secret Scope

db_secrets_put(): Put Secret in Secret Scope

db_secrets_scope_acl_delete(): Delete Secret Scope ACL

db_secrets_scope_acl_get(): Get Secret Scope ACL

db_secrets_scope_acl_list(): List Secret Scope ACL's

db_secrets_scope_acl_put(): Put ACL on Secret Scope

db_secrets_scope_create(): Create Secret Scope

db_secrets_scope_delete(): Delete Secret Scope

db_secrets_scope_list_all(): List Secret Scopes

SQL Statement Execution

db_sql_exec_cancel(): Cancel SQL Query

db_sql_exec_query(): Execute SQL Query

db_sql_exec_result(): Get SQL Query Results

db_sql_exec_status(): Get SQL Query Status

SQL Connector

install_db_sql_connector(): Install Databricks SQL Connector (Python)

db_sql_client(): Create Databricks SQL Connector Client

DatabricksSqlClient: Databricks SQL Connector

Vector Search

db_vs_endpoints_create(): Create a Vector Search Endpoint

db_vs_endpoints_delete(): Delete a Vector Search Endpoint

db_vs_endpoints_get(): Get a Vector Search Endpoint

db_vs_endpoints_list(): List Vector Search Endpoints

db_vs_indexes_create(): Create a Vector Search Index

db_vs_indexes_delete(): Delete a Vector Search Index

db_vs_indexes_delete_data(): Delete Data from a Vector Search Index

db_vs_indexes_get(): Get a Vector Search Index

db_vs_indexes_list(): List Vector Search Indexes

db_vs_indexes_query(): Query a Vector Search Index

db_vs_indexes_query_next_page(): Query Vector Search Next Page

db_vs_indexes_scan(): Scan a Vector Search Index

db_vs_indexes_sync(): Synchronize a Vector Search Index

db_vs_indexes_upsert_data(): Upsert Data into a Vector Search Index

embedding_source_column(): Embedding Source Column

is.embedding_source_column(): Test if object is of class EmbeddingSourceColumn

embedding_vector_column(): Embedding Vector Column

is.embedding_vector_column(): Test if object is of class EmbeddingVectorColumn

delta_sync_index_spec(): Delta Sync Vector Search Index Specification

direct_access_index_spec(): Delta Sync Vector Search Index Specification

is.vector_search_index_spec(): Test if object is of class VectorSearchIndexSpec

is.direct_access_index(): Test if object is of class DirectAccessIndex

is.delta_sync_index(): Test if object is of class DeltaSyncIndex

Warehouses

db_sql_client(): Create Databricks SQL Connector Client

db_sql_exec_cancel(): Cancel SQL Query

db_sql_exec_query(): Execute SQL Query

db_sql_exec_result(): Get SQL Query Results

db_sql_exec_status(): Get SQL Query Status

db_sql_global_warehouse_get(): Get Global Warehouse Config

db_sql_query_history(): List Warehouse Query History

db_sql_warehouse_create(): Create Warehouse

db_sql_warehouse_delete(): Delete Warehouse

db_sql_warehouse_edit(): Edit Warehouse

db_sql_warehouse_get(): Get Warehouse

db_sql_warehouse_list(): List Warehouses

db_sql_warehouse_start(): Start Warehouse

db_sql_warehouse_stop(): Stop Warehouse

get_and_start_warehouse(): Get and Start Warehouse

Workspaces

db_workspace_delete(): Delete Object/Directory (Workspaces)

db_workspace_export(): Export Notebook or Directory (Workspaces)

db_workspace_get_status(): Get Object Status (Workspaces)

db_workspace_import(): Import Notebook/Directory (Workspaces)

db_workspace_list(): List Directory Contents (Workspaces)

db_workspace_mkdirs(): Make a Directory (Workspaces)

Request Helpers

db_request(): Databricks Request Helper

db_perform_request(): Perform Databricks API Request

db_req_error_body(): Propagate Databricks API Errors

db_request_json(): Generate Request JSON

Low Level Helpers

is.access_control_req_group(): Test if object is of class AccessControlRequestForGroup

is.access_control_req_user(): Test if object is of class AccessControlRequestForUser

is.access_control_request(): Test if object is of class AccessControlRequest

is.aws_attributes(): Test if object is of class AwsAttributes

is.azure_attributes(): Test if object is of class AzureAttributes

is.cluster_autoscale(): Test if object is of class AutoScale

is.cluster_log_conf(): Test if object is of class ClusterLogConf

is.cron_schedule(): Test if object is of class CronSchedule

is.dbfs_storage_info(): Test if object is of class DbfsStorageInfo

is.delta_sync_index(): Test if object is of class DeltaSyncIndex

is.direct_access_index(): Test if object is of class DirectAccessIndex

is.docker_image(): Test if object is of class DockerImage

is.email_notifications(): Test if object is of class JobEmailNotifications

is.embedding_source_column(): Test if object is of class EmbeddingSourceColumn

is.embedding_vector_column(): Test if object is of class EmbeddingVectorColumn

is.file_storage_info(): Test if object is of class FileStorageInfo

is.gcp_attributes(): Test if object is of class GcpAttributes

is.git_source(): Test if object is of class GitSource

is.init_script_info(): Test if object is of class InitScriptInfo

is.job_task(): Test if object is of class JobTaskSettings

is.lib_cran(): Test if object is of class CranLibrary

is.lib_egg(): Test if object is of class EggLibrary

is.lib_jar(): Test if object is of class JarLibrary

is.lib_maven(): Test if object is of class MavenLibrary

is.lib_pypi(): Test if object is of class PyPiLibrary

is.lib_whl(): Test if object is of class WhlLibrary

is.libraries(): Test if object is of class Libraries

is.library(): Test if object is of class Library

is.new_cluster(): Test if object is of class NewCluster

is.notebook_task(): Test if object is of class NotebookTask

is.pipeline_task(): Test if object is of class PipelineTask

is.python_wheel_task(): Test if object is of class PythonWheelTask

is.s3_storage_info(): Test if object is of class S3StorageInfo

is.spark_jar_task(): Test if object is of class SparkJarTask

is.spark_python_task(): Test if object is of class SparkPythonTask

is.spark_submit_task(): Test if object is of class SparkSubmitTask

is.valid_task_type(): Test if object is of class JobTask

is.vector_search_index_spec(): Test if object is of class VectorSearchIndexSpec

knitr helpers

setup_databricks_rmd(): Setup Databricks RMarkdown

Workspace Connection

open_workspace(): Connect to Databricks Workspace

close_workspace(): Close Databricks Workspace Connection