@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'
Constructor and Description |
---|
AvroTableProvider() |
Modifier and Type | Method and Description |
---|---|
SchemaIOProvider |
getSchemaIOProvider() |
java.lang.String |
getTableType()
Gets the table type this provider handles.
|
buildBeamSqlTable, getTableStatistics
createTable, dropTable, getTables
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubProvider, getSubProviders, getTable
public SchemaIOProvider getSchemaIOProvider()
getSchemaIOProvider
in class SchemaIOTableProviderWrapper
public java.lang.String getTableType()
TableProvider
getTableType
in interface TableProvider
getTableType
in class SchemaIOTableProviderWrapper