[incubator-nemo] 11/14: substring

[johnyangk]

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 60f50674c83d4b9f7aad4732bc61090e94aa237a
Author: John Yang <johnya...@apache.org>
AuthorDate: Thu Sep 13 10:32:08 2018 +0900

    substring
---
 .../beam/src/main/java/org/apache/nemo/examples/beam/tpch/Tpch.java  | 5 +----
 1 file changed, 1 insertion(+), 4 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 08ab84e..8f7c937 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
@@ -111,10 +111,7 @@ public final class Tpch {
     for (final Map.Entry<String, Schema> tableSchema : hSchemas.entrySet()) {
       final String tableName = tableSchema.getKey();
 
-      final List<String> tokens = Arrays.asList(query.split(" "));
-      LOG.info("Tokens are {}", tokens);
-
-      if (tokens.contains(tableName)) {
+      if (query.contains(tableName)) {
         LOG.info("HIT: tablename {}", tableName);
 
         final String filePattern = inputDirectory + tableSchema.getKey() + 
".tbl*";