У меня есть функция в Java, которая считывает данные из коллекции Firestore и удаляет их с фиксированным размером пакета. Я хочу выполнить это из потока данных, но когда я добавляю это в .apply, я получаю ошибку компиляции: «Метод apply (String, PTransform) в типе Pipeline не применим для аргументов (String, void)»
Как мы можем вызвать такую функцию внутри применения