Obtenir toutes les valeurs de toutes les lignes dans Hbase à l'aide de Java

J'ai le code suivant.Je suis en train de récupérer toutes les lignes de la table de la famille de la colonne. J'ai été en mesure d'obtenir toutes les lignes, mais la sortie n'est pas ce que j'attendais. Je obtenir un résultat qui montre la clé et à l'heure mais pas la valeur. Pourquoi ne pas les valeurs des lignes arriver sur l'écran? S'il vous plaît aider. La sortie est donnée ci-dessous:

  keyvalues={Justin/marks:total/1375104216267/Put/vlen=7/ts=0, Justin/marks:markPercentage/  1375104186783/Put/vlen=4/ts=0}

//Le Code pour obtenir toutes les lignes de hbase

public class GetHbaseData {
public static void getdata() throws IOException{
@SuppressWarnings("resource")
HTable table = new HTable(HBaseConfiguration.create(), "Student");
Scan scan = new Scan();
scan.setCaching(20);

scan.addFamily(Bytes.toBytes("marks"));
ResultScanner scanner = table.getScanner(scan);

for (Result result = scanner.next(); (result != null); result = scanner.next()) {
    Get get = new Get(result.getRow());
    Result entireRow = table.get(get); 
    System.out.println(entireRow);
}
}
InformationsquelleAutor Sindu_ | 2013-07-30
  1. 13

    Pour obtenir toutes les lignes avec toutes les colonnes que vous n'avez pas besoin de faire Obtenir appel à nouveau à l'intérieur de votre boucle. Essayez quelque chose comme ça.

    for (Result result = scanner.next(); (result != null); result = scanner.next()) {
    for(KeyValue keyValue : result.list()) {
        System.out.println("Qualifier : " + keyValue.getKeyString() + " : Value : " + Bytes.toString(keyValue.getValue()));
    }
}
    • C'est beaucoup mieux.
    • résultat.liste() est obsolète maintenant. toute idée de ce à utiliser dans la nouvelle API?
    InformationsquelleAutor Naresh Reddy
  2. 8

    Je tiens à offrir une solution sans des méthodes obsolètes

        //Get
    Get theGet = new Get(Bytes.toBytes("rowkey1"));
    Result result = table.get(theGet);
    //get value first column
    String inValue1 = Bytes.toString(result.value());
    //get value by ColumnFamily and ColumnName
    byte[] inValueByte = result.getValue(Bytes.toBytes(columnFamily), Bytes.toBytes(columnQualifier1));
    String inValue2 = Bytes.toString(inValueByte);

    //loop for result
    for (Cell cell : result.listCells()) {
        String qualifier = Bytes.toString(CellUtil.cloneQualifier(cell));
        String value = Bytes.toString(CellUtil.cloneValue(cell));
        System.out.printf("Qualifier : %s : Value : %s", qualifier, value);
    }

    //create Map by result and print it
    Map<String, String> getResult =  result.listCells().stream().collect(Collectors.toMap(e -> Bytes.toString(CellUtil.cloneQualifier(e)), e -> Bytes.toString(CellUtil.cloneValue(e))));
    getResult.entrySet().stream().forEach(e-> System.out.printf("Qualifier : %s : Value : %s", e.getKey(), e.getValue()));
    InformationsquelleAutor Gleb Belyaev
  3. 5

    voici un code pour analyser les "marques" famille de colonne dans le tableau.

    l'utilisant, vous pouvez obtenir la ligne, la colonne, l'horodatage et la valeur.

        Scan scan = new Scan();
    scan.setCaching(hBaseScanCacheSize);
    scan.setBatch(hbaseScanBatchSize);
    scan.addFamily(Bytes.toBytes("marks"));

    ResultScanner resultScanner = table.getScanner(scan);
    Iterator<Result> iterator = resultScanner.iterator();
    while (iterator.hasNext())
    {
        Result next = iterator.next();
        for(Entry<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>> columnFamilyMap : next.getMap().entrySet())
        {
            for (Entry<byte[], NavigableMap<Long, byte[]>> entryVersion : columnFamilyMap.getValue().entrySet())
            {
                for (Entry<Long, byte[]> entry : entryVersion.getValue().entrySet())
                {
                    String row = Bytes.toString(next.getRow());
                    String column = Bytes.toString(entryVersion.getKey());
                    byte[] value = entry.getValue();
                    long timesstamp = entry.getKey();
                }
            }
        }
    }
    InformationsquelleAutor Udy
  4. 0

    Avec la nouvelle HBase Api, le code ressemble à ceci:

        for (Result result = scanner.next(); (result != null); result = scanner.next()) {
        for(Cell cell : result.listCells()) {
            String qualifier = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());
            String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());
            System.out.println("Qualifier : " + qualifier
                    + " : Value : " + value);
        }
    }
    InformationsquelleAutor Виталий Олегович