Package google.registry.beam.rde

Interface RdePipelineOptions

All Superinterfaces:
org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions, org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions, RegistryPipelineOptions
public interface RdePipelineOptions extends RegistryPipelineOptions
Custom options for running the spec11 pipeline.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

    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.GcpOAuthScopesFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory

    Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

    org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer

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

    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

  • Field Summary

    Fields inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

    STREAMING_ENGINE_EXPERIMENT, WINDMILL_SERVICE_EXPERIMENT

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getPendings()
     
    String
    getRdeStagingBucket()
     
    String
    getStagingKey()
     
    String
    getValidationMode()
     
    void
    setPendings(String value)
     
    void
    setRdeStagingBucket(String value)
     
    void
    setStagingKey(String value)
     
    void
    setValidationMode(String value)
     

    Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

    getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpOauthScopes, getGcpTempLocation, getImpersonateServiceAccount, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpOauthScopes, setGcpTempLocation, setImpersonateServiceAccount, setProject, setWorkerRegion, setWorkerZone, setZone

    Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

    getGoogleApiTrace, setGoogleApiTrace

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

    populateDisplayData

    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 google.registry.beam.common.RegistryPipelineOptions

    getIsolationOverride, getJpaTransactionManagerType, getRegistryEnvironment, getSqlWriteBatchSize, setIsolationOverride, setJpaTransactionManagerType, setRegistryEnvironment, setSqlWriteBatchSize

  • Method Details

    • getPendings

      String getPendings()

    • setPendings

      void setPendings(String value)

    • getValidationMode

      String getValidationMode()

    • setValidationMode

      void setValidationMode(String value)

    • getRdeStagingBucket

      String getRdeStagingBucket()

    • setRdeStagingBucket

      void setRdeStagingBucket(String value)

    • getStagingKey

      String getStagingKey()

    • setStagingKey

      void setStagingKey(String value)