sources.sql_database.arrow_helpers
row_tuples_to_arrow
@with_config
def row_tuples_to_arrow(rows: Sequence[Any],
caps: DestinationCapabilitiesContext = None,
columns: TTableSchemaColumns = None,
tz: str = None) -> Any
Converts column_schema
to arrow schema using caps
and tz
. caps
are injected from the container - which
is always the case if run within the pipeline. This will generate arrow schema compatible with the destination.
Otherwise generic capabilities are used