destinations.impl.athena.athena
AthenaClient Objects
class AthenaClient(SqlJobClientWithStaging, SupportsStagingDestination)
create_load_job
def create_load_job(table: TTableSchema,
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
should_load_data_to_staging_dataset_on_staging_destination
def should_load_data_to_staging_dataset_on_staging_destination(
table: TTableSchema) -> bool
iceberg table data goes into staging on staging destination