PartitionsCreatorFactory
PartitionsCreatorFactory must be implemented by each source connector and serves as the entrypoint to how READ operations are executed for that connector, via the PartitionsCreator and PartitionReader instances which are ultimately created by it.
Functions
Returns a PartitionsCreator which will cause the READ to advance for the Feed for which the FeedBootstrap argument is associated to. The latter exposes methods to obtain the current OpaqueStateValue for this feed but also to peek at the state of other Feeds. This may be useful for synchronizing the READ for this feed by waiting for other Feeds to reach a desired state before proceeding; the waiting may be triggered by PartitionsCreator.tryAcquireResources or PartitionReader.tryAcquireResources.
Default implementation is a no-op as most connectors do not require any resource for their PartitionsCreatorFactory. Postgres connector being the exception.