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.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

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.lang.String getGcsBucket()  
      java.lang.String getPendings()  
      java.lang.String getStagingKey()  
      java.lang.String getValidationMode()  
      void setGcsBucket​(java.lang.String value)  
      void setPendings​(java.lang.String value)  
      void setStagingKey​(java.lang.String value)  
      void setValidationMode​(java.lang.String value)  
      • Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

        getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpTempLocation, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpTempLocation, 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, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
    • Method Detail

      • getPendings

        java.lang.String getPendings()
      • setPendings

        void setPendings​(java.lang.String value)
      • getValidationMode

        java.lang.String getValidationMode()
      • setValidationMode

        void setValidationMode​(java.lang.String value)
      • getGcsBucket

        java.lang.String getGcsBucket()
      • setGcsBucket

        void setGcsBucket​(java.lang.String value)
      • getStagingKey

        java.lang.String getStagingKey()
      • setStagingKey

        void setStagingKey​(java.lang.String value)