Получить строку данных Qubole мудро, используя Java - PullRequest
1 голос
/ 18 апреля 2019

Я пытаюсь выполнить запрос hive, используя Qubole SDK .Хотя я могу получить желаемый результат как string, чтобы лучше его обработать, я хочу получить доступ к этому по строкам.Что-то вроде списка Java-объектов.

Я получаю данные следующим образом:

CommandResponse commandResponse = client.command().hive().query(query).invoke().get();
ResultLatch resultLatch = new ResultLatch(client, commandResponse.getId());
ResultValue resultValue = resultLatch.awaitResult();
System.out.println(resultValue.getResults());

И консоль выдает следующие данные:

"val1"  "val2"  "val3"  "val4"
........ some more set of values .......

Я былпытаясь получить этот набор результатов в виде списка, который я могу перебирать вместо анализа или токенизации набора строк.

Невозможно найти какую-либо библиотеку или класс, если он там есть.

1 Ответ

0 голосов
/ 18 апреля 2019

Сначала разбить строку на \r\n, затем на \t следующим образом:

import org.apache.commons.lang3.StringUtils;

...

private static String convertNulls(String s) {
    \\Use this function to convert blanks, null and \\N to''
    return StringUtils.isBlank(s) | 
       s.equalsIgnoreCase("null") | 
        s.equalsIgnoreCase("\\N") ? "" : s;
}

...

inputStr=resultValue.getResults();

if (!StringUtils.isBlank(inputStr)) {
            for (String row: inputStr.split("\r\n")) { //split rows
                String[] s = row.split("\t");          //split columns

                //Do what you want here with s 
                //Use convertNulls method to convert all NULLs variations to empty strings
                //Or load some ArrayList or Map, etc


            }
...