apache / carbondata / 133

Build # 133

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/a8968f014c34bef6ebbb3351d48055658e64022b">a8968f014<a href="https://github.com/apache/carbondata/commit/a8968f014c34bef6ebbb3351d48055658e64022b">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/f29ec1d80acea6fcb85a55ab37c02847e9282e5b">f29ec1d80</a>">f29ec1d80</a><a href="https://github.com/apache/carbondata/commit/a8968f014c34bef6ebbb3351d48055658e64022b"> into 12ab57992">12ab57992</a>

Run Details

319 of 319 new or added lines in 17 files covered. (100.0%)

57881 of 71391 relevant lines covered (81.08%)

1.07 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

97.73

/core/src/main/java/org/apache/carbondata/core/profiler/TablePruningInfo.java

/*
 * 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.carbondata.core.profiler;

import org.apache.carbondata.common.annotations.InterfaceAudience;
import org.apache.carbondata.core.datamap.dev.expr.DataMapWrapperSimpleInfo;

/**
 * Used for EXPLAIN command
 */
@InterfaceAudience.Internal
public class TablePruningInfo {

  private int totalBlocklets;
  private String filterStatement;

  private DataMapWrapperSimpleInfo defaultDataMap;
  private int numBlockletsAfterDefaultPruning;

  private DataMapWrapperSimpleInfo cgDataMap;
  private int numBlockletsAfterCGPruning;

  private DataMapWrapperSimpleInfo fgDataMap;
  private int numBlockletsAfterFGPruning;

  void addTotalBlocklets(int numBlocklets) {
    this.totalBlocklets += numBlocklets;
  }

  void setFilterStatement(String filterStatement) {
    this.filterStatement = filterStatement;
  }

  void setNumBlockletsAfterDefaultPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
      int numBlocklets) {
    this.defaultDataMap = dataMapWrapperSimpleInfo;
    this.numBlockletsAfterDefaultPruning = numBlocklets;
  }

  void setNumBlockletsAfterCGPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
      int numBlocklets) {
    this.cgDataMap = dataMapWrapperSimpleInfo;
    this.numBlockletsAfterCGPruning = numBlocklets;
  }

  void setNumBlockletsAfterFGPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
      int numBlocklets) {
    this.fgDataMap = dataMapWrapperSimpleInfo;
    this.numBlockletsAfterFGPruning = numBlocklets;
  }

  @Override
  public String toString() {
    StringBuilder builder = new StringBuilder();
    builder
        .append(" - total blocklets: ").append(totalBlocklets).append("\n")
        .append(" - filter: ").append(filterStatement).append("\n");
    if (defaultDataMap != null) {
      int skipBlocklets = totalBlocklets - numBlockletsAfterDefaultPruning;
      builder
          .append(" - pruned by Main DataMap").append("\n")
          .append("    - skipped blocklets: ").append(skipBlocklets).append("\n");
    } else {
      // this means we do not have default datamap for pruning, so reuse the original value
      numBlockletsAfterDefaultPruning = totalBlocklets;
    }

    if (cgDataMap != null) {
      int skipBlocklets = numBlockletsAfterDefaultPruning - numBlockletsAfterCGPruning;
      builder
          .append(" - pruned by CG DataMap").append("\n")
          .append("    - name: ").append(cgDataMap.getDataMapWrapperName()).append("\n")
          .append("    - provider: ").append(cgDataMap.getDataMapWrapperProvider()).append("\n")
          .append("    - skipped blocklets: ").append(skipBlocklets).append("\n");
    } else {
      numBlockletsAfterCGPruning = numBlockletsAfterDefaultPruning;
    }

    if (fgDataMap != null) {
      int skipBlocklets;
      if (numBlockletsAfterCGPruning != 0) {
        skipBlocklets = numBlockletsAfterCGPruning - numBlockletsAfterFGPruning;
      } else {
        skipBlocklets = numBlockletsAfterDefaultPruning - numBlockletsAfterFGPruning;
      }
      builder
          .append(" - pruned by FG DataMap").append("\n")
          .append("    - name: ").append(fgDataMap.getDataMapWrapperName()).append("\n")
          .append("    - provider: ").append(fgDataMap.getDataMapWrapperProvider()).append("\n")
          .append("    - skipped blocklets: ").append(skipBlocklets).append("\n");
    }
    return builder.toString();
  }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package org.apache.carbondata.core.profiler;
