private void removePartitionResults ( QueryResult queryResult , int partitionId ) { List < QueryResultRow > rows = queryResult . getRows ( ) ; rows . removeIf ( resultRow -> getPartitionId ( resultRow ) == partitionId ) ; }
Remove matching entries from given result set with the given partition ID .