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