19
20	import org.apache.carbondata.common.annotations.InterfaceAudience;
21	import org.apache.carbondata.core.datamap.dev.expr.DataMapWrapperSimpleInfo;
22
23	/**
24	* Used for EXPLAIN command
25	*/
26	@InterfaceAudience.Internal
27	public class TablePruningInfo {	1✔
28
29	private int totalBlocklets;
30	private String filterStatement;
31
32	private DataMapWrapperSimpleInfo defaultDataMap;
33	private int numBlockletsAfterDefaultPruning;
34
35	private DataMapWrapperSimpleInfo cgDataMap;
36	private int numBlockletsAfterCGPruning;
37
38	private DataMapWrapperSimpleInfo fgDataMap;
39	private int numBlockletsAfterFGPruning;
40
41	void addTotalBlocklets(int numBlocklets) {
42	this.totalBlocklets += numBlocklets;	1✔
43	}	1✔
44
45	void setFilterStatement(String filterStatement) {
46	this.filterStatement = filterStatement;	1✔
47	}	1✔
48
49	void setNumBlockletsAfterDefaultPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
50	int numBlocklets) {
51	this.defaultDataMap = dataMapWrapperSimpleInfo;	1✔
52	this.numBlockletsAfterDefaultPruning = numBlocklets;	1✔
53	}	1✔
54
55	void setNumBlockletsAfterCGPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
56	int numBlocklets) {
57	this.cgDataMap = dataMapWrapperSimpleInfo;	1✔
58	this.numBlockletsAfterCGPruning = numBlocklets;	1✔
59	}	1✔
60
61	void setNumBlockletsAfterFGPruning(DataMapWrapperSimpleInfo dataMapWrapperSimpleInfo,
62	int numBlocklets) {
63	this.fgDataMap = dataMapWrapperSimpleInfo;	1✔
64	this.numBlockletsAfterFGPruning = numBlocklets;	1✔
65	}	1✔
66
67	@Override
68	public String toString() {
69	StringBuilder builder = new StringBuilder();	1✔
70	builder	1✔
71	.append(" - total blocklets: ").append(totalBlocklets).append("\n")	1✔
72	.append(" - filter: ").append(filterStatement).append("\n");	1✔
73	if (defaultDataMap != null) {	1✔
74	int skipBlocklets = totalBlocklets - numBlockletsAfterDefaultPruning;	1✔
75	builder	1✔
76	.append(" - pruned by Main DataMap").append("\n")	1✔
77	.append(" - skipped blocklets: ").append(skipBlocklets).append("\n");	1✔
78	} else {	1✔
79	// this means we do not have default datamap for pruning, so reuse the original value
80	numBlockletsAfterDefaultPruning = totalBlocklets;	1✔
81	}
82
83	if (cgDataMap != null) {	1✔
84	int skipBlocklets = numBlockletsAfterDefaultPruning - numBlockletsAfterCGPruning;	1✔
85	builder	1✔
86	.append(" - pruned by CG DataMap").append("\n")	1✔
87	.append(" - name: ").append(cgDataMap.getDataMapWrapperName()).append("\n")	1✔
88	.append(" - provider: ").append(cgDataMap.getDataMapWrapperProvider()).append("\n")	1✔
89	.append(" - skipped blocklets: ").append(skipBlocklets).append("\n");	1✔
90	} else {	1✔
91	numBlockletsAfterCGPruning = numBlockletsAfterDefaultPruning;	1✔
92	}
93
94	if (fgDataMap != null) {	1✔
95	int skipBlocklets;
96	if (numBlockletsAfterCGPruning != 0) {	1✔
97	skipBlocklets = numBlockletsAfterCGPruning - numBlockletsAfterFGPruning;	1✔
98	} else {
99	skipBlocklets = numBlockletsAfterDefaultPruning - numBlockletsAfterFGPruning;	×
100	}
101	builder	1✔
102	.append(" - pruned by FG DataMap").append("\n")	1✔
103	.append(" - name: ").append(fgDataMap.getDataMapWrapperName()).append("\n")	1✔
104	.append(" - provider: ").append(fgDataMap.getDataMapWrapperProvider()).append("\n")	1✔
105	.append(" - skipped blocklets: ").append(skipBlocklets).append("\n");	1✔
106	}
107	return builder.toString();	1✔
108	}
109	}

apache / carbondata / 133

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous