summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorjingtinghuang <r06944049@ntu.edu.tw>2020-04-16 16:07:10 +0800
committerjingtinghuang <r06944049@ntu.edu.tw>2020-04-16 16:07:10 +0800
commit4c99c5ef7854433cd7e4e74ecf877d907b5e3187 (patch)
tree0459c9a54129a102dbf8e3ff656fe42a9444d8c3 /vespa-hadoop
parent1c0ae314ffc19ad9f7a1e7d2e08b14df329c16ca (diff)
change variable printId to verbose
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java6
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