-
- Downloads
[SPARK-3873][STREAMING] Import order fixes for streaming.
Also included a few miscelaneous other modules that had very few violations. Author: Marcelo Vanzin <vanzin@cloudera.com> Closes #10532 from vanzin/SPARK-3873-streaming.
Showing
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/TransactionProcessor.scala 1 addition, 1 deletion...che/spark/streaming/flume/sink/TransactionProcessor.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala 2 additions, 2 deletions...a/org/apache/spark/streaming/flume/EventTransformer.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeInputDStream.scala 9 additions, 11 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/main/scala/org/apache/spark/streaming/flume/FlumeTestUtils.scala 1 addition, 1 deletion...ala/org/apache/spark/streaming/flume/FlumeTestUtils.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeUtils.scala 1 addition, 2 deletions...n/scala/org/apache/spark/streaming/flume/FlumeUtils.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/PollingFlumeTestUtils.scala 2 additions, 2 deletions.../apache/spark/streaming/flume/PollingFlumeTestUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala 7 additions, 4 deletions...scala/org/apache/spark/streaming/kafka/KafkaCluster.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala 1 addition, 1 deletion.../org/apache/spark/streaming/kafka/KafkaInputDStream.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala 5 additions, 5 deletions...ain/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala 2 additions, 2 deletions...ala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala 5 additions, 5 deletions...n/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
- external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala 3 additions, 3 deletions.../apache/spark/streaming/kafka/ReliableKafkaReceiver.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala 3 additions, 3 deletions.../apache/spark/streaming/twitter/TwitterInputDStream.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala 3 additions, 2 deletions...ala/org/apache/spark/streaming/twitter/TwitterUtils.scala
- external/zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala 1 addition, 1 deletion...scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala
- repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala 3 additions, 4 deletions...ain/scala/org/apache/spark/repl/ExecutorClassLoader.scala
- streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala 3 additions, 4 deletions...rc/main/scala/org/apache/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 4 additions, 2 deletions.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala 2 additions, 1 deletion...src/main/scala/org/apache/spark/streaming/StateSpec.scala
Loading
Please register or sign in to comment