我已經安裝Zeppelin 0.7.1。當我試圖執行示例星火計劃(這是可利用的Zeppelin Tutorial筆記本電腦),我收到以下錯誤 java.lang.NullPointerException
at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:38)
at org.apache.zeppelin.sp
我想使用在libaray中定義的自定義UDF。我用下面的代碼爲: %spark2 進口org.apache.spark.sql.functions.year VAL sqlContext =新org.apache.spark.sql.hive.HiveContext(SC) sqlContext.sql(S 「ADD JAR /usr/hdp/current/spark-client/lib/my
在Zeppelin中,我使用另一段中創建的數據框。我顯示我的df變量的類型並獲得: res35: String = DataFrame
暗示它是數據框。但是,當我嘗試在DF變量使用select我得到一個錯誤: <console>:62: error: value select is not a member of Object
我必須對象轉換爲數據幀或東西嗎?有人能告訴我我錯過了什麼嗎?
我有三個齊柏林飛艇(0.6)段: PARA1: val hc = new org.apache.spark.sql.hive.HiveContext(sc)
val df = hc.sql("SELECT * FROM tweetsORC")
z.put("wds", df)
PARA2: import org.apache.spark.sql.DataFrame
impo
齊柏林0.6 星火1.6 SQL 我試圖找到一些微博的前20名出現的詞。 filtered包含每個推文的單詞數組。以下: select explode(filtered) AS words from tweettable
列出了每個單詞你所期望的,但我要的是讓每個單詞的數量在所有的鳴叫,然後顯示這些排名前20位。下面的作品,但我需要爲此在SQL: df.select(explode($"fil