You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mnemonic.apache.org by ga...@apache.org on 2017/03/07 20:16:33 UTC
incubator-mnemonic git commit: MNEMONIC-214: Make
MneDurableInputSession rewind-able
Repository: incubator-mnemonic
Updated Branches:
refs/heads/master be32da856 -> 7e1979174
MNEMONIC-214: Make MneDurableInputSession rewind-able
Project: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/commit/7e197917
Tree: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/tree/7e197917
Diff: http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/diff/7e197917
Branch: refs/heads/master
Commit: 7e19791746867a66b006dd1a86c40fa18edbf4ef
Parents: be32da8
Author: paley <pa...@gmail.com>
Authored: Mon Mar 6 15:03:14 2017 -0800
Committer: paley <pa...@gmail.com>
Committed: Tue Mar 7 11:27:46 2017 -0800
----------------------------------------------------------------------
.../apache/mnemonic/hadoop/MneDurableInputSession.java | 13 +++++++------
1 file changed, 7 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-mnemonic/blob/7e197917/mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java
----------------------------------------------------------------------
diff --git a/mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java b/mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java
index 81c1373..c473229 100644
--- a/mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java
+++ b/mnemonic-hadoop/mnemonic-hadoop-mapreduce/src/main/java/org/apache/mnemonic/hadoop/MneDurableInputSession.java
@@ -42,7 +42,7 @@ public class MneDurableInputSession<V>
protected long m_handler;
protected NonVolatileMemAllocator m_act;
- protected Iterator<V> m_iter;
+
public MneDurableInputSession(TaskAttemptContext taskAttemptContext) {
setTaskAttemptContext(taskAttemptContext);
@@ -75,18 +75,19 @@ public class MneDurableInputSession<V>
@Override
public void initialize(Path path) {
- DurableSinglyLinkedList<V> dsllist;
m_act = new NonVolatileMemAllocator(Utils.getNonVolatileMemoryAllocatorService(getServiceName()), 1024000L,
path.toString(), true);
m_handler = m_act.getHandler(getSlotKeyId());
- dsllist = DurableSinglyLinkedListFactory.restore(m_act, getEntityFactoryProxies(), getDurableTypes(), m_handler,
- false);
- m_iter = dsllist.iterator();
}
@Override
public Iterator<V> iterator() {
- return m_iter;
+ Iterator<V> iter;
+ DurableSinglyLinkedList<V> dsllist;
+ dsllist = DurableSinglyLinkedListFactory.restore(m_act, getEntityFactoryProxies(), getDurableTypes(), m_handler,
+ false);
+ iter = dsllist.iterator();
+ return iter;
}
@Override