clean

kuzudb · Jan 3, 2023 · 1155255 · 1155255
1 parent 342577f
commit 1155255
Showing 1 changed file with 0 additions and 28 deletions.
diff --git a/src/planner/operator/sink_util.cpp b/src/planner/operator/sink_util.cpp
@@ -3,34 +3,6 @@
 namespace kuzu {
 namespace planner {
 
-// void SinkOperatorUtil::mergeSchema(
-//    const Schema& inputSchema, Schema& result, const vector<string>& keys) {
-//    unordered_map<uint32_t, vector<string>> keyGroupPosToKeysMap;
-//    for (auto& key : keys) {
-//        auto groupPos = inputSchema.getGroupPos(key);
-//        keyGroupPosToKeysMap[groupPos].push_back(key);
-//    }
-//    for (auto& [keyGroupPos, keysInGroup] : keyGroupPosToKeysMap) {
-//        mergeKeyGroup(inputSchema, result, keyGroupPos, keysInGroup);
-//    }
-//    if (getGroupsPosIgnoringKeyGroups(inputSchema, keys).empty()) { // nothing else to merge
-//        return;
-//    }
-//    auto flatPayloads = getFlatPayloadsIgnoringKeyGroup(inputSchema, keys);
-//    if (!flatPayloads.empty()) {
-//        auto flatPayloadsOutputGroupPos = appendPayloadsToNewGroup(result, flatPayloads);
-//        result.setGroupAsSingleState(flatPayloadsOutputGroupPos);
-//    }
-//    for (auto& payloadGroupPos : getGroupsPosIgnoringKeyGroups(inputSchema, keys)) {
-//        auto payloadGroup = inputSchema.getGroup(payloadGroupPos);
-//        if (!payloadGroup->isFlat()) {
-//            auto payloads = inputSchema.getExpressionsInScope(payloadGroupPos);
-//            auto outputGroupPos = appendPayloadsToNewGroup(result, payloads);
-//            result.getGroup(outputGroupPos)->setMultiplier(payloadGroup->getMultiplier());
-//        }
-//    }
-//}
-
 void SinkOperatorUtil::mergeSchema(
     const Schema& inputSchema, const expression_vector& expressionsToMerge, Schema& resultSchema) {
     auto flatPayloads = getFlatPayloads(inputSchema, expressionsToMerge);