我已經設置了一個測試Cassandra + Spark集羣。我能夠從火花成功查詢卡珊德拉,如果我做到以下幾點: import org.apache.spark.sql.cassandra.CassandraSQLContext
import import sqlContext.implicits._
val cc = new CassandraSQLContext(sc)
val dataf
我使用下面的腳本來提取HH:MM:SS從YYYY-MM-DD HH:MM:SS日期格式 import java.sql.Time
case class Transactions(creationTime: Time)
val formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
def parseTransac(line: St