Я пишу запрос из api таблицы flink для получения записи. Затем проверьте, была ли найдена запись, и если да, получите строковое значение каждого значения столбца записи.
i.e.
users:
|id | name | phone |
|---|------|-------|
| 01| sam | 23354 |
| 02| jake | 23352 |
| 03| kim | 23351 |
Проблема в том, что flink возвращает только таблицу из запроса, поэтому я не могу 1: проверить, была ли найдена запись, и 2: получить отдельные значения значений найденной записи
код sudo:
foundRecord = find record by phone
if foundRecord {
create new instance of Visitor
Visitor.name = foundRecord.name
Visitor.id = foundRecord.id
} else {
throw exception
}
Приведенный ниже код, рекомендованный flink docs, дает мне таблицу, но не уверен, как реализовать приведенный выше код sudo, поскольку он возвращается как другая таблица, и мне нужны фактические значения записи.
Table users = registeredUsers.select("id, name, phone").where("phone === '23354'"));
Перейдите в Документы для ссылки: https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html#expression-syntax