Skip to content

Commit

Permalink
Modify empty value into space character
Browse files Browse the repository at this point in the history
  • Loading branch information
ttnghia committed Aug 31, 2023
1 parent c73ff70 commit d3d848b
Showing 1 changed file with 10 additions and 2 deletions.
12 changes: 10 additions & 2 deletions java/src/main/native/src/TableJni.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1592,7 +1592,11 @@ JNIEXPORT long JNICALL Java_ai_rapids_cudf_Table_writeParquetBufferBegin(
std::map<std::string, std::string> kv_metadata;
std::transform(meta_keys.begin(), meta_keys.end(), meta_values.begin(),
std::inserter(kv_metadata, kv_metadata.end()),
[](auto const &key, auto const &value) { return std::make_pair(key, value); });
[](auto const &key, auto const &value) {
// The metadata value will be ignored if it is empty.
// As such, we modify it into a space character instead.
return std::make_pair(key, value.empty() ? std::string(" ") : value);
});

auto stats = std::make_shared<cudf::io::writer_compression_statistics>();
chunked_parquet_writer_options opts =
Expand Down Expand Up @@ -1638,7 +1642,11 @@ JNIEXPORT long JNICALL Java_ai_rapids_cudf_Table_writeParquetFileBegin(
std::map<std::string, std::string> kv_metadata;
std::transform(meta_keys.begin(), meta_keys.end(), meta_values.begin(),
std::inserter(kv_metadata, kv_metadata.end()),
[](auto const &key, auto const &value) { return std::make_pair(key, value); });
[](auto const &key,
auto const &value) { // The metadata value will be ignored if it is empty.
// As such, we modify it into a space character instead.
return std::make_pair(key, value.empty() ? std::string(" ") : value);
});

sink_info sink{output_path.get()};
auto stats = std::make_shared<cudf::io::writer_compression_statistics>();
Expand Down

0 comments on commit d3d848b

Please sign in to comment.