| 108 | } |
| 109 | |
| 110 | string TableSinkBase::UrlEncodePartitionValue(const string& raw_str) { |
| 111 | string encoded_str; |
| 112 | if (IsIceberg()) { |
| 113 | // Iceberg partition values should be URL encoded, but not Hive compatible way. |
| 114 | UrlEncode(raw_str, &encoded_str, false); |
| 115 | } else { |
| 116 | UrlEncode(raw_str, &encoded_str, true); |
| 117 | } |
| 118 | return encoded_str.empty() ? table_desc_->null_partition_key_value() : encoded_str; |
| 119 | } |
| 120 | |
| 121 | void TableSinkBase::BuildHdfsFileNames( |
| 122 | const HdfsPartitionDescriptor& partition_descriptor, |