Read
Read<K, V>
is a root PTransform to produce PCollection of KafkaRecords (PTransform<PBegin, PCollection<KafkaRecord<K, V>>>
).
Read is a static class of KafkaIO.
expand Method
PCollection<KafkaRecord<K, V>> expand(
PBegin input)
expand…FIXME
expand is part of PTransform abstraction.