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

Table schema for KafkaIO.

See: Description

Class Summary

Class	Description
BeamKafkaAvroTable
BeamKafkaCSVTable	A Kafka topic that saves records as CSV format.
BeamKafkaJsonTable
BeamKafkaProtoTable
BeamKafkaTable	BeamKafkaTable represent a Kafka topic, as source or target.
BeamKafkaThriftTable<FieldT extends org.apache.thrift.TFieldIdEnum,T extends org.apache.thrift.TBase<T,FieldT>>	Kafka table that handles thrift data.
KafkaTableProvider	Kafka table provider.

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

Table schema for KafkaIO.