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:
java.io.Serializable,TableProvider
@AutoService(TableProvider.class) public class DataStoreV1TableProvider extends SchemaIOTableProviderWrapper
TableProviderforDatastoreIOfor consumption by Beam SQL.Passes the
DataStoreV1SchemaIOProviderto 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.beam.sdk.schemas.io.SchemaIOProvidergetSchemaIOProvider()BeamTableStatisticsgetTableStatistics(org.apache.beam.sdk.options.PipelineOptions options, org.apache.beam.sdk.schemas.io.SchemaIO schemaIO)java.lang.StringgetTableType()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
-
-
-
-
Method Detail
-
getSchemaIOProvider
public org.apache.beam.sdk.schemas.io.SchemaIOProvider getSchemaIOProvider()
- Specified by:
getSchemaIOProviderin classSchemaIOTableProviderWrapper
-
getTableType
public java.lang.String getTableType()
Description copied from interface:TableProviderGets the table type this provider handles.- Specified by:
getTableTypein interfaceTableProvider- Overrides:
getTableTypein classSchemaIOTableProviderWrapper
-
getTableStatistics
public BeamTableStatistics getTableStatistics(org.apache.beam.sdk.options.PipelineOptions options, org.apache.beam.sdk.schemas.io.SchemaIO schemaIO)
- Overrides:
getTableStatisticsin classSchemaIOTableProviderWrapper
-
-