Hi,
I want to ingest data from DBs by creating DB inputs. It has very huge amount of records (around 15million). So I can't use Batch Input. The issue is they don't have any timestamp/unique identifier to put as rising column. So it can't pickup the new records every time. What to do now?
Is there anyway to ingest new records only for every 15 mins?
Thanks,
I think you have to find an identifier (e.g. rowID, last update date) from the database to be the rising column if you want to use it.
For ingestion new records every 15mins, you could set the interval input.
interval = */15 * * * *