Class AvroTableProvider
- 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.avro.AvroTableProvider
-
- All Implemented Interfaces:
java.io.Serializable,TableProvider
@AutoService(TableProvider.class) public class AvroTableProvider extends SchemaIOTableProviderWrapper
TableProviderforAvroIOfor consumption by Beam SQL.Passes the
AvroSchemaIOProviderto the generalized table provider wrapper,SchemaIOTableProviderWrapper, for Avro specific behavior.A sample of avro table is:
CREATE EXTERNAL TABLE ORDERS( name VARCHAR, favorite_color VARCHAR, favorite_numbers ARRAY<INTEGER> ) TYPE 'avro' LOCATION '/tmp/persons.avro'- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AvroTableProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.beam.sdk.schemas.io.SchemaIOProvidergetSchemaIOProvider()java.lang.StringgetTableType()Gets the table type this provider handles.-
Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.SchemaIOTableProviderWrapper
buildBeamSqlTable, getTableStatistics
-
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
-
-