[Bigdata-commit] SF.net SVN: bigdata:[7554] branches/BIGDATA_RELEASE_1_3_0/bigdata/src/java/ com/bigdata/bop/engine/ChunkedRunningQuery.java

[<tho...@us...>]

Revision: 7554
          http://bigdata.svn.sourceforge.net/bigdata/?rev=7554&view=rev
Author:   thompsonbry
Date:     2013-11-15 17:01:58 +0000 (Fri, 15 Nov 2013)
Log Message:
-----------
@Override annotations

Modified Paths:
--------------
    branches/BIGDATA_RELEASE_1_3_0/bigdata/src/java/com/bigdata/bop/engine/ChunkedRunningQuery.java

Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata/src/java/com/bigdata/bop/engine/ChunkedRunningQuery.java
===================================================================
--- branches/BIGDATA_RELEASE_1_3_0/bigdata/src/java/com/bigdata/bop/engine/ChunkedRunningQuery.java	2013-11-15 17:00:14 UTC (rev 7553)
+++ branches/BIGDATA_RELEASE_1_3_0/bigdata/src/java/com/bigdata/bop/engine/ChunkedRunningQuery.java	2013-11-15 17:01:58 UTC (rev 7554)
@@ -314,6 +314,7 @@
      * available and no task is currently running, then drain the work queue and
      * submit a task to consume that work.
      */
+    @Override
     protected void consumeChunk() {
         lock.lock();
         try {
@@ -722,6 +723,7 @@
 
         }
 
+        @Override
         public void run() {
 
             try {
@@ -791,6 +793,7 @@
             
         }
         
+        @Override
         public void run() {
 
             final QueryEngine queryEngine = getQueryEngine();
@@ -1015,6 +1018,7 @@
         /**
          * A human readable representation of the {@link ChunkTask}'s state.
          */
+        @Override
         public String toString() {
             return "ChunkTask" + //
                     "{query=" + getQueryId() + //
@@ -1269,6 +1273,7 @@
         /**
          * Evaluate the {@link IChunkMessage}.
          */
+        @Override
         public Void call() throws Exception {
             if (log.isDebugEnabled())
                 log.debug("Running chunk: " + this);
@@ -1355,6 +1360,7 @@
 
         }
 
+        @Override
         public void add(final E e) {
             super.add(e);
             if (SolutionsLog.solutionsLog.isInfoEnabled()) {
@@ -1609,7 +1615,8 @@
             chunkSize = 0;
             smallChunks = null;
         }
-        
+
+        @Override
         synchronized // Note: possible side-effect on internal buffer.
         public long flush() {
             if (open)
@@ -1618,46 +1625,55 @@
 //          return sink.flush();
       }
 
+        @Override
         public void abort(final Throwable cause) {
             open = false;
             q.halt(cause);
 //            sink.abort(cause);
         }
 
+        @Override
         public void close() {
 //            sink.close();
             open = false;
         }
 
+        @Override
         public Future getFuture() {
 //            return sink.getFuture();
             return null;
         }
 
+        @Override
         public boolean isEmpty() {
             return true;
 //            return sink.isEmpty();
         }
 
+        @Override
         public boolean isOpen() {
             return open && !q.isDone();
 //            return sink.isOpen();
         }
 
+        @Override
         public IAsynchronousIterator<IBindingSet[]> iterator() {
             throw new UnsupportedOperationException();
 //            return sink.iterator();
         }
 
+        @Override
         public void reset() {
 //            sink.reset();
         }
 
+        @Override
         public void setFuture(Future future) {
             throw new UnsupportedOperationException();
 //            sink.setFuture(future);
         }
 
+        @Override
         public int size() {
             return 0;
 //            return sink.size();
@@ -1702,6 +1718,7 @@
 
         }
 
+        @Override
         public void run() {
 			try {
 				if (q.isController()) {

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.