10878

Build # 10878

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/39231a86981e1e21d0dbf3832e60e18447bac608">39231a869<a href="https://github.com/apache/carbondata/commit/39231a86981e1e21d0dbf3832e60e18447bac608">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/1ac9320b1cafdda9db180891b82d7197e65a9561">1ac9320b1</a>">1ac9320b1</a><a href="https://github.com/apache/carbondata/commit/39231a86981e1e21d0dbf3832e60e18447bac608"> into 9051ab72c">9051ab72c</a>

Run Details

105 of 105 new or added lines in 7 files covered. (100.0%)

62512 of 78902 relevant lines covered (79.23%)

1.05 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/indexstore/row/DataMapRowImpl.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.indexstore.row;

import org.apache.carbondata.core.indexstore.schema.CarbonRowSchema;
import org.apache.carbondata.core.metadata.datatype.DataTypes;

/**
 * Data map row.
 */
public class DataMapRowImpl extends DataMapRow {

  private Object[] data;

  private int totalLengthInBytes;

  public DataMapRowImpl(CarbonRowSchema[] schemas) {
    super(schemas);
    this.data = new Object[schemas.length];
  }

  @Override public byte[] getByteArray(int ordinal) {
    return (byte[]) data[ordinal];
  }

  @Override public byte[] getByteArray(int ordinal, int position) {
    return (byte[]) data[ordinal];
  }

  @Override public int getLengthInBytes(int ordinal) {
    return ((byte[]) data[ordinal]).length;
  }

