vendor: Update vendored sources to duckdb/duckdb@d769821

Parquet Reader: for DeltaLengthByteArray encoding, directly refer to strings from the block without copying (duckdb/duckdb#16186)

Author: krlmlr

src/duckdb/extension/parquet/column_reader.cpp

@@ -549,7 +549,7 @@ void ColumnReader::ReadData(idx_t read_now, data_ptr_t define_out, data_ptr_t re
 		rle_decoder.Read(define_ptr, read_now, result, result_offset);
 		break;
 	case ColumnEncoding::DELTA_LENGTH_BYTE_ARRAY:
-		delta_length_byte_array_decoder.Read(define_ptr, read_now, result, result_offset);
+		delta_length_byte_array_decoder.Read(block, define_ptr, read_now, result, result_offset);
 		break;
 	case ColumnEncoding::DELTA_BYTE_ARRAY:
 		delta_byte_array_decoder.Read(define_ptr, read_now, result, result_offset);

src/duckdb/extension/parquet/decoder/delta_length_byte_array_decoder.cpp

@@ -2,12 +2,12 @@
 #include "decoder/delta_byte_array_decoder.hpp"
 #include "column_reader.hpp"
 #include "parquet_reader.hpp"
-#include "reader/templated_column_reader.hpp"
+#include "reader/string_column_reader.hpp"
 
 namespace duckdb {
 
 DeltaLengthByteArrayDecoder::DeltaLengthByteArrayDecoder(ColumnReader &reader)
-    : reader(reader), length_buffer(reader.encoding_buffers[0]) {
+    : reader(reader), length_buffer(reader.encoding_buffers[0]), length_idx(0) {
 }
 
 void DeltaLengthByteArrayDecoder::InitializePage() {
@@ -21,8 +21,9 @@ void DeltaLengthByteArrayDecoder::InitializePage() {
 	length_idx = 0;
 }
 
-void DeltaLengthByteArrayDecoder::Read(uint8_t *defines, idx_t read_count, Vector &result, idx_t result_offset) {
-	auto &block = *reader.block;
+void DeltaLengthByteArrayDecoder::Read(shared_ptr<ResizeableBuffer> &block_ref, uint8_t *defines, idx_t read_count,
+                                       Vector &result, idx_t result_offset) {
+	auto &block = *block_ref;
 	auto length_data = reinterpret_cast<uint32_t *>(length_buffer.ptr);
 	auto result_data = FlatVector::GetData<string_t>(result);
 	auto &result_mask = FlatVector::Validity(result);
@@ -40,17 +41,16 @@ void DeltaLengthByteArrayDecoder::Read(uint8_t *defines, idx_t read_count, Vecto
 		}
 		auto str_len = length_data[length_idx++];
 		block.available(str_len);
-		result_data[result_idx] = StringVector::EmptyString(result, str_len);
-		auto str_data = result_data[result_idx].GetDataWriteable();
-		memcpy(str_data, block.ptr, str_len);
-		block.inc(str_len);
-		result_data[result_idx].Finalize();
+		result_data[result_idx] = string_t(char_ptr_cast(block.ptr), str_len);
+		block.unsafe_inc(str_len);
 	}
+	StringColumnReader::ReferenceBlock(result, block_ref);
 }
 
 void DeltaLengthByteArrayDecoder::Skip(uint8_t *defines, idx_t skip_count) {
 	auto &block = *reader.block;
 	auto length_data = reinterpret_cast<uint32_t *>(length_buffer.ptr);
+	idx_t skip_bytes = 0;
 	for (idx_t row_idx = 0; row_idx < skip_count; row_idx++) {
 		if (defines && defines[row_idx] != reader.MaxDefine()) {
 			continue;
@@ -61,9 +61,9 @@ void DeltaLengthByteArrayDecoder::Skip(uint8_t *defines, idx_t skip_count) {
 			    "read of %d from %d entries) - corrupt file?",
 			    length_idx, byte_array_count);
 		}
-		auto str_len = length_data[length_idx++];
-		block.inc(str_len);
+		skip_bytes += length_data[length_idx++];
 	}
+	block.inc(skip_bytes);
 }
 
 } // namespace duckdb

src/duckdb/extension/parquet/include/decoder/delta_length_byte_array_decoder.hpp

@@ -22,7 +22,8 @@ class DeltaLengthByteArrayDecoder {
 public:
 	void InitializePage();
 
-	void Read(uint8_t *defines, idx_t read_count, Vector &result, idx_t result_offset);
+	void Read(shared_ptr<ResizeableBuffer> &block, uint8_t *defines, idx_t read_count, Vector &result,
+	          idx_t result_offset);
 	void Skip(uint8_t *defines, idx_t skip_count);
 
 private:

src/duckdb/extension/parquet/include/reader/string_column_reader.hpp

@@ -25,6 +25,8 @@ class StringColumnReader : public ColumnReader {
 	static void VerifyString(const char *str_data, uint32_t str_len, const bool isVarchar);
 	void VerifyString(const char *str_data, uint32_t str_len);
 
+	static void ReferenceBlock(Vector &result, shared_ptr<ResizeableBuffer> &block);
+
 protected:
 	void Plain(ByteBuffer &plain_data, uint8_t *defines, idx_t num_values, idx_t result_offset,
 	           Vector &result) override {

src/duckdb/extension/parquet/reader/string_column_reader.cpp

@@ -45,9 +45,13 @@ class ParquetStringVectorBuffer : public VectorBuffer {
 	shared_ptr<ResizeableBuffer> buffer;
 };
 
+void StringColumnReader::ReferenceBlock(Vector &result, shared_ptr<ResizeableBuffer> &block) {
+	StringVector::AddBuffer(result, make_buffer<ParquetStringVectorBuffer>(block));
+}
+
 void StringColumnReader::Plain(shared_ptr<ResizeableBuffer> &plain_data, uint8_t *defines, idx_t num_values,
                                idx_t result_offset, Vector &result) {
-	StringVector::AddBuffer(result, make_buffer<ParquetStringVectorBuffer>(plain_data));
+	ReferenceBlock(result, plain_data);
 	PlainTemplated<string_t, StringParquetValueConversion>(*plain_data, defines, num_values, result_offset, result);
 }
 
@@ -57,7 +61,7 @@ void StringColumnReader::PlainSkip(ByteBuffer &plain_data, uint8_t *defines, idx
 
 void StringColumnReader::PlainSelect(shared_ptr<ResizeableBuffer> &plain_data, uint8_t *defines, idx_t num_values,
                                      Vector &result, const SelectionVector &sel, idx_t count) {
-	StringVector::AddBuffer(result, make_buffer<ParquetStringVectorBuffer>(plain_data));
+	ReferenceBlock(result, plain_data);
 	PlainSelectTemplated<string_t, StringParquetValueConversion>(*plain_data, defines, num_values, result, sel, count);
 }
 

src/duckdb/src/function/table/version/pragma_version.cpp

@@ -1,5 +1,5 @@
 #ifndef DUCKDB_PATCH_VERSION
-#define DUCKDB_PATCH_VERSION "1-dev203"
+#define DUCKDB_PATCH_VERSION "1-dev205"
 #endif
 #ifndef DUCKDB_MINOR_VERSION
 #define DUCKDB_MINOR_VERSION 2
@@ -8,10 +8,10 @@
 #define DUCKDB_MAJOR_VERSION 1
 #endif
 #ifndef DUCKDB_VERSION
-#define DUCKDB_VERSION "v1.2.1-dev203"
+#define DUCKDB_VERSION "v1.2.1-dev205"
 #endif
 #ifndef DUCKDB_SOURCE_ID
-#define DUCKDB_SOURCE_ID "1584c228c8"
+#define DUCKDB_SOURCE_ID "d76982157f"
 #endif
 #include "duckdb/function/table/system_functions.hpp"
 #include "duckdb/main/database.hpp"