9859

Build # 9859

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/22ed3f05934215a8aed296e69027d6570ec57d54">22ed3f059<a href="https://github.com/apache/carbondata/commit/22ed3f05934215a8aed296e69027d6570ec57d54">&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/22ed3f05934215a8aed296e69027d6570ec57d54&quot;&gt;22ed3f059&lt;/a&gt;&lt;a href=&quot;https://github.com/apache/carbondata/commit/22ed3f05934215a8aed296e69027d6570ec57d54&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/carbondata/commit/22ed3f05934215a8aed296e69027d657&lt;/a&gt;0ec57d54">&quot;&gt;Merge &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/222bd3f48c6ba0cfc3a4df2187b867759c51035c">222bd3f48</a><a href="https://github.com/apache/carbondata/commit/22ed3f05934215a8aed296e69027d6570ec57d54">&amp;quot;&amp;gt;222bd3f48&amp;lt;/a&amp;gt;&amp;quot;&amp;gt;222bd3f48&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/apache/carbondata/commit/22ed3f05934215a8aed296e69027d6570ec57&lt;/a&gt;d54&quot;&gt; into &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/6e04fe65a">6e04fe65a">6e04fe65a</a>

Run Details

1492 of 1492 new or added lines in 117 files covered. (100.0%)

62402 of 78304 relevant lines covered (79.69%)

1.06 hits per line

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

66.67

/core/src/main/java/org/apache/carbondata/core/datastore/chunk/reader/dimension/AbstractChunkReader.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.datastore.chunk.reader.dimension;

import java.io.IOException;

import org.apache.carbondata.core.constants.CarbonCommonConstants;
import org.apache.carbondata.core.datastore.ReusableDataBuffer;
import org.apache.carbondata.core.datastore.chunk.impl.DimensionRawColumnChunk;
import org.apache.carbondata.core.datastore.chunk.reader.DimensionColumnChunkReader;
import org.apache.carbondata.core.datastore.compression.Compressor;
import org.apache.carbondata.core.keygenerator.mdkey.NumberCompressor;
import org.apache.carbondata.core.memory.MemoryException;
import org.apache.carbondata.core.scan.result.vector.ColumnVectorInfo;
import org.apache.carbondata.core.util.CarbonProperties;

/**
 * Class which will have all the common properties and behavior among all type
 * of reader
 */
public abstract class AbstractChunkReader implements DimensionColumnChunkReader {

  /**
   * compressor will be used to uncompress the data
   */
  protected Compressor compressor;

  /**
   * size of the each column value
   * for no dictionary column it will be -1
   */
  protected int[] eachColumnValueSize;

  /**
   * full qualified path of the data file from
   * which data will be read
   */
  protected String filePath;

  /**
   * this will be used to uncompress the
   * row id and rle chunk
   */
  protected NumberCompressor numberCompressor;

  /**
   * number of element in each chunk
   */
  protected int numberOfRows;

  /**
   * Constructor to get minimum parameter to create
   * instance of this class
   *
   * @param eachColumnValueSize  size of the each column value
   * @param filePath             file from which data will be read
   */
  public AbstractChunkReader(final int[] eachColumnValueSize, final String filePath,
      int numberOfRows) {
    this.eachColumnValueSize = eachColumnValueSize;
    this.filePath = filePath;
    int numberOfElement = 0;
    try {
      numberOfElement = Integer.parseInt(CarbonProperties.getInstance()
          .getPropertyOrDefault(CarbonCommonConstants.BLOCKLET_SIZE));
    } catch (NumberFormatException exception) {
      numberOfElement = Integer.parseInt(CarbonCommonConstants.BLOCKLET_SIZE
          .getDefaultValueString());
    }
    this.numberCompressor = new NumberCompressor(numberOfElement);
    this.numberOfRows = numberOfRows;
  }

  @Override
  public void decodeColumnPageAndFillVector(DimensionRawColumnChunk dimensionRawColumnChunk,
      int pageNumber, ColumnVectorInfo vectorInfo, ReusableDataBuffer reusableDataBuffer)
      throws IOException, MemoryException {
    throw new UnsupportedOperationException(
        "This operation is not supported in this reader " + this.getClass().getName());
  }
}

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.datastore.chunk.reader.dimension;
18
19	import java.io.IOException;
20
21	import org.apache.carbondata.core.constants.CarbonCommonConstants;
22	import org.apache.carbondata.core.datastore.ReusableDataBuffer;
23	import org.apache.carbondata.core.datastore.chunk.impl.DimensionRawColumnChunk;
24	import org.apache.carbondata.core.datastore.chunk.reader.DimensionColumnChunkReader;
25	import org.apache.carbondata.core.datastore.compression.Compressor;
26	import org.apache.carbondata.core.keygenerator.mdkey.NumberCompressor;
27	import org.apache.carbondata.core.memory.MemoryException;
28	import org.apache.carbondata.core.scan.result.vector.ColumnVectorInfo;
29	import org.apache.carbondata.core.util.CarbonProperties;
30
31	/**
32	* Class which will have all the common properties and behavior among all type
33	* of reader
34	*/
35	public abstract class AbstractChunkReader implements DimensionColumnChunkReader {
36
37	/**
38	* compressor will be used to uncompress the data
39	*/
40	protected Compressor compressor;
41
42	/**
43	* size of the each column value
44	* for no dictionary column it will be -1
45	*/
46	protected int[] eachColumnValueSize;
47
48	/**
49	* full qualified path of the data file from
50	* which data will be read
51	*/
52	protected String filePath;
53
54	/**
55	* this will be used to uncompress the
56	* row id and rle chunk
57	*/
58	protected NumberCompressor numberCompressor;
59
60	/**
61	* number of element in each chunk
62	*/
63	protected int numberOfRows;
64
65	/**
66	* Constructor to get minimum parameter to create
67	* instance of this class
68	*
69	* @param eachColumnValueSize size of the each column value
70	* @param filePath file from which data will be read
71	*/
72	public AbstractChunkReader(final int[] eachColumnValueSize, final String filePath,
73	int numberOfRows) {	1✔
74	this.eachColumnValueSize = eachColumnValueSize;	1✔
75	this.filePath = filePath;	1✔
76	int numberOfElement = 0;	1✔
77	try {
78	numberOfElement = Integer.parseInt(CarbonProperties.getInstance()	1✔
79	.getPropertyOrDefault(CarbonCommonConstants.BLOCKLET_SIZE));	1✔
80	} catch (NumberFormatException exception) {	×
81	numberOfElement = Integer.parseInt(CarbonCommonConstants.BLOCKLET_SIZE	×
82	.getDefaultValueString());	×
83	}	1✔
84	this.numberCompressor = new NumberCompressor(numberOfElement);	1✔
85	this.numberOfRows = numberOfRows;	1✔
86	}	1✔
87
88	@Override
89	public void decodeColumnPageAndFillVector(DimensionRawColumnChunk dimensionRawColumnChunk,
90	int pageNumber, ColumnVectorInfo vectorInfo, ReusableDataBuffer reusableDataBuffer)
91	throws IOException, MemoryException {
92	throw new UnsupportedOperationException(	×
93	"This operation is not supported in this reader " + this.getClass().getName());	×
94	}
95	}

apache / carbondata / 9859

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