@@ -168,20 +168,20 @@ case class BulkLoadIntoTable(path: String, relation: HBaseRelation, isLocal: Boo
168168 var preKV : (ImmutableBytesWritableWrapper , PutWrapper ) = null
169169 var nowKV : (ImmutableBytesWritableWrapper , PutWrapper ) = null
170170 val ret = new ArrayBuffer [(ImmutableBytesWritable , KeyValue )]()
171- if (iter.hasNext) {
171+ if (iter.hasNext) {
172172 preKV = iter.next()
173173 var cellsIter = preKV._2.toPut().getFamilyCellMap.values().iterator()
174- while (cellsIter.hasNext()) {
174+ while (cellsIter.hasNext()) {
175175 cellsIter.next().foreach { cell =>
176176 val kv = KeyValueUtil .ensureKeyValue(cell)
177177 map.add(kv)
178178 }
179179 }
180- while (iter.hasNext) {
180+ while (iter.hasNext) {
181181 nowKV = iter.next()
182- if (0 == (nowKV._1 compareTo preKV._1)) {
182+ if (0 == (nowKV._1 compareTo preKV._1)) {
183183 cellsIter = nowKV._2.toPut().getFamilyCellMap.values().iterator()
184- while (cellsIter.hasNext()) {
184+ while (cellsIter.hasNext()) {
185185 cellsIter.next().foreach { cell =>
186186 val kv = KeyValueUtil .ensureKeyValue(cell)
187187 map.add(kv)
@@ -192,7 +192,7 @@ case class BulkLoadIntoTable(path: String, relation: HBaseRelation, isLocal: Boo
192192 preKV = nowKV
193193 map.clear()
194194 cellsIter = preKV._2.toPut().getFamilyCellMap.values().iterator()
195- while (cellsIter.hasNext()) {
195+ while (cellsIter.hasNext()) {
196196 cellsIter.next().foreach { cell =>
197197 val kv = KeyValueUtil .ensureKeyValue(cell)
198198 map.add(kv)
0 commit comments