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

Interface WordCount.WordCountOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

Enclosing class:

WordCount

public static interface WordCount.WordCountOptions
extends 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

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, 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, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, 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)