MNEMONIC-224: Create a Mnemonic-sessions module

MNEMONIC-223: Abstract MneSessions from Mnemonic-hadoop module

Author: Wang, Gang(Gary)

build-tools/source-assembly.xml

@@ -35,6 +35,7 @@
       <includes>
         <include>org.apache.mnemonic:mnemonic-core</include>
         <include>org.apache.mnemonic:mnemonic-collections</include>
+        <include>org.apache.mnemonic:mnemonic-sessions</include>
         <include>org.apache.mnemonic:mnemonic-examples</include>
       </includes>
       <sources>

mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java

@@ -18,32 +18,20 @@
 
 package org.apache.mnemonic.hadoop;
 
-import java.util.Iterator;
-
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.mnemonic.ConfigurationException;
 import org.apache.mnemonic.DurableType;
-import org.apache.mnemonic.EntityFactoryProxy;
 import org.apache.mnemonic.NonVolatileMemAllocator;
 import org.apache.mnemonic.Utils;
-import org.apache.mnemonic.collections.DurableSinglyLinkedList;
-import org.apache.mnemonic.collections.DurableSinglyLinkedListFactory;
+import org.apache.mnemonic.sessions.DurableInputSession;
 
 public class MneDurableInputSession<V>
-    implements MneInputSession<V>, MneDurableComputable<NonVolatileMemAllocator> {
+    extends DurableInputSession<V, NonVolatileMemAllocator> {
 
   private TaskAttemptContext taskAttemptContext;
   private Configuration configuration;
-  private String serviceName;
-  private DurableType[] durableTypes;
-  private EntityFactoryProxy[] entityFactoryProxies;
-  private long slotKeyId;
-
-  protected long m_handler;
-  protected NonVolatileMemAllocator m_act;
-
 
   public MneDurableInputSession(TaskAttemptContext taskAttemptContext) {
     this(taskAttemptContext.getConfiguration());
@@ -59,13 +47,12 @@ public void validateConfig() {
       throw new ConfigurationException("The durable type of record parameters does not exist");
     } else {
       if (DurableType.DURABLE == getDurableTypes()[0]
-          && getEntityFactoryProxies().length < 1) { /* T.B.D. BUFFER & CHUNK */
+          && getEntityFactoryProxies().length < 1) {
         throw new ConfigurationException("The durable entity proxy of record parameters does not exist");
       }
     }
   }
 
-  @Override
   public void readConfig(String prefix) {
     Configuration conf = getConfiguration();
     if (conf == null) {
@@ -79,28 +66,12 @@ public void readConfig(String prefix) {
     validateConfig();
   }
 
-  @Override
   public void initialize(Path path) {
     m_act = new NonVolatileMemAllocator(Utils.getNonVolatileMemoryAllocatorService(getServiceName()), 1024000L,
         path.toString(), true);
     m_handler = m_act.getHandler(getSlotKeyId());
   }
 
-  @Override
-  public Iterator<V> iterator() {
-    Iterator<V> iter;
-    DurableSinglyLinkedList<V> dsllist;
-    dsllist = DurableSinglyLinkedListFactory.restore(m_act, getEntityFactoryProxies(), getDurableTypes(), m_handler,
-        false);
-    iter = dsllist.iterator();
-    return iter;
-  }
-
-  @Override
-  public void close() {
-    m_act.close();
-  }
-
   public TaskAttemptContext getTaskAttemptContext() {
     return taskAttemptContext;
   }
@@ -109,48 +80,6 @@ public void setTaskAttemptContext(TaskAttemptContext taskAttemptContext) {
     this.taskAttemptContext = taskAttemptContext;
   }
 
-  public String getServiceName() {
-    return serviceName;
-  }
-
-  public void setServiceName(String serviceName) {
-    this.serviceName = serviceName;
-  }
-
-  public DurableType[] getDurableTypes() {
-    return durableTypes;
-  }
-
-  public void setDurableTypes(DurableType[] durableTypes) {
-    this.durableTypes = durableTypes;
-  }
-
-  public EntityFactoryProxy[] getEntityFactoryProxies() {
-    return entityFactoryProxies;
-  }
-
-  public void setEntityFactoryProxies(EntityFactoryProxy[] entityFactoryProxies) {
-    this.entityFactoryProxies = entityFactoryProxies;
-  }
-
-  public long getSlotKeyId() {
-    return slotKeyId;
-  }
-
-  public void setSlotKeyId(long slotKeyId) {
-    this.slotKeyId = slotKeyId;
-  }
-
-  @Override
-  public NonVolatileMemAllocator getAllocator() {
-    return m_act;
-  }
-
-  @Override
-  public long getHandler() {
-    return m_handler;
-  }
-
   public Configuration getConfiguration() {
     return configuration;
   }