public interface OutputOptions
extends org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions
CompositeOutput
transform.org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.EnableStreamingEngineFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory
org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer
org.apache.beam.sdk.options.PipelineOptions.AtomicLongFactory, org.apache.beam.sdk.options.PipelineOptions.CheckEnabled, org.apache.beam.sdk.options.PipelineOptions.DirectRunner, org.apache.beam.sdk.options.PipelineOptions.JobNameFactory, org.apache.beam.sdk.options.PipelineOptions.UserAgentFactory
getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpTempLocation, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpTempLocation, setProject, setWorkerRegion, setWorkerZone, setZone
getGoogleApiTrace, setGoogleApiTrace
String getOutputFile()
void setOutputFile(String value)
String getOutputBigQuery()
void setOutputBigQuery(String value)
String[] getOutputPubsub()
void setOutputPubsub(String[] value)
String getOutputSqs()
void setOutputSqs(String value)
String[] getOutputIprepd()
void setOutputIprepd(String[] value)
@Default.Boolean(value=false) Boolean getOutputIprepdEnableDatastoreExemptions()
void setOutputIprepdEnableDatastoreExemptions(Boolean value)
String getOutputIprepdDatastoreExemptionsProject()
void setOutputIprepdDatastoreExemptionsProject(String value)
String getOutputAlertSmtpCredentials()
void setOutputAlertSmtpCredentials(String value)
String getOutputAlertSmtpRelay()
void setOutputAlertSmtpRelay(String value)
String getOutputAlertEmailFrom()
void setOutputAlertEmailFrom(String value)
String getOutputAlertEmailCatchall()
void setOutputAlertEmailCatchall(String value)
String getOutputAlertSlackToken()
void setOutputAlertSlackToken(String value)
String getOutputAlertSlackCatchall()
void setOutputAlertSlackCatchall(String value)
@Validation.Required String getMonitoredResourceIndicator()
void setMonitoredResourceIndicator(String value)
String getAlertStateMemcachedHost()
void setAlertStateMemcachedHost(String value)
@Default.Integer(value=11211) Integer getAlertStateMemcachedPort()
void setAlertStateMemcachedPort(Integer value)
String getAlertStateDatastoreNamespace()
void setAlertStateDatastoreNamespace(String value)
String getAlertStateDatastoreKind()
void setAlertStateDatastoreKind(String value)
String getOutputAlertGcsTemplateBasePath()
void setOutputAlertGcsTemplateBasePath(String value)
@Hidden String[] getOutputAlertTemplates()
@Hidden void setOutputAlertTemplates(String[] value)
String getCriticalNotificationEmail()
void setCriticalNotificationEmail(String value)
static org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone> compositeOutput(OutputOptions o)
Copyright © 2022. All rights reserved.