У меня есть apache настройка трубопровода луча. Я хочу читать / писать из / в облачный пожарный магазин Google, но не могу найти ни одного примера (с помощью java / scala) для подключения к пожарному хранилищу. Я прошел через Apache API библиотеки Beam, у них есть класс DatastoreIO, который дает нам объект v1, но я не могу найти, как его использовать.
val fireStoreReader =
DatastoreIO.v1()
.read()
val fireStoreWrited = DatastoreIO.v1().write()
чтение и запись принимают, какой документ какой БД Я хочу читать или записывать данные.
Любая помощь будет оценена Спасибо.