Cómo utilizar Eclipse para crear un entorno de desarrollo HBase
Los pasos son los siguientes:
1: Copie un archivo de implementación de Hbase del clúster de HBase y colóquelo en un directorio en el lado de desarrollo (como /app/hadoop/ directorio hbase096).
2: Cree un nuevo proyecto java HBase en eclipse, luego seleccione las propiedades del proyecto, en Bibliotecas-gt..., y luego seleccione el paquete JAR relevante en /app/hadoop/hbase096; /lib, si es solo para pruebas, es más simple y selecciona todos los JAR.
3: Agregue una carpeta conf en el proyecto HBase, copie el archivo de configuración del clúster Hbase hbase-site.xml al directorio y luego seleccione las propiedades del proyecto en Bibliotecas-gt y agregue; Seleccione el directorio conf agregado.
4: Agregue un paquete del capítulo 12 al proyecto HBase, luego agregue una clase HBaseTestCase, luego copie el código del Capítulo 12 de "Hadoop Practical Edition 2" y realice las modificaciones apropiadas. El código es el siguiente: <. /p>
paquete capítulo12;
importar java.io.IOException;
importar org.apache.hadoop.conf.Configuration;
importar org .apache.hadoop.hbase.HBaseConfiguration;
importar org.apache.hadoop.hbase.HColumnDescriptor;
importar org.apache.hadoop.hbase.HTableDescriptor;
importar org.apache.hadoop.hbase.client.Get;
importar org.apache.hadoop.hbase.client.HBaseAdmin;
importar org.apache.hadoop. .client.HTable;
importar org.apache.hadoop.hbase.client.Put;
importar org.apache.hadoop.hbase.client.Result;
importar org.apache.hadoop.hbase.client.ResultScanner;
importar org.apache.hadoop.hbase.client.Scan;
importar org.apache.hadoop. .util.Bytes;
clase pública HBaseTestCase {
//Declarar configuración estática HBaseConfiguration
Configuración estática cfg=HBaseConfiguration.create();
//Crear una tabla a través de HBaseAdmin HTableDescriptor
public static void creat(String tablename, String columnFamily) lanza una excepción {
HBaseAdmin admin = new HBaseAdmin( cfg);
if (admin.tableExists(nombre de tabla)) {
System.out.println("¡la tabla existe!");
System.exit (0);
}
else{
HTableDescriptor tableDesc = nuevo HTableDescriptor(nombre de tabla);
tableDesc.addFamily(nuevo HColumnDescriptor (columnFamily));
admin.createTable(tableDe
sc);
System.out.println("¡Creación de tabla exitosa!");
}
}
//Agregar Un dato, agregue datos a una tabla existente a través de HTable Put
public static void put (nombre de tabla de cadena, fila de cadena, familia de columnas de cadena, columna de cadena, datos de cadena) arroja una excepción {
HTable table = new HTable(cfg, tablename);
Put p1=new Put(Bytes.toBytes(fila));
p1.add(Bytes.toBytes(columnFamily) , Bytes.toBytes(columna), Bytes.toBytes(datos));
table.put(p1);
System.out.println("poner '" fila "' ,'" columnFamily ":" columna "','" datos "'");
}
public static void get(String nombre de tabla, String fila) lanza IOException{
HTable table=new HTable(cfg, tablename);
Get g=new Get(Bytes.toBytes(row));
Resultado result=table.get (g);
System.out.println("Obtener: " resultado);
}
//Muestra todos los datos obtenidos a través de HTable Scan Information sobre tablas existentes
El escaneo público estático de vacío (String tablename) arroja una excepción{
HTable table = new HTable(cfg, tablename);
Scan s = new Scan();
ResultScanner rs = table.getScanner(s);
for(Resultado r: rs){
System.out.println (" Escaneo: " r);
}
}
la eliminación booleana estática pública (nombre de tabla de cadena) arroja IOException{
HBaseAdmin admin= nuevo HBaseAdmin(cfg);
if(admin.tableExists(nombre de tabla)){
pruebe
{
admin. nombre de tabla);
admin.deleteTable(nombre de tabla);
}catch(Exception ex){
ex.printStackTrace();
devuelve falso
se;
}
}
return true;
}
public static void main (String [ ] agrs) {
String tablename="hbase_tb";
String columnFamily="cf";
pruebe {
HBaseTestCase. creat(nombretabla, familiacolumna);
HBaseTestCase.put(nombretabla, "fila1", familiacolumna, "cl1", "datos");
HBaseTestCase.get(nombretabla, "fila1 ");
HBaseTestCase.scan(nombre de tabla);
/* if(true==HBaseTestCase.delete(nombre de tabla))
System.out.println ("Eliminar tabla:" nombre de tabla "éxito!");
*/
}
catch (Excepción e) {
e.printStackTrace();
}
}
}
5: establezca la configuración en ejecución y luego ejecute. Inicie el clúster Hbase antes de ejecutarlo.
6: Verifique, use hbase shell para ver hbase y descubra que se ha creado la tabla hbase_tb.