  @Override public void setBoolean(boolean value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.BOOLEAN);
    data[ordinal] = value;
  }

  @Override public boolean getBoolean(int ordinal) {
    return (boolean) data[ordinal];
  }

  @Override public DataMapRow getRow(int ordinal) {
    return (DataMapRow) data[ordinal];
  }

  @Override public DataMapRow getRow(int ordinal, int position) {
    return (DataMapRow) data[ordinal];
  }

  @Override public void setByteArray(byte[] byteArray, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.BYTE_ARRAY);
    data[ordinal] = byteArray;
  }

  @Override public int getInt(int ordinal) {
    return (Integer) data[ordinal];
  }

  @Override public void setInt(int value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.INT);
    data[ordinal] = value;
  }

  @Override public void setByte(byte value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.BYTE);
    data[ordinal] = value;
  }

  @Override public byte getByte(int ordinal) {
    return (Byte) data[ordinal];
  }

  @Override public void setShort(short value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.SHORT);
    data[ordinal] = value;
  }

  @Override public short getShort(int ordinal) {
    return (Short) data[ordinal];
  }

  @Override public void setLong(long value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.LONG);
    data[ordinal] = value;
  }

  @Override public long getLong(int ordinal) {
    return (Long) data[ordinal];
  }

  @Override public void setFloat(float value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.FLOAT);
    data[ordinal] = value;
  }

  @Override public float getFloat(int ordinal) {
    return (Float) data[ordinal];
  }

  @Override public void setDouble(double value, int ordinal) {
    assert (schemas[ordinal].getDataType() == DataTypes.DOUBLE);
    data[ordinal] = value;
  }

  @Override public void setRow(DataMapRow row, int ordinal) {
    assert (DataTypes.isStructType(schemas[ordinal].getDataType()));
    data[ordinal] = row;
  }

  @Override public double getDouble(int ordinal) {
    return (Double) data[ordinal];
  }

  public void setTotalLengthInBytes(int totalLengthInBytes) {
    this.totalLengthInBytes = totalLengthInBytes;
  }

  @Override public int getTotalSizeInBytes() {
    if (totalLengthInBytes > 0) {
      return totalLengthInBytes;
    } else {
      return super.getTotalSizeInBytes();
    }
  }
}

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.indexstore.row;
18
19	import org.apache.carbondata.core.indexstore.schema.CarbonRowSchema;
20	import org.apache.carbondata.core.metadata.datatype.DataTypes;
21
22	/**
23	* Data map row.
24	*/
25	public class DataMapRowImpl extends DataMapRow {	1✔
26
27	private Object[] data;
28
29	private int totalLengthInBytes;
30
31	public DataMapRowImpl(CarbonRowSchema[] schemas) {
32	super(schemas);	1✔
33	this.data = new Object[schemas.length];	1✔
34	}	1✔
35
36	@Override public byte[] getByteArray(int ordinal) {
37	return (byte[]) data[ordinal];	1✔
38	}
39
40	@Override public byte[] getByteArray(int ordinal, int position) {
41	return (byte[]) data[ordinal];	1✔
42	}
43
44	@Override public int getLengthInBytes(int ordinal) {
45	return ((byte[]) data[ordinal]).length;	1✔
46	}
47
48	@Override public void setBoolean(boolean value, int ordinal) {
49	assert (schemas[ordinal].getDataType() == DataTypes.BOOLEAN);	×
50	data[ordinal] = value;	×
51	}	×
52
53	@Override public boolean getBoolean(int ordinal) {
54	return (boolean) data[ordinal];	×
55	}
56
57	@Override public DataMapRow getRow(int ordinal) {
58	return (DataMapRow) data[ordinal];	1✔
59	}
60
61	@Override public DataMapRow getRow(int ordinal, int position) {
62	return (DataMapRow) data[ordinal];	1✔
63	}
64
65	@Override public void setByteArray(byte[] byteArray, int ordinal) {
66	assert (schemas[ordinal].getDataType() == DataTypes.BYTE_ARRAY);	1✔
67	data[ordinal] = byteArray;	1✔
68	}	1✔
69
70	@Override public int getInt(int ordinal) {
71	return (Integer) data[ordinal];	1✔
72	}
73
74	@Override public void setInt(int value, int ordinal) {
75	assert (schemas[ordinal].getDataType() == DataTypes.INT);	1✔
76	data[ordinal] = value;	1✔
77	}	1✔
78
79	@Override public void setByte(byte value, int ordinal) {
80	assert (schemas[ordinal].getDataType() == DataTypes.BYTE);	×
81	data[ordinal] = value;	×
82	}	×
83
84	@Override public byte getByte(int ordinal) {
85	return (Byte) data[ordinal];	×
86	}
87
88	@Override public void setShort(short value, int ordinal) {
89	assert (schemas[ordinal].getDataType() == DataTypes.SHORT);	1✔
90	data[ordinal] = value;	1✔
91	}	1✔
92
93	@Override public short getShort(int ordinal) {
94	return (Short) data[ordinal];	1✔
95	}
96
97	@Override public void setLong(long value, int ordinal) {
98	assert (schemas[ordinal].getDataType() == DataTypes.LONG);	1✔
99	data[ordinal] = value;	1✔
100	}	1✔
101
102	@Override public long getLong(int ordinal) {
103	return (Long) data[ordinal];	1✔
104	}
105
106	@Override public void setFloat(float value, int ordinal) {
107	assert (schemas[ordinal].getDataType() == DataTypes.FLOAT);	×
108	data[ordinal] = value;	×
109	}	×
110
111	@Override public float getFloat(int ordinal) {
112	return (Float) data[ordinal];	×
113	}
114
115	@Override public void setDouble(double value, int ordinal) {
116	assert (schemas[ordinal].getDataType() == DataTypes.DOUBLE);	×
117	data[ordinal] = value;	×
118	}	×
119
120	@Override public void setRow(DataMapRow row, int ordinal) {
121	assert (DataTypes.isStructType(schemas[ordinal].getDataType()));	1✔
122	data[ordinal] = row;	1✔
123	}	1✔
124
125	@Override public double getDouble(int ordinal) {
126	return (Double) data[ordinal];	×
127	}
128
129	public void setTotalLengthInBytes(int totalLengthInBytes) {
130	this.totalLengthInBytes = totalLengthInBytes;	1✔
131	}	1✔
132
133	@Override public int getTotalSizeInBytes() {
134	if (totalLengthInBytes > 0) {	1✔
135	return totalLengthInBytes;	1✔
136	} else {
137	return super.getTotalSizeInBytes();	1✔
138	}
139	}
140	}

apache / carbondata / 10878

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