Package com.linkedin.venice.vpj.pubsub.input
package com.linkedin.venice.vpj.pubsub.input
-
ClassDescriptionDefines the available strategies for splitting a
PubSubTopicPartitioninto one or morePubSubPartitionSplitinstances.Describes a contiguous range of records within a singlePubSubTopicPartition.PubSubSplitIteratorprovides an iterator-like abstraction over a bounded range of messages from aPubSubConsumerAdapter.Utility class for planningPubSubPartitionSplits for both MapReduce and Spark ingestion jobs.