Home
last modified time | relevance | path

Searched refs:stopSparkContext (Results 1 – 19 of 19) sorted by relevance

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/rdd/
H A DWriteAheadLogBackedBlockRDDSuite.scala63 stopSparkContext()
77 private def stopSparkContext(): Unit = { method
123 stopSparkContext()
129 stopSparkContext()
/dports/devel/spark/spark-2.1.1/external/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/
H A DKinesisStreamSuite.scala93 ssc.stop(stopSparkContext = false)
196 ssc.stop(stopSparkContext = false)
225 ssc.stop(stopSparkContext = false)
267 ssc.stop(stopSparkContext = true) // stop the SparkContext so that the blocks are not reused
/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/
H A DStreamingContextSuite.scala272 ssc.stop(stopSparkContext = false)
291 ssc.stop(stopSparkContext = false)
293 ssc.stop(stopSparkContext = true)
319 ssc.stop(stopSparkContext = false, stopGracefully = true)
342 ssc.stop(stopSparkContext = true, stopGracefully = true)
365 ssc.stop(stopSparkContext = false, stopGracefully = true)
594 ssc.stop(stopSparkContext = false)
826 ssc.stop(stopSparkContext = true, stopGracefully = false)
H A DMapWithStateSuite.scala41 StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) }
46 StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) }
H A DCheckpointSuite.scala152 stopSparkContext: Boolean
181 ssc.stop(stopSparkContext = stopSparkContext)
771 generateOutput(ssc, Time(batchDurationMillis * 3), checkpointDir, stopSparkContext = true)
H A DTestSuiteBase.scala282 ssc.stop(stopSparkContext = true)
441 ssc.stop(stopSparkContext = true)
H A DDStreamClosureSuite.scala43 ssc.stop(stopSparkContext = true)
H A DDStreamScopeSuite.scala46 ssc.stop(stopSparkContext = true)
H A DReceiverSuite.scala257 ssc.stop(stopSparkContext = true, stopGracefully = true)
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/
H A DStreamingContext.scala641 stopSparkContext: Boolean = conf.getBoolean("spark.streaming.stopSparkContextByDefault", true)
643 stop(stopSparkContext, false)
656 def stop(stopSparkContext: Boolean, stopGracefully: Boolean): Unit = {
705 if (stopSparkContext) sc.stop()
712 stop(stopSparkContext = false, stopGracefully = stopGracefully)
/dports/devel/spark/spark-2.1.1/python/pyspark/streaming/
H A Dcontext.py220 def stop(self, stopSparkContext=True, stopGraceFully=False): argument
229 self._jssc.stop(stopSparkContext, stopGraceFully)
231 if stopSparkContext:
H A Dtests.py1220 ssc2.stop(stopSparkContext=False, stopGraceFully=True)
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/api/java/
H A DJavaStreamingContext.scala592 def stop(stopSparkContext: Boolean): Unit = ssc.stop(stopSparkContext)
600 def stop(stopSparkContext: Boolean, stopGracefully: Boolean): Unit = {
601 ssc.stop(stopSparkContext, stopGracefully)
/dports/devel/spark/spark-2.1.1/examples/src/main/python/streaming/
H A Dqueue_stream.py49 ssc.stop(stopSparkContext=True, stopGraceFully=True)
/dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/engine/spark/
H A DSparkCommandLineProgram.java57 SparkContextFactory.stopSparkContext(ctx); in afterPipeline()
H A DSparkContextFactory.java155 public static synchronized void stopSparkContext(final JavaSparkContext context) { in stopSparkContext() method in SparkContextFactory
/dports/devel/spark/spark-2.1.1/examples/src/main/python/mllib/
H A Dstreaming_k_means_example.py63 ssc.stop(stopSparkContext=True, stopGraceFully=True)
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/api/python/
H A DPythonDStream.scala211 StreamingContext.getActive().foreach(_.stop(stopSparkContext = false))
/dports/devel/spark/spark-2.1.1/docs/
H A Dstreaming-programming-guide.md543 …ly the StreamingContext, set the optional parameter of `stop()` called `stopSparkContext` to false.