Package google.registry.beam.spec11

Interface Spec11PipelineOptions

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 Spec11PipelineOptions 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
    getDate()
     
    String
    getReportingBucketUrl()
     
    String
    getSafeBrowsingApiKey()
     
    void
    setDate(String value)
     
    void
    setReportingBucketUrl(String value)
     
    void
    setSafeBrowsingApiKey(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

    • getDate

      String getDate()

    • setDate

      void setDate(String value)

    • getSafeBrowsingApiKey

      String getSafeBrowsingApiKey()

    • setSafeBrowsingApiKey

      void setSafeBrowsingApiKey(String value)

    • getReportingBucketUrl

      String getReportingBucketUrl()

    • setReportingBucketUrl

      void setReportingBucketUrl(String value)