Interface BatchLogRead.BatchLogReadPipelineOptions

  • All Superinterfaces:
    org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions
    Enclosing class:
    BatchLogRead

    public static interface BatchLogRead.BatchLogReadPipelineOptions
    extends org.apache.beam.sdk.options.PipelineOptions
    • 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
      long getStartBatchReadDelayMs()  
      void setStartBatchReadDelayMs​(long readDelayMs)  
      • 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
    • Method Detail

      • getStartBatchReadDelayMs

        @Long(0L)
        long getStartBatchReadDelayMs()
      • setStartBatchReadDelayMs

        void setStartBatchReadDelayMs​(long readDelayMs)