From 6213bc3c8e9446ba8a556d195649ee9960dac79c Mon Sep 17 00:00:00 2001
From: Michael Stack <stack@apache.org>
Date: Mon, 5 Oct 2009 21:07:58 +0000
Subject: [PATCH] HBASE-1875 Compression test utility

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@822010 13f79535-47bb-0310-9956-ffa450edef68
---
 CHANGES.txt                                   |  1 +
 .../hadoop/hbase/util/CompressionTest.java    | 89 +++++++++++++++++++
 2 files changed, 90 insertions(+)
 create mode 100644 src/java/org/apache/hadoop/hbase/util/CompressionTest.java

diff --git a/CHANGES.txt b/CHANGES.txt
index 616cc91a164..74df819a6fd 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -93,6 +93,7 @@ Release 0.21.0 - Unreleased
                (listTables, tableExists), is very slow if the client is far
                away from the HBase cluster (Andrei Dragomir via Stack)
    HBASE-1879  ReadOnly transactions generate WAL activity (Clint Morgan via Stack)
+   HBASE-1875  Compression test utility
 
   OPTIMIZATIONS
 
diff --git a/src/java/org/apache/hadoop/hbase/util/CompressionTest.java b/src/java/org/apache/hadoop/hbase/util/CompressionTest.java
new file mode 100644
index 00000000000..850e993890d
--- /dev/null
+++ b/src/java/org/apache/hadoop/hbase/util/CompressionTest.java
@@ -0,0 +1,89 @@
+/**
+ * Copyright 2009 The Apache Software Foundation
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.util;
+
+import java.net.URI;
+
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hbase.io.hfile.HFile;
+import org.apache.hadoop.hdfs.DistributedFileSystem;
+
+/**
+ * Compression validation test.  Checks compression is working.  Be sure to run
+ * on every node in your cluster.
+ */
+public class CompressionTest {
+  protected static Path path = new Path(".hfile-comp-test");
+
+  public static void usage() {
+    System.out.println("Usage: CompressionTest HDFS_PATH none|gz|lzo");
+    System.exit(0);
+  }
+
+  protected static DistributedFileSystem openConnection(String urlString)
+  throws java.net.URISyntaxException, java.io.IOException {
+    URI dfsUri = new URI(urlString);
+    Configuration dfsConf = new Configuration();
+    DistributedFileSystem dfs = new DistributedFileSystem();
+    dfs.initialize(dfsUri, dfsConf);
+    return dfs;
+  }
+
+  protected static boolean closeConnection(DistributedFileSystem dfs) {
+    if (dfs != null) {
+      try {
+        dfs.close();
+        dfs = null;
+      } catch (Exception e) {
+        e.printStackTrace();
+      }
+    }
+    return dfs == null;
+  }
+
+  public static void main(String[] args) {
+    if (args.length != 2) usage();
+    try {
+      DistributedFileSystem dfs = openConnection(args[0]);
+      dfs.delete(path, false);
+      HFile.Writer writer = new HFile.Writer(dfs, path,
+        HFile.DEFAULT_BLOCKSIZE, args[1], null);
+      writer.append(Bytes.toBytes("testkey"), Bytes.toBytes("testval"));
+      writer.appendFileInfo(Bytes.toBytes("infokey"), Bytes.toBytes("infoval"));
+      writer.close();
+
+      HFile.Reader reader = new HFile.Reader(dfs, path, null, false);
+      reader.loadFileInfo();
+      byte[] key = reader.getFirstKey();
+      boolean rc = Bytes.toString(key).equals("testkey");
+      reader.close();
+
+      dfs.delete(path, false);
+      closeConnection(dfs);
+
+      if (rc) System.exit(0);
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+    System.out.println("FAILED");
+    System.exit(1);
+  }
+}
\ No newline at end of file