Было бы хорошо, если кто-нибудь знает о том, как обрезать таблицу MySQL в потоке данных Google Cloud с помощью кода Java?
Я знаю, используя org.apache.beam.sdk.io.jdbc.JdbcIO, мы можем читать и записывать данные в MySQL.Мое требование - очищать данные перед записью данных в таблицу MySQL каждый раз, когда выполняется задание потока данных.