bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.read/DefaultJdbcPartitionFactory/create

create

open override fun create(streamFeedBootstrap: StreamFeedBootstrap): DefaultJdbcPartition?

Deserializes the current OpaqueStateValue and creates a JdbcPartition instance corresponding to all remaining unread data in the Stream, if any; null otherwise.