3195

Build # 3195

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/a22762e6ec32c202923623a79877e181024c0d92">a22762e6e">&lt;a href=&quot;https://github.com/apache/carbondata/commit/</a><a class="double-link" href="https://github.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/a22762e6ec32c202923623a79877e181024c0d92">a22762e6e</a><a href="https://github.com/apache/carbondata/commit/a22762e6ec32c202923623a79877e181024c0d92">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/carbondata/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/a22762e6ec32c202923623a79877e181024c0d92&quot;&gt;a22762e6e&lt;/a&gt;&lt;a href=&quot;https://github.com/apache/carbondata/commit/a22762e6ec32c202923623a79877e181024c0d92&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/apache/carbondata/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/apache/carbondata/commit/&amp;amp;lt;a ... (continued)

Run Details

264 of 264 new or added lines in 13 files covered. (100.0%)

63395 of 80042 relevant lines covered (79.2%)

1.05 hits per line

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

85.19

/core/src/main/java/org/apache/carbondata/core/datamap/DataMapFilter.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.datamap;

import java.io.Serializable;

import org.apache.carbondata.core.datastore.block.SegmentProperties;
import org.apache.carbondata.core.metadata.schema.table.CarbonTable;
import org.apache.carbondata.core.scan.executor.util.RestructureUtil;
import org.apache.carbondata.core.scan.expression.Expression;
import org.apache.carbondata.core.scan.filter.resolver.FilterResolverIntf;

/**
 * the filter of DataMap
 */
public class DataMapFilter implements Serializable {

  private CarbonTable table;

  private Expression expression;

  private FilterResolverIntf resolver;

  public DataMapFilter(CarbonTable table, Expression expression) {
    this.table = table;
    this.expression = expression;
    resolve();
  }

  public DataMapFilter(FilterResolverIntf resolver) {
    this.resolver = resolver;
  }

  private void resolve() {
    if (expression != null) {
      table.processFilterExpression(expression, null, null);
      resolver = CarbonTable.resolveFilter(expression, table.getAbsoluteTableIdentifier());
    }
  }

  public Expression getExpression() {
    return expression;
  }

  public void setExpression(Expression expression) {
    this.expression = expression;
  }

  public FilterResolverIntf getResolver() {
    return resolver;
  }

  public void setResolver(FilterResolverIntf resolver) {
    this.resolver = resolver;
  }

  public boolean isEmpty() {
    return resolver == null;
  }

  public boolean isResolvedOnSegment(SegmentProperties segmentProperties) {
    if (expression == null || table == null) {
      return true;
    }
    if (!table.isTransactionalTable()) {
      return false;
    }
    if (table.hasColumnDrift() && RestructureUtil
        .hasColumnDriftOnSegment(table, segmentProperties)) {
      return false;
    }
    return true;
  }
}

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.datamap;
19
20	import java.io.Serializable;
21
22	import org.apache.carbondata.core.datastore.block.SegmentProperties;
23	import org.apache.carbondata.core.metadata.schema.table.CarbonTable;
24	import org.apache.carbondata.core.scan.executor.util.RestructureUtil;
25	import org.apache.carbondata.core.scan.expression.Expression;
26	import org.apache.carbondata.core.scan.filter.resolver.FilterResolverIntf;
27
28	/**
29	* the filter of DataMap
30	*/
31	public class DataMapFilter implements Serializable {
32
33	private CarbonTable table;
34
35	private Expression expression;
36
37	private FilterResolverIntf resolver;
38
39	public DataMapFilter(CarbonTable table, Expression expression) {	1✔
40	this.table = table;	1✔
41	this.expression = expression;	1✔
42	resolve();	1✔
43	}	1✔
44
45	public DataMapFilter(FilterResolverIntf resolver) {	1✔
46	this.resolver = resolver;	1✔
47	}	1✔
48
49	private void resolve() {
50	if (expression != null) {	1✔
51	table.processFilterExpression(expression, null, null);	1✔
52	resolver = CarbonTable.resolveFilter(expression, table.getAbsoluteTableIdentifier());	1✔
53	}
54	}	1✔
55
56	public Expression getExpression() {
57	return expression;	1✔
58	}
59
60	public void setExpression(Expression expression) {
61	this.expression = expression;	×
62	}	×
63
64	public FilterResolverIntf getResolver() {
65	return resolver;	1✔
66	}
67
68	public void setResolver(FilterResolverIntf resolver) {
69	this.resolver = resolver;	×
70	}	×
71
72	public boolean isEmpty() {
73	return resolver == null;	1✔
74	}
75
76	public boolean isResolvedOnSegment(SegmentProperties segmentProperties) {
77	if (expression == null \|\| table == null) {	1✔
78	return true;	1✔
79	}
80	if (!table.isTransactionalTable()) {	1✔
81	return false;	1✔
82	}
83	if (table.hasColumnDrift() && RestructureUtil	1✔
84	.hasColumnDriftOnSegment(table, segmentProperties)) {	1✔
85	return false;	1✔
86	}
87	return true;	1✔
88	}
89	}

apache / carbondata / 3195

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