You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2015/05/11 19:02:37 UTC
hbase git commit: Revert "Fixed example code" Reverted because
missing associated JIRA reference.
Repository: hbase
Updated Branches:
refs/heads/master ec51d7b2e -> e1628106a
Revert "Fixed example code"
Reverted because missing associated JIRA reference.
This reverts commit 0dfb3647237523204765e95cc1c161751e8a8987.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e1628106
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e1628106
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e1628106
Branch: refs/heads/master
Commit: e1628106aef4c67ec9bee24b3279853d9b7c26d5
Parents: ec51d7b
Author: stack <st...@apache.org>
Authored: Mon May 11 10:02:06 2015 -0700
Committer: stack <st...@apache.org>
Committed: Mon May 11 10:02:06 2015 -0700
----------------------------------------------------------------------
src/main/asciidoc/_chapters/hbase_apis.adoc | 109 ++++++++++++-----------
1 file changed, 56 insertions(+), 53 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/e1628106/src/main/asciidoc/_chapters/hbase_apis.adoc
----------------------------------------------------------------------
diff --git a/src/main/asciidoc/_chapters/hbase_apis.adoc b/src/main/asciidoc/_chapters/hbase_apis.adoc
index 6d2777b..85dbad1 100644
--- a/src/main/asciidoc/_chapters/hbase_apis.adoc
+++ b/src/main/asciidoc/_chapters/hbase_apis.adoc
@@ -36,99 +36,102 @@ See <<external_apis>> for more information.
== Examples
-.Create, modify and delete a Table Using Java
+.Create a Table Using Java
====
[source,java]
----
package com.example.hbase.admin;
-package util;
-
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.HColumnDescriptor;
-import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
-import org.apache.hadoop.hbase.client.Connection;
-import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.io.compress.Compression.Algorithm;
+import org.apache.hadoop.conf.Configuration;
-public class Example {
+import static com.example.hbase.Constants.*;
- private static final String TABLE_NAME = "MY_TABLE_NAME_TOO";
- private static final String CF_DEFAULT = "DEFAULT_COLUMN_FAMILY";
+public class CreateSchema {
public static void createOrOverwrite(Admin admin, HTableDescriptor table) throws IOException {
- if (admin.tableExists(table.getTableName())) {
- admin.disableTable(table.getTableName());
- admin.deleteTable(table.getTableName());
+ if (admin.tableExists(table.getName())) {
+ admin.disableTable(table.getName());
+ admin.deleteTable(table.getName());
}
admin.createTable(table);
}
- public static void createSchemaTables(Configuration config) throws IOException {
- try (Connection connection = ConnectionFactory.createConnection(config);
- Admin admin = connection.getAdmin()) {
-
+ public static void createSchemaTables (Configuration config) {
+ try {
+ final Admin admin = new Admin(config);
HTableDescriptor table = new HTableDescriptor(TableName.valueOf(TABLE_NAME));
table.addFamily(new HColumnDescriptor(CF_DEFAULT).setCompressionType(Algorithm.SNAPPY));
System.out.print("Creating table. ");
createOrOverwrite(admin, table);
System.out.println(" Done.");
+
+ admin.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.exit(-1);
}
}
- public static void modifySchema (Configuration config) throws IOException {
- try (Connection connection = ConnectionFactory.createConnection(config);
- Admin admin = connection.getAdmin()) {
+}
+----
+====
+
+.Add, Modify, and Delete a Table
+====
+
+[source,java]
+----
+public static void upgradeFrom0 (Configuration config) {
+
+ try {
+ final Admin admin = new Admin(config);
+ TableName tableName = TableName.valueOf(TABLE_ASSETMETA);
+ HTableDescriptor table_assetmeta = new HTableDescriptor(tableName);
+ table_assetmeta.addFamily(new HColumnDescriptor(CF_DEFAULT).setCompressionType(Algorithm.SNAPPY));
- TableName tableName = TableName.valueOf(TABLE_NAME);
- if (admin.tableExists(tableName)) {
- System.out.println("Table does not exist.");
- System.exit(-1);
- }
+ // Create a new table.
- HTableDescriptor table = new HTableDescriptor(tableName);
+ System.out.print("Creating table_assetmeta. ");
+ admin.createTable(table_assetmeta);
+ System.out.println(" Done.");
- // Update existing table
- HColumnDescriptor newColumn = new HColumnDescriptor("NEWCF");
- newColumn.setCompactionCompressionType(Algorithm.GZ);
- newColumn.setMaxVersions(HConstants.ALL_VERSIONS);
- admin.addColumn(tableName, newColumn);
+ // Update existing table
+ HColumnDescriptor newColumn = new HColumnDescriptor("NEWCF");
+ newColumn.setCompactionCompressionType(Algorithm.GZ);
+ newColumn.setMaxVersions(HConstants.ALL_VERSIONS);
+ admin.addColumn(tableName, newColumn);
- // Update existing column family
- HColumnDescriptor existingColumn = new HColumnDescriptor(CF_DEFAULT);
- existingColumn.setCompactionCompressionType(Algorithm.GZ);
- existingColumn.setMaxVersions(HConstants.ALL_VERSIONS);
- table.modifyFamily(existingColumn);
- admin.modifyTable(tableName, table);
+ // Update existing column family
+ HColumnDescriptor existingColumn = new HColumnDescriptor(CF_DEFAULT);
+ existingColumn.setCompactionCompressionType(Algorithm.GZ);
+ existingColumn.setMaxVersions(HConstants.ALL_VERSIONS);
+ table_assetmeta.modifyFamily(existingColumn)
+ admin.modifyTable(tableName, table_assetmeta);
- // Disable an existing table
- admin.disableTable(tableName);
+ // Disable an existing table
+ admin.disableTable(tableName);
- // Delete an existing column family
- admin.deleteColumn(tableName, CF_DEFAULT.getBytes("UTF-8"));
+ // Delete an existing column family
+ admin.deleteColumn(tableName, CF_DEFAULT);
- // Delete a table (Need to be disabled first)
- admin.deleteTable(tableName);
- }
- }
+ // Delete a table (Need to be disabled first)
+ admin.deleteTable(tableName);
- public static void main(String... args) throws IOException {
- Configuration config = HBaseConfiguration.create();
- //Add any necessary configuration files (hbase-site.xml, core-site.xml)
- config.addResource(new Path(System.getenv("HBASE_CONF_DIR"), "hbase-site.xml"));
- config.addResource(new Path(System.getenv("HADOOP_CONF_DIR"), "core-site.xml"));
- createSchemaTables(config);
- modifySchema(config);
+ admin.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.exit(-1);
}
}
----