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 <[email protected]> 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())
