Package org.apache.beam.sdk.extensions.sql.impl.schema.kafka

table schema for KafkaIO.

See: Description

Class Summary

Class	Description
BeamKafkaCSVTable	A Kafka topic that saves records as CSV format.
BeamKafkaCSVTable.CsvRecorderDecoder	A PTransform to convert KV<byte[], byte[]> to BeamRecord.
BeamKafkaCSVTable.CsvRecorderEncoder	A PTransform to convert BeamRecord to KV<byte[], byte[]>.
BeamKafkaTable	BeamKafkaTable represent a Kafka topic, as source or target.

Package org.apache.beam.sdk.extensions.sql.impl.schema.kafka Description

table schema for KafkaIO.