Package org.apache.calcite.adapter.kafka

Class KafkaTableFactory

java.lang.Object

org.apache.calcite.adapter.kafka.KafkaTableFactory

All Implemented Interfaces:

TableFactory<KafkaStreamTable>

public class KafkaTableFactory
extends Object
implements TableFactory<KafkaStreamTable>

Implementation of TableFactory for Apache Kafka. Currently an Apache Kafka topic is mapping to a STREAM table.

Constructor Summary

Constructors

Constructor	Description
KafkaTableFactory()

Method Summary

Modifier and Type	Method	Description
KafkaStreamTable	create(SchemaPlus schema, String name, Map<String,Object> operand, @Nullable RelDataType rowType)	Creates a Table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaTableFactory

public KafkaTableFactory()

Method Details

create

public KafkaStreamTable create(SchemaPlus schema,
 String name,
 Map<String,Object> operand,
 @Nullable RelDataType rowType)

Description copied from interface: TableFactory

Creates a Table.

Specified by:

create in interface TableFactory<KafkaStreamTable>

Parameters:

schema - Schema this table belongs to

name - Name of this table

operand - The "operand" JSON property

rowType - Row type. Specified if the "columns" JSON property.

Returns:

created table