9525

Build # 9525

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/06a55cd4352d43af4f32e579f72b78b4c76c0010">06a55cd43<a href="https://github.com/apache/carbondata/commit/06a55cd4352d43af4f32e579f72b78b4c76c0010">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/efbbc2a3d8bf91f1612663d53d1deaff1fb52b73">efbbc2a3d</a>">efbbc2a3d</a><a href="https://github.com/apache/carbondata/commit/06a55cd4352d43af4f32e579f72b78b4c76c0010"> into 5a0bc6e71">5a0bc6e71</a>

Run Details

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

61912 of 77235 relevant lines covered (80.16%)

1.06 hits per line

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

54.1

/core/src/main/java/org/apache/carbondata/core/metadata/encoder/Encoding.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.metadata.encoder;

import java.util.List;

/**
 * Encoding type supported in carbon
 */
public enum Encoding {
  DICTIONARY,
  DELTA,
  RLE,
  INVERTED_INDEX,
  BIT_PACKED,
  DIRECT_DICTIONARY,
  IMPLICIT,
  DIRECT_COMPRESS,
  ADAPTIVE_INTEGRAL,
  ADAPTIVE_DELTA_INTEGRAL,
  RLE_INTEGRAL,
  DIRECT_STRING,
  ADAPTIVE_FLOATING,
  BOOL_BYTE,
  ADAPTIVE_DELTA_FLOATING,
  DIRECT_COMPRESS_VARCHAR;

  public static Encoding valueOf(int ordinal) {
    if (ordinal == DICTIONARY.ordinal()) {
      return DICTIONARY;
    } else if (ordinal == DELTA.ordinal()) {
      return DELTA;
    } else if (ordinal == RLE.ordinal()) {
      return RLE;
    } else if (ordinal == INVERTED_INDEX.ordinal()) {
      return INVERTED_INDEX;
    } else if (ordinal == BIT_PACKED.ordinal()) {
      return BIT_PACKED;
    } else if (ordinal == DIRECT_DICTIONARY.ordinal()) {
      return DIRECT_DICTIONARY;
    } else if (ordinal == IMPLICIT.ordinal()) {
      return IMPLICIT;
    } else if (ordinal == DIRECT_COMPRESS.ordinal()) {
      return DIRECT_COMPRESS;
    } else if (ordinal == ADAPTIVE_INTEGRAL.ordinal()) {
      return ADAPTIVE_INTEGRAL;
    } else if (ordinal == ADAPTIVE_DELTA_INTEGRAL.ordinal()) {
      return ADAPTIVE_DELTA_INTEGRAL;
    } else if (ordinal == RLE_INTEGRAL.ordinal()) {
      return RLE_INTEGRAL;
    } else if (ordinal == DIRECT_STRING.ordinal()) {
      return DIRECT_STRING;
    } else if (ordinal == ADAPTIVE_FLOATING.ordinal()) {
      return ADAPTIVE_FLOATING;
    } else if (ordinal == BOOL_BYTE.ordinal()) {
      return BOOL_BYTE;
    } else if (ordinal == ADAPTIVE_DELTA_FLOATING.ordinal()) {
      return ADAPTIVE_DELTA_FLOATING;
    } else if (ordinal == DIRECT_COMPRESS_VARCHAR.ordinal()) {
      return DIRECT_COMPRESS_VARCHAR;
    } else {
      throw new RuntimeException("create Encoding with invalid ordinal: " + ordinal);
    }
  }

