Merge pull request apache#16 from jackylk/reformat

reformating
jackylk · Nov 6, 2014 · adecb45 · adecb45
2 parents 18c96f0 + 0306443
commit adecb45
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/sql/hbase/src/main/scala/org/apache/spark/sql/hbase/execution/hbaseOperators.scala b/sql/hbase/src/main/scala/org/apache/spark/sql/hbase/execution/hbaseOperators.scala
@@ -168,20 +168,20 @@ case class BulkLoadIntoTable(path: String, relation: HBaseRelation, isLocal: Boo
       var preKV: (ImmutableBytesWritableWrapper, PutWrapper) = null
       var nowKV: (ImmutableBytesWritableWrapper, PutWrapper) = null
       val ret = new ArrayBuffer[(ImmutableBytesWritable, KeyValue)]()
-      if(iter.hasNext) {
+      if (iter.hasNext) {
         preKV = iter.next()
         var cellsIter = preKV._2.toPut().getFamilyCellMap.values().iterator()
-        while(cellsIter.hasNext()) {
+        while (cellsIter.hasNext()) {
           cellsIter.next().foreach { cell =>
             val kv = KeyValueUtil.ensureKeyValue(cell)
             map.add(kv)
           }
         }
-        while(iter.hasNext) {
+        while (iter.hasNext) {
           nowKV = iter.next()
-          if(0 == (nowKV._1 compareTo preKV._1)) {
+          if (0 == (nowKV._1 compareTo preKV._1)) {
             cellsIter = nowKV._2.toPut().getFamilyCellMap.values().iterator()
-            while(cellsIter.hasNext()) {
+            while (cellsIter.hasNext()) {
               cellsIter.next().foreach { cell =>
                 val kv = KeyValueUtil.ensureKeyValue(cell)
                 map.add(kv)
@@ -192,7 +192,7 @@ case class BulkLoadIntoTable(path: String, relation: HBaseRelation, isLocal: Boo
             preKV = nowKV
             map.clear()
             cellsIter = preKV._2.toPut().getFamilyCellMap.values().iterator()
-            while(cellsIter.hasNext()) {
+            while (cellsIter.hasNext()) {
               cellsIter.next().foreach { cell =>
                 val kv = KeyValueUtil.ensureKeyValue(cell)
                 map.add(kv)