Hello, I have a rather simple use case where I would like to read a db table, which acts as a queue (~ hundreds millions events in initial load, but only thousands of events per day), and write that data out to a sink. This pipeline would be unbounded.
I'm looking for reading material, and or code, which displays reading from the JdbcIO API with checkpoints. I would like to avoid the initial load on restarts, upgrades, etc. :) Thank you for your time! Eric
