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

Class SplitRequest

java.lang.Object

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

public final class SplitRequest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SplitRequest.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_SPLITS
static final long	DEFAULT_RECORDS_PER_SPLIT
static final long	DEFAULT_TIME_WINDOW_MS

Method Summary

Modifier and Type	Method	Description
Integer	getMaxSplits()
PubSubTopicPartition	getPubSubTopicPartition()
long	getRecordsPerSplit()
PartitionSplitStrategy	getSplitType()
long	getTimeWindowInMs()
TopicManager	getTopicManager()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_RECORDS_PER_SPLIT

public static final long DEFAULT_RECORDS_PER_SPLIT

See Also:

• Constant Field Values

DEFAULT_TIME_WINDOW_MS

public static final long DEFAULT_TIME_WINDOW_MS

DEFAULT_MAX_SPLITS

public static final int DEFAULT_MAX_SPLITS

See Also:

• Constant Field Values

Method Details

getPubSubTopicPartition

public PubSubTopicPartition getPubSubTopicPartition()

getTopicManager

public TopicManager getTopicManager()

getSplitType

public PartitionSplitStrategy getSplitType()

getMaxSplits

public Integer getMaxSplits()

getRecordsPerSplit

public long getRecordsPerSplit()

getTimeWindowInMs

public long getTimeWindowInMs()

toString

public String toString()

Overrides:

toString in class Object