org.apache.beam.it.gcp.datagenerator

Class DataGenerator.Builder

java.lang.Object

org.apache.beam.it.gcp.datagenerator.DataGenerator.Builder

Enclosing class:

DataGenerator

public static final class DataGenerator.Builder
extends java.lang.Object

Builder for the DataGenerator.

Method Summary

Modifier and Type	Method and Description
DataGenerator	build()
java.lang.String	getJobName()
java.util.Map<java.lang.String,java.lang.String>	getParameters()
DataGenerator.Builder	setAutoscalingAlgorithm(DataGenerator.AutoscalingAlgorithmType value)
DataGenerator.Builder	setAvroSchemaLocation(java.lang.String value)
DataGenerator.Builder	setConnectionProperties(java.lang.String value)
DataGenerator.Builder	setConnectionUrl(java.lang.String value)
DataGenerator.Builder	setDriverClassName(java.lang.String value)
DataGenerator.Builder	setMaxNumWorkers(java.lang.String value)
DataGenerator.Builder	setMessagesLimit(java.lang.String value)
DataGenerator.Builder	setNumShards(java.lang.String value)
DataGenerator.Builder	setNumWorkers(java.lang.String value)
DataGenerator.Builder	setOutputDirectory(java.lang.String value)
DataGenerator.Builder	setOutputType(java.lang.String value)
DataGenerator.Builder	setPassword(java.lang.String value)
DataGenerator.Builder	setProjectId(java.lang.String value)
DataGenerator.Builder	setQPS(java.lang.String value)
DataGenerator.Builder	setSchemaLocation(java.lang.String value)
DataGenerator.Builder	setSchemaTemplate(java.lang.String value)
DataGenerator.Builder	setSinkType(java.lang.String value)
DataGenerator.Builder	setSpannerDatabaseName(java.lang.String value)
DataGenerator.Builder	setSpannerInstanceName(java.lang.String value)
DataGenerator.Builder	setSpannerTableName(java.lang.String value)
DataGenerator.Builder	setStatement(java.lang.String value)
DataGenerator.Builder	setTopic(java.lang.String value)
DataGenerator.Builder	setUsername(java.lang.String value)
DataGenerator.Builder	setWorkerMachineType(java.lang.String value)

Methods inherited from class java.lang.Object

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

Method Detail

getJobName

public java.lang.String getJobName()

getParameters

public java.util.Map<java.lang.String,java.lang.String> getParameters()

setSchemaTemplate

public DataGenerator.Builder setSchemaTemplate(java.lang.String value)

setSchemaLocation

public DataGenerator.Builder setSchemaLocation(java.lang.String value)

setMessagesLimit

public DataGenerator.Builder setMessagesLimit(java.lang.String value)

setQPS

public DataGenerator.Builder setQPS(java.lang.String value)

setSinkType

public DataGenerator.Builder setSinkType(java.lang.String value)

setWorkerMachineType

public DataGenerator.Builder setWorkerMachineType(java.lang.String value)

setNumWorkers

public DataGenerator.Builder setNumWorkers(java.lang.String value)

setMaxNumWorkers

public DataGenerator.Builder setMaxNumWorkers(java.lang.String value)

setAutoscalingAlgorithm

public DataGenerator.Builder setAutoscalingAlgorithm(DataGenerator.AutoscalingAlgorithmType value)

setOutputDirectory

public DataGenerator.Builder setOutputDirectory(java.lang.String value)

setOutputType

public DataGenerator.Builder setOutputType(java.lang.String value)

setNumShards

public DataGenerator.Builder setNumShards(java.lang.String value)

setAvroSchemaLocation

public DataGenerator.Builder setAvroSchemaLocation(java.lang.String value)

setTopic

public DataGenerator.Builder setTopic(java.lang.String value)

setProjectId

public DataGenerator.Builder setProjectId(java.lang.String value)

setSpannerInstanceName

public DataGenerator.Builder setSpannerInstanceName(java.lang.String value)

setSpannerDatabaseName

public DataGenerator.Builder setSpannerDatabaseName(java.lang.String value)

setSpannerTableName

public DataGenerator.Builder setSpannerTableName(java.lang.String value)

setDriverClassName

public DataGenerator.Builder setDriverClassName(java.lang.String value)

setConnectionUrl

public DataGenerator.Builder setConnectionUrl(java.lang.String value)

setUsername

public DataGenerator.Builder setUsername(java.lang.String value)

setPassword

public DataGenerator.Builder setPassword(java.lang.String value)

setConnectionProperties

public DataGenerator.Builder setConnectionProperties(java.lang.String value)

setStatement

public DataGenerator.Builder setStatement(java.lang.String value)

build

public DataGenerator build()