My aggregate query is
db.collection.Aggregate([{ “$match” : { “IsDeleted” : { “$ne” : true } } },
{“$match” : { “$expr” : { “$eq” : [{ “$toString” : “$Body.group” }, “group name”] }}}])
and after this I am using join statement
.Join(otherCollection,
main => main.Id,
other => other.Id,
(main, other) => new Entity
{
Id = main.Id,
Model = main.Model,
Body = main.Body,
Status = main.Status,
Version = main.Version,
WorkFlowInfo = other.Body
});