What is below is a simple class to read a random set of records from a table. This should be a good start if you are looking for a simple one class test case, that may also be useful for simple stress testing.<\/p>\n
As other example regarding HBase, it assumes you have configured your hbase-site.xml with the location of your HBase database.<\/p>\n
\r\nimport java.util.*;\r\nimport org.apache.hadoop.hbase.client.*;\r\nimport org.apache.hadoop.hbase.util.*;\r\n\r\nclass hbaseStresser implements Runnable {\r\n Thread t;\r\n\r\n public static void main(String args[]) {\r\n try {\r\n\r\n System.out.println(new java.util.Date());\r\n for(int i=1; i <= Integer.parseInt(args[0]); i++){ \/\/pass in the number of threads you want to run\r\n hbaseStresser r = new hbaseStresser();\r\n }\r\n }\r\n catch(Exception e) {\r\n e.printStackTrace();\r\n }\r\n }\r\n\r\n hbaseStresser() {\r\n try {\r\n t = new Thread(this);\r\n t.start();\r\n }\r\n catch (Exception e) {\r\n e.printStackTrace();\r\n }\r\n }\r\n\r\n public void run() {\r\n try {\r\n HTable hTable = new HTable(\"t1\"); \/\/this is your table name\r\n\r\n byte[] rowId = null;\r\n byte[] famA = Bytes.toBytes(\"data\"); \/\/this is your column family\r\n byte[] col1 = Bytes.toBytes(\"xml\"); \/\/this is your on the fly column name in the table\r\n\r\n Random rId = new Random();\r\n for (int j = 1; j < 1000; j++) { \/\/each thread loops 1000 times\r\n int id = rId.nextInt(100000000); \/\/and randomly selects a record with an id between 1 and 100 million\r\n rowId = Bytes.toBytes(Integer.toString(id));\r\n Get get = new Get(rowId);\r\n Result result = hTable.get(get);\r\n byte[] value = result.getValue(famA, col1);\r\n System.out.println(id);\r\n System.out.println(Bytes.toString(value));\r\n }\r\n }\r\n catch (Exception e) {\r\n e.printStackTrace();\r\n }\r\n }\r\n}\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"What is below is a simple class to read a random set of records from a table. This should be a good start if you are looking for a simple one class test case, that may also be useful for…<\/p>\n