You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nemo.apache.org by jo...@apache.org on 2018/10/17 01:13:27 UTC
[incubator-nemo] 10/14: update
This is an automated email from the ASF dual-hosted git repository.
johnyangk pushed a commit to branch tpch-fix
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git
commit 4e98b4f27abd3d9e37c5d36eded542346c003814
Author: John Yang <jo...@apache.org>
AuthorDate: Thu Sep 13 10:26:38 2018 +0900
update
---
.../beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/examples/beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java b/examples/beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java
index bf1393c..08ab84e 100644
--- a/examples/beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java
+++ b/examples/beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java
@@ -93,9 +93,9 @@ public final class Tpch {
.put("nation", Schemas.NATION_SCHEMA)
.put("region", Schemas.REGION_SCHEMA)
- /*
.put("part", Schemas.PART_SCHEMA)
.put("partsupp", Schemas.PARTSUPP_SCHEMA)
+ /*
.put("store_sales", Schemas.STORE_SALES_SCHEMA)
.put("catalog_sales", Schemas.CATALOG_SALES_SCHEMA)
.put("item", Schemas.ITEM_SCHEMA)
@@ -117,7 +117,7 @@ public final class Tpch {
if (tokens.contains(tableName)) {
LOG.info("HIT: tablename {}", tableName);
- final String filePattern = inputDirectory + tableSchema.getKey() + ".tbl";
+ final String filePattern = inputDirectory + tableSchema.getKey() + ".tbl*";
final PCollection<Row> table = GenericSourceSink.read(pipeline, filePattern)
.apply("StringToRow", new TextTableProvider.CsvToRow(tableSchema.getValue(), csvFormat))
.setCoder(tableSchema.getValue().getRowCoder())