獲取超過20行並在火花外殼中顯示列的全部值

我使用spark-shell中的cassandraSQL查詢來自cassandra的數據。所以，我想知道如何使用cassnadraSQL獲取超過20行的兩件事，第二我如何顯示列的完整值。正如您在下面默認看到的，它會在字符串值中追加點。獲取超過20行並在火花外殼中顯示列的全部值

代碼：

val csc = new CassandraSQLContext(sc) 
csc.setKeyspace("KeySpace") 
val maxDF = csc.sql("SQL_QUERY") 
maxDF.show

輸出：

+--------------------+--------------------+-----------------+--------------------+ 
|     id|    Col2|    Col3|    Col4| 
+--------------------+--------------------+-----------------+--------------------+ 
|8wzloRMrGpf8Q3bbk...|    Value1|     X|     K1| 
|AxRfoHDjV1Fk18OqS...|    Value2|     Y|     K2| 
|FpMVRlaHsEOcHyDgy...|    Value3|     Z|     K3| 
|HERt8eFLRtKkiZndy...|    Value4|     U|     K4| 
|nWOcbbbm8ZOjUSNfY...|    Value5|     V|     K5|

來源

2016-06-10 Naresh

嘗試第一次或scala打印而不是show。 – phact

我會嘗試。你能告訴我如何查看列的全部價值嗎？ – Naresh

如果你想打印一列的全部價值，你只需要設置的參數從show方法false截斷：

maxDf.show(false)

，如果你希望顯示超過20行：

// example showing 30 columns of 
// maxDf untruncated 
maxDf.show(30, false)

來源

2016-06-10 08:11:00 eliasah

對不起，我沒有看到你的回答，然後發佈我的。 –

@eliasah你能幫我解決這個問題嗎？我在這裏卡住'http：// stackoverflow.com/questions/39363586/issue-while-storage-data-from-spark-streaming-to-cassanadra' – Naresh

@Naresh我不知道我能幫什麼忙。我從來沒有與C *合作過。 – eliasah

你不會好的表格形式，而不是將它轉換到斯卡拉對象獲取。

maxDF.take(50)

來源

2016-06-10 07:11:59 WoodChopper

獲取超過20行並在火花外殼中顯示列的全部值

回答

相關問題