編輯： 經過一些更多的故障排除之後，我發現了以下內容 - 我將lag（event_time）添加到查詢中，查看查詢收集的日期，結果： SELECT device_id,
event_time,
unix_time,
event_id,
lag(event_time) OVER (PARTITION BY device_id ORDER BY unix
火花的1.5.0似乎可以編寫自己的UDAF的對DataFrames定製的聚合： Spark 1.5 DataFrame API Highlights: Date/Time/String Handling, Time Intervals, and UDAFs 如果此功能是Python API所支持然而我不清楚？
http://spark.apache.org/docs/latest/sql-programming-guide.html#interoperating-with-rdds 該鏈接顯示如何將txt文件更改爲RDD，然後更改爲Dataframe。 那麼如何處理二進制文件呢？ 問一個例子，非常感謝。 有沒有在這裏回答類似的問題：reading binary data into (py) spark
我希望有人可以幫助我解決這個問題。 在火花外殼哪裏，如果我試圖像下面的東西： var sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
var query = "select * from myDB.table limit 10; drop table if exists"
var queryDF = sqlContext