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