org.apache.beam.sdk.extensions.sql.impl

Interface BeamSqlPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface BeamSqlPipelineOptions
extends PipelineOptions

Options used to configure BeamSQL.

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	getPlannerName()
java.lang.Boolean	getVerifyRowValues()
java.lang.String	getZetaSqlDefaultTimezone()
void	setPlannerName(java.lang.String className)
void	setVerifyRowValues(java.lang.Boolean verifyRowValues)
void	setZetaSqlDefaultTimezone(java.lang.String timezone)

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

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

populateDisplayData

Method Detail

getPlannerName

@Default.String(value="org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner")
java.lang.String getPlannerName()

setPlannerName

void setPlannerName(java.lang.String className)

getZetaSqlDefaultTimezone

@Default.String(value="UTC")
java.lang.String getZetaSqlDefaultTimezone()

setZetaSqlDefaultTimezone

void setZetaSqlDefaultTimezone(java.lang.String timezone)

getVerifyRowValues

@Default.Boolean(value=false)
java.lang.Boolean getVerifyRowValues()

setVerifyRowValues

void setVerifyRowValues(java.lang.Boolean verifyRowValues)