spark-cassandra-connect python deleteFromCassandra方法

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

# 创建SparkSession
spark = SparkSession.builder \
    .appName("Delete from Cassandra") \
    .config("spark.cassandra.connection.host", "localhost") \
    .config("spark.cassandra.connection.port", "9042") \
    .getOrCreate()

# 从Cassandra表中删除数据
spark.read \
    .format("org.apache.spark.sql.cassandra") \
    .options(table="table_name", keyspace="keyspace_name") \
    .load() \
    .filter(col("column_name") == "value_to_delete") \
    .write \
    .format("org.apache.spark.sql.cassandra") \
    .options(table="table_name", keyspace="keyspace_name") \
    .mode("append") \
    .deleteFromCassandra()

# 关闭SparkSession
spark.stop()