org.apache.beam.sdk.extensions.sql.impl.schema.kafka
Classes
BeamKafkaCSVTable
BeamKafkaCSVTable.CsvRecorderDecoder
BeamKafkaCSVTable.CsvRecorderEncoder
BeamKafkaTable