@AutoService(value=TableProvider.class) public class KafkaTableProvider extends InMemoryMetaTableProvider
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 and Description |
---|
KafkaTableProvider() |
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.
|
createTable, dropTable, getTables
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubProvider, getSubProviders, getTable, supportsPartitioning
public BeamSqlTable buildBeamSqlTable(Table table)
TableProvider
BeamSqlTable
using the given table meta info.public java.lang.String getTableType()
TableProvider