Interface BeamWordCount.WordCountOptions

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

    public static interface BeamWordCount.WordCountOptions
    extends org.apache.beam.sdk.options.PipelineOptions
    Options supported by WordCount.

    Concept #4: Defining your own configuration options. Here, you can add your own arguments to be processed by the command-line parser, and specify default values for them. You can then access the options values in your pipeline code.

    Inherits standard configuration options.

    • 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
      String getInputFile()
      By default, this example reads from a public dataset containing the text of King Lear.
      String getOutput()
      Set this required option to specify where to write the output.
      void setInputFile​(String value)  
      void setOutput​(String value)  
      • 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

      • getInputFile

        @String("gs://apache-beam-samples/shakespeare/kinglear.txt")
        String getInputFile()
        By default, this example reads from a public dataset containing the text of King Lear. Set this option to choose a different input file or glob.
      • setInputFile

        void setInputFile​(String value)
      • getOutput

        @Required
        String getOutput()
        Set this required option to specify where to write the output.
      • setOutput

        void setOutput​(String value)