Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
49 changes: 7 additions & 42 deletions cpp/deeplake_pg/index_search.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -755,72 +755,37 @@ PGDLLEXPORT Datum deeplake_cosine_similarity(PG_FUNCTION_ARGS)

PGDLLEXPORT Datum deeplake_vector_lt(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
bool result = pg::pg_index::instance().vector_lt(v1, v2);
PG_RETURN_BOOL(result);
});
return array_lt(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_le(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
bool result = pg::pg_index::instance().vector_le(v1, v2);
PG_RETURN_BOOL(result);
});
return array_le(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_eq(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
const bool result = pg::pg_index::instance().vector_eq(v1, v2);
PG_RETURN_BOOL(result);
});
return array_eq(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_ne(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
bool result = pg::pg_index::instance().vector_ne(v1, v2);
PG_RETURN_BOOL(result);
});
return array_ne(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_ge(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
bool result = pg::pg_index::instance().vector_ge(v1, v2);
PG_RETURN_BOOL(result);
});
return array_ge(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_gt(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
bool result = pg::pg_index::instance().vector_gt(v1, v2);
PG_RETURN_BOOL(result);
});
return array_gt(fcinfo);
}

PGDLLEXPORT Datum deeplake_vector_compare(PG_FUNCTION_ARGS)
{
return pg::utils::pg_try([&] {
auto v1 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(0), false);
auto v2 = pg::utils::pg_to_nd(PG_GETARG_ARRAYTYPE_P(1), false);
int64_t result = pg::pg_index::instance().vector_compare(v1, v2);
PG_RETURN_INT32(result);
});
return btarraycmp(fcinfo);
}

PGDLLEXPORT Datum deeplake_maxsim(PG_FUNCTION_ARGS)
Expand Down