-
- Downloads
[SPARK-3850] Trim trailing spaces for examples/streaming/yarn.
Author: Reynold Xin <rxin@databricks.com> Closes #6530 from rxin/trim-whitespace-1 and squashes the following commits: 7b7b3a0 [Reynold Xin] Reset again. dc14597 [Reynold Xin] Reset scalastyle. cd556c4 [Reynold Xin] YARN, Kinesis, Flume. 4223fe1 [Reynold Xin] [SPARK-3850] Trim trailing spaces for examples/streaming.
Showing
- examples/src/main/scala/org/apache/spark/examples/LogQuery.scala 1 addition, 1 deletion...s/src/main/scala/org/apache/spark/examples/LogQuery.scala
- examples/src/main/scala/org/apache/spark/examples/mllib/DenseGaussianMixture.scala 5 additions, 5 deletions...rg/apache/spark/examples/mllib/DenseGaussianMixture.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala 5 additions, 5 deletions...a/org/apache/spark/examples/streaming/MQTTWordCount.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeInputDStream.scala 5 additions, 5 deletions.../org/apache/spark/streaming/flume/FlumeInputDStream.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala 1 addition, 1 deletion...ache/spark/streaming/flume/FlumePollingInputDStream.scala
- external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala 1 addition, 1 deletion...a/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala 1 addition, 1 deletion...scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala 4 additions, 4 deletions...n/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
- extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala 6 additions, 6 deletions...apache/spark/examples/streaming/KinesisWordCountASL.scala
- extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointState.scala 4 additions, 4 deletions...ache/spark/streaming/kinesis/KinesisCheckpointState.scala
- extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala 4 additions, 4 deletions.../org/apache/spark/streaming/kinesis/KinesisReceiver.scala
- extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisRecordProcessor.scala 14 additions, 14 deletions...ache/spark/streaming/kinesis/KinesisRecordProcessor.scala
- graphx/src/test/scala/org/apache/spark/graphx/EdgeSuite.scala 5 additions, 5 deletions...hx/src/test/scala/org/apache/spark/graphx/EdgeSuite.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala 1 addition, 1 deletion.../org/apache/spark/streaming/receiver/BlockGenerator.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala 1 addition, 1 deletion...pache/spark/streaming/receiver/ReceivedBlockHandler.scala
- streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala 0 additions, 4 deletions...st/scala/org/apache/spark/streaming/UISeleniumSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/util/WriteAheadLogSuite.scala 2 additions, 2 deletions.../org/apache/spark/streaming/util/WriteAheadLogSuite.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientDistributedCacheManager.scala 13 additions, 13 deletions...che/spark/deploy/yarn/ClientDistributedCacheManager.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala 2 additions, 2 deletions...la/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala
- yarn/src/test/scala/org/apache/spark/deploy/yarn/ClientDistributedCacheManagerSuite.scala 12 additions, 12 deletions...park/deploy/yarn/ClientDistributedCacheManagerSuite.scala
Loading
Please register or sign in to comment