Details
-
Sub-task
-
Status: Open
-
P2
-
Resolution: Unresolved
-
None
-
None
Description
basically we'd turn ReadFn into an SDF that can dynamically partition the range it's currently reading.
To commit this change, we'd need to performance-test its behavior, to make sure that duplicatiopn of work on the Database-side is not a problem when we subpartition a range that we're already querying.
Attachments
Issue Links
- is related to
-
BEAM-13846 Add a proper string partitioner for JdbcIO.readWithPartitions
- Open