How to convert Documents read from Mongo Collection using MongoDbIO.read() directly to a table row w-CodePudding

Read read= MongoDbIO.read().withUri(<uri>).withBucketAuto(true)
            .withDatabase(<db>).withCollection(<collection>);

PCollection<Document> lines = p.apply(read);

How to convert lines to tablerows dynamically without fetching each line and setting the table row like this:

String offer_id=document.getString("oid");
TableRow row;
row=new TableRow().set("offerId", offer_id)

CodePudding user response：

I don't think it's possible now since anyway MongodbIO.Read will return a PCollection<Document> that has to be converted into PCollection<TableRow>.

However, if you need it to write the result of MongodbIO.Read into BigQuery then I think you may try to use BigQueryIO.Write.withFormatFunction(...) and provide a function to convert MongoDB document into TableRow. Though, I think it will be kind of the same in terms of performance.