6623

Build # 6623

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/42c1d1a5e1019da73ab4ea2f811f2c925c973026">42c1d1a5e<a href="https://github.com/apache/carbondata/commit/42c1d1a5e1019da73ab4ea2f811f2c925c973026">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/9fb0af6f403c5c9d2e14a704566cee2f9958465a">9fb0af6f4</a>">9fb0af6f4</a><a href="https://github.com/apache/carbondata/commit/42c1d1a5e1019da73ab4ea2f811f2c925c973026"> into 8b9c65540">8b9c65540</a>

Run Details

22066 of 70653 relevant lines covered (31.23%)

0.46 hits per line

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

0.0

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

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

import org.apache.carbondata.core.datamap.DataMapDistributable;
import org.apache.carbondata.core.datamap.DataMapLevel;
import org.apache.carbondata.core.datamap.Segment;
import org.apache.carbondata.core.indexstore.ExtendedBlocklet;
import org.apache.carbondata.core.indexstore.PartitionSpec;
import org.apache.carbondata.core.scan.filter.resolver.FilterResolverIntf;

/**
 * Or expression for datamaps
 */
public class OrDataMapExprWrapper implements DataMapExprWrapper {

  private DataMapExprWrapper left;

  private DataMapExprWrapper right;

  private FilterResolverIntf resolverIntf;

  public OrDataMapExprWrapper(DataMapExprWrapper left, DataMapExprWrapper right,
      FilterResolverIntf resolverIntf) {
    this.left = left;
    this.right = right;
    this.resolverIntf = resolverIntf;
  }

  @Override
  public List<ExtendedBlocklet> prune(List<Segment> segments, List<PartitionSpec> partitionsToPrune)
      throws IOException {
    List<ExtendedBlocklet> leftPrune = left.prune(segments, partitionsToPrune);
    List<ExtendedBlocklet> rightPrune = right.prune(segments, partitionsToPrune);
    Set<ExtendedBlocklet> andBlocklets = new HashSet<>();
    andBlocklets.addAll(leftPrune);
    andBlocklets.addAll(rightPrune);
    return new ArrayList<>(andBlocklets);
  }

  @Override
  public List<ExtendedBlocklet> prune(DataMapDistributable distributable,
      List<PartitionSpec> partitionsToPrune)
          throws IOException {
    List<ExtendedBlocklet> leftPrune = left.prune(distributable, partitionsToPrune);
    List<ExtendedBlocklet> rightPrune = right.prune(distributable, partitionsToPrune);
    Set<ExtendedBlocklet> andBlocklets = new HashSet<>();
    andBlocklets.addAll(leftPrune);
    andBlocklets.addAll(rightPrune);
    return new ArrayList<>(andBlocklets);
  }

  @Override public List<ExtendedBlocklet> pruneBlocklets(List<ExtendedBlocklet> blocklets)
      throws IOException {
    List<ExtendedBlocklet> leftPrune = left.pruneBlocklets(blocklets);
    List<ExtendedBlocklet> rightPrune = right.pruneBlocklets(blocklets);
    Set<ExtendedBlocklet> andBlocklets = new HashSet<>();
    andBlocklets.addAll(leftPrune);
    andBlocklets.addAll(rightPrune);
    return new ArrayList<>(andBlocklets);
  }

  @Override public List<DataMapDistributableWrapper> toDistributable(List<Segment> segments)
      throws IOException {
    List<DataMapDistributableWrapper> wrappers = new ArrayList<>();
    wrappers.addAll(left.toDistributable(segments));
    wrappers.addAll(right.toDistributable(segments));
    return wrappers;
  }

  @Override public FilterResolverIntf getFilterResolverIntf() {
    return resolverIntf;
  }

  @Override public FilterResolverIntf getFilterResolverIntf(String uniqueId) {
    FilterResolverIntf leftExp = left.getFilterResolverIntf(uniqueId);
    FilterResolverIntf rightExp = right.getFilterResolverIntf(uniqueId);
    if (leftExp != null) {
      return leftExp;
    } else if (rightExp != null) {
      return rightExp;
    }
    return null;
  }


  @Override public DataMapLevel getDataMapLevel() {
    return left.getDataMapLevel();
  }

  @Override
  public DataMapExprWrapper getLeftDataMapWrapper() {
    return left;
  }

