Skip to content

Commit ed8584f

Browse files
committed
[native] Include storageParameters in HiveConnectorSplit
1 parent 8930308 commit ed8584f

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

presto-native-execution/presto_cpp/main/types/PrestoToVeloxConnector.cpp

+6
Original file line numberDiff line numberDiff line change
@@ -1128,6 +1128,11 @@ HivePrestoToVeloxConnector::toVeloxSplit(
11281128
for (const auto& [key, value] : hiveSplit->storage.serdeParameters) {
11291129
serdeParameters[key] = value;
11301130
}
1131+
std::unordered_map<std::string, std::string> storageParameters;
1132+
storageParameters.reserve(hiveSplit->storage.parameters.size());
1133+
for (const auto& [key, value] : hiveSplit->storage.parameters) {
1134+
storageParameters[key] = value;
1135+
}
11311136
std::unordered_map<std::string, std::string> infoColumns = {
11321137
{"$path", hiveSplit->fileSplit.path},
11331138
{"$file_size", std::to_string(hiveSplit->fileSplit.fileSize)},
@@ -1151,6 +1156,7 @@ HivePrestoToVeloxConnector::toVeloxSplit(
11511156
customSplitInfo,
11521157
extraFileInfo,
11531158
serdeParameters,
1159+
storageParameters,
11541160
hiveSplit->splitWeight,
11551161
splitContext->cacheable,
11561162
infoColumns);

presto-native-execution/velox

Submodule velox updated 94 files

0 commit comments

Comments
 (0)