如何在Apache Spark項目中找到類OpenHashMapBasedStateMap的源代碼

-1

我正在嘗試查找在下面給出的鏈接中使用的OpenHashMapBasedStateMap的源代碼。但是我無法在spark庫中的任何地方找到實現。有什麼能這樣做的原因，我怎麼能看那個斯卡拉類的源代碼如何在Apache Spark項目中找到類OpenHashMapBasedStateMap的源代碼

https://github.com/apache/spark/blob/branch-2.0/streaming/src/main/scala/org/apache/spark/streaming/util/StateMap.scala

來源

2016-08-23 Rishi

是否在鏈接文件的第84行上定義？ – maxymoo

這只是在StateMap.scala：

/** Implementation of StateMap based on Spark's [[org.apache.spark.util.collection.OpenHashMap]] */ 
private[streaming] class OpenHashMapBasedStateMap[K, S](
    @transient @volatile var parentStateMap: StateMap[K, S], 
    private var initialCapacity: Int = DEFAULT_INITIAL_CAPACITY, 
    private var deltaChainThreshold: Int = DELTA_CHAIN_LENGTH_THRESHOLD 
)(implicit private var keyClassTag: ClassTag[K], private var stateClassTag: ClassTag[S]) 
extends StateMap[K, S] with KryoSerializable { 
    ... 
}

直到現在（八月23）它來自第84行

來源

2016-08-23 09:19:16

我不知道我是如何錯過的。非常感謝答覆。 – Rishi

如何在Apache Spark項目中找到類OpenHashMapBasedStateMap的源代碼

回答

相關問題