diff options
author | pmanoj133 <manojbits2005@gmail.com> | 2020-02-05 10:58:35 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-02-05 10:58:35 -0800 |
commit | 9d947619b9e3ff9225a951326685515a3d7c0f57 (patch) | |
tree | c745773724ae373a2bd5e7c09f9a1d7b6c33624b /vespa-hadoop/src | |
parent | 1ca517416834e664504480e5f811ea07ad86ef0a (diff) |
Update VespaDocumentOperationTest.java
Diffstat (limited to 'vespa-hadoop/src')
-rw-r--r-- | vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java b/vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java index 7d0fe72fc64..597967cfafb 100644 --- a/vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java +++ b/vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java @@ -47,6 +47,19 @@ public class VespaDocumentOperationTest { assertEquals(3, fields.get("value").get("assign").getIntValue()); } + @Test + public void requireThatUDFSupportsConditionalUpdateAssign() throws IOException { + String json = getDocumentOperationJson("docid=id:<application>:metrics::<name>-<date>", "operation=update", "condition=clicks>100"); + ObjectMapper m = new ObjectMapper(); + JsonNode root = m.readTree(json); + JsonNode fields = root.path("fields"); + + assertEquals("id:testapp:metrics::clicks-20160112", root.get("update").getTextValue()); + assertEquals("clicks>100", root.get("condition").getTextValue()); + assertEquals("testapp", fields.get("application").get("assign").getTextValue()); + assertEquals("clicks", fields.get("name").get("assign").getTextValue()); + assertEquals(3, fields.get("value").get("assign").getIntValue()); + } @Test public void requireThatUDFSupportsCreateIfNonExistent() throws IOException { |