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

Class SplitRequest.Builder

java.lang.Object

com.linkedin.venice.vpj.pubsub.input.SplitRequest.Builder

Enclosing class:

SplitRequest

public static final class SplitRequest.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
SplitRequest	build()
SplitRequest.Builder	maxSplits(Integer value)	Used when partitionSplitStrategy is CAPPED_SPLIT_COUNT.
SplitRequest.Builder	pubSubTopicPartition(PubSubTopicPartition value)
SplitRequest.Builder	recordsPerSplit(long value)	Used when partitionSplitStrategy is FIXED_RECORD_COUNT.
SplitRequest.Builder	splitType(PartitionSplitStrategy value)
SplitRequest.Builder	timeWindowInMs(long value)	Used when partitionSplitStrategy is TIME_WINDOW.
SplitRequest.Builder	topicManager(TopicManager value)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

pubSubTopicPartition

public SplitRequest.Builder pubSubTopicPartition(PubSubTopicPartition value)

topicManager

public SplitRequest.Builder topicManager(TopicManager value)

splitType

public SplitRequest.Builder splitType(PartitionSplitStrategy value)

maxSplits

public SplitRequest.Builder maxSplits(Integer value)

Used when partitionSplitStrategy is CAPPED_SPLIT_COUNT.

recordsPerSplit

public SplitRequest.Builder recordsPerSplit(long value)

Used when partitionSplitStrategy is FIXED_RECORD_COUNT.

timeWindowInMs

public SplitRequest.Builder timeWindowInMs(long value)

Used when partitionSplitStrategy is TIME_WINDOW.

build

public SplitRequest build()