/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/rdd/ |
H A D | WriteAheadLogBackedBlockRDDSuite.scala | 63 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 D | KinesisStreamSuite.scala | 93 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 D | StreamingContextSuite.scala | 272 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 D | MapWithStateSuite.scala | 41 StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) } 46 StreamingContext.getActive().foreach { _.stop(stopSparkContext = false) }
|
H A D | CheckpointSuite.scala | 152 stopSparkContext: Boolean 181 ssc.stop(stopSparkContext = stopSparkContext) 771 generateOutput(ssc, Time(batchDurationMillis * 3), checkpointDir, stopSparkContext = true)
|
H A D | TestSuiteBase.scala | 282 ssc.stop(stopSparkContext = true) 441 ssc.stop(stopSparkContext = true)
|
H A D | DStreamClosureSuite.scala | 43 ssc.stop(stopSparkContext = true)
|
H A D | DStreamScopeSuite.scala | 46 ssc.stop(stopSparkContext = true)
|
H A D | ReceiverSuite.scala | 257 ssc.stop(stopSparkContext = true, stopGracefully = true)
|
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/ |
H A D | StreamingContext.scala | 641 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 D | context.py | 220 def stop(self, stopSparkContext=True, stopGraceFully=False): argument 229 self._jssc.stop(stopSparkContext, stopGraceFully) 231 if stopSparkContext:
|
H A D | tests.py | 1220 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 D | JavaStreamingContext.scala | 592 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 D | queue_stream.py | 49 ssc.stop(stopSparkContext=True, stopGraceFully=True)
|
/dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/engine/spark/ |
H A D | SparkCommandLineProgram.java | 57 SparkContextFactory.stopSparkContext(ctx); in afterPipeline()
|
H A D | SparkContextFactory.java | 155 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 D | streaming_k_means_example.py | 63 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 D | PythonDStream.scala | 211 StreamingContext.getActive().foreach(_.stop(stopSparkContext = false))
|
/dports/devel/spark/spark-2.1.1/docs/ |
H A D | streaming-programming-guide.md | 543 …ly the StreamingContext, set the optional parameter of `stop()` called `stopSparkContext` to false.
|