@@ -0,0 +1,604 @@
+package com.stratio.deep.rdd;%0A%0Aimport com.stratio.deep.config.DeepJobConfig;%0Aimport org.apache.spark.Partition;%0Aimport org.apache.spark.TaskContext;%0A%0Aimport java.io.Serializable;%0Aimport java.util.Iterator;%0A%0A/**%0A * Created by rcrespo on 4/08/14.%0A */%0Apublic interface IExtractor%3CT%3E extends Serializable %7B%0A%0A%0A    DeepTokenRange%5B%5D getPartitions(DeepJobConfig%3CT%3E config);%0A%0A%0A    boolean hasNext();%0A%0A    T next();%0A%0A    void close();%0A%0A    void initIterator(final DeepTokenRange dp,%0A                      DeepJobConfig%3CT%3E config);%0A%0A    // TODO Implement and document%0A    // void write(Cells rawKey, Cells data);%0A%7D%0A

rename IdeepRDD --> Iextractor