En este momento, Cloud Dataflow no proporciona una fuente de entrada de MySQL.
La forma preferida de implementar la compatibilidad con esto es implementar una fuente de entrada definida por el usuario que puede manejar consultas MySQL.
Una forma alternativa sería ejecutar la consulta en el programa principal y organizar los resultados de la consulta en una ubicación temporal en GCS, procesar los resultados con Dataflow y eliminar los archivos en forma temporal.
Espero que esto ayude
