Package com.linkedin.venice.samza

Class VeniceSystemProducerConfig.Builder

java.lang.Object

com.linkedin.venice.samza.VeniceSystemProducerConfig.Builder

Enclosing class:

VeniceSystemProducerConfig

public static class VeniceSystemProducerConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
VeniceSystemProducerConfig	build()
VeniceSystemProducerConfig.Builder	setDiscoveryUrl(String discoveryUrl)
VeniceSystemProducerConfig.Builder	setFactory(VeniceSystemFactory factory)
VeniceSystemProducerConfig.Builder	setPartitioners(String partitioners)
VeniceSystemProducerConfig.Builder	setPrimaryControllerColoD2ZKHost(String primaryControllerColoD2ZKHost)
VeniceSystemProducerConfig.Builder	setPrimaryControllerD2ServiceName(String primaryControllerD2ServiceName)
VeniceSystemProducerConfig.Builder	setProvidedChildColoD2Client(com.linkedin.d2.balancer.D2Client providedChildColoD2Client)
VeniceSystemProducerConfig.Builder	setProvidedPrimaryControllerColoD2Client(com.linkedin.d2.balancer.D2Client providedPrimaryControllerColoD2Client)
VeniceSystemProducerConfig.Builder	setPushType(Version.PushType pushType)
VeniceSystemProducerConfig.Builder	setRouterUrl(String routerUrl)
VeniceSystemProducerConfig.Builder	setRunningFabric(String runningFabric)
VeniceSystemProducerConfig.Builder	setSamzaConfig(org.apache.samza.config.Config samzaConfig)
VeniceSystemProducerConfig.Builder	setSamzaJobId(String samzaJobId)
VeniceSystemProducerConfig.Builder	setSslFactory(SSLFactory sslFactory)
VeniceSystemProducerConfig.Builder	setStoreName(String storeName)
VeniceSystemProducerConfig.Builder	setTime(Time time)
VeniceSystemProducerConfig.Builder	setVeniceChildD2ZkHost(String veniceChildD2ZkHost)
VeniceSystemProducerConfig.Builder	setVerifyLatestProtocolPresent(boolean verifyLatestProtocolPresent)
VeniceSystemProducerConfig.Builder	setWriterHook(VeniceWriterHook writerHook)

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

setStoreName

public VeniceSystemProducerConfig.Builder setStoreName(String storeName)

Parameters:

storeName - the Venice store to write to (required)

setPushType

public VeniceSystemProducerConfig.Builder setPushType(Version.PushType pushType)

Parameters:

pushType - the Version.PushType to use for writing (required)

setSamzaJobId

public VeniceSystemProducerConfig.Builder setSamzaJobId(String samzaJobId)

Parameters:

samzaJobId - unique ID for jobs that may concurrently write to the same store

setRunningFabric

public VeniceSystemProducerConfig.Builder setRunningFabric(String runningFabric)

Parameters:

runningFabric - the colo where the job is running, used to determine the optimal write destination

setVerifyLatestProtocolPresent

public VeniceSystemProducerConfig.Builder setVerifyLatestProtocolPresent(boolean verifyLatestProtocolPresent)

Parameters:

verifyLatestProtocolPresent - whether to verify that runtime protocol versions are valid in Venice backend

setVeniceChildD2ZkHost

public VeniceSystemProducerConfig.Builder setVeniceChildD2ZkHost(String veniceChildD2ZkHost)

Parameters:

veniceChildD2ZkHost - D2 ZK address where components in the child colo announce themselves

setPrimaryControllerColoD2ZKHost

public VeniceSystemProducerConfig.Builder setPrimaryControllerColoD2ZKHost(String primaryControllerColoD2ZKHost)

Parameters:

primaryControllerColoD2ZKHost - D2 ZK address of the colo where the primary controller resides

setPrimaryControllerD2ServiceName

public VeniceSystemProducerConfig.Builder setPrimaryControllerD2ServiceName(String primaryControllerD2ServiceName)

Parameters:

primaryControllerD2ServiceName - the D2 service name the primary controller uses to announce itself

setProvidedChildColoD2Client

public VeniceSystemProducerConfig.Builder setProvidedChildColoD2Client(com.linkedin.d2.balancer.D2Client providedChildColoD2Client)

Parameters:

providedChildColoD2Client - pre-configured D2Client for the child colo (must be paired with primary)

setProvidedPrimaryControllerColoD2Client

public VeniceSystemProducerConfig.Builder setProvidedPrimaryControllerColoD2Client(com.linkedin.d2.balancer.D2Client providedPrimaryControllerColoD2Client)

Parameters:

providedPrimaryControllerColoD2Client - pre-configured D2Client for the primary controller colo (must be paired with child)

setDiscoveryUrl

public VeniceSystemProducerConfig.Builder setDiscoveryUrl(String discoveryUrl)

Parameters:

discoveryUrl - controller discovery URL (mutually exclusive with ZK hosts and D2 clients)

setFactory

public VeniceSystemProducerConfig.Builder setFactory(VeniceSystemFactory factory)

Parameters:

factory - the VeniceSystemFactory that created this producer

setSslFactory

public VeniceSystemProducerConfig.Builder setSslFactory(SSLFactory sslFactory)

Parameters:

sslFactory - SSL factory for secure communication, or null to disable SSL

setPartitioners

public VeniceSystemProducerConfig.Builder setPartitioners(String partitioners)

Parameters:

partitioners - comma-separated list of supported partitioner class names, or null for default

setTime

public VeniceSystemProducerConfig.Builder setTime(Time time)

Parameters:

time - time provider, defaults to SystemTime.INSTANCE. Must not be null.

setWriterHook

public VeniceSystemProducerConfig.Builder setWriterHook(VeniceWriterHook writerHook)

Parameters:

writerHook - callback invoked before each produce for backpressure/quota throttling

setSamzaConfig

public VeniceSystemProducerConfig.Builder setSamzaConfig(org.apache.samza.config.Config samzaConfig)

Parameters:

samzaConfig - the Samza job Config, applied as additional writer properties

setRouterUrl

public VeniceSystemProducerConfig.Builder setRouterUrl(String routerUrl)

Parameters:

routerUrl - Venice router URL for schema verification

build

public VeniceSystemProducerConfig build()