我想直接在Cassandra DB上过滤数据，并使用Spark Java加载过滤后的数据。到目前为止，我只找到了用于选择行的.select()和用于过滤数据的.filter()，**在将其加载为数据集之后。
这是到目前为止的代码片段：

SparkConf sparkConf = new SparkConf()
                .setMaster("local")
                .setAppName("")
                .set("spark.cassandra.connection.host", "localhost")
                .set("spark.cassandra.auth.username", "cassandra")
                .set("spark.cassandra.auth.password", "cassandra")
                .set("spark.cassandra.output.consistency.level", "ONE");

SparkSession spark = SparkSession.builder().config(sparkConf).getOrCreate();

Dataset<Row> dataset = spark
                .read()
                .format("org.apache.spark.sql.cassandra")
                .options(ImmutableMap.of("table", "my_table", "keyspace", "my_keyspace"))
                .select("col1", "col2")
                .load();

dataset = dataset.filter("col1 > 9");

有人能在加载数据之前直接帮助应用过滤器吗？