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

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

Table schema for KafkaIO.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.meta.provider	Table providers.

Classes

Class	Description
BeamKafkaCSVTable	A Kafka topic that saves records as CSV format.
BeamKafkaTable	BeamKafkaTable represent a Kafka topic, as source or target.
KafkaTableProvider	Kafka table provider.
PayloadSerializerKafkaTable