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

Class TableSchemaCache

java.lang.Object

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

public class TableSchemaCache
extends java.lang.Object

An updatable cache for table schemas.

Method Summary

Modifier and Type	Method and Description
TableSchema	getSchema(TableReference tableReference, BigQueryServices.DatasetService datasetService)
TableSchema	putSchemaIfAbsent(TableReference tableReference, TableSchema tableSchema) Registers schema for a table if one is not already present.
void	refreshSchema(TableReference tableReference, BigQueryServices.DatasetService datasetService)
void	refreshThread()

Methods inherited from class java.lang.Object

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

Method Detail

getSchema

@Nullable
public TableSchema getSchema(TableReference tableReference,
                                       BigQueryServices.DatasetService datasetService)

putSchemaIfAbsent

@Nullable
public TableSchema putSchemaIfAbsent(TableReference tableReference,
                                               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(TableReference tableReference,
                          BigQueryServices.DatasetService datasetService)

refreshThread

public void refreshThread()