BeamSqlPipelineOptions (Apache Beam 2.68.0)

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

Description

Map<String,String>

getCalciteConnectionProperties()

String

getPlannerName()

Boolean

getVerifyRowValues()

String

getZetaSqlDefaultTimezone()

void

setCalciteConnectionProperties(Map<String,String> properties)

void

setPlannerName(String className)

void

setVerifyRowValues(Boolean verifyRowValues)

void

setZetaSqlDefaultTimezone(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, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Details
- getPlannerName
  
  @String("org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner") String getPlannerName()
- setPlannerName
  
  void setPlannerName(String className)
- getCalciteConnectionProperties
  
  Map<String,String> getCalciteConnectionProperties()
- setCalciteConnectionProperties
  
  void setCalciteConnectionProperties(Map<String,String> properties)
- getZetaSqlDefaultTimezone
  
  @String("UTC") String getZetaSqlDefaultTimezone()
- setZetaSqlDefaultTimezone
  
  void setZetaSqlDefaultTimezone(String timezone)
- getVerifyRowValues
  
  @Boolean(false) Boolean getVerifyRowValues()
- setVerifyRowValues
  
  void setVerifyRowValues(Boolean verifyRowValues)