public class BeamKafkaCSVTable extends BeamKafkaTable
Modifier and Type | Class and Description |
---|---|
static class |
BeamKafkaCSVTable.CsvRecorderDecoder
A PTransform to convert
KV<byte[], byte[]> to Row . |
static class |
BeamKafkaCSVTable.CsvRecorderEncoder
A PTransform to convert
Row to KV<byte[], byte[]> . |
numberOfRecordsForRate
schema
Constructor and Description |
---|
BeamKafkaCSVTable(Schema beamSchema,
java.lang.String bootstrapServers,
java.util.List<java.lang.String> topics) |
BeamKafkaCSVTable(Schema beamSchema,
java.lang.String bootstrapServers,
java.util.List<java.lang.String> topics,
CSVFormat format) |
Modifier and Type | Method and Description |
---|---|
PTransform<PCollection<KV<byte[],byte[]>>,PCollection<Row>> |
getPTransformForInput() |
PTransform<PCollection<Row>,PCollection<KV<byte[],byte[]>>> |
getPTransformForOutput() |
buildIOReader, buildIOWriter, getBootstrapServers, getTableStatistics, getTopics, isBounded, updateConsumerProperties
getSchema
buildIOReader, constructFilter, supportsProjects
public BeamKafkaCSVTable(Schema beamSchema, java.lang.String bootstrapServers, java.util.List<java.lang.String> topics)
public PTransform<PCollection<KV<byte[],byte[]>>,PCollection<Row>> getPTransformForInput()
getPTransformForInput
in class BeamKafkaTable
public PTransform<PCollection<Row>,PCollection<KV<byte[],byte[]>>> getPTransformForOutput()
getPTransformForOutput
in class BeamKafkaTable