diff --git a/analytical_engine/apps/flash/api.h b/analytical_engine/apps/flash/api.h index 1c07fc863b7c..136e7c2d5920 100644 --- a/analytical_engine/apps/flash/api.h +++ b/analytical_engine/apps/flash/api.h @@ -142,7 +142,8 @@ template VSet edgeMapDenseFunction(const fragment_t& graph, const std::shared_ptr fw, VSet& U, int h, - VSet& T, F& f, M& m, C& c, bool b = true) { + VSet& T, bool is_join, F& f, M& m, C& c, + bool b = true) { if ((&T) == (&All)) return edgeMapDenseFunction(graph, fw, U, h, f, m, c, b); using vertex_t = typename fragment_t::vertex_t; @@ -219,7 +220,8 @@ template VSet edgeMapDenseFunction(const fragment_t& graph, const std::shared_ptr fw, VSet& U, H& h, - VSet& T, F& f, M& m, C& c, bool b = true) { + VSet& T, bool is_join, F& f, M& m, C& c, + bool b = true) { using vid_t = typename fragment_t::vid_t; using edata_t = typename fragment_t::edata_t; bool flag = ((&U) == (&All)); @@ -381,8 +383,9 @@ template inline VSet edgeMapFunction(const fragment_t& graph, const std::shared_ptr fw, VSet& U, H h, - VSet& T, F& f, M& m, C& c, bool b = true) { - return edgeMapDenseFunction(graph, fw, U, h, T, f, m, c, b); + VSet& T, bool is_join, F& f, M& m, C& c, + bool b = true) { + return edgeMapDenseFunction(graph, fw, U, h, T, is_join, f, m, c, b); } template diff --git a/analytical_engine/apps/flash/flash_utils.h b/analytical_engine/apps/flash/flash_utils.h index aa23369a5b7b..9bc330cb34f0 100644 --- a/analytical_engine/apps/flash/flash_utils.h +++ b/analytical_engine/apps/flash/flash_utils.h @@ -110,7 +110,7 @@ namespace gs { #define CTrueV cTrueV #define CTrueE cTrueE -#define EjoinV(E, V) E, V +#define EjoinV(E, V) E, V, true #define VjoinP(property) \ std::vector res; \ res.clear(); \