1000

Build # 1000

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/078a579a882086bb7989d2b94f3b7c2ace58fd17">078a579a8<a href="https://github.com/apache/carbondata/commit/078a579a882086bb7989d2b94f3b7c2ace58fd17">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/359543aaf6a0c91559a734d4b6a9f2fd6c6fe41b">359543aaf</a>">359543aaf</a><a href="https://github.com/apache/carbondata/commit/078a579a882086bb7989d2b94f3b7c2ace58fd17"> into 15d38260c">15d38260c</a>

Run Details

302 of 302 new or added lines in 24 files covered. (100.0%)

60545 of 74859 relevant lines covered (80.88%)

1.07 hits per line

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

36.84

/core/src/main/java/org/apache/carbondata/core/memory/CarbonUnsafe.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.memory;

import java.lang.reflect.Field;
import java.nio.ByteOrder;

import org.apache.carbondata.core.metadata.datatype.DataType;
import org.apache.carbondata.core.metadata.datatype.DataTypes;

import sun.misc.Unsafe;


public final class CarbonUnsafe {

  public static final int BYTE_ARRAY_OFFSET;

  public static final int SHORT_ARRAY_OFFSET;

  public static final int INT_ARRAY_OFFSET;

  public static final int LONG_ARRAY_OFFSET;

  public static final int DOUBLE_ARRAY_OFFSET;

  public static final int FLOAT_ARRAY_OFFSET;

  public static final boolean ISLITTLEENDIAN =
      ByteOrder.nativeOrder().equals(ByteOrder.LITTLE_ENDIAN);

  private static Unsafe unsafe;

  static {
    try {
      Field cause = Unsafe.class.getDeclaredField("theUnsafe");
      cause.setAccessible(true);
      unsafe = (Unsafe) cause.get(null);
    } catch (Throwable var2) {
      unsafe = null;
    }
    if (unsafe != null) {
      BYTE_ARRAY_OFFSET = unsafe.arrayBaseOffset(byte[].class);
      SHORT_ARRAY_OFFSET = unsafe.arrayBaseOffset(short[].class);
      INT_ARRAY_OFFSET = unsafe.arrayBaseOffset(int[].class);
      LONG_ARRAY_OFFSET = unsafe.arrayBaseOffset(long[].class);
      FLOAT_ARRAY_OFFSET = unsafe.arrayBaseOffset(float[].class);
      DOUBLE_ARRAY_OFFSET = unsafe.arrayBaseOffset(double[].class);
    } else {
      BYTE_ARRAY_OFFSET = 0;
      SHORT_ARRAY_OFFSET = 0;
      INT_ARRAY_OFFSET = 0;
      LONG_ARRAY_OFFSET = 0;
      FLOAT_ARRAY_OFFSET = 0;
      DOUBLE_ARRAY_OFFSET = 0;
    }
  }

  public static Unsafe getUnsafe() {
    return unsafe;
  }

  public static int getOffsetByDataType(DataType dataType) {
    if (DataTypes.BYTE == dataType) {
      return BYTE_ARRAY_OFFSET;
    } else if (DataTypes.SHORT == dataType) {
      return SHORT_ARRAY_OFFSET;
    } else if (DataTypes.SHORT_INT == dataType) {
      return BYTE_ARRAY_OFFSET;
    } else if (DataTypes.INT == dataType) {
      return INT_ARRAY_OFFSET;
    } else if (DataTypes.LONG == dataType) {
      return LONG_ARRAY_OFFSET;
    } else if (DataTypes.FLOAT == dataType) {
      return FLOAT_ARRAY_OFFSET;
    } else if (DataTypes.DOUBLE == dataType) {
      return DOUBLE_ARRAY_OFFSET;
    } else {
      throw new UnsupportedOperationException("Invalid data type " + dataType);
    }
  }
}

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.memory;
19
20	import java.lang.reflect.Field;
21	import java.nio.ByteOrder;
22
23	import org.apache.carbondata.core.metadata.datatype.DataType;
24	import org.apache.carbondata.core.metadata.datatype.DataTypes;
25
26	import sun.misc.Unsafe;
27
28
29	public final class CarbonUnsafe {	×
30
31	public static final int BYTE_ARRAY_OFFSET;
32
33	public static final int SHORT_ARRAY_OFFSET;
34
35	public static final int INT_ARRAY_OFFSET;
36
37	public static final int LONG_ARRAY_OFFSET;
38
39	public static final int DOUBLE_ARRAY_OFFSET;
40
41	public static final int FLOAT_ARRAY_OFFSET;
42
43	public static final boolean ISLITTLEENDIAN =
44	ByteOrder.nativeOrder().equals(ByteOrder.LITTLE_ENDIAN);	2✔
45
46	private static Unsafe unsafe;
47
48	static {
49	try {
50	Field cause = Unsafe.class.getDeclaredField("theUnsafe");	2✔
51	cause.setAccessible(true);	2✔
52	unsafe = (Unsafe) cause.get(null);	2✔
53	} catch (Throwable var2) {	×
54	unsafe = null;	×
55	}	2✔
56	if (unsafe != null) {	2✔
57	BYTE_ARRAY_OFFSET = unsafe.arrayBaseOffset(byte[].class);	2✔
58	SHORT_ARRAY_OFFSET = unsafe.arrayBaseOffset(short[].class);	2✔
59	INT_ARRAY_OFFSET = unsafe.arrayBaseOffset(int[].class);	2✔
60	LONG_ARRAY_OFFSET = unsafe.arrayBaseOffset(long[].class);	2✔
61	FLOAT_ARRAY_OFFSET = unsafe.arrayBaseOffset(float[].class);	2✔
62	DOUBLE_ARRAY_OFFSET = unsafe.arrayBaseOffset(double[].class);	2✔
63	} else {
64	BYTE_ARRAY_OFFSET = 0;	×
65	SHORT_ARRAY_OFFSET = 0;	×
66	INT_ARRAY_OFFSET = 0;	×
67	LONG_ARRAY_OFFSET = 0;	×
68	FLOAT_ARRAY_OFFSET = 0;	×
69	DOUBLE_ARRAY_OFFSET = 0;	×
70	}
71	}	2✔
72
73	public static Unsafe getUnsafe() {
74	return unsafe;	2✔
75	}
76
77	public static int getOffsetByDataType(DataType dataType) {
78	if (DataTypes.BYTE == dataType) {	×
79	return BYTE_ARRAY_OFFSET;	×
80	} else if (DataTypes.SHORT == dataType) {	×
81	return SHORT_ARRAY_OFFSET;	×
82	} else if (DataTypes.SHORT_INT == dataType) {	×
83	return BYTE_ARRAY_OFFSET;	×
84	} else if (DataTypes.INT == dataType) {	×
85	return INT_ARRAY_OFFSET;	×
86	} else if (DataTypes.LONG == dataType) {	×
87	return LONG_ARRAY_OFFSET;	×
88	} else if (DataTypes.FLOAT == dataType) {	×
89	return FLOAT_ARRAY_OFFSET;	×
90	} else if (DataTypes.DOUBLE == dataType) {	×
91	return DOUBLE_ARRAY_OFFSET;	×
92	} else {
93	throw new UnsupportedOperationException("Invalid data type " + dataType);	×
94	}
95	}
96	}

apache / carbondata / 1000

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