/src/duckdb/extension/parquet/serialize_parquet.cpp
Line | Count | Source |
1 | | //===----------------------------------------------------------------------===// |
2 | | // This file is automatically generated by scripts/generate_serialization.py |
3 | | // Do not edit this file manually, your changes will be overwritten |
4 | | //===----------------------------------------------------------------------===// |
5 | | |
6 | | #include "duckdb/common/serializer/serializer.hpp" |
7 | | #include "duckdb/common/serializer/deserializer.hpp" |
8 | | #include "parquet_reader.hpp" |
9 | | #include "parquet_crypto.hpp" |
10 | | #include "parquet_field_id.hpp" |
11 | | #include "parquet_shredding.hpp" |
12 | | |
13 | | namespace duckdb { |
14 | | |
15 | 0 | void ChildFieldIDs::Serialize(Serializer &serializer) const { |
16 | 0 | serializer.WritePropertyWithDefault<case_insensitive_map_t<FieldID>>(100, "ids", ids.operator*()); |
17 | 0 | } |
18 | | |
19 | 0 | ChildFieldIDs ChildFieldIDs::Deserialize(Deserializer &deserializer) { |
20 | 0 | ChildFieldIDs result; |
21 | 0 | deserializer.ReadPropertyWithDefault<case_insensitive_map_t<FieldID>>(100, "ids", result.ids.operator*()); |
22 | 0 | return result; |
23 | 0 | } |
24 | | |
25 | 0 | void ChildShreddingTypes::Serialize(Serializer &serializer) const { |
26 | 0 | serializer.WritePropertyWithDefault<case_insensitive_map_t<ShreddingType>>(100, "types", types.operator*()); |
27 | 0 | } |
28 | | |
29 | 0 | ChildShreddingTypes ChildShreddingTypes::Deserialize(Deserializer &deserializer) { |
30 | 0 | ChildShreddingTypes result; |
31 | 0 | deserializer.ReadPropertyWithDefault<case_insensitive_map_t<ShreddingType>>(100, "types", result.types.operator*()); |
32 | 0 | return result; |
33 | 0 | } |
34 | | |
35 | 0 | void FieldID::Serialize(Serializer &serializer) const { |
36 | 0 | serializer.WritePropertyWithDefault<bool>(100, "set", set); |
37 | 0 | serializer.WritePropertyWithDefault<int32_t>(101, "field_id", field_id); |
38 | 0 | serializer.WriteProperty<ChildFieldIDs>(102, "child_field_ids", child_field_ids); |
39 | 0 | } |
40 | | |
41 | 0 | FieldID FieldID::Deserialize(Deserializer &deserializer) { |
42 | 0 | FieldID result; |
43 | 0 | deserializer.ReadPropertyWithDefault<bool>(100, "set", result.set); |
44 | 0 | deserializer.ReadPropertyWithDefault<int32_t>(101, "field_id", result.field_id); |
45 | 0 | deserializer.ReadProperty<ChildFieldIDs>(102, "child_field_ids", result.child_field_ids); |
46 | 0 | return result; |
47 | 0 | } |
48 | | |
49 | 0 | void ParquetColumnDefinition::Serialize(Serializer &serializer) const { |
50 | 0 | serializer.WritePropertyWithDefault<int32_t>(100, "field_id", field_id); |
51 | 0 | serializer.WritePropertyWithDefault<string>(101, "name", name); |
52 | 0 | serializer.WriteProperty<LogicalType>(103, "type", type); |
53 | 0 | serializer.WriteProperty<Value>(104, "default_value", default_value); |
54 | 0 | serializer.WritePropertyWithDefault<Value>(105, "identifier", identifier, Value()); |
55 | 0 | } |
56 | | |
57 | 0 | ParquetColumnDefinition ParquetColumnDefinition::Deserialize(Deserializer &deserializer) { |
58 | 0 | ParquetColumnDefinition result; |
59 | 0 | deserializer.ReadPropertyWithDefault<int32_t>(100, "field_id", result.field_id); |
60 | 0 | deserializer.ReadPropertyWithDefault<string>(101, "name", result.name); |
61 | 0 | deserializer.ReadProperty<LogicalType>(103, "type", result.type); |
62 | 0 | deserializer.ReadProperty<Value>(104, "default_value", result.default_value); |
63 | 0 | deserializer.ReadPropertyWithExplicitDefault<Value>(105, "identifier", result.identifier, Value()); |
64 | 0 | return result; |
65 | 0 | } |
66 | | |
67 | 0 | void ParquetEncryptionConfig::Serialize(Serializer &serializer) const { |
68 | 0 | serializer.WritePropertyWithDefault<string>(100, "footer_key", footer_key); |
69 | 0 | serializer.WritePropertyWithDefault<unordered_map<string, string>>(101, "column_keys", column_keys); |
70 | 0 | } |
71 | | |
72 | 0 | shared_ptr<ParquetEncryptionConfig> ParquetEncryptionConfig::Deserialize(Deserializer &deserializer) { |
73 | 0 | auto result = duckdb::shared_ptr<ParquetEncryptionConfig>(new ParquetEncryptionConfig()); |
74 | 0 | deserializer.ReadPropertyWithDefault<string>(100, "footer_key", result->footer_key); |
75 | 0 | deserializer.ReadPropertyWithDefault<unordered_map<string, string>>(101, "column_keys", result->column_keys); |
76 | 0 | return result; |
77 | 0 | } |
78 | | |
79 | 0 | void ParquetOptionsSerialization::Serialize(Serializer &serializer) const { |
80 | 0 | serializer.WritePropertyWithDefault<bool>(100, "binary_as_string", parquet_options.binary_as_string); |
81 | 0 | serializer.WritePropertyWithDefault<bool>(101, "file_row_number", parquet_options.file_row_number); |
82 | 0 | serializer.WriteProperty<MultiFileOptions>(102, "file_options", file_options); |
83 | 0 | serializer.WritePropertyWithDefault<vector<ParquetColumnDefinition>>(103, "schema", parquet_options.schema); |
84 | 0 | serializer.WritePropertyWithDefault<shared_ptr<ParquetEncryptionConfig>>(104, "encryption_config", parquet_options.encryption_config, nullptr); |
85 | | /* [Deleted] (bool) "parquet_options.debug_use_openssl" */ |
86 | 0 | serializer.WritePropertyWithDefault<idx_t>(106, "explicit_cardinality", parquet_options.explicit_cardinality, 0); |
87 | 0 | serializer.WritePropertyWithDefault<bool>(107, "can_have_nan", parquet_options.can_have_nan, false); |
88 | 0 | } |
89 | | |
90 | 0 | ParquetOptionsSerialization ParquetOptionsSerialization::Deserialize(Deserializer &deserializer) { |
91 | 0 | ParquetOptionsSerialization result; |
92 | 0 | deserializer.ReadPropertyWithDefault<bool>(100, "binary_as_string", result.parquet_options.binary_as_string); |
93 | 0 | deserializer.ReadPropertyWithDefault<bool>(101, "file_row_number", result.parquet_options.file_row_number); |
94 | 0 | deserializer.ReadProperty<MultiFileOptions>(102, "file_options", result.file_options); |
95 | 0 | deserializer.ReadPropertyWithDefault<vector<ParquetColumnDefinition>>(103, "schema", result.parquet_options.schema); |
96 | 0 | deserializer.ReadPropertyWithExplicitDefault<shared_ptr<ParquetEncryptionConfig>>(104, "encryption_config", result.parquet_options.encryption_config, nullptr); |
97 | 0 | deserializer.ReadDeletedProperty<bool>(105, "debug_use_openssl"); |
98 | 0 | deserializer.ReadPropertyWithExplicitDefault<idx_t>(106, "explicit_cardinality", result.parquet_options.explicit_cardinality, 0); |
99 | 0 | deserializer.ReadPropertyWithExplicitDefault<bool>(107, "can_have_nan", result.parquet_options.can_have_nan, false); |
100 | 0 | return result; |
101 | 0 | } |
102 | | |
103 | 0 | void ShreddingType::Serialize(Serializer &serializer) const { |
104 | 0 | serializer.WritePropertyWithDefault<bool>(100, "set", set); |
105 | 0 | serializer.WriteProperty<LogicalType>(101, "type", type); |
106 | 0 | serializer.WriteProperty<ChildShreddingTypes>(102, "children", children); |
107 | 0 | } |
108 | | |
109 | 0 | ShreddingType ShreddingType::Deserialize(Deserializer &deserializer) { |
110 | 0 | ShreddingType result; |
111 | 0 | deserializer.ReadPropertyWithDefault<bool>(100, "set", result.set); |
112 | 0 | deserializer.ReadProperty<LogicalType>(101, "type", result.type); |
113 | 0 | deserializer.ReadProperty<ChildShreddingTypes>(102, "children", result.children); |
114 | 0 | return result; |
115 | 0 | } |
116 | | |
117 | | } // namespace duckdb |