Package org.apache.beam.sdk.io.gcp.bigquery

Class TableSchemaCache

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.TableSchemaCache

public class TableSchemaCache
extends Object

An updatable cache for table schemas.

Method Summary

Modifier and Type	Method	Description
@Nullable com.google.api.services.bigquery.model.TableSchema	getSchema(com.google.api.services.bigquery.model.TableReference tableReference, BigQueryServices.DatasetService datasetService)
@Nullable com.google.api.services.bigquery.model.TableSchema	putSchemaIfAbsent(com.google.api.services.bigquery.model.TableReference tableReference, com.google.api.services.bigquery.model.TableSchema tableSchema)	Registers schema for a table if one is not already present.
void	refreshSchema(com.google.api.services.bigquery.model.TableReference tableReference, BigQueryServices.DatasetService datasetService, BigQueryServices.WriteStreamService writeStreamService, BigQueryOptions options)
void	refreshThread()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getSchema

public @Nullable com.google.api.services.bigquery.model.TableSchema getSchema(com.google.api.services.bigquery.model.TableReference tableReference,
 BigQueryServices.DatasetService datasetService)

putSchemaIfAbsent

public @Nullable com.google.api.services.bigquery.model.TableSchema putSchemaIfAbsent(com.google.api.services.bigquery.model.TableReference tableReference,
 com.google.api.services.bigquery.model.TableSchema tableSchema)

Registers schema for a table if one is not already present. If a schema is already in the cache, returns the existing schema, otherwise returns null.

refreshSchema

public void refreshSchema(com.google.api.services.bigquery.model.TableReference tableReference,
 BigQueryServices.DatasetService datasetService,
 BigQueryServices.WriteStreamService writeStreamService,
 BigQueryOptions options)

refreshThread

public void refreshThread()