File tree Expand file tree Collapse file tree 4 files changed +11
-10
lines changed
storages/fuse/src/io/read/block Expand file tree Collapse file tree 4 files changed +11
-10
lines changed Original file line number Diff line number Diff line change @@ -845,9 +845,9 @@ impl DefaultSettings {
845
845
scope : SettingScope :: Both ,
846
846
range : Some ( SettingRange :: Numeric ( 2 ..=u64:: MAX ) ) ,
847
847
} ) ,
848
- ( "use_parquet2 " , DefaultSettingValue {
848
+ ( "use_experimental_parquet_reader " , DefaultSettingValue {
849
849
value : UserSettingValue :: UInt64 ( 0 ) ,
850
- desc : "This setting is deprecated " ,
850
+ desc : "Use experimental parquet reader to deserialize parquet data of fuse table. " ,
851
851
mode : SettingMode :: Both ,
852
852
scope : SettingScope :: Both ,
853
853
range : Some ( SettingRange :: Numeric ( 0 ..=1 ) ) ,
Original file line number Diff line number Diff line change @@ -656,12 +656,12 @@ impl Settings {
656
656
self . try_get_u64 ( "auto_compaction_segments_limit" )
657
657
}
658
658
659
- pub fn get_use_parquet2 ( & self ) -> Result < bool > {
660
- Ok ( self . try_get_u64 ( "use_parquet2 " ) ? != 0 )
659
+ pub fn get_use_experimental_parquet_reader ( & self ) -> Result < bool > {
660
+ Ok ( self . try_get_u64 ( "use_experimental_parquet_reader " ) ? != 0 )
661
661
}
662
662
663
- pub fn set_use_parquet2 ( & self , val : bool ) -> Result < ( ) > {
664
- self . try_set_u64 ( "use_parquet2 " , u64:: from ( val) )
663
+ pub fn set_use_experimental_parquet_reader ( & self , val : bool ) -> Result < ( ) > {
664
+ self . try_set_u64 ( "use_experimental_parquet_reader " , u64:: from ( val) )
665
665
}
666
666
667
667
pub fn get_enable_replace_into_partitioning ( & self ) -> Result < bool > {
Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ pub struct BlockReader {
52
52
53
53
pub original_schema : TableSchemaRef ,
54
54
pub native_columns_reader : NativeColumnsReader ,
55
- pub use_parquet2_to_read_parquet : bool ,
55
+ pub use_experimental_parquet_reader : bool ,
56
56
}
57
57
58
58
fn inner_project_field_default_values ( default_vals : & [ Scalar ] , paths : & [ usize ] ) -> Result < Scalar > {
@@ -139,7 +139,8 @@ impl BlockReader {
139
139
140
140
let project_indices = Self :: build_projection_indices ( & project_column_nodes) ;
141
141
142
- let use_parquet2_to_read_parquet = ctx. get_settings ( ) . get_use_parquet2 ( ) ?;
142
+ let use_experimental_parquet_reader =
143
+ ctx. get_settings ( ) . get_use_experimental_parquet_reader ( ) ?;
143
144
144
145
Ok ( Arc :: new ( BlockReader {
145
146
ctx,
@@ -154,7 +155,7 @@ impl BlockReader {
154
155
put_cache,
155
156
original_schema : schema,
156
157
native_columns_reader,
157
- use_parquet2_to_read_parquet ,
158
+ use_experimental_parquet_reader ,
158
159
} ) )
159
160
}
160
161
Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ impl BlockReader {
51
51
compression : & Compression ,
52
52
block_path : & str ,
53
53
) -> databend_common_exception:: Result < DataBlock > {
54
- if self . use_parquet2_to_read_parquet {
54
+ if self . use_experimental_parquet_reader {
55
55
self . deserialize_v2 (
56
56
block_path,
57
57
num_rows,
You can’t perform that action at this time.
0 commit comments