diff options
author | jingtinghuang <r06944049@ntu.edu.tw> | 2020-04-16 16:07:10 +0800 |
---|---|---|
committer | jingtinghuang <r06944049@ntu.edu.tw> | 2020-04-16 16:07:10 +0800 |
commit | 4c99c5ef7854433cd7e4e74ecf877d907b5e3187 (patch) | |
tree | 0459c9a54129a102dbf8e3ff656fe42a9444d8c3 /vespa-hadoop/src | |
parent | 1c0ae314ffc19ad9f7a1e7d2e08b14df329c16ca (diff) |
change variable printId to verbose
Diffstat (limited to 'vespa-hadoop/src')
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java index d0d9790c07e..b6fe19f8cde 100644 --- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java +++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java @@ -81,7 +81,6 @@ public class VespaDocumentOperation extends EvalFunc<String> { private static final String PARTIAL_UPDATE_ASSIGN = "assign"; private static final String PARTIAL_UPDATE_ADD = "add"; private static final String PARTIAL_UPDATE_REMOVE = "remove"; - private static boolean printId; private static Map<String, String> mapPartialOperationMap; @@ -101,6 +100,7 @@ public class VespaDocumentOperation extends EvalFunc<String> { partialOperationMap.put(UPDATE_MAP_FIELDS, PARTIAL_UPDATE_ASSIGN); } + private final boolean verbose; private final String template; private final Operation operation; private final Properties properties; @@ -115,7 +115,7 @@ public class VespaDocumentOperation extends EvalFunc<String> { properties = VespaConfiguration.loadProperties(params); template = properties.getProperty(PROPERTY_ID_TEMPLATE); operation = Operation.fromString(properties.getProperty(PROPERTY_OPERATION, "put")); - printId = Boolean.parseBoolean(properties.getProperty(PROPERTY_VERBOSE, "false")); + verbose = Boolean.parseBoolean(properties.getProperty(PROPERTY_VERBOSE, "false")); } @Override @@ -148,7 +148,7 @@ public class VespaDocumentOperation extends EvalFunc<String> { Schema inputSchema = getInputSchema(); Map<String, Object> fields = TupleTools.tupleMap(inputSchema, tuple); String docId = TupleTools.toString(fields, template); - if (printId) { + if (verbose) { System.out.println("Processing docId: "+ docId); } // create json |