DatabaseInitialStatusGatherer
Some destinations can efficiently fetch multiple tables' information in a single query, so this interface accepts multiple streams in a single method call.
For destinations which do not support that optimization, a simpler implementation would be something like this:
streams.forEach { (stream, (tableNames, columnNames)) ->
launch {
// ... gather state...
}
}Content copied to clipboard