enter image description here嘗試在我的臨時表上選擇時收到錯誤消息。有人可以幫助我嗎？ object StreamingLinReg extends java.lang.Object{
val conf = new SparkConf(true)
.set("spark.cassandra.connection.host", "127.0.0.1
我正在使用pyspark和pyspark-cassandra。 我已經注意到使用COPY，sstableloader，現在pysparksaveToCassandra上卡桑德拉（3.0.x和3.6.x）的多個版本的這種行爲。 我有以下模式 CREATE TABLE test (
id int,
time timestamp,
a int,
b int,