i'm creating a pipeline where i migrate a database to hdfs, and after i want to track all the the insert and update in any table in the database
well as first solution i used this pipline :
listDatabaseTables => generateTableFetch => ExtractText => ExecuteSQL => convertAvroToJSON => PutFile
but i still cant track the changement in tables !
any one know how to handle this