@@ -9,7 +9,7 @@ use url::Url;
9
9
10
10
use super :: schema:: StructType ;
11
11
use crate :: kernel:: { error:: Error , DeltaResult } ;
12
- use crate :: DeltaConfigKey ;
12
+ use crate :: TableProperty ;
13
13
14
14
/// Defines a file format used in table
15
15
#[ derive( Serialize , Deserialize , Debug , Clone , PartialEq , Eq ) ]
@@ -240,10 +240,10 @@ impl Protocol {
240
240
new_properties : & HashMap < String , String > ,
241
241
raise_if_not_exists : bool ,
242
242
) -> DeltaResult < Protocol > {
243
- let mut parsed_properties: HashMap < DeltaConfigKey , String > = HashMap :: new ( ) ;
243
+ let mut parsed_properties: HashMap < TableProperty , String > = HashMap :: new ( ) ;
244
244
245
245
for ( key, value) in new_properties {
246
- if let Ok ( parsed_key) = key. parse :: < DeltaConfigKey > ( ) {
246
+ if let Ok ( parsed_key) = key. parse :: < TableProperty > ( ) {
247
247
parsed_properties. insert ( parsed_key, value. to_string ( ) ) ;
248
248
} else if raise_if_not_exists {
249
249
return Err ( Error :: Generic ( format ! (
@@ -254,7 +254,7 @@ impl Protocol {
254
254
}
255
255
256
256
// Check and update delta.minReaderVersion
257
- if let Some ( min_reader_version) = parsed_properties. get ( & DeltaConfigKey :: MinReaderVersion ) {
257
+ if let Some ( min_reader_version) = parsed_properties. get ( & TableProperty :: MinReaderVersion ) {
258
258
let new_min_reader_version = min_reader_version. parse :: < i32 > ( ) ;
259
259
match new_min_reader_version {
260
260
Ok ( version) => match version {
@@ -280,7 +280,7 @@ impl Protocol {
280
280
}
281
281
282
282
// Check and update delta.minWriterVersion
283
- if let Some ( min_writer_version) = parsed_properties. get ( & DeltaConfigKey :: MinWriterVersion ) {
283
+ if let Some ( min_writer_version) = parsed_properties. get ( & TableProperty :: MinWriterVersion ) {
284
284
let new_min_writer_version = min_writer_version. parse :: < i32 > ( ) ;
285
285
match new_min_writer_version {
286
286
Ok ( version) => match version {
@@ -306,7 +306,7 @@ impl Protocol {
306
306
}
307
307
308
308
// Check enableChangeDataFeed and bump protocol or add writerFeature if writer versions is >=7
309
- if let Some ( enable_cdf) = parsed_properties. get ( & DeltaConfigKey :: EnableChangeDataFeed ) {
309
+ if let Some ( enable_cdf) = parsed_properties. get ( & TableProperty :: EnableChangeDataFeed ) {
310
310
let if_enable_cdf = enable_cdf. to_ascii_lowercase ( ) . parse :: < bool > ( ) ;
311
311
match if_enable_cdf {
312
312
Ok ( true ) => {
@@ -335,7 +335,7 @@ impl Protocol {
335
335
}
336
336
}
337
337
338
- if let Some ( enable_dv) = parsed_properties. get ( & DeltaConfigKey :: EnableDeletionVectors ) {
338
+ if let Some ( enable_dv) = parsed_properties. get ( & TableProperty :: EnableDeletionVectors ) {
339
339
let if_enable_dv = enable_dv. to_ascii_lowercase ( ) . parse :: < bool > ( ) ;
340
340
match if_enable_dv {
341
341
Ok ( true ) => {
0 commit comments