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

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(value=TableProvider.class)
public class AvroTableProvider
extends SchemaIOTableProviderWrapper

TableProvider for AvroIO for consumption by Beam SQL.

Passes the AvroSchemaIOProvider to 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 and Description
AvroTableProvider()

Method Summary

Modifier and Type	Method and Description
SchemaIOProvider	getSchemaIOProvider()
java.lang.String	getTableType() 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

Constructor Detail

AvroTableProvider

public AvroTableProvider()

Method Detail

getSchemaIOProvider

public SchemaIOProvider getSchemaIOProvider()

Specified by:

getSchemaIOProvider in class SchemaIOTableProviderWrapper

getTableType

public java.lang.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