Package com.linkedin.venice.controllerapi

Class RequestTopicForPushRequest

java.lang.Object

com.linkedin.venice.controllerapi.RequestTopicForPushRequest

public class RequestTopicForPushRequest
extends Object

Constructor Summary

Constructors

Constructor	Description
RequestTopicForPushRequest(String clusterName, String storeName, Version.PushType pushType, String pushJobId)

Method Summary

Modifier and Type	Method	Description
X509Certificate	getCertificateInRequest()
String	getClusterName()
String	getCompressionDictionary()
String	getEmergencySourceRegion()
Set<String>	getPartitioners()
String	getPushJobId()
Version.PushType	getPushType()
int	getRepushSourceVersion()
long	getRewindTimeInSecondsOverride()
String	getSourceGridFabric()
String	getStoreName()
String	getTargetedRegions()
boolean	isDeferVersionSwap()
boolean	isSendStartOfPush()
boolean	isSeparateRealTimeTopicEnabled()
boolean	isSorted()
boolean	isWriteComputeEnabled()
void	setCertificateInRequest(X509Certificate certificateInRequest)
void	setCompressionDictionary(String compressionDictionary)
void	setDeferVersionSwap(boolean deferVersionSwap)
void	setEmergencySourceRegion(String emergencySourceRegion)
void	setPartitioners(String commaSeparatedPartitioners)
void	setPartitioners(Set<String> partitioners)
void	setRepushSourceVersion(int repushSourceVersion)
void	setRewindTimeInSecondsOverride(long rewindTimeInSecondsOverride)
void	setSendStartOfPush(boolean sendStartOfPush)
void	setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)
void	setSorted(boolean sorted)
void	setSourceGridFabric(String sourceGridFabric)
void	setTargetedRegions(String targetedRegions)
void	setWriteComputeEnabled(boolean writeComputeEnabled)

Methods inherited from class java.lang.Object

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

Constructor Details

RequestTopicForPushRequest

public RequestTopicForPushRequest(String clusterName,
 String storeName,
 Version.PushType pushType,
 String pushJobId)

Method Details

getClusterName

public String getClusterName()

getStoreName

public String getStoreName()

getPushType

public Version.PushType getPushType()

getPushJobId

public String getPushJobId()

isSendStartOfPush

public boolean isSendStartOfPush()

isSorted

public boolean isSorted()

isWriteComputeEnabled

public boolean isWriteComputeEnabled()

getSourceGridFabric

public String getSourceGridFabric()

getRewindTimeInSecondsOverride

public long getRewindTimeInSecondsOverride()

isDeferVersionSwap

public boolean isDeferVersionSwap()

getTargetedRegions

public String getTargetedRegions()

getRepushSourceVersion

public int getRepushSourceVersion()

getPartitioners

public Set<String> getPartitioners()

getCompressionDictionary

public String getCompressionDictionary()

getCertificateInRequest

public X509Certificate getCertificateInRequest()

getEmergencySourceRegion

public String getEmergencySourceRegion()

setSendStartOfPush

public void setSendStartOfPush(boolean sendStartOfPush)

setSorted

public void setSorted(boolean sorted)

setWriteComputeEnabled

public void setWriteComputeEnabled(boolean writeComputeEnabled)

setSourceGridFabric

public void setSourceGridFabric(String sourceGridFabric)

setRewindTimeInSecondsOverride

public void setRewindTimeInSecondsOverride(long rewindTimeInSecondsOverride)

setDeferVersionSwap

public void setDeferVersionSwap(boolean deferVersionSwap)

setTargetedRegions

public void setTargetedRegions(String targetedRegions)

setRepushSourceVersion

public void setRepushSourceVersion(int repushSourceVersion)

setPartitioners

public void setPartitioners(String commaSeparatedPartitioners)

setPartitioners

public void setPartitioners(Set<String> partitioners)

setCompressionDictionary

public void setCompressionDictionary(String compressionDictionary)

setCertificateInRequest

public void setCertificateInRequest(X509Certificate certificateInRequest)

setEmergencySourceRegion

public void setEmergencySourceRegion(String emergencySourceRegion)

isSeparateRealTimeTopicEnabled

public boolean isSeparateRealTimeTopicEnabled()

setSeparateRealTimeTopicEnabled

public void setSeparateRealTimeTopicEnabled(boolean separateRealTimeTopicEnabled)