1 Respuesta
- Más nuevo
- Más votos
- Más comentarios
0
Hello,
As per the doc there are only two ways to update the schema 1.getSink() and 2.from_catalog() automatically from an AWS Glue Job and your job needs to use the Iceberg connection or Iceberg jars.
getSink() does not support market place connections. Reference
from_catalog() needs to read the metadata like classification or connection from the existing iceberg table. However, if you are creating iceberg tables from Athena as shown here . This method does not work as well. Reference
So, the only way I could see is to use from_options() method and use Spark dataframes to write to your Iceberg table.
Schema evolution for Iceberg tables are documented here and using Athena here
Contenido relevante
- OFICIAL DE AWSActualizada hace 2 años
- OFICIAL DE AWSActualizada hace 9 meses
- OFICIAL DE AWSActualizada hace 3 años
- OFICIAL DE AWSActualizada hace un año