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'
 TYPE kafka
 // Optional. One broker host:port pair to bootstrap with and a topic.
 // Only one topic overall may be provided for writing.
 LOCATION 'my.company.url.com:2181/topic1'
 // Extra bootstrap_servers and topics can be provided explicitly. These will be merged
 // with the server and topic in LOCATION.
 TBLPROPERTIES '{
   "bootstrap_servers": ["104.126.7.88:7743", "104.111.9.22:7743"],
   "topics": ["topic2", "topic3"]
 }'
 

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

getSubProvider, getSubProviders, getTable

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.