Mysql
 sql >> Database >  >> RDS >> Mysql

Come convertire una tabella SQL da 500 GB in Apache Parquet?

Apache Spark può essere utilizzato per eseguire questa operazione:

1.load your table from mysql via jdbc
2.save it as a parquet file

Esempio:

from pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()
df = spark.read.jdbc("YOUR_MYSQL_JDBC_CONN_STRING",  "YOUR_TABLE",properties={"user": "YOUR_USER", "password": "YOUR_PASSWORD"})
df.write.parquet("YOUR_HDFS_FILE")