Function NewCondTraverseOp

src/execution_plan/ops/op_conditional_traverse.c:72–108

}

OpBase *NewCondTraverseOp
(
	const ExecutionPlan *plan,
	Graph *g,
	AlgebraicExpression *ae
) {
	OpCondTraverse *op = rm_calloc(sizeof(OpCondTraverse), 1);

	op->ae         = ae;
	op->graph      = g;
	op->record_cap = BATCH_SIZE;

	// Set our Op operations
	OpBase_Init((OpBase *)op, OPType_CONDITIONAL_TRAVERSE,
			"Conditional Traverse", CondTraverseInit, CondTraverseConsume,
			CondTraverseReset, CondTraverseToString, CondTraverseClone,
			CondTraverseFree, false, plan);

	bool aware = OpBase_Aware((OpBase *)op, AlgebraicExpression_Src(ae),
			&op->srcNodeIdx);
	UNUSED(aware);
	ASSERT(aware == true);

	const char *dest = AlgebraicExpression_Dest(ae);
	op->destNodeIdx = OpBase_Modifies((OpBase *)op, dest);

	const char *edge = AlgebraicExpression_Edge(ae);
	if(edge) {
		// this operation will populate an edge in the Record
		// prepare all necessary information for collecting matching edges
		uint edge_idx = OpBase_Modifies((OpBase *)op, edge);
		QGEdge *e = QueryGraph_GetEdgeByAlias(plan->query_graph, edge);
		op->edge_ctx = EdgeTraverseCtx_New(ae, e, edge_idx);
	}

	return (OpBase *)op;
}

static OpResult CondTraverseInit(OpBase *opBase) {
	OpCondTraverse *op = (OpCondTraverse *)opBase;