summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorpmanoj133 <manojbits2005@gmail.com>2020-02-05 13:29:32 -0800
committerGitHub <noreply@github.com>2020-02-05 13:29:32 -0800
commit372756f6de4691d3076272d5f7d764e164baa3fc (patch)
tree98cefd95e7ead9dcc8181517c043bda564077f37 /vespa-hadoop
parentda1e25af296b02988db0cd4ec67aff3a17c0bead (diff)
Update VespaDocumentOperation.java
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperation.java5
1 files changed, 3 insertions, 2 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 1c7edf34fe0..32cdbf9af5c 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
@@ -163,8 +163,9 @@ public class VespaDocumentOperation extends EvalFunc<String> {
if (op == Operation.UPDATE && createIfNonExistent) {
writeField("create", true, DataType.BOOLEAN, g, properties, schema, op, 0);
}
- String testSetCondition = properties.getProperty(TESTSET_CONDITION);
- if (testSetCondition != null) {
+ String testSetConditionTemplate = properties.getProperty(TESTSET_CONDITION);
+ if (testSetConditionTemplate != null) {
+ String testSetCondition = TupleTools.toString(fields, testSetConditionTemplate);
writeField(TESTSET_CONDITION, testSetCondition, DataType.CHARARRAY, g, properties, schema, op, 0);
}
if (op != Operation.REMOVE) {