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

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getQueryString

@Validation.Required
java.lang.String getQueryString()

SQL Query.

setQueryString

void setQueryString(java.lang.String queryString)

getOutputFilePrefix

@Validation.Required
java.lang.String getOutputFilePrefix()

Output file prefix.

setOutputFilePrefix

void setOutputFilePrefix(java.lang.String outputPathPrefix)