public class PayloadSerializerKafkaTable extends BeamKafkaTable
numberOfRecordsForRate
schema
Modifier and Type | Method and Description |
---|---|
protected PTransform<PCollection<KafkaRecord<byte[],byte[]>>,PCollection<Row>> |
getPTransformForInput() |
protected PTransform<PCollection<Row>,PCollection<ProducerRecord<byte[],byte[]>>> |
getPTransformForOutput() |
buildIOReader, buildIOWriter, getBootstrapServers, getTableStatistics, getTopics, isBounded, updateConsumerProperties
getSchema
buildIOReader, constructFilter, supportsProjects
protected PTransform<PCollection<KafkaRecord<byte[],byte[]>>,PCollection<Row>> getPTransformForInput()
getPTransformForInput
in class BeamKafkaTable
protected PTransform<PCollection<Row>,PCollection<ProducerRecord<byte[],byte[]>>> getPTransformForOutput()
getPTransformForOutput
in class BeamKafkaTable