From 24ec69c626426235b35de2c3333945701e422a92 Mon Sep 17 00:00:00 2001 From: John Zhao Date: Mon, 25 Apr 2016 11:06:18 -0700 Subject: [PATCH] KYLIN-1620 support read from metadata replica regions --- .../main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java index 914c8e1..75bc16f 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseResourceStore.java @@ -134,6 +134,7 @@ public class HBaseResourceStore extends ResourceStore { Table table = getConnection().getTable(TableName.valueOf(getAllInOneTableName())); Scan scan = new Scan(startRow, endRow); + scan.setConsistency(Consistency.TIMELINE); scan.setFilter(new KeyOnlyFilter()); try { ResultScanner scanner = table.getScanner(scan); @@ -169,6 +170,7 @@ public class HBaseResourceStore extends ResourceStore { byte[] endRow = plusZero(Bytes.toBytes(rangeEnd)); Scan scan = new Scan(startRow, endRow); + scan.setConsistency(Consistency.TIMELINE); scan.addColumn(B_FAMILY, B_COLUMN_TS); scan.addColumn(B_FAMILY, B_COLUMN); FilterList filterList = generateTimeFilterList(timeStartInMillis, timeEndInMillis); @@ -311,6 +313,7 @@ public class HBaseResourceStore extends ResourceStore { byte[] rowkey = Bytes.toBytes(path); Get get = new Get(rowkey); + get.setConsistency(Consistency.TIMELINE); if (!fetchContent && !fetchTimestamp) { get.setCheckExistenceOnly(true); -- 2.6.4 (Apple Git-63)