You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2012/12/15 00:54:55 UTC
svn commit: r1422158 - in /hbase/trunk/hbase-server/src:
main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java
test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java
test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
Author: apurtell
Date: Fri Dec 14 23:54:54 2012
New Revision: 1422158
URL: http://svn.apache.org/viewvc?rev=1422158&view=rev
Log:
HBASE-7359. [REST] 'accessToken' in RemoteHTable is vestigial
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java?rev=1422158&r1=1422157&r2=1422158&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/RemoteHTable.java Fri Dec 14 23:54:54 2012
@@ -78,7 +78,6 @@ public class RemoteHTable implements HTa
final Client client;
final Configuration conf;
final byte[] name;
- final String accessToken;
final int maxRetries;
final long sleepTime;
@@ -87,10 +86,6 @@ public class RemoteHTable implements HTa
final long startTime, final long endTime, final int maxVersions) {
StringBuffer sb = new StringBuffer();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append(Bytes.toStringBinary(row));
@@ -208,17 +203,17 @@ public class RemoteHTable implements HTa
* @param name
*/
public RemoteHTable(Client client, String name) {
- this(client, HBaseConfiguration.create(), Bytes.toBytes(name), null);
+ this(client, HBaseConfiguration.create(), Bytes.toBytes(name));
}
/**
* Constructor
* @param client
+ * @param conf
* @param name
- * @param accessToken
*/
- public RemoteHTable(Client client, String name, String accessToken) {
- this(client, HBaseConfiguration.create(), Bytes.toBytes(name), accessToken);
+ public RemoteHTable(Client client, Configuration conf, String name) {
+ this(client, conf, Bytes.toBytes(name));
}
/**
@@ -226,23 +221,11 @@ public class RemoteHTable implements HTa
* @param client
* @param conf
* @param name
- * @param accessToken
- */
- public RemoteHTable(Client client, Configuration conf, String name,
- String accessToken) {
- this(client, conf, Bytes.toBytes(name), accessToken);
- }
-
- /**
- * Constructor
- * @param conf
*/
- public RemoteHTable(Client client, Configuration conf, byte[] name,
- String accessToken) {
+ public RemoteHTable(Client client, Configuration conf, byte[] name) {
this.client = client;
this.conf = conf;
this.name = name;
- this.accessToken = accessToken;
this.maxRetries = conf.getInt("hbase.rest.client.max.retries", 10);
this.sleepTime = conf.getLong("hbase.rest.client.sleep", 1000);
}
@@ -258,10 +241,6 @@ public class RemoteHTable implements HTa
public HTableDescriptor getTableDescriptor() throws IOException {
StringBuilder sb = new StringBuilder();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append("schema");
@@ -371,10 +350,6 @@ public class RemoteHTable implements HTa
CellSetModel model = buildModelFromPut(put);
StringBuilder sb = new StringBuilder();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append(Bytes.toStringBinary(put.getRow()));
@@ -429,10 +404,6 @@ public class RemoteHTable implements HTa
// build path for multiput
StringBuilder sb = new StringBuilder();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append("/$multiput"); // can be any nonexistent row
for (int i = 0; i < maxRetries; i++) {
@@ -498,10 +469,6 @@ public class RemoteHTable implements HTa
}
StringBuffer sb = new StringBuffer();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append("scanner");
@@ -656,10 +623,6 @@ public class RemoteHTable implements HTa
CellSetModel model = buildModelFromPut(put);
StringBuilder sb = new StringBuilder();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append(Bytes.toStringBinary(put.getRow()));
@@ -695,10 +658,6 @@ public class RemoteHTable implements HTa
CellSetModel model = buildModelFromPut(put);
StringBuilder sb = new StringBuilder();
sb.append('/');
- if (accessToken != null) {
- sb.append(accessToken);
- sb.append('/');
- }
sb.append(Bytes.toStringBinary(name));
sb.append('/');
sb.append(Bytes.toStringBinary(row));
Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java?rev=1422158&r1=1422157&r2=1422158&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/PerformanceEvaluation.java Fri Dec 14 23:54:54 2012
@@ -113,7 +113,6 @@ public class PerformanceEvaluation {
protected Map<String, CmdDescriptor> commands = new TreeMap<String, CmdDescriptor>();
protected static Cluster cluster = new Cluster();
- protected static String accessToken = null;
volatile Configuration conf;
private boolean nomapred = false;
@@ -448,8 +447,7 @@ public class PerformanceEvaluation {
*/
private boolean checkTable() throws IOException {
HTableDescriptor tableDescriptor = getTableDescriptor();
- RemoteAdmin admin =
- new RemoteAdmin(new Client(cluster), conf, accessToken);
+ RemoteAdmin admin = new RemoteAdmin(new Client(cluster), conf);
if (!admin.isTableAvailable(tableDescriptor.getName())) {
admin.createTable(tableDescriptor);
return true;
@@ -713,8 +711,7 @@ public class PerformanceEvaluation {
}
void testSetup() throws IOException {
- this.table = new RemoteHTable(new Client(cluster), conf, tableName,
- accessToken);
+ this.table = new RemoteHTable(new Client(cluster), conf, tableName);
}
void testTakedown() throws IOException {
@@ -1132,7 +1129,6 @@ public class PerformanceEvaluation {
System.err.println();
System.err.println("Options:");
System.err.println(" host String. Specify Stargate endpoint.");
- System.err.println(" token String. API access token.");
System.err.println(" rows Integer. Rows each client runs. Default: One million");
System.err.println(" rowsPerPut Integer. Rows each Stargate (multi)Put. Default: 100");
System.err.println(" nomapred (Flag) Run multiple clients using threads " +
@@ -1207,12 +1203,6 @@ public class PerformanceEvaluation {
continue;
}
- final String token = "--token=";
- if (cmd.startsWith(token)) {
- accessToken = cmd.substring(token.length());
- continue;
- }
-
Class<? extends Test> cmdClass = determineCommandClass(cmd);
if (cmdClass != null) {
getArgs(i + 1, args);
Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java?rev=1422158&r1=1422157&r2=1422158&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/rest/client/TestRemoteTable.java Fri Dec 14 23:54:54 2012
@@ -96,7 +96,7 @@ public class TestRemoteTable {
remoteTable = new RemoteHTable(
new Client(new Cluster().add("localhost",
REST_TEST_UTIL.getServletPort())),
- TEST_UTIL.getConfiguration(), TABLE, null);
+ TEST_UTIL.getConfiguration(), TABLE);
}
@AfterClass