Package com.google.cloud.pubsublite.spark.internal (0.3.4)

Classes

CachedPartitionCountReader

CachedPublishers

Cached Publishers to reuse publisher of same settings in 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.

PslCredentialsProvider

Interfaces

MultiPartitionCommitter

MultiPartitionCommitter.CommitterFactory

PartitionCountReader

PartitionSubscriberFactory

PerTopicHeadOffsetReader

PublisherFactory