Package org.apache.nemo.compiler.frontend.beam

Interface NemoPipelineOptions

  • All Superinterfaces:
    org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions
    public interface NemoPipelineOptions
extends org.apache.beam.sdk.options.PipelineOptions
    NemoPipelineOptions.

    • Nested Class Summary

      • 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
      java.lang.Long getMaxBundleSize()  
      java.lang.Long getMaxBundleTimeMills()  
      void setMaxBundleSize​(java.lang.Long size)  
      void setMaxBundleTimeMills​(java.lang.Long time)  

      • 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

      • getMaxBundleSize

        @Long(1000L)
java.lang.Long getMaxBundleSize()
        Returns:
        the maximum number of elements in a bundle.

      • setMaxBundleSize

        void setMaxBundleSize​(java.lang.Long size)
        Parameters:
        size - the maximum number of elements in a bundle.

      • getMaxBundleTimeMills

        @Long(1000L)
java.lang.Long getMaxBundleTimeMills()
        Returns:
        the maximum time to wait before finalising a bundle (in milliseconds).

      • setMaxBundleTimeMills

        void setMaxBundleTimeMills​(java.lang.Long time)
        Parameters:
        time - the maximum time to wait before finalising a bundle (in milliseconds).