[BEAM-7683] MongoDBIO.withQueryFn ignores custom filter

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.13.0
• Fix Version/s: 2.15.0
• Component/s: io-java-mongodb
• Assignee: Chaim
• Reporter: Chaim
• Created: 03/Jul/19 11:45
• Updated: 16/May/20 13:34
• Resolved: 04/Jul/19 09:18

Description

begin.apply(tableInfo.getTableName(), MongoDbIO.read()
.withUri("mongodb://" + connectionParams)
.withQueryFn(FindQuery.create().withFilters(filter))
.withDatabase(dbName)
.withNumSplits(splitCount)
.withCollection(tableInfo.getTableName()));

 

the filter in withQueryFn is ignored

Issue Links

• links to: GitHub Pull Request #9004