diff options
Diffstat (limited to 'external')
-rw-r--r-- | external/kafka-0-8-assembly/pom.xml (renamed from external/kafka-assembly/pom.xml) | 6 | ||||
-rw-r--r-- | external/kafka-0-8/pom.xml (renamed from external/kafka/pom.xml) | 6 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package-info.java (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package-info.java) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package.scala (renamed from external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java (renamed from external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java (renamed from external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java (renamed from external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/resources/log4j.properties (renamed from external/kafka/src/test/resources/log4j.properties) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala (renamed from external/kafka/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala (renamed from external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala (renamed from external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala (renamed from external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala) | 0 | ||||
-rw-r--r-- | external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala (renamed from external/kafka/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala) | 0 |
23 files changed, 6 insertions, 6 deletions
diff --git a/external/kafka-assembly/pom.xml b/external/kafka-0-8-assembly/pom.xml index e1b5a7e713..3cc288abea 100644 --- a/external/kafka-assembly/pom.xml +++ b/external/kafka-0-8-assembly/pom.xml @@ -26,19 +26,19 @@ </parent> <groupId>org.apache.spark</groupId> - <artifactId>spark-streaming-kafka-assembly_2.11</artifactId> + <artifactId>spark-streaming-kafka-0-8-assembly_2.11</artifactId> <packaging>jar</packaging> <name>Spark Project External Kafka Assembly</name> <url>http://spark.apache.org/</url> <properties> - <sbt.project.name>streaming-kafka-assembly</sbt.project.name> + <sbt.project.name>streaming-kafka-0-8-assembly</sbt.project.name> </properties> <dependencies> <dependency> <groupId>org.apache.spark</groupId> - <artifactId>spark-streaming-kafka_${scala.binary.version}</artifactId> + <artifactId>spark-streaming-kafka-0-8_${scala.binary.version}</artifactId> <version>${project.version}</version> </dependency> <dependency> diff --git a/external/kafka/pom.xml b/external/kafka-0-8/pom.xml index 68d52e9339..cccfda3c61 100644 --- a/external/kafka/pom.xml +++ b/external/kafka-0-8/pom.xml @@ -26,12 +26,12 @@ </parent> <groupId>org.apache.spark</groupId> - <artifactId>spark-streaming-kafka_2.11</artifactId> + <artifactId>spark-streaming-kafka-0-8_2.11</artifactId> <properties> - <sbt.project.name>streaming-kafka</sbt.project.name> + <sbt.project.name>streaming-kafka-0-8</sbt.project.name> </properties> <packaging>jar</packaging> - <name>Spark Project External Kafka</name> + <name>Spark Integration for Kafka 0.8</name> <url>http://spark.apache.org/</url> <dependencies> diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala index 9159051ba0..9159051ba0 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/Broker.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala index fb58ed7898..fb58ed7898 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala index 726b5d8ec3..726b5d8ec3 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala index 3713bda41b..3713bda41b 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala index d4881b140d..d4881b140d 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala index 02917becf0..02917becf0 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDPartition.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala index d9d4240c05..d9d4240c05 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala index edaafb912c..edaafb912c 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala index d9b856e469..d9b856e469 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala index 39abe3c3e2..39abe3c3e2 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package-info.java b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package-info.java index 2e5ab0fb3b..2e5ab0fb3b 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package-info.java +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package-info.java diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package.scala b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package.scala index 47c5187f87..47c5187f87 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/package.scala +++ b/external/kafka-0-8/src/main/scala/org/apache/spark/streaming/kafka/package.scala diff --git a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java index fa6b0dbc8c..fa6b0dbc8c 100644 --- a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java +++ b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java diff --git a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java index c41b6297b0..c41b6297b0 100644 --- a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java +++ b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java diff --git a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java index 868df64e8c..868df64e8c 100644 --- a/external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java +++ b/external/kafka-0-8/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java diff --git a/external/kafka/src/test/resources/log4j.properties b/external/kafka-0-8/src/test/resources/log4j.properties index fd51f8faf5..fd51f8faf5 100644 --- a/external/kafka/src/test/resources/log4j.properties +++ b/external/kafka-0-8/src/test/resources/log4j.properties diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala index cb782d27fe..cb782d27fe 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala +++ b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/DirectKafkaStreamSuite.scala diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala index d66830cbac..d66830cbac 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala +++ b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaClusterSuite.scala diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala index 5e539c1d79..5e539c1d79 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala +++ b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaRDDSuite.scala diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala index 6a35ac14a8..6a35ac14a8 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala +++ b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala index 7b9aee39ff..7b9aee39ff 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala +++ b/external/kafka-0-8/src/test/scala/org/apache/spark/streaming/kafka/ReliableKafkaStreamSuite.scala |