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

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

getDataCatalogEndpoint

@Validation.Required
 @Default.String(value="datacatalog.googleapis.com:443")
java.lang.String getDataCatalogEndpoint()

DataCatalog endpoint.

setDataCatalogEndpoint

void setDataCatalogEndpoint(java.lang.String dataCatalogEndpoint)

getTruncateTimestamps

@Validation.Required
 @Default.Boolean(value=false)
boolean getTruncateTimestamps()

Whether to truncate timestamps in tables described by Data Catalog.

setTruncateTimestamps

void setTruncateTimestamps(boolean newValue)