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