udit ujagar
05/09/2023, 10:29 AMMatthew Powers
05/09/2023, 12:29 PMudit ujagar
05/09/2023, 12:32 PMdef read_write_delta_rs:
dt = DeltaTable(input_file)
pyarrow_table = dt.to_pyarrow_table()
op = pyarrow_table.to_pandas()
write_deltalake(table_or_uri="<S3 path>", data=op, partition_by=["col_name"], mode="append", storage_options=storage_options)
Matthew Powers
05/09/2023, 12:34 PMudit ujagar
05/24/2023, 2:03 PM