Databricks

DatabricksHook

Interact with Databricks.

DatabricksRunNowOperator

Runs an existing Spark job run to Databricks using the api/2.1/jobs/run-now API endpoint.

DatabricksSubmitRunOperator

Submits a Spark job run to Databricks using the api/2.1/jobs/runs/submit API endpoint.

DatabricksSqlHook

Hook to interact with Databricks SQL.

BaseDatabricksHook

Base for interaction with Databricks.

DatabricksSqlOperator

Executes SQL code in a Databricks SQL endpoint or a Databricks cluster

DatabricksCopyIntoOperator

Executes COPY INTO command in a Databricks SQL endpoint or a Databricks cluster. COPY INTO command is constructed from individual pieces, that are des…

DatabricksReposDeleteOperator

Deletes specified repository using DELETE api/2.0/repos API endpoint.

DatabricksReposCreateOperator

Creates a Databricks Repo using POST api/2.0/repos API endpoint and optionally checking it out to a specific branch or tag.

DatabricksReposUpdateOperator

Updates specified repository to a given branch or tag using PATCH api/2.0/repos API endpoint.

DatabricksSubmitRunDeferrableOperator

Deferrable version of DatabricksSubmitRunOperator

DatabricksExecutionTrigger

The trigger handles the logic of async communication with DataBricks API.

DatabricksRunNowDeferrableOperator

Deferrable version of DatabricksRunNowOperator