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. 


---

Reply via email to