aligned.sources.databricks.DatabricksConnectionConfig

class documentation

class DatabricksConnectionConfig: (source)

Constructors: DatabricksConnectionConfig.databricks_or_serverless(host, token), DatabricksConnectionConfig.serverless(host, token), DatabricksConnectionConfig.with_cluster_id(cluster_id, host), DatabricksConnectionConfig(host, cluster_id, token)

View In Hierarchy

Undocumented

Static Method databricks_or_serverless Undocumented
Static Method serverless Undocumented
Static Method with_cluster_id Undocumented
Method __init__ Undocumented
Method catalog Undocumented
Method connection Undocumented
Method sql Undocumented
Method with_auth Undocumented
Instance Variable cluster_id Undocumented
Instance Variable host Undocumented
Instance Variable token Undocumented
@staticmethod
def databricks_or_serverless(host: str | ConfigValue | None = None, token: str | ConfigValue | None = None) -> DatabricksConnectionConfig: (source)

Undocumented

@staticmethod
def serverless(host: str | ConfigValue | None = None, token: str | ConfigValue | None = None) -> DatabricksConnectionConfig: (source)

Undocumented

@staticmethod
def with_cluster_id(cluster_id: str | ConfigValue, host: str | ConfigValue) -> DatabricksConnectionConfig: (source)

Undocumented

def __init__(self, host: str | ConfigValue, cluster_id: str | ConfigValue | None, token: str | ConfigValue | None): (source)

Undocumented

def catalog(self, catalog: str | ConfigValue) -> UnityCatalog: (source)

Undocumented

def connection(self) -> SparkSession: (source)

Undocumented

def sql(self, query: str) -> UCSqlSource: (source)

Undocumented

def with_auth(self, token: str | ConfigValue, host: str | ConfigValue) -> DatabricksConnectionConfig: (source)

Undocumented

cluster_id: ConfigValue | None = (source)

Undocumented

host: ConfigValue = (source)

Undocumented

token: ConfigValue | None = (source)

Undocumented