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 <[email protected]> Authored: Tue Dec 29 15:19:12 2015 +0530 Committer: yogidevendra <[email protected]> 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. *
