Author: afuchs
Date: Mon Apr 16 15:51:01 2012
New Revision: 1326662

URL: http://svn.apache.org/viewvc?rev=1326662&view=rev
Log:
ACCUMULO-533 merge from 1.4 branch

Modified:
    accumulo/trunk/   (props changed)
    accumulo/trunk/core/   (props changed)
    
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/iterators/system/SynchronizedIterator.java

Propchange: accumulo/trunk/
------------------------------------------------------------------------------
  Merged /accumulo/branches/1.4/src:r1325932-1326654
  Merged /accumulo/branches/1.4:r1325931-1326654

Propchange: accumulo/trunk/core/
------------------------------------------------------------------------------
  Merged /accumulo/branches/1.4/src/core:r1325932-1326654

Modified: 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/iterators/system/SynchronizedIterator.java
URL: 
http://svn.apache.org/viewvc/accumulo/trunk/core/src/main/java/org/apache/accumulo/core/iterators/system/SynchronizedIterator.java?rev=1326662&r1=1326661&r2=1326662&view=diff
==============================================================================
--- 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/iterators/system/SynchronizedIterator.java
 (original)
+++ 
accumulo/trunk/core/src/main/java/org/apache/accumulo/core/iterators/system/SynchronizedIterator.java
 Mon Apr 16 15:51:01 2012
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.apache.accumulo.core.iterators.system;
 
 import java.io.IOException;
@@ -14,8 +30,8 @@ import org.apache.hadoop.io.WritableComp
 /***
  * SynchronizedIterator: wrap a SortedKeyValueIterator so that all of its 
methods are synchronized
  */
-public class SynchronizedIterator <K extends WritableComparable<?>,V extends 
Writable> implements SortedKeyValueIterator<K,V> {
-
+public class SynchronizedIterator<K extends WritableComparable<?>,V extends 
Writable> implements SortedKeyValueIterator<K,V> {
+  
   private SortedKeyValueIterator<K,V> source = null;
   
   @Override
@@ -23,41 +39,40 @@ public class SynchronizedIterator <K ext
     this.source = source;
     source.init(source, options, env);
   }
-
+  
   @Override
   public synchronized boolean hasTop() {
     return source.hasTop();
   }
-
+  
   @Override
   public synchronized void next() throws IOException {
     source.next();
   }
-
+  
   @Override
   public synchronized void seek(Range range, Collection<ByteSequence> 
columnFamilies, boolean inclusive) throws IOException {
     source.seek(range, columnFamilies, inclusive);
   }
-
+  
   @Override
   public synchronized K getTopKey() {
     return source.getTopKey();
   }
-
+  
   @Override
   public synchronized V getTopValue() {
     return source.getTopValue();
   }
-
+  
   @Override
   public synchronized SortedKeyValueIterator<K,V> deepCopy(IteratorEnvironment 
env) {
     return new SynchronizedIterator<K,V>(source.deepCopy(env));
   }
   
-  public SynchronizedIterator(){}
+  public SynchronizedIterator() {}
   
-  public SynchronizedIterator(SortedKeyValueIterator<K,V> source)
-  {
+  public SynchronizedIterator(SortedKeyValueIterator<K,V> source) {
     this.source = source;
   }
 }


Reply via email to