apache / carbondata / 429

Build # 429

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/a6c23d35d16098beb7f298ed4bf3d0a6bd19a5fa">a6c23d35d<a href="https://github.com/apache/carbondata/commit/a6c23d35d16098beb7f298ed4bf3d0a6bd19a5fa">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/28e60d022ecfb01628ff78432f91ebf2c0f65e2a">28e60d022</a>">28e60d022</a><a href="https://github.com/apache/carbondata/commit/a6c23d35d16098beb7f298ed4bf3d0a6bd19a5fa"> into 4c692d185">4c692d185</a>

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

58702 of 72766 relevant lines covered (80.67%)

1.07 hits per line

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

35.19

/core/src/main/java/org/apache/carbondata/core/datastore/page/DecimalColumnPage.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.page;

import java.math.BigDecimal;

import org.apache.carbondata.core.datastore.page.encoding.ColumnPageEncoderMeta;
import org.apache.carbondata.core.metadata.datatype.DataTypes;
import org.apache.carbondata.core.metadata.datatype.DecimalConverterFactory;

/**
 * Represent a columnar data in one page for one column of decimal data type
 */
public abstract class DecimalColumnPage extends VarLengthColumnPageBase {

  /**
   * decimal converter instance
   */
  DecimalConverterFactory.DecimalConverter decimalConverter;

  DecimalColumnPage(ColumnPageEncoderMeta columnPageEncoderMeta, int pageSize) {
    super(columnPageEncoderMeta, pageSize);
    decimalConverter = DecimalConverterFactory.INSTANCE.getDecimalConverter(
        columnPageEncoderMeta.getColumnSpec().getPrecision(),
        columnPageEncoderMeta.getColumnSpec().getScale());
  }

  public DecimalConverterFactory.DecimalConverter getDecimalConverter() {
    return decimalConverter;
  }

