GORA-276: Refactor and organize o.a.g.mapreduce package naming

Update pom.xml
apache · Nov 9, 2021 · b3c45b0 · b3c45b0
1 parent 44ecabb
commit b3c45b0
Show file tree

Hide file tree

Showing 54 changed files with 67 additions and 68 deletions.
diff --git a/...spike/src/test/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreCountQuery.java b/...spike/src/test/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreCountQuery.java
@@ -19,7 +19,7 @@
 import org.apache.gora.aerospike.store.AerospikeStartupLogWaitStrategy;
 import org.apache.gora.aerospike.store.AerospikeStore;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.junit.After;

diff --git a/...st/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreMapReduceSerialization.java b/...st/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreMapReduceSerialization.java
@@ -19,7 +19,7 @@
 import org.apache.gora.aerospike.store.AerospikeStartupLogWaitStrategy;
 import org.apache.gora.aerospike.store.AerospikeStore;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.junit.After;

diff --git a/...ospike/src/test/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreWordCount.java b/...ospike/src/test/java/org/apache/gora/aerospike/mapreduce/TestAerospikeStoreWordCount.java
@@ -20,7 +20,7 @@
 import org.apache.gora.aerospike.store.AerospikeStore;
 import org.apache.gora.examples.generated.TokenDatum;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.junit.After;

diff --git a/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/MapReduceSerialization.java b/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/MapReduceSerialization.java
@@ -21,8 +21,8 @@
 import java.io.IOException;
 
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.GoraMapper;
-import org.apache.gora.mapreduce.GoraReducer;
+import org.apache.gora.io.serializer.GoraMapper;
+import org.apache.gora.io.serializer.GoraReducer;
 import org.apache.gora.query.Query;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;

diff --git a/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/QueryCounter.java b/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/QueryCounter.java
@@ -20,7 +20,7 @@
 
 import java.io.IOException;
 
-import org.apache.gora.mapreduce.GoraMapper;
+import org.apache.gora.io.serializer.GoraMapper;
 import org.apache.gora.persistency.Persistent;
 import org.apache.gora.query.Query;
 import org.apache.gora.store.DataStore;

diff --git a/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/WordCount.java b/gora-core/src/examples/java/org/apache/gora/examples/mapreduce/WordCount.java
@@ -24,8 +24,8 @@
 
 import org.apache.gora.examples.generated.TokenDatum;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.GoraMapper;
-import org.apache.gora.mapreduce.GoraReducer;
+import org.apache.gora.io.serializer.GoraMapper;
+import org.apache.gora.io.serializer.GoraReducer;
 import org.apache.gora.query.Query;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;

diff --git a/gora-core/src/main/java/org/apache/gora/flink/GoraFlinkEngine.java b/gora-core/src/main/java/org/apache/gora/flink/GoraFlinkEngine.java
@@ -25,8 +25,8 @@
 import org.apache.flink.api.java.operators.DataSource;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.util.Preconditions;
-import org.apache.gora.mapreduce.GoraInputFormat;
-import org.apache.gora.mapreduce.GoraOutputFormat;
+import org.apache.gora.io.serializer.GoraInputFormat;
+import org.apache.gora.io.serializer.GoraOutputFormat;
 import org.apache.gora.persistency.impl.PersistentBase;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;

diff --git a/gora-core/src/main/java/org/apache/gora/flink/PersistentTypeSerializer.java b/gora-core/src/main/java/org/apache/gora/flink/PersistentTypeSerializer.java
@@ -24,8 +24,8 @@
 import org.apache.flink.api.java.typeutils.runtime.DataOutputViewStream;
 import org.apache.flink.core.memory.DataInputView;
 import org.apache.flink.core.memory.DataOutputView;
-import org.apache.gora.mapreduce.PersistentDeserializer;
-import org.apache.gora.mapreduce.PersistentSerializer;
+import org.apache.gora.io.serializer.PersistentDeserializer;
+import org.apache.gora.io.serializer.PersistentSerializer;
 import org.apache.gora.persistency.impl.PersistentBase;
 import org.apache.gora.util.AvroUtils;
 

diff --git a/...pache/gora/mapreduce/GoraInputFormat.java → ...e/gora/io/serializer/GoraInputFormat.java b/...pache/gora/mapreduce/GoraInputFormat.java → ...e/gora/io/serializer/GoraInputFormat.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.util.ArrayList;

