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

Class KafkaTableProvider

java.lang.Object

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

org.apache.beam.sdk.extensions.sql.meta.provider.kafka.KafkaTableProvider

All Implemented Interfaces:

TableProvider

@AutoService(value=TableProvider.class)
public class KafkaTableProvider
extends InMemoryMetaTableProvider

Kafka table provider.

A sample of text table is:

 CREATE TABLE ORDERS(
   ID INT COMMENT 'this is the primary key',
   NAME VARCHAR(127) COMMENT 'this is the name'
 )
 COMMENT 'this is the table orders'
 LOCATION 'kafka://localhost:2181/brokers?topic=test'
 TBLPROPERTIES '{"bootstrap.servers":"localhost:9092", "topics": ["topic1", "topic2"]}'
 

Constructor Summary

Constructors

Constructor and Description
KafkaTableProvider()

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) Build a BeamSqlTable using the given table meta info.
java.lang.String	getTableType() Gets the table type this provider handles.

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

Constructor Detail

KafkaTableProvider

public KafkaTableProvider()

Method Detail

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.