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

Class ParquetTableProvider

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.parquet.ParquetTableProvider

All Implemented Interfaces:

java.io.Serializable, TableProvider

@AutoService(value=TableProvider.class)
public class ParquetTableProvider
extends SchemaIOTableProviderWrapper

TableProvider for ParquetIO for consumption by Beam SQL.

Passes the ParquetSchemaIOProvider to the generalized table provider wrapper, SchemaIOTableProviderWrapper, for Parquet specific behavior.

A sample of parquet table is:

 CREATE TABLE ORDERS(
   name VARCHAR,
   favorite_color VARCHAR,
   favorite_numbers ARRAY<INTEGER>
 )
 TYPE 'parquet'
 LOCATION '/home/admin/users.parquet'
 

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ParquetTableProvider()

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

ParquetTableProvider

public ParquetTableProvider()

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