Apache Spark SQl读写Cassandra TTL

问题描述 投票:0回答:1

Spark sql如何使用Dataframe(Spark Sql)读取apache cassandra data ttl。我找不到任何例子吗?我可以举个例子吗?

我之前的问题是在rdd是否发火花:Spark get ttl column from cassandra

但是现在查询是针对数据框的。

java scala datastax datastax-enterprise cassandra-2.0
1个回答
0
投票

Spark Cassandra连接器在DataFrame API中不支持TTL和WriteTime。您可以跟踪JIRA SPARKC-528的进度。

您可以使用RDD API(最好与mapper to case class一起读取TTL和/或WriteTime,然后将其转换为DataFrame。

© www.soinside.com 2019 - 2024. All rights reserved.