org.apache.beam.sdk.expansion.service

Interface ExpansionServiceOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface ExpansionServiceOptions
extends PipelineOptions

Options used to configure the ExpansionService.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ExpansionServiceOptions.ExpansionServiceConfigFactory Loads the ExpansionService config.
static class	ExpansionServiceOptions.JavaClassLookupAllowListFactory Loads the allow list from getJavaClassLookupAllowlistFile(), defaulting to an empty JavaClassLookupTransformProvider.AllowList.

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
boolean	getAlsoStartLoopbackWorker()
ExpansionServiceConfig	getExpansionServiceConfig()
java.lang.String	getExpansionServiceConfigFile()
org.apache.beam.sdk.expansion.service.JavaClassLookupTransformProvider.AllowList	getJavaClassLookupAllowlist()
java.lang.String	getJavaClassLookupAllowlistFile()
void	setAlsoStartLoopbackWorker(boolean value)
void	setExpansionServiceConfig(ExpansionServiceConfig configFile)
void	setExpansionServiceConfigFile(java.lang.String configFile)
void	setJavaClassLookupAllowlist(org.apache.beam.sdk.expansion.service.JavaClassLookupTransformProvider.AllowList file)
void	setJavaClassLookupAllowlistFile(java.lang.String file)

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

getJavaClassLookupAllowlist

@Default.InstanceFactory(value=ExpansionServiceOptions.JavaClassLookupAllowListFactory.class)
org.apache.beam.sdk.expansion.service.JavaClassLookupTransformProvider.AllowList getJavaClassLookupAllowlist()

setJavaClassLookupAllowlist

void setJavaClassLookupAllowlist(org.apache.beam.sdk.expansion.service.JavaClassLookupTransformProvider.AllowList file)

getJavaClassLookupAllowlistFile

java.lang.String getJavaClassLookupAllowlistFile()

setJavaClassLookupAllowlistFile

void setJavaClassLookupAllowlistFile(java.lang.String file)

getAlsoStartLoopbackWorker

boolean getAlsoStartLoopbackWorker()

setAlsoStartLoopbackWorker

void setAlsoStartLoopbackWorker(boolean value)

getExpansionServiceConfigFile

java.lang.String getExpansionServiceConfigFile()

setExpansionServiceConfigFile

void setExpansionServiceConfigFile(java.lang.String configFile)

getExpansionServiceConfig

@Default.InstanceFactory(value=ExpansionServiceOptions.ExpansionServiceConfigFactory.class)
ExpansionServiceConfig getExpansionServiceConfig()

setExpansionServiceConfig

void setExpansionServiceConfig(ExpansionServiceConfig configFile)