We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 03375ce commit cdb7f70Copy full SHA for cdb7f70
wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java
@@ -40,9 +40,9 @@ public static void main(String[] args){
40
41
/* Get a plan builder */
42
WayangContext wayangContext = new WayangContext(new Configuration())
43
-// .withPlugin(Java.basicPlugin())
44
- .withPlugin(Spark.basicPlugin())
45
- .withPlugin(Flink.basicPlugin());
+ .withPlugin(Java.basicPlugin())
+ .withPlugin(Spark.basicPlugin());
+// .withPlugin(Flink.basicPlugin());
46
47
JavaPlanBuilder planBuilder = new JavaPlanBuilder(wayangContext)
48
.withJobName("WordCount")
0 commit comments