  @Override
  public byte[] getBytePage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public short[] getShortPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public byte[] getShortIntPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public int[] getIntPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public long[] getLongPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public float[] getFloatPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public double[] getDoublePage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public byte[][] getByteArrayPage() {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public float getFloat(int rowId) {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public double getDouble(int rowId) {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public void putDouble(int rowId, double value) {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public void setFloatPage(float[] floatData) {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  @Override
  public void setDoublePage(double[] doubleData) {
    throw new UnsupportedOperationException(
        "invalid data type: " + columnPageEncoderMeta.getStoreDataType());
  }

  // used for building datamap in loading process
  private BigDecimal getDecimalFromRawData(int rowId) {
    long value;
    switch (decimalConverter.getDecimalConverterType()) {
      case DECIMAL_INT:
        value = getInt(rowId);
        break;
      case DECIMAL_LONG:
        value = getLong(rowId);
        break;
      default:
        value = getByte(rowId);
    }
    return decimalConverter.getDecimal(value);
  }

  private BigDecimal getDecimalFromDecompressData(int rowId) {
    long value;
    if (columnPageEncoderMeta.getStoreDataType() == DataTypes.BYTE) {
      value = getByte(rowId);
    } else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.SHORT) {
      value = getShort(rowId);
    } else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.SHORT_INT) {
      value = getShortInt(rowId);
    } else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.INT) {
      value = getInt(rowId);
    } else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.LONG) {
      value = getLong(rowId);
    } else {
      return decimalConverter.getDecimal(getBytes(rowId));
    }
    return decimalConverter.getDecimal(value);
  }

  @Override
  public BigDecimal getDecimal(int rowId) {
    // rowOffset is initialed for query in `VarLengthColumnPageBase.getDecimalColumnPage`
    // if its size is 0, we are in loading process and the data in column page is raw
    if (rowOffset.getActualRowCount() == 0) {
      return getDecimalFromRawData(rowId);
    } else {
      return getDecimalFromDecompressData(rowId);
    }
  }

}

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.datastore.page;
19
20	import java.math.BigDecimal;
21
22	import org.apache.carbondata.core.datastore.page.encoding.ColumnPageEncoderMeta;
23	import org.apache.carbondata.core.metadata.datatype.DataTypes;
24	import org.apache.carbondata.core.metadata.datatype.DecimalConverterFactory;
25
26	/**
27	* Represent a columnar data in one page for one column of decimal data type
28	*/
29	public abstract class DecimalColumnPage extends VarLengthColumnPageBase {
30
31	/**
32	* decimal converter instance
33	*/
34	DecimalConverterFactory.DecimalConverter decimalConverter;
35
36	DecimalColumnPage(ColumnPageEncoderMeta columnPageEncoderMeta, int pageSize) {
37	super(columnPageEncoderMeta, pageSize);	2✔
38	decimalConverter = DecimalConverterFactory.INSTANCE.getDecimalConverter(	2✔
39	columnPageEncoderMeta.getColumnSpec().getPrecision(),	2✔
40	columnPageEncoderMeta.getColumnSpec().getScale());	2✔
41	}	2✔
42
43	public DecimalConverterFactory.DecimalConverter getDecimalConverter() {
44	return decimalConverter;	1✔
45	}
46
47	@Override
48	public byte[] getBytePage() {
49	throw new UnsupportedOperationException(	×
50	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
51	}
52
53	@Override
54	public short[] getShortPage() {
55	throw new UnsupportedOperationException(	×
56	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
57	}
58
59	@Override
60	public byte[] getShortIntPage() {
61	throw new UnsupportedOperationException(	×
62	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
63	}
64
65	@Override
66	public int[] getIntPage() {
67	throw new UnsupportedOperationException(	×
68	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
69	}
70
71	@Override
72	public long[] getLongPage() {
73	throw new UnsupportedOperationException(	×
74	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
75	}
76
77	@Override
78	public float[] getFloatPage() {
79	throw new UnsupportedOperationException(	×
80	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
81	}
82
83	@Override
84	public double[] getDoublePage() {
85	throw new UnsupportedOperationException(	×
86	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
87	}
88
89	@Override
90	public byte[][] getByteArrayPage() {
91	throw new UnsupportedOperationException(	×
92	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
93	}
94
95	@Override
96	public float getFloat(int rowId) {
97	throw new UnsupportedOperationException(	×
98	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
99	}
100
101	@Override
102	public double getDouble(int rowId) {
103	throw new UnsupportedOperationException(	×
104	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
105	}
106
107	@Override
108	public void putDouble(int rowId, double value) {
109	throw new UnsupportedOperationException(	×
110	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
111	}
112
113	@Override
114	public void setFloatPage(float[] floatData) {
115	throw new UnsupportedOperationException(	×
116	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
117	}
118
119	@Override
120	public void setDoublePage(double[] doubleData) {
121	throw new UnsupportedOperationException(	×
122	"invalid data type: " + columnPageEncoderMeta.getStoreDataType());	×
123	}
124
125	// used for building datamap in loading process
126	private BigDecimal getDecimalFromRawData(int rowId) {
127	long value;
128	switch (decimalConverter.getDecimalConverterType()) {	1✔
129	case DECIMAL_INT:
130	value = getInt(rowId);	×
131	break;	×
132	case DECIMAL_LONG:
133	value = getLong(rowId);	1✔
134	break;	1✔
135	default:
136	value = getByte(rowId);	×
137	}
138	return decimalConverter.getDecimal(value);	1✔
139	}
140
141	private BigDecimal getDecimalFromDecompressData(int rowId) {
142	long value;
143	if (columnPageEncoderMeta.getStoreDataType() == DataTypes.BYTE) {	1✔
144	value = getByte(rowId);	×
145	} else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.SHORT) {	1✔
146	value = getShort(rowId);	×
147	} else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.SHORT_INT) {	1✔
148	value = getShortInt(rowId);	×
149	} else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.INT) {	1✔
150	value = getInt(rowId);	×
151	} else if (columnPageEncoderMeta.getStoreDataType() == DataTypes.LONG) {	1✔
152	value = getLong(rowId);	×
153	} else {
154	return decimalConverter.getDecimal(getBytes(rowId));	1✔
155	}
156	return decimalConverter.getDecimal(value);	×
157	}
158
159	@Override
160	public BigDecimal getDecimal(int rowId) {
161	// rowOffset is initialed for query in `VarLengthColumnPageBase.getDecimalColumnPage`
162	// if its size is 0, we are in loading process and the data in column page is raw
163	if (rowOffset.getActualRowCount() == 0) {	1✔
164	return getDecimalFromRawData(rowId);	1✔
165	} else {
166	return getDecimalFromDecompressData(rowId);	1✔
167	}
168	}
169
170	}

apache / carbondata / 429

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