destinations.impl.redshift.redshift
RedshiftMergeJob Objects
class RedshiftMergeJob(SqlMergeFollowupJob)
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]
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)
create_load_job
def create_load_job(table: PreparedTableSchema,
file_path: str,
load_id: str,
restore: bool = False) -> LoadJob
Starts SqlLoadJob for files ending with .sql or returns None to let derived classes to handle their specific jobs