fix merge

apache · Feb 21, 2024 · 17fcf81 · 17fcf81
1 parent b7f7724
commit 17fcf81
Show file tree

Hide file tree

Showing 2 changed files with 99 additions and 11 deletions.
diff --git a/core/Cargo.lock b/core/Cargo.lock
diff --git a/core/src/parquet/util/test_common/page_util.rs b/core/src/parquet/util/test_common/page_util.rs
@@ -22,7 +22,7 @@ use rand::distributions::uniform::SampleUniform;
 use parquet::{
     basic::Encoding,
     column::page::{Page, PageIterator, PageMetadata, PageReader},
-    data_type::{AsBytes, DataType},
+    data_type::DataType,
     encodings::{
         encoding::{get_encoder, DictEncoder, Encoder},
         levels::{max_buffer_size, LevelEncoder},
@@ -31,8 +31,6 @@ use parquet::{
     schema::types::{ColumnDescPtr, SchemaDescPtr},
 };
 
-use crate::parquet::util::memory::ByteBufferPtr;
-
 use super::random_numbers_range;
 use bytes::Bytes;
 use zstd::zstd_safe::WriteBuf;
@@ -292,7 +290,7 @@ pub fn make_pages<T: DataType>(
                 let indices = dict_encoder
                     .write_indices()
                     .expect("write_indices() should be OK");
-                pb.add_indices(ByteBufferPtr::new(indices.as_bytes().to_vec()));
+                pb.add_indices(indices);
             }
             Encoding::PLAIN => {
                 pb.add_values::<T>(encoding, &values[value_range]);