Package org.apache.beam.sdk.extensions.sql.meta.provider.datacatalog

Interface DataCatalogPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface DataCatalogPipelineOptions
extends PipelineOptions

Pipeline options for Data Catalog table provider.

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
String	getDataCatalogEndpoint()	DataCatalog endpoint.
boolean	getTruncateTimestamps()	Whether to truncate timestamps in tables described by Data Catalog.
void	setDataCatalogEndpoint(String dataCatalogEndpoint)
void	setTruncateTimestamps(boolean newValue)

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

getDataCatalogEndpoint

@Required
@String("datacatalog.googleapis.com:443")
String getDataCatalogEndpoint()

DataCatalog endpoint.

setDataCatalogEndpoint

void setDataCatalogEndpoint(String dataCatalogEndpoint)

getTruncateTimestamps

@Required
@Boolean(false)
boolean getTruncateTimestamps()

Whether to truncate timestamps in tables described by Data Catalog.

setTruncateTimestamps

void setTruncateTimestamps(boolean newValue)