Package org.apache.beam.sdk.extensions.sql.example

Interface BeamSqlDataCatalogExample.DCExamplePipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

Enclosing class:

BeamSqlDataCatalogExample

public static interface BeamSqlDataCatalogExample.DCExamplePipelineOptions
extends PipelineOptions

Pipeline options to specify the query and the output for the example.

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	getOutputFilePrefix()	Output file prefix.
String	getQueryString()	SQL Query.
void	setOutputFilePrefix(String outputPathPrefix)
void	setQueryString(String queryString)

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

getQueryString

@Required
String getQueryString()

SQL Query.

setQueryString

void setQueryString(String queryString)

getOutputFilePrefix

@Required
String getOutputFilePrefix()

Output file prefix.

setOutputFilePrefix

void setOutputFilePrefix(String outputPathPrefix)