public interface BeamSqlPipelineOptions extends PipelineOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
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) |
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.String(value="org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner") java.lang.String getPlannerName()
void setPlannerName(java.lang.String className)
@Default.String(value="UTC") java.lang.String getZetaSqlDefaultTimezone()
void setZetaSqlDefaultTimezone(java.lang.String timezone)
@Default.Boolean(value=false) java.lang.Boolean getVerifyRowValues()
void setVerifyRowValues(java.lang.Boolean verifyRowValues)