destinations.impl.redshift.redshift

RedshiftMergeJob Objects

class RedshiftMergeJob(SqlMergeFollowupJob)

[view_source]

gen_key_table_clauses

@classmethod
def gen_key_table_clauses(cls, root_table_name: str,
                          staging_root_table_name: str,
                          key_clauses: Sequence[str],
                          for_delete: bool) -> List[str]

[view_source]

Generate sql clauses that may be used to select or delete rows in root table of destination dataset

A list of clauses may be returned for engines that do not support OR in subqueries. Like BigQuery

RedshiftClient Objects

class RedshiftClient(InsertValuesJobClient, SupportsStagingDestination)

[view_source]

create_load_job

def create_load_job(table: TTableSchema,
                    file_path: str,
                    load_id: str,
                    restore: bool = False) -> LoadJob

[view_source]

Starts SqlLoadJob for files ending with .sql or returns None to let derived classes to handle their specific jobs