  @Override
  public DataMapExprWrapper getRightDataMapWrapprt() {
    return right;
  }
}

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	package org.apache.carbondata.core.datamap.dev.expr;
18
19	import java.io.IOException;
20	import java.util.ArrayList;
21	import java.util.HashSet;
22	import java.util.List;
23	import java.util.Set;
24
25	import org.apache.carbondata.core.datamap.DataMapDistributable;
26	import org.apache.carbondata.core.datamap.DataMapLevel;
27	import org.apache.carbondata.core.datamap.Segment;
28	import org.apache.carbondata.core.indexstore.ExtendedBlocklet;
29	import org.apache.carbondata.core.indexstore.PartitionSpec;
30	import org.apache.carbondata.core.scan.filter.resolver.FilterResolverIntf;
31
32	/**
33	* Or expression for datamaps
34	*/
35	public class OrDataMapExprWrapper implements DataMapExprWrapper {
36
37	private DataMapExprWrapper left;
38
39	private DataMapExprWrapper right;
40
41	private FilterResolverIntf resolverIntf;
42
43	public OrDataMapExprWrapper(DataMapExprWrapper left, DataMapExprWrapper right,
44	FilterResolverIntf resolverIntf) {	×
45	this.left = left;	×
46	this.right = right;	×
47	this.resolverIntf = resolverIntf;	×
48	}	×
49
50	@Override
51	public List<ExtendedBlocklet> prune(List<Segment> segments, List<PartitionSpec> partitionsToPrune)
52	throws IOException {
53	List<ExtendedBlocklet> leftPrune = left.prune(segments, partitionsToPrune);	×
54	List<ExtendedBlocklet> rightPrune = right.prune(segments, partitionsToPrune);	×
55	Set<ExtendedBlocklet> andBlocklets = new HashSet<>();	×
56	andBlocklets.addAll(leftPrune);	×
57	andBlocklets.addAll(rightPrune);	×
58	return new ArrayList<>(andBlocklets);	×
59	}
60
61	@Override
62	public List<ExtendedBlocklet> prune(DataMapDistributable distributable,
63	List<PartitionSpec> partitionsToPrune)
64	throws IOException {
65	List<ExtendedBlocklet> leftPrune = left.prune(distributable, partitionsToPrune);	×
66	List<ExtendedBlocklet> rightPrune = right.prune(distributable, partitionsToPrune);	×
67	Set<ExtendedBlocklet> andBlocklets = new HashSet<>();	×
68	andBlocklets.addAll(leftPrune);	×
69	andBlocklets.addAll(rightPrune);	×
70	return new ArrayList<>(andBlocklets);	×
71	}
72
73	@Override public List<ExtendedBlocklet> pruneBlocklets(List<ExtendedBlocklet> blocklets)
74	throws IOException {
75	List<ExtendedBlocklet> leftPrune = left.pruneBlocklets(blocklets);	×
76	List<ExtendedBlocklet> rightPrune = right.pruneBlocklets(blocklets);	×
77	Set<ExtendedBlocklet> andBlocklets = new HashSet<>();	×
78	andBlocklets.addAll(leftPrune);	×
79	andBlocklets.addAll(rightPrune);	×
80	return new ArrayList<>(andBlocklets);	×
81	}
82
83	@Override public List<DataMapDistributableWrapper> toDistributable(List<Segment> segments)
84	throws IOException {
85	List<DataMapDistributableWrapper> wrappers = new ArrayList<>();	×
86	wrappers.addAll(left.toDistributable(segments));	×
87	wrappers.addAll(right.toDistributable(segments));	×
88	return wrappers;	×
89	}
90
91	@Override public FilterResolverIntf getFilterResolverIntf() {
92	return resolverIntf;	×
93	}
94
95	@Override public FilterResolverIntf getFilterResolverIntf(String uniqueId) {
96	FilterResolverIntf leftExp = left.getFilterResolverIntf(uniqueId);	×
97	FilterResolverIntf rightExp = right.getFilterResolverIntf(uniqueId);	×
98	if (leftExp != null) {	×
99	return leftExp;	×
100	} else if (rightExp != null) {	×
101	return rightExp;	×
102	}
103	return null;	×
104	}
105
106
107	@Override public DataMapLevel getDataMapLevel() {
108	return left.getDataMapLevel();	×
109	}
110
111	@Override
112	public DataMapExprWrapper getLeftDataMapWrapper() {
113	return left;	×
114	}
115
116	@Override
117	public DataMapExprWrapper getRightDataMapWrapprt() {
118	return right;	×
119	}
120	}

apache / carbondata / 6623

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