Package org.apache.beam.runners.spark.structuredstreaming.examples

Interface WordCount.WordCountOptions

All Superinterfaces:
org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions
Enclosing class:
WordCount
public static interface WordCount.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

    Modifier and Type
    Method
    Description
    String
    getInputFile()
     
    String
    getOutput()
     
    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, getGbek, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setGbek, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

  • Method Details

    • getInputFile

      @String("gs://beam-samples/shakespeare/kinglear.txt") String getInputFile()

    • setInputFile

      void setInputFile(String value)

    • getOutput

      String getOutput()

    • setOutput

      void setOutput(String value)