commit dc6e7583054f191e9267e9243f593a0f73c77295
author AlexanderSaydakov <AlexanderSaydakov@users.noreply.github.com> Mon Apr 17 19:56:01 2023 -0700
committer AlexanderSaydakov <AlexanderSaydakov@users.noreply.github.com> Mon Apr 17 19:56:01 2023 -0700
tree 5770f97b0be04276f5d244ef28ef3f75a76d1a4e
parent 5534d28ab81771ad5edb28d5ca538cd5c3fbcac1

removed unnecessary field

src/theta_sketch_pg_functions.c

diff --git a/src/theta_sketch_pg_functions.c b/src/theta_sketch_pg_functions.c
index 3f84a90..edcfa99 100644
--- a/src/theta_sketch_pg_functions.c
+++ b/src/theta_sketch_pg_functions.c
@@ -329,9 +329,8 @@
   } else if (stateptr->type == INTERSECTION) {
     stateptr->ptr = theta_intersection_get_result(stateptr->ptr);
   }
-  bytes_out = theta_sketch_serialize(stateptr->ptr, VARHDRSZ + 2);
-  ((char*)bytes_out.ptr)[VARHDRSZ] = IMMUTABLE_SKETCH;
-  ((char*)bytes_out.ptr)[VARHDRSZ + 1] = stateptr->lg_k;
+  bytes_out = theta_sketch_serialize(stateptr->ptr, VARHDRSZ + 1);
+  ((char*)bytes_out.ptr)[VARHDRSZ] = stateptr->lg_k;
   theta_sketch_delete(stateptr->ptr);
   pfree(stateptr);
   SET_VARSIZE(bytes_out.ptr, bytes_out.size);
@@ -357,9 +356,8 @@
 
   bytes_in = PG_GETARG_BYTEA_P(0);
   stateptr = palloc(sizeof(struct agg_state));
-  stateptr->type = *VARDATA(bytes_in);
-  stateptr->lg_k = *(VARDATA(bytes_in) + 1);
-  stateptr->ptr = theta_sketch_deserialize(VARDATA(bytes_in) + 2, VARSIZE(bytes_in) - VARHDRSZ - 2);
+  stateptr->lg_k = *VARDATA(bytes_in);
+  stateptr->ptr = theta_sketch_deserialize(VARDATA(bytes_in) + 1, VARSIZE(bytes_in) - VARHDRSZ - 1);
 
   MemoryContextSwitchTo(oldcontext);