destinations.impl.athena.athena
AthenaClient Objects
class AthenaClient(SqlJobClientWithStaging, SupportsStagingDestination)
start_file_load
def start_file_load(table: TTableSchema, file_path: str,
load_id: str) -> 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