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

Class CappedSplitCountStrategy

java.lang.Object

com.linkedin.venice.vpj.pubsub.input.splitter.CappedSplitCountStrategy

All Implemented Interfaces:

PubSubTopicPartitionSplitStrategy

public class CappedSplitCountStrategy
extends Object
implements PubSubTopicPartitionSplitStrategy

Splits a PubSubTopicPartition into multiple splits, with the total number of splits capped at a configured maximum. The size of each split is calculated by dividing the total record count by this maximum.

Constructor Summary

Constructors

Constructor	Description
CappedSplitCountStrategy()

Method Summary

Modifier and Type	Method	Description
List<PubSubPartitionSplit>	split(SplitRequest splitRequest)

Methods inherited from class java.lang.Object

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

Constructor Details

CappedSplitCountStrategy

public CappedSplitCountStrategy()

Method Details

split

public List<PubSubPartitionSplit> split(SplitRequest splitRequest)

Specified by:

split in interface PubSubTopicPartitionSplitStrategy