[
https://issues.apache.org/jira/browse/KYLIN-5387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689274#comment-17689274
]
ASF GitHub Bot commented on KYLIN-5387:
---------------------------------------
dethrive commented on code in PR #2089:
URL: https://github.com/apache/kylin/pull/2089#discussion_r1107482568
##########
src/spark-project/engine-spark/src/main/scala/org/apache/kylin/engine/spark/model/planner/CuboIdToLayoutUtils.java:
##########
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.kylin.engine.spark.model.planner;
+
+import java.math.BigInteger;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.kylin.metadata.cube.cuboid.NAggregationGroup;
+import org.apache.kylin.metadata.cube.model.LayoutEntity;
+import org.apache.kylin.metadata.cube.model.RuleBasedIndex;
+
+import com.google.common.collect.Lists;
+
+public class CuboIdToLayoutUtils {
+ /**
+ * convert the cuboids to layout entity
+ *
+ * @param cuboids
+ * @param ruleBasedIndex
+ * @return
+ */
+ public static Set<LayoutEntity>
convertCuboIdsToLayoutEntity(Map<BigInteger, Long> cuboids,
+
RuleBasedIndex ruleBasedIndex) {
+ // convert the cuboid to each agg group
+ Set<LayoutEntity> result = new HashSet<>();
+ List<NAggregationGroup> aggregationGroups =
ruleBasedIndex.getAggregationGroups();
+ for (NAggregationGroup group : aggregationGroups) {
+ // dimension order in this agg group
+ List<Integer> dimensionOrder =
Lists.newArrayList(group.getIncludes());
+ // measure order in this agg group
+ List<Integer> measuresIds =
Lists.newArrayList(group.getMeasures());
+ Set<List<Integer>> colOrders = convertCuboIdsToColOrders(cuboids,
ruleBasedIndex.countOfIncludeDimension(),
+ measuresIds, ruleBasedIndex.getRowKeyIdToColumnId(),
dimensionOrder);
+ for (List<Integer> colOrder : colOrders) {
+ result.add(createRecommendAggIndexLayout(colOrder));
+ }
+ }
+
+ // base agg layout for each agg group
+ for (NAggregationGroup group : aggregationGroups) {
+ List<Integer> colOrders = Lists.newArrayList();
+ // all dimension in the agg
+ colOrders.addAll(Lists.newArrayList(group.getIncludes()));
+ // all measure in this agg
+ colOrders.addAll(Lists.newArrayList(group.getMeasures()));
+ result.add(createRecommendAggIndexLayout(colOrders));
+ }
+ return result;
+ }
+
+ /**
+ * create recommend agg layout base on the colOrder.
+ *
+ * @param colOrder
+ * @return LayoutEntity or null
+ * null: if the measures in the colOrder can't match the measures in this
Index Plan
+ */
+ private static LayoutEntity createRecommendAggIndexLayout(List<Integer>
colOrder) {
+ LayoutEntity newAddIndexLayout = new LayoutEntity();
+ // The layout is not the manual
+ newAddIndexLayout.setManual(false);
+ newAddIndexLayout.setColOrder(colOrder);
+ newAddIndexLayout.setUpdateTime(System.currentTimeMillis());
+ newAddIndexLayout.setBase(false);
+ newAddIndexLayout.initalId(true);
Review Comment:
这边是 initial id 吗？这个单词有拼写错误，建议一并更正一下。
> Migrate cube planner phase 1 to kylin5
> --------------------------------------
>
> Key: KYLIN-5387
> URL: https://issues.apache.org/jira/browse/KYLIN-5387
> Project: Kylin
> Issue Type: Improvement
> Components: Job Engine
> Affects Versions: 5.0-alpha
> Reporter: Kun Liu
> Assignee: Kun Liu
> Priority: Major
>
> kylin3.1 support the cube planner to recommend cuboid when building the first
> segment.
>
> We need to migrate the cost based algorithm to the kylin5, and leverage the
> cube planner algorithm with the index in kylin5
>
> designe doc:
> https://docs.google.com/document/d/1wUNd8U1u-w8T-qQUReplPhDFkETj3AtFr_Shex501ls/edit?usp=sharing
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
