1857

Build # 1857

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/80aea04357da54a75e9722970a7f791ed7230465">80aea0435<a href="https://github.com/apache/carbondata/commit/80aea04357da54a75e9722970a7f791ed7230465">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/e25346caaad9472a9eea51d9186463ea4fe3c64a">e25346caa</a>">e25346caa</a><a href="https://github.com/apache/carbondata/commit/80aea04357da54a75e9722970a7f791ed7230465"> into 382ce430a">382ce430a</a>

Run Details

19 of 19 new or added lines in 2 files covered. (100.0%)

61614 of 77450 relevant lines covered (79.55%)

1.05 hits per line

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

77.78

/core/src/main/java/org/apache/carbondata/core/scan/complextypes/ComplexQueryType.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.scan.complextypes;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

import org.apache.carbondata.core.datastore.chunk.DimensionColumnPage;
import org.apache.carbondata.core.datastore.chunk.impl.DimensionRawColumnChunk;
import org.apache.carbondata.core.scan.processor.RawBlockletColumnChunks;

public class ComplexQueryType {
  protected String name;

  protected String parentname;

  protected int blockIndex;

  protected Map<Integer, DimensionColumnPage> decodedPagesWithPageNumber = new HashMap<>();

  public ComplexQueryType(String name, String parentname, int blockIndex) {
    this.name = name;
    this.parentname = parentname;
    this.blockIndex = blockIndex;
  }

  /**
   * Method will copy the block chunk holder data and return the cloned value.
   * This method is also used by child.
   */
  protected byte[] copyBlockDataChunk(DimensionRawColumnChunk[] rawColumnChunks,
      int rowNumber, int pageNumber) {
    byte[] data = getDecodedPage(rawColumnChunks[blockIndex], pageNumber).getChunkData(rowNumber);
    byte[] output = new byte[data.length];
    System.arraycopy(data, 0, output, 0, output.length);
    return output;
  }

  /*
   * This method will read the block data chunk from the respective block
   */
  protected void readBlockDataChunk(RawBlockletColumnChunks blockChunkHolder) throws IOException {
    if (null == blockChunkHolder.getDimensionRawColumnChunks()[blockIndex]) {
      blockChunkHolder.getDimensionRawColumnChunks()[blockIndex] = blockChunkHolder.getDataBlock()
          .readDimensionChunk(blockChunkHolder.getFileReader(), blockIndex);
    }
  }

  private DimensionColumnPage getDecodedPage(DimensionRawColumnChunk dimensionRawColumnChunk,
      int pageNumber) {
    if (null == this.decodedPagesWithPageNumber.get(pageNumber)) {
      this.decodedPagesWithPageNumber
          .put(pageNumber, dimensionRawColumnChunk.decodeColumnPage(pageNumber));
    }
    return this.decodedPagesWithPageNumber.get(pageNumber);
  }
}

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.scan.complextypes;
19
20	import java.io.IOException;
21	import java.util.HashMap;
22	import java.util.Map;
23
24	import org.apache.carbondata.core.datastore.chunk.DimensionColumnPage;
25	import org.apache.carbondata.core.datastore.chunk.impl.DimensionRawColumnChunk;
26	import org.apache.carbondata.core.scan.processor.RawBlockletColumnChunks;
27
28	public class ComplexQueryType {
29	protected String name;
30
31	protected String parentname;
32
33	protected int blockIndex;
34
35	protected Map<Integer, DimensionColumnPage> decodedPagesWithPageNumber = new HashMap<>();	2✔
36
37	public ComplexQueryType(String name, String parentname, int blockIndex) {	2✔
38	this.name = name;	2✔
39	this.parentname = parentname;	2✔
40	this.blockIndex = blockIndex;	2✔
41	}	2✔
42
43	/**
44	* Method will copy the block chunk holder data and return the cloned value.
45	* This method is also used by child.
46	*/
47	protected byte[] copyBlockDataChunk(DimensionRawColumnChunk[] rawColumnChunks,
48	int rowNumber, int pageNumber) {
49	byte[] data = getDecodedPage(rawColumnChunks[blockIndex], pageNumber).getChunkData(rowNumber);	1✔
50	byte[] output = new byte[data.length];	1✔
51	System.arraycopy(data, 0, output, 0, output.length);	1✔
52	return output;	1✔
53	}
54
55	/*
56	* This method will read the block data chunk from the respective block
57	*/
58	protected void readBlockDataChunk(RawBlockletColumnChunks blockChunkHolder) throws IOException {
59	if (null == blockChunkHolder.getDimensionRawColumnChunks()[blockIndex]) {	×
60	blockChunkHolder.getDimensionRawColumnChunks()[blockIndex] = blockChunkHolder.getDataBlock()	×
61	.readDimensionChunk(blockChunkHolder.getFileReader(), blockIndex);	×
62	}
63	}	×
64
65	private DimensionColumnPage getDecodedPage(DimensionRawColumnChunk dimensionRawColumnChunk,
66	int pageNumber) {
67	if (null == this.decodedPagesWithPageNumber.get(pageNumber)) {	1✔
68	this.decodedPagesWithPageNumber	1✔
69	.put(pageNumber, dimensionRawColumnChunk.decodeColumnPage(pageNumber));	1✔
70	}
71	return this.decodedPagesWithPageNumber.get(pageNumber);	1✔
72	}
73	}

apache / carbondata / 1857

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