Trying to port flink code to Apache Beam but I'm having trouble decoding the 
documentation.

I have flink code which looks like:

DataSet<GenericRecord> d1 = Read parquet
DataSet<GenericRecord> d2 = Read Avro
KeyExtractor<GenericRecord> k1 = ... (extracts an object containing the key 
fields from d1 records)
KeyExtractor<GenericRecord> k2 = ... (extracts an object containing the key 
fields from d2 records)

CoGroup<GenericRecord,GenericRecord,GenericRecord> grouper = (combines values 
for equal keys in to a combined list for that key)

DataSet<GenericRecord> combined = 
d1.coGroup(d2).where(k1).equalTo(k2).with(grouper)

Whats the beam equivalent?

Thanks



Reply via email to