Github user lewismc commented on a diff in the pull request: https://github.com/apache/gora/pull/135#discussion_r222542819 --- Diff: gora-pig/src/main/java/org/apache/gora/pig/GoraDeleteStorage.java --- @@ -0,0 +1,111 @@ +package org.apache.gora.pig; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +import org.apache.gora.mapreduce.GoraRecordWriter; +import org.apache.gora.persistency.impl.PersistentBase; +import org.apache.hadoop.mapreduce.Job; +import org.apache.hadoop.mapreduce.RecordReader; +import org.apache.pig.ResourceSchema; +import org.apache.pig.ResourceSchema.ResourceFieldSchema; +import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit; +import org.apache.pig.data.DataType; +import org.apache.pig.data.Tuple; +import org.codehaus.jackson.JsonParseException; +import org.codehaus.jackson.map.JsonMappingException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Storage to delete rows by key. + * + * Given a relation with schema (key:chararray) rows, the following will delete + * all rows with that keys: + * + * <pre> + * STORE webpages INTO '.' USING org.apache.gora.pig.GoraDeleteStorage('{ --- End diff -- This is killer. So cool.
---