You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 20:12:39 UTC
[22/50] [abbrv] incubator-apex-malhar git commit: APEXMALHAR-1958
Provide access to doneTuple field in AbstractReconciler for derived classes
APEXMALHAR-1958 Provide access to doneTuple field in AbstractReconciler for derived classes
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/ccb712af
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/ccb712af
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/ccb712af
Branch: refs/heads/master
Commit: ccb712afe89caffc0b980379ab66e9bda3a3fd53
Parents: 07959bb
Author: yogidevendra <de...@datatorrent.com>
Authored: Tue Dec 29 15:19:12 2015 +0530
Committer: yogidevendra <de...@datatorrent.com>
Committed: Tue Jan 5 12:54:43 2016 +0530
----------------------------------------------------------------------
.../main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/ccb712af/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
index 7fc39a1..cc549a1 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractReconciler.java
@@ -73,8 +73,8 @@ public abstract class AbstractReconciler<INPUT, QUEUETUPLE> extends BaseOperator
// this stores the mapping from the window to the list of enqueued tuples
private Map<Long, List<QUEUETUPLE>> currentWindowTuples = Maps.newConcurrentMap();
private Queue<Long> currentWindows = Queues.newLinkedBlockingQueue();
- private Queue<QUEUETUPLE> committedTuples = Queues.newLinkedBlockingQueue();
- private transient Queue<QUEUETUPLE> doneTuples = Queues.newLinkedBlockingQueue();
+ protected Queue<QUEUETUPLE> committedTuples = Queues.newLinkedBlockingQueue();
+ protected transient Queue<QUEUETUPLE> doneTuples = Queues.newLinkedBlockingQueue();
private transient Queue<QUEUETUPLE> waitingTuples = Queues.newLinkedBlockingQueue();
private transient volatile boolean execute;
private transient AtomicReference<Throwable> cause;
@@ -185,7 +185,6 @@ public abstract class AbstractReconciler<INPUT, QUEUETUPLE> extends BaseOperator
}
};
}
-
/**
* The implementation class should call this method to enqueue output once input is converted to queue input.
*