Как часть нашего конвейера потока данных, я хочу прочитать файл maxmind dat из GCS и инициализировать сервис поиска вне основных шагов конвейера.Это будет больше похоже на запуск статического сервиса и его использование внутри DoFn для выполнения ip-поиска.Чтение файла работает локально с использованием DirectRunner, но не использует DataflowRunner.
При чтении документации упоминается опция --filesToStage, которая может использоваться для передачи информации о файле, но также упоминается, что если мыпереопределите этот параметр, тогда мы также должны указать все зависимости classpath.Может кто-нибудь посоветовать, как передать существующие зависимости и код конвейера вместе с моим новым файлом на сцену?
Спасибо