包跑龍套
類型成員
- 文摘類WriteAheadLog擴展AnyRef
- 注釋
- @DeveloperApi ()
- 文摘類WriteAheadLogRecordHandle擴展可序列化的
- 注釋
- @DeveloperApi ()
磚Scala API火花
<回來
磚Scala API火花
<回來
核心火花功能。
核心火花功能。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僅供高級用戶希望延長火花通過低層接口。這些小版本中更改或刪除。
火花流功能。
火花流功能。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功能。
DStream的各種實現。
DStream的各種實現。