diff --git a/...apache/gora/mapreduce/GoraInputSplit.java → ...he/gora/io/serializer/GoraInputSplit.java b/...apache/gora/mapreduce/GoraInputSplit.java → ...he/gora/io/serializer/GoraInputSplit.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.DataInput;
 import java.io.DataOutput;

diff --git a/...he/gora/mapreduce/GoraMapReduceUtils.java → ...ora/io/serializer/GoraMapReduceUtils.java b/...he/gora/mapreduce/GoraMapReduceUtils.java → ...ora/io/serializer/GoraMapReduceUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.util.List;

diff --git a/...org/apache/gora/mapreduce/GoraMapper.java → ...apache/gora/io/serializer/GoraMapper.java b/...org/apache/gora/mapreduce/GoraMapper.java → ...apache/gora/io/serializer/GoraMapper.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...ache/gora/mapreduce/GoraOutputFormat.java → .../gora/io/serializer/GoraOutputFormat.java b/...ache/gora/mapreduce/GoraOutputFormat.java → .../gora/io/serializer/GoraOutputFormat.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...che/gora/mapreduce/GoraRecordCounter.java → ...gora/io/serializer/GoraRecordCounter.java b/...che/gora/mapreduce/GoraRecordCounter.java → ...gora/io/serializer/GoraRecordCounter.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 public class GoraRecordCounter {
   /**

diff --git a/...ache/gora/mapreduce/GoraRecordReader.java → .../gora/io/serializer/GoraRecordReader.java b/...ache/gora/mapreduce/GoraRecordReader.java → .../gora/io/serializer/GoraRecordReader.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...ache/gora/mapreduce/GoraRecordWriter.java → .../gora/io/serializer/GoraRecordWriter.java b/...ache/gora/mapreduce/GoraRecordWriter.java → .../gora/io/serializer/GoraRecordWriter.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...rg/apache/gora/mapreduce/GoraReducer.java → ...pache/gora/io/serializer/GoraReducer.java b/...rg/apache/gora/mapreduce/GoraReducer.java → ...pache/gora/io/serializer/GoraReducer.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import org.apache.gora.persistency.Persistent;
 import org.apache.gora.store.DataStore;

diff --git a/...e/gora/mapreduce/NullOutputCommitter.java → ...ra/io/serializer/NullOutputCommitter.java b/...e/gora/mapreduce/NullOutputCommitter.java → ...ra/io/serializer/NullOutputCommitter.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...ora/mapreduce/PersistentDeserializer.java → ...io/serializer/PersistentDeserializer.java b/...ora/mapreduce/PersistentDeserializer.java → ...io/serializer/PersistentDeserializer.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.io.InputStream;

diff --git a/...ra/mapreduce/PersistentSerialization.java → ...o/serializer/PersistentSerialization.java b/...ra/mapreduce/PersistentSerialization.java → ...o/serializer/PersistentSerialization.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import org.apache.gora.persistency.impl.PersistentBase;
 import org.apache.hadoop.io.serializer.Deserializer;

diff --git a/.../gora/mapreduce/PersistentSerializer.java → ...a/io/serializer/PersistentSerializer.java b/.../gora/mapreduce/PersistentSerializer.java → ...a/io/serializer/PersistentSerializer.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.io.OutputStream;

diff --git a/...ache/gora/mapreduce/StringComparator.java → .../gora/io/serializer/StringComparator.java b/...ache/gora/mapreduce/StringComparator.java → .../gora/io/serializer/StringComparator.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import org.apache.hadoop.io.RawComparator;
 import org.apache.hadoop.io.Text;

diff --git a/...e/gora/mapreduce/StringSerialization.java → ...ra/io/serializer/StringSerialization.java b/...e/gora/mapreduce/StringSerialization.java → ...ra/io/serializer/StringSerialization.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;

diff --git a/...g/apache/gora/mapreduce/package-info.java → ...ache/gora/io/serializer/package-info.java b/...g/apache/gora/mapreduce/package-info.java → ...ache/gora/io/serializer/package-info.java
@@ -17,4 +17,4 @@
 /**
  * MapReduce related utilities for Gora.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
diff --git a/gora-core/src/main/java/org/apache/gora/spark/GoraSparkEngine.java b/gora-core/src/main/java/org/apache/gora/spark/GoraSparkEngine.java
@@ -19,9 +19,9 @@
 
 import java.io.IOException;
 
-import org.apache.gora.mapreduce.GoraInputFormat;
-import org.apache.gora.mapreduce.GoraMapReduceUtils;
-import org.apache.gora.mapreduce.GoraOutputFormat;
+import org.apache.gora.io.serializer.GoraInputFormat;
+import org.apache.gora.io.serializer.GoraMapReduceUtils;
+import org.apache.gora.io.serializer.GoraOutputFormat;
 import org.apache.gora.persistency.Persistent;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.util.IOUtils;

diff --git a/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java b/gora-core/src/main/java/org/apache/gora/store/impl/FileBackedDataStoreBase.java
@@ -28,7 +28,7 @@
 import java.util.Properties;
 
 import org.apache.gora.avro.store.AvroStore;
-import org.apache.gora.mapreduce.GoraMapReduceUtils;
+import org.apache.gora.io.serializer.GoraMapReduceUtils;
 import org.apache.gora.persistency.impl.PersistentBase;
 import org.apache.gora.query.PartitionQuery;
 import org.apache.gora.query.Query;

diff --git a/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java b/gora-core/src/test/java/org/apache/gora/avro/mapreduce/TestDataFileAvroStoreMapReduce.java
@@ -24,7 +24,7 @@
 
 import org.apache.gora.avro.store.DataFileAvroStore;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.DataStoreMapReduceTestBase;
+import org.apache.gora.io.serializer.DataStoreMapReduceTestBase;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;
 

diff --git a/...mapreduce/DataStoreMapReduceTestBase.java → ...erializer/DataStoreMapReduceTestBase.java b/...mapreduce/DataStoreMapReduceTestBase.java → ...erializer/DataStoreMapReduceTestBase.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 

diff --git a/...he/gora/mapreduce/MapReduceTestUtils.java → ...ora/io/serializer/MapReduceTestUtils.java b/...he/gora/mapreduce/MapReduceTestUtils.java → ...ora/io/serializer/MapReduceTestUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.nio.ByteBuffer;
 import java.nio.charset.Charset;

diff --git a/...e/gora/mapreduce/TestGoraInputFormat.java → ...ra/io/serializer/TestGoraInputFormat.java b/...e/gora/mapreduce/TestGoraInputFormat.java → ...ra/io/serializer/TestGoraInputFormat.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.util.Arrays;

diff --git a/...he/gora/mapreduce/TestGoraInputSplit.java → ...ora/io/serializer/TestGoraInputSplit.java b/...he/gora/mapreduce/TestGoraInputSplit.java → ...ora/io/serializer/TestGoraInputSplit.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.io.IOException;
 import java.util.List;

diff --git a/...apreduce/TestPersistentSerialization.java → ...rializer/TestPersistentSerialization.java b/...apreduce/TestPersistentSerialization.java → ...rializer/TestPersistentSerialization.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
 
 import java.util.ArrayList;
 import java.util.HashMap;

diff --git a/...g/apache/gora/mapreduce/package-info.java → ...ache/gora/io/serializer/package-info.java b/...g/apache/gora/mapreduce/package-info.java → ...ache/gora/io/serializer/package-info.java
@@ -17,4 +17,4 @@
 /**
  * This package contains test cases releated mapreduce.
  */
-package org.apache.gora.mapreduce;
+package org.apache.gora.io.serializer;
diff --git a/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java b/gora-core/src/test/java/org/apache/gora/util/TestIOUtils.java
@@ -29,9 +29,8 @@
 
 import org.apache.avro.util.ByteBufferInputStream;
 import org.apache.avro.util.ByteBufferOutputStream;
-import org.apache.gora.mapreduce.GoraMapReduceUtils;
+import org.apache.gora.io.serializer.GoraMapReduceUtils;
 import org.apache.gora.persistency.impl.PersistentBase;
-import org.apache.gora.util.IOUtils;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.DataInputBuffer;
 import org.apache.hadoop.io.DataOutputBuffer;

diff --git a/...rc/test/java/org/apache/gora/elasticsearch/mapreduce/ElasticsearchStoreMapReduceTest.java b/...rc/test/java/org/apache/gora/elasticsearch/mapreduce/ElasticsearchStoreMapReduceTest.java
@@ -18,8 +18,8 @@
 
 import org.apache.gora.elasticsearch.GoraElasticsearchTestDriver;
 import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.mapreduce.DataStoreMapReduceTestBase;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.DataStoreMapReduceTestBase;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;
 import org.junit.After;

diff --git a/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java b/gora-goraci/src/main/java/org/apache/gora/goraci/Verify.java
@@ -31,7 +31,7 @@
 import org.apache.commons.cli.HelpFormatter;
 import org.apache.commons.cli.Options;
 import org.apache.commons.cli.ParseException;
-import org.apache.gora.mapreduce.GoraMapper;
+import org.apache.gora.io.serializer.GoraMapper;
 import org.apache.gora.query.Query;
 import org.apache.gora.query.Result;
 import org.apache.gora.store.DataStore;

diff --git a/gora-hbase/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreCountQuery.java b/gora-hbase/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreCountQuery.java
@@ -21,7 +21,7 @@
 import org.apache.gora.examples.generated.WebPage;
 import org.apache.gora.hbase.store.HBaseStore;
 import org.apache.gora.hbase.util.HBaseClusterSingleton;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 
 import org.junit.After;

diff --git a/...e/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreMapReduceSerialization.java b/...e/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreMapReduceSerialization.java
@@ -21,7 +21,7 @@
 import org.apache.gora.examples.generated.WebPage;
 import org.apache.gora.hbase.store.HBaseStore;
 import org.apache.gora.hbase.util.HBaseClusterSingleton;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 import org.junit.After;
 import org.junit.Before;

diff --git a/gora-hbase/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreWordCount.java b/gora-hbase/src/test/java/org/apache/gora/hbase/mapreduce/TestHBaseStoreWordCount.java
@@ -22,7 +22,7 @@
 import org.apache.gora.examples.generated.WebPage;
 import org.apache.gora.hbase.store.HBaseStore;
 import org.apache.gora.hbase.util.HBaseClusterSingleton;
-import org.apache.gora.mapreduce.MapReduceTestUtils;
+import org.apache.gora.io.serializer.MapReduceTestUtils;
 import org.apache.gora.store.DataStoreFactory;
 
 import org.junit.After;

diff --git a/gora-ignite/src/test/java/org/apache/gora/ignite/mapreduce/IgniteStoreMapReduceTest.java b/gora-ignite/src/test/java/org/apache/gora/ignite/mapreduce/IgniteStoreMapReduceTest.java
@@ -20,7 +20,7 @@
 import java.io.IOException;
 import org.apache.gora.examples.generated.WebPage;
 import org.apache.gora.ignite.GoraIgniteTestDriver;
-import org.apache.gora.mapreduce.DataStoreMapReduceTestBase;
+import org.apache.gora.io.serializer.DataStoreMapReduceTestBase;
 import org.apache.gora.store.DataStore;
 import org.apache.gora.store.DataStoreFactory;
 import org.junit.After;

diff --git a/gora-infinispan/src/main/java/org/apache/gora/infinispan/store/InfinispanStore.java b/gora-infinispan/src/main/java/org/apache/gora/infinispan/store/InfinispanStore.java
@@ -17,8 +17,8 @@
  */
 package org.apache.gora.infinispan.store;
 
-import static org.apache.gora.mapreduce.GoraRecordReader.BUFFER_LIMIT_READ_NAME;
-import static org.apache.gora.mapreduce.GoraRecordReader.BUFFER_LIMIT_READ_VALUE;
+import static org.apache.gora.io.serializer.GoraRecordReader.BUFFER_LIMIT_READ_NAME;
+import static org.apache.gora.io.serializer.GoraRecordReader.BUFFER_LIMIT_READ_VALUE;
 
 import java.io.IOException;
 import java.util.ArrayList;

diff --git a/...span/src/test/java/org/apache/gora/infinispan/mapreduce/InfinispanStoreMapReduceTest.java b/...span/src/test/java/org/apache/gora/infinispan/mapreduce/InfinispanStoreMapReduceTest.java
@@ -20,7 +20,7 @@
 import org.apache.gora.examples.generated.WebPage;
 import org.apache.gora.infinispan.GoraInfinispanTestDriver;
 import org.apache.gora.infinispan.store.InfinispanStore;
-import org.apache.gora.mapreduce.DataStoreMapReduceTestBase;
+import org.apache.gora.io.serializer.DataStoreMapReduceTestBase;
 import org.apache.gora.store.DataStore;
 import org.apache.hadoop.conf.Configuration;
 import org.junit.After;