| /dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/ui/ |
| H A D | StreamingJobProgressListenerSuite.scala | 185 val jobStart = createJobStart(Time(1000 + i * 100), outputOpId = 0, jobId = 1) constant
190 val jobStart = createJobStart(Time(1000 + limit * 100), outputOpId = 0, jobId = 0) constant
216 val jobStart = createJobStart(Time(1000 + i * 100), outputOpId = 0, jobId = 1) constant
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/util/ |
| H A D | JsonProtocolSuite.scala | 58 val jobStart = { constant
309 val jobStart = SparkListenerJobStart(10, jobSubmissionTime, stageInfos, properties) constant
321 val jobStart = SparkListenerJobStart(11, jobSubmissionTime, stageInfos, properties) constant
|
| /dports/www/firefox/firefox-99.0/third_party/python/sentry_sdk/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 159 def onJobStart(self, jobStart): # noqa: N802,N803 argument
216 def onJobStart(self, jobStart): # noqa: N802,N803 argument
|
| /dports/devel/py-sentry-sdk/sentry-sdk-1.4.3/sentry_sdk/integrations/spark/ |
| H A D | spark_driver.py | 159 def onJobStart(self, jobStart): # noqa: N802,N803 argument
216 def onJobStart(self, jobStart): # 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 | 159 def onJobStart(self, jobStart): # noqa: N802,N803 argument
216 def onJobStart(self, jobStart): # 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 | 159 def onJobStart(self, jobStart): # noqa: N802,N803 argument
216 def onJobStart(self, jobStart): # 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 | 159 def onJobStart(self, jobStart): # noqa: N802,N803 argument
216 def onJobStart(self, jobStart): # noqa: N802,N803 argument
|
| /dports/devel/spark/spark-2.1.1/core/src/main/java/org/apache/spark/ |
| H A D | SparkFirehoseListener.java | 61 public final void onJobStart(SparkListenerJobStart jobStart) { in onJobStart()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/ |
| H A D | RumenToSLSConverter.java | 169 long jobStart = (Long) rumenJob.get("submitTime"); in createSLSJob() local
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/ui/ |
| H A D | SQLListenerSuite.scala | 374 val jobStart = SparkListenerJobStart(0, 0, Seq(stageInfo), createProperties(0)) constant
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.jdt.core/org.eclipse.jdt.core/search/org/eclipse/jdt/internal/core/search/processing/ |
| H A D | JobManager.java | 25 protected int jobStart = 0; field in JobManager
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/ |
| H A D | JsonProtocol.scala | 501 val jobStart = Utils.getFormattedClassName(SparkListenerJobStart) constant
|