  /**
   * Method to validate for supported encoding types that can be read using the current version
   *
   * @param encodings
   */
  public static void validateEncodingTypes(List<org.apache.carbondata.format.Encoding> encodings) {
    if (null != encodings && !encodings.isEmpty()) {
      for (org.apache.carbondata.format.Encoding encoder : encodings) {
        // if case is handle unsupported encoding type. An encoding not supported for read will
        // be added as null by thrift during deserialization
        // if given encoding name is not supported exception will be thrown
        if (null == encoder) {
          throw new UnsupportedOperationException(
              "There is mismatch between the encodings in data file and the encodings supported"
                  + " for read in the current version");
        } else {
          try {
            Encoding.valueOf(encoder.name());
          } catch (IllegalArgumentException ex) {
            throw new UnsupportedOperationException(
                "There is mismatch between the encodings in data file and the encodings supported"
                    + " for read in the current version. Encoding: " + encoder.name());
          }
        }
      }
    }
  }
}

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.metadata.encoder;
18
19	import java.util.List;
20
21	/**
22	* Encoding type supported in carbon
23	*/
24	public enum Encoding {	2✔
25	DICTIONARY,	2✔
26	DELTA,	2✔
27	RLE,	2✔
28	INVERTED_INDEX,	2✔
29	BIT_PACKED,	2✔
30	DIRECT_DICTIONARY,	2✔
31	IMPLICIT,	2✔
32	DIRECT_COMPRESS,	2✔
33	ADAPTIVE_INTEGRAL,	2✔
34	ADAPTIVE_DELTA_INTEGRAL,	2✔
35	RLE_INTEGRAL,	2✔
36	DIRECT_STRING,	2✔
37	ADAPTIVE_FLOATING,	2✔
38	BOOL_BYTE,	2✔
39	ADAPTIVE_DELTA_FLOATING,	2✔
40	DIRECT_COMPRESS_VARCHAR;	2✔
41
42	public static Encoding valueOf(int ordinal) {
43	if (ordinal == DICTIONARY.ordinal()) {	1✔
44	return DICTIONARY;	1✔
45	} else if (ordinal == DELTA.ordinal()) {	1✔
46	return DELTA;	×
47	} else if (ordinal == RLE.ordinal()) {	1✔
48	return RLE;	×
49	} else if (ordinal == INVERTED_INDEX.ordinal()) {	1✔
50	return INVERTED_INDEX;	1✔
51	} else if (ordinal == BIT_PACKED.ordinal()) {	1✔
52	return BIT_PACKED;	×
53	} else if (ordinal == DIRECT_DICTIONARY.ordinal()) {	1✔
54	return DIRECT_DICTIONARY;	1✔
55	} else if (ordinal == IMPLICIT.ordinal()) {	×
56	return IMPLICIT;	×
57	} else if (ordinal == DIRECT_COMPRESS.ordinal()) {	×
58	return DIRECT_COMPRESS;	×
59	} else if (ordinal == ADAPTIVE_INTEGRAL.ordinal()) {	×
60	return ADAPTIVE_INTEGRAL;	×
61	} else if (ordinal == ADAPTIVE_DELTA_INTEGRAL.ordinal()) {	×
62	return ADAPTIVE_DELTA_INTEGRAL;	×
63	} else if (ordinal == RLE_INTEGRAL.ordinal()) {	×
64	return RLE_INTEGRAL;	×
65	} else if (ordinal == DIRECT_STRING.ordinal()) {	×
66	return DIRECT_STRING;	×
67	} else if (ordinal == ADAPTIVE_FLOATING.ordinal()) {	×
68	return ADAPTIVE_FLOATING;	×
69	} else if (ordinal == BOOL_BYTE.ordinal()) {	×
70	return BOOL_BYTE;	×
71	} else if (ordinal == ADAPTIVE_DELTA_FLOATING.ordinal()) {	×
72	return ADAPTIVE_DELTA_FLOATING;	×
73	} else if (ordinal == DIRECT_COMPRESS_VARCHAR.ordinal()) {	×
74	return DIRECT_COMPRESS_VARCHAR;	×
75	} else {
76	throw new RuntimeException("create Encoding with invalid ordinal: " + ordinal);	×
77	}
78	}
79
80	/**
81	* Method to validate for supported encoding types that can be read using the current version
82	*
83	* @param encodings
84	*/
85	public static void validateEncodingTypes(List<org.apache.carbondata.format.Encoding> encodings) {
86	if (null != encodings && !encodings.isEmpty()) {	1✔
87	for (org.apache.carbondata.format.Encoding encoder : encodings) {	1✔
88	// if case is handle unsupported encoding type. An encoding not supported for read will
89	// be added as null by thrift during deserialization
90	// if given encoding name is not supported exception will be thrown
91	if (null == encoder) {	1✔
92	throw new UnsupportedOperationException(	×
93	"There is mismatch between the encodings in data file and the encodings supported"
94	+ " for read in the current version");
95	} else {
96	try {
97	Encoding.valueOf(encoder.name());	1✔
98	} catch (IllegalArgumentException ex) {	×
99	throw new UnsupportedOperationException(	×
100	"There is mismatch between the encodings in data file and the encodings supported"
101	+ " for read in the current version. Encoding: " + encoder.name());	×
102	}	1✔
103	}
104	}	1✔
105	}
106	}	1✔
107	}

apache / carbondata / 9525

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