| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ui/exec/ |
| H A D | ExecutorsTab.scala | 76 override def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit = synchronized {
77 val eid = executorAdded.executorId
79 taskSummary.executorLogs = executorAdded.executorInfo.logUrlMap
80 taskSummary.totalCores = executorAdded.executorInfo.totalCores
82 executorEvents += executorAdded
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/ |
| H A D | SparkListenerBus.scala | 60 case executorAdded: SparkListenerExecutorAdded =>
61 listener.onExecutorAdded(executorAdded)
|
| H A D | SparkListener.scala | 234 def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit
292 override def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit = { }
|
| H A D | TaskSchedulerImpl.scala | 301 executorAdded(o.executorId, o.host)
321 taskSet.executorAdded()
579 def executorAdded(execId: String, host: String) { method
580 dagScheduler.executorAdded(execId, host)
|
| H A D | TaskSetManager.scala | 972 def executorAdded() { method
|
| H A D | DAGScheduler.scala | 249 def executorAdded(execId: String, host: String): Unit = { method
|
| /dports/devel/spark/spark-2.1.1/core/src/main/java/org/apache/spark/ |
| H A D | SparkFirehoseListener.java | 107 public final void onExecutorAdded(SparkListenerExecutorAdded executorAdded) { in onExecutorAdded() argument
108 onEvent(executorAdded); in onExecutorAdded()
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
| H A D | TaskSetManagerSuite.scala | 48 override def executorAdded(execId: String, host: String) {}
521 manager.executorAdded()
526 manager.executorAdded()
549 manager.executorAdded()
551 manager.executorAdded()
767 manager.executorAdded()
780 manager.executorAdded()
798 manager.executorAdded()
801 manager.executorAdded()
804 manager.executorAdded()
|
| H A D | TaskSchedulerImplSuite.scala | 79 override def executorAdded(execId: String, host: String): Unit = {}
424 override def executorAdded(execId: String, host: String) {}
455 override def executorAdded(execId: String, host: String) {}
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ |
| H A D | HeartbeatReceiver.scala | 165 override def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit = {
166 addExecutor(executorAdded.executorId)
|
| H A D | ExecutorAllocationManager.scala | 700 override def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit = {
701 val executorId = executorAdded.executorId
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/client/ |
| H A D | StandaloneAppClientListener.scala | 36 def executorAdded( method
|
| H A D | StandaloneAppClient.scala | 175 listener.executorAdded(fullId, workerId, hostPort, cores, memory)
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/ |
| H A D | JsonProtocol.scala | 93 case executorAdded: SparkListenerExecutorAdded =>
94 executorAddedToJson(executorAdded)
215 def executorAddedToJson(executorAdded: SparkListenerExecutorAdded): JValue = {
216 ("Event" -> Utils.getFormattedClassName(executorAdded)) ~
217 ("Timestamp" -> executorAdded.time) ~
218 ("Executor ID" -> executorAdded.executorId) ~
219 ("Executor Info" -> executorInfoToJson(executorAdded.executorInfo))
509 val executorAdded = Utils.getFormattedClassName(SparkListenerExecutorAdded) constant
528 case `executorAdded` => executorAddedFromJson(json)
|
| /dports/www/firefox/firefox-99.0/third_party/python/sentry_sdk/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 133 def onExecutorAdded(self, executorAdded): # noqa: N802,N803 argument
|
| /dports/devel/py-sentry-sdk/sentry-sdk-1.4.3/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 133 def onExecutorAdded(self, executorAdded): # noqa: N802,N803 argument
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/python/sentry_sdk/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 133 def onExecutorAdded(self, executorAdded): # noqa: N802,N803 argument
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/python/sentry_sdk/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 133 def onExecutorAdded(self, executorAdded): # noqa: N802,N803 argument
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/sentry-sdk/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 133 def onExecutorAdded(self, executorAdded): # noqa: N802,N803 argument
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/cluster/ |
| H A D | StandaloneSchedulerBackend.scala | 148 override def executorAdded(fullId: String, workerId: String, hostPort: String, cores: Int,
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/client/ |
| H A D | AppClientSuite.scala | 204 def executorAdded( method
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/util/ |
| H A D | JsonProtocolSuite.scala | 82 val executorAdded = SparkListenerExecutorAdded(executorAddedTime, "exec1", constant
110 testEvent(executorAdded, executorAddedJsonString)
|