recompress_chunk_segmentwise_impl

Author: svenklemm

tsl/src/compression/recompress.c

@@ -126,7 +126,7 @@ tsl_recompress_chunk_segmentwise(PG_FUNCTION_ARGS)
 				 NameStr(chunk->fd.schema_name),
 				 NameStr(chunk->fd.table_name));
 		}
-		uncompressed_relid = recompress_chunk_segmentwise_impl(chunk, nullable_orderby);
+		recompress_chunk_segmentwise_impl(chunk, nullable_orderby);
 	}
 
 	PG_RETURN_OID(uncompressed_relid);
@@ -235,7 +235,7 @@ free_chunk_recompress_ctx(RecompressContext *recompress_ctx)
 	pfree(recompress_ctx);
 }
 
-Oid
+void
 recompress_chunk_segmentwise_impl(Chunk *uncompressed_chunk,
 								  bool fullrecompress /* do full decompress/compress segmentwise */)
 {
@@ -307,7 +307,7 @@ recompress_chunk_segmentwise_impl(Chunk *uncompressed_chunk,
 			table_close(uncompressed_chunk_rel, NoLock);
 			table_close(compressed_chunk_rel, NoLock);
 
-			PG_RETURN_OID(uncompressed_relid);
+			return;
 		}
 	}
 
@@ -739,8 +739,6 @@ recompress_chunk_segmentwise_impl(Chunk *uncompressed_chunk,
 
 	table_close(uncompressed_chunk_rel, NoLock);
 	table_close(compressed_chunk_rel, NoLock);
-
-	PG_RETURN_OID(uncompressed_relid);
 }
 
 /*

tsl/src/compression/recompress.h

@@ -30,7 +30,7 @@ typedef struct RecompressContext
 
 extern Datum tsl_recompress_chunk_segmentwise(PG_FUNCTION_ARGS);
 
-Oid recompress_chunk_segmentwise_impl(Chunk *chunk, bool fullrecompress);
+void recompress_chunk_segmentwise_impl(Chunk *chunk, bool fullrecompress);
 bool recompress_chunk_in_memory_impl(Chunk *uncompressed_chunk);
 
 /* Result of matching an uncompressed tuple against a compressed batch */