2
我有看起來像這樣的Spark Java。代碼使用JDBC從oracle表中提取數據並顯示groupby輸出。Spark DataFrame groupBy
DataFrame jdbcDF = sqlContext.read().format("jdbc").options(options).load();
jdbcDF.show();
jdbcDF.groupBy("VA_HOSTNAME").count().show();
Long ll = jdbcDF.count();
System.out.println("ll="+ll);
當我運行的代碼,jdbcDF.show();
工作,而groupBy
和計數不打印任何東西,被拋出任何錯誤。
我的專欄名稱是正確的。我試圖通過打印該列,它的工作,但當groupBy
它無法正常工作。
有人可以幫我DataFrame
輸出?我正在使用spark 1.6.3。