在Pyspark中填充空的postgres数据库

from pyspark.sql import SparkSession
from pyspark.sql.functions import col

spark = SparkSession.builder \
    .appName("Fill Null Values in PostgreSQL") \
    .getOrCreate()

url = "jdbc:postgresql://<hostname>:<port>/<database>"
properties = {
    "user": "<username>",
    "password": "<password>",
    "driver": "org.postgresql.Driver"
}

df = spark.read.jdbc(url=url, table="<table_name>", properties=properties)

filled_df = df.fillna("<value>")

filled_df.write.jdbc(url=url, table="<table_name>", mode="overwrite", properties=properties)