Commit 7016288a5a919fecfb30b6ed8d039a2a660d1551

Authored by joel ago
1 parent 858cabbac5
Exists in master

initial setting

Showing 1 changed file with 6 additions and 1 deletions Side-by-side Diff

app/com/piki_ds/utils/hbase/PikiHbase.scala View file @ 7016288
... ... @@ -69,6 +69,8 @@
69 69 val scan = new Scan
70 70 scan.setStartRow(startrow)
71 71 scan.setStopRow(stoprow)
  72 + scan.setMaxVersions(2)
  73 + //scan.setTimeRange(1438589717268L, 1438589717321L)
72 74 table.getScanner(scan)
73 75 } catch {
74 76 case e: Exception => {
... ... @@ -220,7 +222,10 @@
220 222 val end = "31-07-2015 23:59:59"
221 223  
222 224 val uuid = "VqA720"
223   - val scanner = scan(table, s"$uuid,${Base62.encode(sdf.parse(start).getTime())}".getBytes(), s"$uuid,${Base62.encode(sdf.parse(end).getTime())}".getBytes)
  225 + //uuid,timestamp
  226 + //val scanner = scan(table, s"$uuid,${Base62.encode(sdf.parse(start).getTime())}".getBytes(), s"$uuid,${Base62.encode(sdf.parse(end).getTime())}".getBytes)
  227 + //uuid,cid
  228 + val scanner = scanWithPrefixFilter(table, uuid)
224 229 val iterator = scanner.iterator()
225 230  
226 231 while (iterator.hasNext) {