? phoenix作為查詢引擎，為了提高查詢效率，為phoenix表創建了二級索引，而數據是sparkstreaming通過hbase api直接向hbase插數據。那么問題來了，對于phoenix的二級索引，直接插入底層hbase的源表，不會引起二級索引的更新，從而導

1. Spark 為 RDD 提供的成員函數 .stats()：包括（count：計數，mean：均值，stdev：標準差，max：最大，min：最小值） countByValue：執行統計計數 根據值統計出現的次數； scala>

經過了三年的開發努力，Apache Solr Server 4.0終于發布了。Apache Solr是流行的，速度極快，開源的NoSQL的搜索平臺，來自于Apache Lucene項目。它的主要功能包括強大的全文搜索，命中高亮顯示、面搜索、動態集群、數據庫集成、豐富的文檔和地

本節的主要內容： docker rocketmq、一、ReceiverTracker的架構設計 二、消息循環系統 三、ReceiverTracker具體實現 ? Spark Streaming作為Spark Core基礎 架構之上的一個應用程序，其中的ReceiverTracker接收到數據之后，具體該怎么進行數據處理呢？

Spark2.2出現異常：ERROR SparkUI: Failed to bind SparkUI 參考文章： （1）Spark2.2出現異常：ERROR SparkUI: Failed to bind SparkUI （2）https://www.cnblogs.com/yy3b2007com/p/10558379.html 備忘一下。

Spark中使用Scala實現WordCount業務創建一個Projectsbt選擇1.0.4Scala選擇2.11.8配置路徑Project SourcesDependencies新建objectMyScalaWordCount.scala本地模式object MyScalaWordCount {def main(args: Array[String]): Unit = {val conf = new SparkConf().setApp

關于openfire和spark無法使用中文用戶名的問題。 前一篇文章通過更改數據庫雖然可以使用中文用戶名，但通過spark無法使用中文用戶名進行登陸。 這里需要重新編譯spark。 通過svn下載最新的代碼重新編譯后就可以了。 通過修改資源文件可以將沒有漢化的部分漢化，

? ?maven打包時報錯： 報錯信息： "D:\Program Files\Java\jdk1.8.0_131\bin\java" -Dmaven.multiModuleProjectDirectory=D:\Workspace\IDEA_work\Spark_Work\spark01\sparkCore "-Dmaven.home=D:\Program Files\JetBrains\IntelliJ IDEA 20

不知道咋的，家里的網只能夠上這個博客園了。 Map跟Set在可變和不可變這一點兒上很相似，幾乎就是相同嘛。 var treasureMap = Map[Int, String]() treasureMap += (1 -> "Go to island.") scala object？treasureMap += (2 ->

更多精彩內容參見云棲社區大數據頻道https://yq.aliyun.com/big-data；此外，通過Maxcompute及其配套產品，低廉的大數據分析僅需幾步，詳情訪問https://www.aliyun.com/product/odps。 本講義出自Sameer Agarwal在Spark Summit EU 2016上的演講