dlt.destinations.sql_jobs
SqlFollowupJob Objects
class SqlFollowupJob(FollowupJobRequestImpl)
Sql base job for jobs that rely on the whole table chain
from_table_chain
@classmethod
def from_table_chain(cls, table_chain: Sequence[PreparedTableSchema],
sql_client: SqlClientBase[Any]) -> FollowupJobRequestImpl
Generates a list of sql statements, that will be executed by the sql client when the job is executed in the loader.
The table_chain
contains a list of schemas of nested tables, ordered by the ancestry (the root of the tree is first on the list).
SqlStagingFollowupJob Objects
class SqlStagingFollowupJob(SqlFollowupJob)
Generates a list of sql statements that copy the data from staging dataset into destination dataset.
SqlStagingReplaceFollowupJob Objects
class SqlStagingReplaceFollowupJob(SqlStagingFollowupJob)
Generates a list of sql statements that replace the data from staging dataset into destination dataset.
SqlStagingCopyFollowupJob Objects
class SqlStagingCopyFollowupJob(SqlStagingFollowupJob)
Generates a list of sql statements that copy the data from staging dataset into destination dataset.
SqlMergeFollowupJob Objects
class SqlMergeFollowupJob(SqlFollowupJob)
Generates a list of sql statements that merge the data from staging dataset into destination dataset. If no merge keys are discovered, falls back to append.