summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop/src/test/java
diff options
context:
space:
mode:
authorjingtinghuang <r06944049@ntu.edu.tw>2020-03-31 17:39:04 +0800
committerjingtinghuang <r06944049@ntu.edu.tw>2020-03-31 17:39:04 +0800
commitd254707e6a9f5555321c108996cfd7b61c55f23d (patch)
tree59651ebf98a93219b35e2aed9d4717a655cb356e /vespa-hadoop/src/test/java
parent4788d1fdaae9a49f4cde171066f589cc0d5e3f4e (diff)
pr fix and add counter
Diffstat (limited to 'vespa-hadoop/src/test/java')
-rw-r--r--vespa-hadoop/src/test/java/com/yahoo/vespa/hadoop/pig/VespaDocumentOperationTest.java9
1 files changed, 4 insertions, 5 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 b86e927e914..72d0a2ec069 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
@@ -1,7 +1,6 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hadoop.pig;
-import com.google.gson.JsonArray;
import org.apache.pig.data.*;
import org.apache.pig.impl.logicalLayer.FrontendException;
import org.apache.pig.impl.logicalLayer.schema.Schema;
@@ -120,7 +119,7 @@ public class VespaDocumentOperationTest {
addToTuple("bag", DataType.BAG, bag, bagSchema, schema, tuple);
addToTuple("id", DataType.CHARARRAY, "123", schema, tuple);
- VespaDocumentOperation docOp = new VespaDocumentOperation("docid=id", "remove-bag-as-map-fields=bag","operation=update");
+ VespaDocumentOperation docOp = new VespaDocumentOperation("docid=id", "remove-map-fields=bag","operation=update");
docOp.setInputSchema(schema);
String json = docOp.exec(tuple);
@@ -154,7 +153,7 @@ public class VespaDocumentOperationTest {
Tuple tuple = TupleFactory.getInstance().newTuple();
addToTuple("bag", DataType.BAG, bag, bagSchema, schema, tuple);
addToTuple("id", DataType.CHARARRAY, "123", schema, tuple);
- VespaDocumentOperation docOp = new VespaDocumentOperation("docid=id", "add-bag-as-map-fields=bag","operation=update");
+ VespaDocumentOperation docOp = new VespaDocumentOperation("docid=id", "update-map-fields=bag","operation=update");
docOp.setInputSchema(schema);
String json = docOp.exec(tuple);
@@ -184,7 +183,7 @@ public class VespaDocumentOperationTest {
addToTuple("id", DataType.CHARARRAY, "123", schema, tuple);
addToTuple("tensor", DataType.MAP, tensor, schema, tuple);
- VespaDocumentOperation docOp = new VespaDocumentOperation("docid=empty", "add-tensor-fields=tensor","operation=update");
+ VespaDocumentOperation docOp = new VespaDocumentOperation("docid=empty", "update-tensor-fields=tensor","operation=update");
docOp.setInputSchema(schema);
String json = docOp.exec(tuple);
@@ -232,7 +231,7 @@ public class VespaDocumentOperationTest {
JsonNode fields = root.get("fields");
JsonNode tensorValue = fields.get("tensor");
JsonNode remove = tensorValue.get("remove");
- JsonNode address = remove.get("address");
+ JsonNode address = remove.get("addresses");
Iterator<JsonNode> addressIterator = address.getElements();