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

Class DataStoreV1TableProvider

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.provider.InMemoryMetaTableProvider

org.apache.beam.sdk.extensions.sql.meta.provider.SchemaIOTableProviderWrapper

org.apache.beam.sdk.extensions.sql.meta.provider.datastore.DataStoreV1TableProvider

All Implemented Interfaces:

Serializable, TableProvider

@AutoService(TableProvider.class)
public class DataStoreV1TableProvider
extends SchemaIOTableProviderWrapper

TableProvider for DatastoreIO for consumption by Beam SQL.

Passes the DataStoreV1SchemaIOProvider to the generalized table provider wrapper, SchemaIOTableProviderWrapper, for DataStoreV1 specific behavior.

A sample of DataStoreV1Table table is:

 CREATE TABLE ORDERS(
   name VARCHAR,
   favorite_color VARCHAR,
   favorite_numbers ARRAY<INTEGER>
 )
 TYPE 'datastoreV1'
 LOCATION 'projectId/kind'
 

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataStoreV1TableProvider()

Method Summary

Modifier and Type	Method	Description
SchemaIOProvider	getSchemaIOProvider()
BeamTableStatistics	getTableStatistics(PipelineOptions options, SchemaIO schemaIO)
String	getTableType()	Gets the table type this provider handles.

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.SchemaIOTableProviderWrapper

buildBeamSqlTable

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.InMemoryMetaTableProvider

createTable, dropTable, getTables

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

getSubProvider, getSubProviders, getTable, supportsPartitioning

Constructor Details

DataStoreV1TableProvider

public DataStoreV1TableProvider()

Method Details

getSchemaIOProvider

public SchemaIOProvider getSchemaIOProvider()

Specified by:

getSchemaIOProvider in class SchemaIOTableProviderWrapper

getTableType

public String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

Specified by:

getTableType in interface TableProvider

Overrides:

getTableType in class SchemaIOTableProviderWrapper

getTableStatistics

public BeamTableStatistics getTableStatistics(PipelineOptions options,
 SchemaIO schemaIO)

Overrides:

getTableStatistics in class SchemaIOTableProviderWrapper