You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by ey...@apache.org on 2011/08/18 06:48:25 UTC
svn commit: r1159032 - in /incubator/chukwa/trunk: CHANGES.txt
src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
Author: eyang
Date: Thu Aug 18 04:48:25 2011
New Revision: 1159032
URL: http://svn.apache.org/viewvc?rev=1159032&view=rev
Log:
CHUKWA-596. Updated schema retrieve REST API to use end time for scanning columns. (Eric Yang)
Modified:
incubator/chukwa/trunk/CHANGES.txt
incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
Modified: incubator/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/CHANGES.txt?rev=1159032&r1=1159031&r2=1159032&view=diff
==============================================================================
--- incubator/chukwa/trunk/CHANGES.txt (original)
+++ incubator/chukwa/trunk/CHANGES.txt Thu Aug 18 04:48:25 2011
@@ -32,6 +32,8 @@ Trunk (unreleased changes)
IMPROVEMENTS
+ CHUKWA-596. Updated schema retrieve REST API to use end time for scanning columns. (Eric Yang)
+
CHUKWA-586. Updated HBase dependency to HBase 0.90.3. (Eric Yang)
CHUKWA-569. Added temperory fix for load meta data faster for graph_explorer.jsp. (Eric Yang)
@@ -88,7 +90,9 @@ Trunk (unreleased changes)
BUG FIXES
- CHUKWA_595. Fixed buffering time calculation for Agent to send data to Collector. (Eric Yang)
+ CHUKWA-38. Download Hadoop jar files from ivy. (Eric Yang)
+
+ CHUKWA-595. Fixed buffering time calculation for Agent to send data to Collector. (Eric Yang)
CHUKWA-594. Fix row key matching in HICC web interface. (Preetam Patil via Eric Yang)
Modified: incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java?rev=1159032&r1=1159031&r2=1159032&view=diff
==============================================================================
--- incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java (original)
+++ incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datastore/ChukwaHBaseStore.java Thu Aug 18 04:48:25 2011
@@ -136,12 +136,12 @@ public class ChukwaHBaseStore {
HTableInterface table = pool.getTable(tableName);
Scan scan = new Scan();
if(!fullScan) {
- // Take sample columns of the starting time.
+ // Take sample columns of the recent time.
StringBuilder temp = new StringBuilder();
- temp.append(startTime);
+ temp.append(endTime-300000L);
scan.setStartRow(temp.toString().getBytes());
temp.setLength(0);
- temp.append(startTime+60000L);
+ temp.append(endTime);
scan.setStopRow(temp.toString().getBytes());
} else {
StringBuilder temp = new StringBuilder();
@@ -176,11 +176,12 @@ public class ChukwaHBaseStore {
Scan scan = new Scan();
scan.addColumn(family.getBytes(), qualifier.getBytes());
if(!fullScan) {
+ // Take sample columns of the recent time.
StringBuilder temp = new StringBuilder();
- temp.append(startTime);
+ temp.append(endTime-300000L);
scan.setStartRow(temp.toString().getBytes());
temp.setLength(0);
- temp.append(startTime+60000L);
+ temp.append(endTime);
scan.setStopRow(temp.toString().getBytes());
} else {
StringBuilder temp = new StringBuilder();