Changes between Initial Version and Version 1 of waue/2011/0425_Itri5ShowReport

Timestamp:

Apr 25, 2011, 4:21:47 PM (13 years ago)

Author:

waue

Comment:

--

waue/2011/0425_Itri5ShowReport

@@ +1 @@
+{{{
+#!java
+
+package itri;
+
+
+
+// ITRI serial program number 5
+
+// 0. after Itri4SortTurnover
+
+// run it
+
+
+
+import java.io.IOException;
+
+
+
+import org.apache.hadoop.conf.Configuration;
+
+import org.apache.hadoop.fs.Path;
+
+import org.apache.hadoop.hbase.HBaseConfiguration;
+
+import org.apache.hadoop.hbase.HConstants;
+
+import org.apache.hadoop.hbase.client.Result;
+
+import org.apache.hadoop.hbase.client.ResultScanner;
+
+import org.apache.hadoop.hbase.client.tableindexed.IndexedTable;
+
+import org.apache.hadoop.hbase.filter.CompareFilter;
+
+import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
+
+import org.apache.hadoop.hbase.util.Bytes;
+
+import org.apache.hadoop.util.GenericOptionsParser;
+
+
+
+public class Itri5ShowReport {
+
+
+
+        static public void readSortedValGreater(String filter_val)
+
+                        throws IOException {
+
+                HBaseConfiguration conf = new HBaseConfiguration();
+
+                conf.addResource(new Path("/opt/hbase/conf/hbase-site.xml"));
+
+                // the id of the index to use
+
+                String tablename = "itri";
+
+                String indexId = "Sum";
+
+                byte[] column_1 = Bytes.toBytes("Turnover:Sum");
+
+                byte[] column_2 = Bytes.toBytes("Detail:Name");
+
+
+
+                byte[] indexStartRow = HConstants.EMPTY_START_ROW;
+
+                byte[] indexStopRow = null;
+
+                byte[][] indexColumns = null;
+
+
+
+                SingleColumnValueFilter indexFilter = new SingleColumnValueFilter(Bytes
+
+                                .toBytes("Turnover"), Bytes.toBytes("Sum"),
+
+                                CompareFilter.CompareOp.GREATER_OR_EQUAL, Bytes
+
+                                                .toBytes(filter_val));
+
+
+
+                byte[][] baseColumns = new byte[][] { column_1, column_2 };
+
+
+
+                IndexedTable table = new IndexedTable(conf, Bytes.toBytes(tablename));
+
+
+
+                ResultScanner scanner = table.getIndexedScanner(indexId, indexStartRow,
+
+                                indexStopRow, indexColumns, indexFilter, baseColumns);
+
+
+
+                for (Result rowResult : scanner) {
+
+                        String sum = Bytes.toString(rowResult.getValue(column_1));
+
+                        String name = Bytes.toString(rowResult.getValue(column_2));
+
+                        System.out.println(name + " 's turnover is " + sum + " $.");
+
+                }
+
+                table.close();
+
+        }
+
+
+
+        public static void main(String[] argv) throws IOException {
+
+
+
+                String[] args = new GenericOptionsParser(new Configuration(), argv)
+
+                                .getRemainingArgs();
+
+                if (args.length < 1) {
+
+                        System.out.println("Input the MIN number:");
+
+                        return;
+
+                }
+
+                readSortedValGreater(args[0]);
+
+        }
+
+}
+
+}}}