Луч Apache с Redis - выбрать базу данных и прочитать из хэша?

Я начинаю с Apache Beam и хочу прочитать хэш, который я сохранил в Redis, и мне также нужно будет выбрать базу данных (номер). Я просмотрел исходный код RedisIO, но не похоже, что он включает в себя возможность делать любую из этих вещей. Я что-то пропустил, или мне придется написать свою собственную реализацию, чтобы добиться этого?


person Steve Storck    schedule 24.08.2019    source источник


Ответы (1)


К сожалению, эти параметры в настоящее время не поддерживаются.

На данный момент самый простой способ сделать это — расширить RedisIO.BaseReadFn и перезаписать setup и teardown.

person Ankur    schedule 26.08.2019