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

Interface BeamSqlPipelineOptions

All Superinterfaces:

org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions

public interface BeamSqlPipelineOptions
extends org.apache.beam.sdk.options.PipelineOptions

Options used to configure BeamSQL.

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
java.util.Map<java.lang.String,java.lang.String>	getCalciteConnectionProperties()
java.lang.String	getPlannerName()
java.lang.Boolean	getVerifyRowValues()
java.lang.String	getZetaSqlDefaultTimezone()
void	setCalciteConnectionProperties(java.util.Map<java.lang.String,java.lang.String> properties)
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.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 Detail

getPlannerName

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

setPlannerName

void setPlannerName(java.lang.String className)

getCalciteConnectionProperties

java.util.Map<java.lang.String,java.lang.String> getCalciteConnectionProperties()

setCalciteConnectionProperties

void setCalciteConnectionProperties(java.util.Map<java.lang.String,java.lang.String> properties)

getZetaSqlDefaultTimezone

@String("UTC")
java.lang.String getZetaSqlDefaultTimezone()

setZetaSqlDefaultTimezone

void setZetaSqlDefaultTimezone(java.lang.String timezone)

getVerifyRowValues

@Boolean(false)
java.lang.Boolean getVerifyRowValues()

setVerifyRowValues

void setVerifyRowValues(java.lang.Boolean verifyRowValues)