Observar nuevos archivos que coincidan con un patrón de archivos en Apache Beam
Tengo un directorio en GCS u otro sistema de archivos compatible en el que un proceso externo escribe nuevos archivos.
Me gustaría escribir una canalización de transmisión de Apache Beam que supervise continuamente este directorio en busca de nuevos archivos y lea y procese cada nuevo archivo a medida que llegue. es posible?