包

包根

定義類: 根

包org

定義類: 根

包apache

定義類: org

包火花

核心火花功能。

核心火花功能。org.apache.spark.SparkContext作為火花的主要入口點,org.apache.spark.rdd.RDD是代表一個分布式的數據類型集合,並提供大多數並行操作。

此外,org.apache.spark.rdd.PairRDDFunctions包含操作隻能在抽樣鍵值對,等groupByKey和加入;org.apache.spark.rdd.DoubleRDDFunctions包含操作隻能在雙打的抽樣;和org.apache.spark.rdd.SequenceFileRDDFunctions包含操作可以在抽樣SequenceFiles能得救。這些操作是自動上可用任何抽樣的類型(如抽樣((Int, Int))通過隱式轉換。

Java程序員應該引用org.apache.spark.api.java包火花在Java編程api。

類和方法標注實驗是麵向用戶的功能還沒有被正式采用火花項目。這些小版本中更改或刪除。

類和方法標注開發人員API僅供高級用戶希望延長火花通過低層接口。這些小版本中更改或刪除。

定義類: apache

包api

定義類: 火花

包廣播

火花的廣播變量,用於所有節點廣播不可變的數據集。

定義類: 火花

包graphx

α組件GraphX是一個圖像處理框架之上的火花。

定義類: 火花

包輸入

定義類: 火花

包io

IO用於壓縮編解碼器。

IO用於壓縮編解碼器。看到org.apache.spark.io.CompressionCodec。

定義類: 火花

包發射器

定義類: 火花

包mapred

定義類: 火花

包指標

定義類: 火花

包毫升

DataFrame-based機器學習api來讓用戶快速組裝和配置實用機器學習管道。

定義類: 火花

包mllib

RDD-based機器學習api(在維護模式)。

的spark.mllib包是在維護模式下的火花2.0.0發布鼓勵下遷移到DataFrame-based apiorg.apache.spark.ml包中。在維護模式,

RDD-based中沒有的新特性spark.mllib包將被接受,除非他們DataFrame-based塊實現新功能spark.ml包;
修補缺陷RDD-based api仍將被接受。

開發人員將繼續添加更多特性的DataFrame-based api 2。x係列達到1:1的特點RDD-based api。一旦我們達到功能平價,這個包會被棄用。

定義類: 火花
另請參閱: 火星- 4591平價的進步跟蹤特性

包部分

支持近似的結果。

支持近似的結果。這也提供了方便的api和實現近似計算。

定義類: 火花
另請參閱: org.apache.spark.rdd.RDD.countApprox

包抽樣

提供了幾種抽樣的實現。

提供了幾種抽樣的實現。看到org.apache.spark.rdd.RDD。

定義類: 火花

包資源

定義類: 火花

包調度器

火花的調度組件。

火花的調度組件。這包括org.apache.spark.scheduler.DAGScheduler和較低的水平org.apache.spark.scheduler.TaskScheduler。

定義類: 火花

包安全

定義類: 火花

包序列化器

可熱插拔的抽樣和洗牌數據序列化器。

定義類: 火花
另請參閱: org.apache.spark.serializer.Serializer

包洗牌

定義類: 火花

包sql

允許關係查詢的執行,包括那些用SQL表達使用火花。

定義類: 火花

包狀態

定義類: 火花

包存儲

定義類: 火花

包流媒體

火花流功能。

火花流功能。org.apache.spark.streaming.StreamingContext作為火花流的主要入口點,org.apache.spark.streaming.dstream.DStream是抽樣的數據類型代表一個連續的序列,代表一個連續的數據流。

此外,org.apache.spark.streaming.dstream.PairDStreamFunctions包含操作隻能在DStreams鍵值對,等groupByKey和reduceByKey。這些操作是自動上可用任何DStream正確的類型(例如DStream [(Int, Int)]通過隱式轉換。

Java API的火花流,看一看org.apache.spark.streaming.api.java.JavaStreamingContext作為入口點,和org.apache.spark.streaming.api.java.JavaDStream和org.apache.spark.streaming.api.java.JavaPairDStreamDStream功能。

定義類: 火花

包不安全的

定義類: 火花

包跑龍套

火花工具。

定義類: 火花

InterruptibleIterator

SparkFirehoseListener

org。apache。火花

SparkJobInfo

特征SparkJobInfo擴展可序列化的

線性超

可序列化的,AnyRef,任何

訂購

字母
通過繼承

繼承了

SparkJobInfo
可序列化的
AnyRef
任何

隱藏所有
顯示所有

可見性

公共
所有

抽象價值的成員

文摘defjobId():Int
文摘defstageIds():數組(Int]
文摘def狀態():JobExecutionStatus

具體值的成員

最後def! =(arg0:任何):布爾

定義類

AnyRef→任何
最後def# #():Int

定義類

AnyRef→任何
最後def= =(arg0:任何):布爾

定義類

AnyRef→任何
最後defasInstanceOf(T0]:T0

定義類

任何
def克隆():AnyRef

屬性

保護(朗]

定義類

AnyRef

注釋

@throws (…) @native ()
最後def情商(arg0:AnyRef):布爾

定義類

AnyRef
def=(arg0:任何):布爾

定義類

AnyRef→任何
def完成():單位

屬性

保護(朗]

定義類

AnyRef

注釋

@throws (名為[java.lang.Throwable] classOf)
最後defgetClass():類(_)

定義類

AnyRef→任何

注釋

@native ()
defhashCode():Int

定義類

AnyRef→任何

注釋

@native ()
最後defisInstanceOf(T0]:布爾

定義類

任何
最後def不(arg0:AnyRef):布爾

定義類

AnyRef
最後def通知():單位

定義類

AnyRef

注釋

@native ()
最後defnotifyAll():單位

定義類

AnyRef

注釋

@native ()
最後def同步(T0](arg0:⇒T0):T0

定義類

AnyRef
deftoString():字符串

定義類

AnyRef→任何
最後def等待():單位

定義類

AnyRef

注釋

@throws (…)
最後def等待(arg0:長,__arg1:Int):單位

定義類

AnyRef

注釋

@throws (…)
最後def等待(arg0:長):單位

定義類

AnyRef

注釋

@throws (…) @native ()

包

SparkJobInfo

特征SparkJobInfo擴展可序列化的

抽象價值的成員

具體值的成員

繼承自可序列化的

繼承自AnyRef

繼承自任何

未分組的

包

SparkJobInfo

特征SparkJobInfo擴展可序列化的

抽象價值的成員

具體值的成員

繼承自可序列化的

繼承自AnyRef

繼承自任何

未分組的

SparkJobInfo