adp.ingest.sources.mssql.MSSQLEntitySource

class adp.ingest.sources.mssql.MSSQLEntitySource(entity: EntityType, ingest: Ingest)

Source of the Microsoft SQL type

__init__(entity: EntityType, ingest: Ingest)

Methods

__init__(entity, ingest)
custom_query(query)	Run a custom query for the MSSQLSource
get_data(run_metadata)	Load the DataFrame from the table using JDBC.

Attributes

source

custom_query(query) → DataFrame

Run a custom query for the MSSQLSource

get_data(run_metadata: IngestRunMetadata) → DataFrame

Load the DataFrame from the table using JDBC.

Parameters:

where (str, optional) – Add a WHERE statement after the select. To return a subset of the table. Defaults to ‘’.

Returns:

Loaded source data

Return type:

pyspark.sql.DataFrame