Renamed 'Wordcount' jobs in 'peel-archetypes'.

* Renamed Flink's Wordcount to FlinkWC. * Renamed Spark's Wordcount to SparkWC.
peelframework · Sep 3, 2015 · 1fd59cb · 1fd59cb
1 parent 8010d00
commit 1fd59cb
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 10 deletions.
diff --git a/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml b/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml
@@ -55,7 +55,7 @@
     <bean id="experiment.flink.wordcount" parent="experiment.flink-0.9.0" abstract="true">
         <constructor-arg name="command">
             <value><![CDATA[
-              -v -c ${package}.flink.Wordcount                    ${symbol_escape}
+              -v -c ${package}.flink.FlinkWC                      ${symbol_escape}
               ${symbol_dollar}{app.path.apps}/${parentArtifactId}-flink-jobs-${version}.jar          ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.input}/rubbish.txt                            ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.output}/wordcount
@@ -125,4 +125,4 @@
         </constructor-arg>
     </bean>
 
-</beans>
+</beans>
diff --git a/...jobs/src/main/scala/flink/Wordcount.scala → ...k-jobs/src/main/scala/flink/FlinkWC.scala b/...jobs/src/main/scala/flink/Wordcount.scala → ...k-jobs/src/main/scala/flink/FlinkWC.scala
@@ -6,7 +6,7 @@ package ${package}.flink
 import org.apache.flink.api.scala._
 
 /** A `WordCount` workload job for Flink. */
-object Wordcount {
+object FlinkWC {
 
   def main(args: Array[String]) {
     if (args.length != 2) {

diff --git a/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml b/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml
@@ -55,7 +55,7 @@
     <bean id="experiment.flink.wordcount" parent="experiment.flink-0.9.0" abstract="true">
         <constructor-arg name="command">
             <value><![CDATA[
-              -v -c ${package}.flink.Wordcount                    ${symbol_escape}
+              -v -c ${package}.flink.FlinkWC                      ${symbol_escape}
               ${symbol_dollar}{app.path.apps}/${parentArtifactId}-flink-jobs-${version}.jar          ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.input}/rubbish.txt                            ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.output}/wordcount
@@ -72,7 +72,7 @@
     <bean id="experiment.spark.wordcount" parent="experiment.spark-1.4.0" abstract="true">
         <constructor-arg name="command">
             <value><![CDATA[
-              --class ${package}.spark.Wordcount                  ${symbol_escape}
+              --class ${package}.spark.SparkWC                    ${symbol_escape}
               ${symbol_dollar}{app.path.apps}/${parentArtifactId}-spark-jobs-${version}.jar          ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.input}/rubbish.txt                            ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.output}/wordcount

diff --git a/...jobs/src/main/scala/flink/Wordcount.scala → ...k-jobs/src/main/scala/flink/FlinkWC.scala b/...jobs/src/main/scala/flink/Wordcount.scala → ...k-jobs/src/main/scala/flink/FlinkWC.scala
@@ -6,7 +6,7 @@ package ${package}.flink
 import org.apache.flink.api.scala._
 
 /** A `WordCount` workload job for Flink. */
-object Wordcount {
+object FlinkWC {
 
   def main(args: Array[String]) {
     if (args.length != 2) {

diff --git a/...jobs/src/main/scala/spark/Wordcount.scala → ...k-jobs/src/main/scala/spark/SparkWC.scala b/...jobs/src/main/scala/spark/Wordcount.scala → ...k-jobs/src/main/scala/spark/SparkWC.scala
@@ -6,7 +6,7 @@ package ${package}.spark
 import org.apache.spark.{SparkConf, SparkContext}
 
 /** A `WordCount` workload job for Spark. */
-object Wordcount {
+object SparkWC {
 
   def main(args: Array[String]) {
     if (args.length != 2) {

diff --git a/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml b/...e-resources/__rootArtifactId__-bundle/src/main/resources/config/experiments.wordcount.xml
@@ -55,7 +55,7 @@
     <bean id="experiment.spark.wordcount" parent="experiment.spark-1.4.0" abstract="true">
         <constructor-arg name="command">
             <value><![CDATA[
-              --class ${package}.spark.Wordcount                  ${symbol_escape}
+              --class ${package}.spark.SparkWC                    ${symbol_escape}
               ${symbol_dollar}{app.path.apps}/${parentArtifactId}-spark-jobs-${version}.jar          ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.input}/rubbish.txt                            ${symbol_escape}
               ${symbol_dollar}{system.hadoop-2.path.output}/wordcount
@@ -125,4 +125,4 @@
         </constructor-arg>
     </bean>
 
-</beans>
+</beans>
diff --git a/...jobs/src/main/scala/spark/Wordcount.scala → ...k-jobs/src/main/scala/spark/SparkWC.scala b/...jobs/src/main/scala/spark/Wordcount.scala → ...k-jobs/src/main/scala/spark/SparkWC.scala
@@ -6,7 +6,7 @@ package ${package}.spark
 import org.apache.spark.{SparkConf, SparkContext}
 
 /** A `WordCount` workload job for Spark. */
-object Wordcount {
+object SparkWC {
 
   def main(args: Array[String]) {
     if (args.length != 2) {