Cómo ejecutar el trabajo hbase mapreduce
importar java.io.IOException;
importar java.util.Map
importar org.apache.hadoop.conf.hadoop.hbase; .HColumnDescriptor;
importar org.apache.Result;
clase pública Htable {
/**
* @param args
*/
public static void main(String[] args) lanza IOException {
// TODO Código auxiliar de método generado automáticamente
Configuración hbaseConf = HBaseConfiguration.create();
HBaseAdmin admin = new HBaseAdmin(hbaseConf);
HTableDescriptor htableDescriptor = new HTableDescriptor("table"
.addFamily (new HColumnDescriptor("fam1")); //establece el nombre de los grupos de columnas
admin.createTable(htableDescriptor); //crea una tabla
HTable table = nueva tabla HTable = new HTable(htableDescriptor); //crea una tabla
HTable table = new HTable(hbaseConf, "table"); //obtiene una instancia de la tabla.
for (int i = 0; i lt; 3; i) { //para el número de filas
Put putRow = new Put(("row" i).getBytes()); p>
putRow.add("fam1".getBytes(), "col1".getBytes(), "vaule1"
.getBytes()); //establece el nombre de la columna y el valor .
putRow.add("fam1".getBytes(), "col2".getBytes(), "vaule2"
.getBytes()
.getBytes();
table.put(putRow) ;
}
for(Resultado resultado: table.getScanner ("fam1"
.getBytes())){//obtener datos de grupos de columnas
for(Map.entry: result.getFamilyMap("fam1".getBytes()).entrySet()){/obtener la colección de resultado
Columna de cadena = new String(entry.getKey());
Valor de cadena = new String(entry.getValue());
System. out.print(columna);
System.out.print(artículo
System.out.print(artículo
Valor de cadena = nuevo); String(entry.getValue());
System.out.print(artículo
System.out.print(artículo)out.println(columna ", " valor) ;
}
}
}
admin.disableTable("table".getBytes()); //Desactivar tabla
admin.deleteTable("table".getBytes()); //Eliminar tabla
}
}