Package org.apache.beam.runners.direct

Interface DirectOptions

  • All Superinterfaces:
    org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions
    public interface DirectOptions
extends org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.options.ApplicationNameOptions
    Options that can be used to configure the DirectRunner.

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Interface Description
      static class  DirectOptions.AvailableParallelismFactory
      A DefaultValueFactory that returns the result of Runtime.availableProcessors() from the DirectOptions.AvailableParallelismFactory.create(PipelineOptions) method.

      • 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

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      int getTargetParallelism()  
      boolean isBlockOnRun()  
      boolean isEnforceEncodability()  
      boolean isEnforceImmutability()  
      void setBlockOnRun​(boolean b)  
      void setEnforceEncodability​(boolean test)  
      void setEnforceImmutability​(boolean test)  
      void setTargetParallelism​(int target)  

      • Methods inherited from interface org.apache.beam.sdk.options.ApplicationNameOptions

        getAppName, setAppName

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

        populateDisplayData

      • Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

        as, getGbek, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setGbek, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

    • Method Detail

      • isBlockOnRun

        @Boolean(true)
boolean isBlockOnRun()

      • setBlockOnRun

        void setBlockOnRun​(boolean b)

      • isEnforceImmutability

        @Boolean(true)
boolean isEnforceImmutability()

      • setEnforceImmutability

        void setEnforceImmutability​(boolean test)

      • isEnforceEncodability

        @Boolean(true)
boolean isEnforceEncodability()

      • setEnforceEncodability

        void setEnforceEncodability​(boolean test)

      • setTargetParallelism

        void setTargetParallelism​(int target)