Package com.google.cloud.pubsublite.spark.internal (1.0.0)
Stay organized with collections
Save and categorize content based on your preferences.
Classes
CachedPartitionCountReader
CachedPublishers
Cached Publishers to reuse publisher of same settings in the same task.
CachedSubscriberClients
Singleton class that caches subscriber service clients to be re-used by the same task.
LimitingHeadOffsetReader
Rate limited HeadOffsetReader, utilizing a LoadingCache that refreshes all partitions head offsets for the topic at most once per minute.
MultiPartitionCommitterImpl
A MultiPartitionCommitter that lazily adjusts for partition changes when MultiPartitionCommitter#commit(PslSourceOffset) is called.