fix: remove extra preprocess

Signed-off-by: usamoi <[email protected]>
tensorchord · Nov 20, 2024 · ce55ed8 · ce55ed8
1 parent a1d9f78
commit ce55ed8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/index/am.rs b/src/index/am.rs
@@ -190,7 +190,7 @@ pub unsafe extern "C" fn ambuild(
                 let vector = unsafe { opfamily.datum_to_vector(*values.add(0), *is_null.add(0)) };
                 let pointer = unsafe { ctid_to_pointer(ctid.read()) };
                 if let Some(vector) = vector {
-                    let vector = match opfamily.preprocess(vector.as_borrowed()) {
+                    let vector = match vector {
                         OwnedVector::Vecf32(x) => x,
                         OwnedVector::Vecf16(_) => unreachable!(),
                         OwnedVector::SVecf32(_) => unreachable!(),
@@ -567,7 +567,7 @@ unsafe fn parallel_build(
                 let vector = unsafe { opfamily.datum_to_vector(*values.add(0), *is_null.add(0)) };
                 let pointer = unsafe { ctid_to_pointer(ctid.read()) };
                 if let Some(vector) = vector {
-                    let vector = match opfamily.preprocess(vector.as_borrowed()) {
+                    let vector = match vector {
                         OwnedVector::Vecf32(x) => x,
                         OwnedVector::Vecf16(_) => unreachable!(),
                         OwnedVector::SVecf32(_) => unreachable!(),
@@ -662,7 +662,7 @@ pub unsafe extern "C" fn aminsert(
     let opfamily = unsafe { am_options::opfamily(index) };
     let vector = unsafe { opfamily.datum_to_vector(*values.add(0), *is_null.add(0)) };
     if let Some(vector) = vector {
-        let vector = match opfamily.preprocess(vector.as_borrowed()) {
+        let vector = match vector {
             OwnedVector::Vecf32(x) => x,
             OwnedVector::Vecf16(_) => unreachable!(),
             OwnedVector::SVecf32(_) => unreachable!(),
@@ -695,7 +695,7 @@ pub unsafe extern "C" fn aminsert(
     let opfamily = unsafe { am_options::opfamily(index) };
     let vector = unsafe { opfamily.datum_to_vector(*values.add(0), *is_null.add(0)) };
     if let Some(vector) = vector {
-        let vector = match opfamily.preprocess(vector.as_borrowed()) {
+        let vector = match vector {
             OwnedVector::Vecf32(x) => x,
             OwnedVector::Vecf16(_) => unreachable!(),
             OwnedVector::SVecf32(_) => unreachable!(),

diff --git a/src/index/am_scan.rs b/src/index/am_scan.rs
@@ -76,7 +76,7 @@ pub fn scan_next(scanner: &mut Scanner, relation: Relation) -> Option<(Pointer,
         if let Some((vector, opfamily)) = vector.as_ref() {
             let vbase = scan(
                 relation,
-                match opfamily.preprocess(vector.as_borrowed()) {
+                match vector {
                     OwnedVector::Vecf32(x) => x.slice().to_vec(),
                     OwnedVector::Vecf16(_) => unreachable!(),
                     OwnedVector::SVecf32(_) => unreachable!(),