We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c3ca273 commit 46715b3Copy full SHA for 46715b3
core/src/main/scala/org/apache/spark/status/api/v1/api.scala
@@ -197,7 +197,7 @@ class RDDDataDistribution private[spark](
197
@JsonDeserialize(contentAs = classOf[JLong])
198
val offHeapMemoryRemaining: Option[Long]) {
199
200
- def toLiveRDDDistribution(executors: scala.collection.Map[String, LiveExecutor])
+ private[spark] def toLiveRDDDistribution(executors: scala.collection.Map[String, LiveExecutor])
201
: LiveRDDDistribution = {
202
val exec = executors.get(executorId).get
203
val liveRDDDistribution = new LiveRDDDistribution(exec)
0 commit comments