org.apache.beam.sdk.extensions.python

Interface PythonExternalTransformOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface PythonExternalTransformOptions
extends PipelineOptions

Pipeline options for PythonExternalTransform.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCustomBeamRequirement()
boolean	getUseTransformService()
void	setCustomBeamRequirement(java.lang.String customBeamRequirement) Set custom Beam version for bootstrap Beam venv.
void	setUseTransformService(boolean useTransformService)

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getUseTransformService

@Default.Boolean(value=false)
boolean getUseTransformService()

setUseTransformService

void setUseTransformService(boolean useTransformService)

getCustomBeamRequirement

java.lang.String getCustomBeamRequirement()

setCustomBeamRequirement

void setCustomBeamRequirement(java.lang.String customBeamRequirement)

Set custom Beam version for bootstrap Beam venv.

For example: 2.50.0rc1, "/path/to/apache-beam.whl"