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?