Skip to content

Commit 60ac8ef

Browse files
committed
fix: as requested remove empty configuration and deleted the WordCountWithPlanBuilder.java
1 parent bf7a708 commit 60ac8ef

3 files changed

Lines changed: 2 additions & 119 deletions

File tree

wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public static void main(String[] args) throws IOException, URISyntaxException {
3939
System.exit(1);
4040
}
4141

42-
WayangContext wayangContext = new WayangContext(new Configuration());
42+
WayangContext wayangContext = new WayangContext();
4343
for (String platform : args[0].split(",")) {
4444
switch (platform) {
4545
case "java":

wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public static void main(String[] args){
3737
System.exit(1);
3838
}
3939

40-
WayangContext wayangContext = new WayangContext(new Configuration());
40+
WayangContext wayangContext = new WayangContext();
4141
for (String platform : args[0].split(",")) {
4242
switch (platform) {
4343
case "java":
@@ -90,4 +90,3 @@ public static void main(String[] args){
9090
wordcounts.forEach(wc -> System.out.printf("%dx %s\n", wc.field1, wc.field0));
9191
}
9292
}
93-

wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountWithPlanBuilder.java

Lines changed: 0 additions & 116 deletions
This file was deleted.

0 commit comments

Comments
 (0)