У меня есть таблица заказов Mysql, в которой есть идентификатор автоинкремента, и статус заказа будет обновляться, а дата последнего изменения не будет изменена, и это очень большая таблица. Теперь я планировал создать приемник HDFS в реальном времени с использованием Sqoop.
Я не могу перехватывать обновления в sqoop.Я попытался добавить и добавить ключ слияния с lastmodified, но оба не смогли решить проблему.
Я не могу перезагрузить всю таблицу, так как она очень большая.
Я ищу способ использования sqoop, чтобы мы могли обнаруживать обновления, такие как изменения статуса и переходить на hdfs