Package com.linkedin.venice.vpj.pubsub.input

Class PubSubSplitPlanner

java.lang.Object

com.linkedin.venice.vpj.pubsub.input.PubSubSplitPlanner

public class PubSubSplitPlanner
extends Object

Utility class for planning PubSubPartitionSplits for both MapReduce and Spark ingestion jobs.

This class encapsulates the common logic for:

• Building a TopicManager from job configuration.
• Reading split parameters (split type, max records per split, max splits per partition, time window, etc.).
• Determining the number of partitions for a topic and generating splits using the appropriate PubSubTopicPartitionSplitStrategy.

Constructor Summary

Constructors

Constructor	Description
PubSubSplitPlanner()

Method Summary

Modifier and Type	Method	Description
List<PubSubPartitionSplit>	plan(VeniceProperties jobConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PubSubSplitPlanner

public PubSubSplitPlanner()

Method Details

plan

public List<PubSubPartitionSplit> plan(VeniceProperties jobConfig)