Red de conocimiento informático - Material del sitio web - Cómo ejecutar el trabajo hbase mapreduce

Cómo ejecutar el trabajo hbase mapreduce

prueba de paquete;

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()

putRow.add("fam1".getBytes(), "col3".getBytes(), "vaule3"

.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

}

}