apache / carbondata / 425

Build # 425

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/21ee47837a3d85306e6c6c86560c34bda297bfd0">21ee47837<a href="https://github.com/apache/carbondata/commit/21ee47837a3d85306e6c6c86560c34bda297bfd0">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/1a409ecd41b99208bc31c412fd0f4d30c50fbfbc">1a409ecd4</a>">1a409ecd4</a><a href="https://github.com/apache/carbondata/commit/21ee47837a3d85306e6c6c86560c34bda297bfd0"> into daa91c88e">daa91c88e</a>

Run Details

173 of 173 new or added lines in 12 files covered. (100.0%)

58739 of 72832 relevant lines covered (80.65%)

1.07 hits per line

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

70.33

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

import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.apache.carbondata.common.constants.LoggerAction;
import org.apache.carbondata.common.logging.LogService;
import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.cache.CacheProvider;
import org.apache.carbondata.core.constants.CarbonCommonConstants;
import org.apache.carbondata.core.constants.CarbonCommonConstantsInternal;
import org.apache.carbondata.core.constants.CarbonLoadOptionConstants;
import org.apache.carbondata.core.datamap.DataMapStoreManager;
import org.apache.carbondata.core.exception.InvalidConfigurationException;

import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_CUSTOM_BLOCK_DISTRIBUTION;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_MAJOR_COMPACTION_SIZE;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_SEARCH_MODE_ENABLE;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.COMPACTION_SEGMENT_LEVEL_THRESHOLD;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_AUTO_LOAD_MERGE;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_OFFHEAP_SORT;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_UNSAFE_IN_QUERY_EXECUTION;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_UNSAFE_SORT;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_VECTOR_READER;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.NUM_CORES_COMPACTING;
import static org.apache.carbondata.core.constants.CarbonCommonConstants.NUM_CORES_LOADING;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_ACTION;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_LOGGER_ENABLE;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORD_PATH;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BATCH_SORT_SIZE_INMB;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_DATEFORMAT;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_GLOBAL_SORT_PARTITIONS;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_IS_EMPTY_DATA_BAD_RECORD;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SINGLE_PASS;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SORT_SCOPE;
import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_TIMESTAMPFORMAT;
import static org.apache.carbondata.core.constants.CarbonV3DataFormatConstants.BLOCKLET_SIZE_IN_MB;

/**
 * This class maintains carbon session params
 */
public class SessionParams implements Serializable, Cloneable {

  private static final LogService LOGGER =
      LogServiceFactory.getLogService(CacheProvider.class.getName());
  private static final long serialVersionUID = -7801994600594915264L;

  private Map<String, String> sProps;
  private ConcurrentHashMap<String, String> addedProps;
  // below field to be used when we want the objects to be serialized
  private Map<String, Object> extraInfo;
  public SessionParams() {
    sProps = new HashMap<>();
    addedProps = new ConcurrentHashMap<>();
    extraInfo = new HashMap<>();
  }

  public void setExtraInfo(String key, Object value) {
    this.extraInfo.put(key, value);
  }

  public Object getExtraInfo(String key) {
    return this.extraInfo.get(key);
  }

  /**
   * This method will be used to get the properties value
   *
   * @param key
   * @return properties value
   */
  public String getProperty(String key) {
    return sProps.get(key);
  }

  public String getProperty(String key, String defaultValue) {
    if (!sProps.containsKey(key)) {
      return defaultValue;
    }
    return sProps.get(key);
  }

  /**
   * This method will be used to add a new property
   *
   * @param key
   * @return properties value
   */
  public SessionParams addProperty(String key, String value) throws InvalidConfigurationException {
    return addProperty(key, value, true);
  }

  /**
   * This method will be used to add a new property
   *
   * @param key
   * @return properties value
   */
  public SessionParams addProperty(String key, String value, Boolean doAuditing)
      throws InvalidConfigurationException {
    boolean isValidConf = validateKeyValue(key, value);
    if (isValidConf) {
      if (key.equals(CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_ACTION)) {
        value = value.toUpperCase();
      }
      if (doAuditing) {
        LOGGER.audit("The key " + key + " with value " + value + " added in the session param");
      }
      sProps.put(key, value);
    }
    return this;
  }

  public Map<String, String> getAll() {
    return sProps;
  }

  public SessionParams addProps(Map<String, String> addedProps) {
    this.addedProps.putAll(addedProps);
    return this;
  }

  public Map<String, String> getAddedProps() {
    return addedProps;
  }

  /**
   * validate the key value to be set using set command
   * @param key
   * @param value
   * @return
   * @throws InvalidConfigurationException
   */
  private boolean validateKeyValue(String key, String value) throws InvalidConfigurationException {
    boolean isValid = false;
    switch (key) {
      case ENABLE_UNSAFE_SORT:
      case ENABLE_OFFHEAP_SORT:
      case CARBON_CUSTOM_BLOCK_DISTRIBUTION:
      case CARBON_OPTIONS_BAD_RECORDS_LOGGER_ENABLE:
      case CARBON_OPTIONS_IS_EMPTY_DATA_BAD_RECORD:
      case CARBON_OPTIONS_SINGLE_PASS:
      case CARBON_SEARCH_MODE_ENABLE:
      case ENABLE_VECTOR_READER:
      case ENABLE_UNSAFE_IN_QUERY_EXECUTION:
      case ENABLE_AUTO_LOAD_MERGE:
        isValid = CarbonUtil.validateBoolean(value);
        if (!isValid) {
          throw new InvalidConfigurationException("Invalid value " + value + " for key " + key);
        }
        break;
      case CARBON_OPTIONS_BAD_RECORDS_ACTION:
        try {
          LoggerAction.valueOf(value.toUpperCase());
          isValid = true;
        } catch (IllegalArgumentException iae) {
          throw new InvalidConfigurationException(
              "The key " + key + " can have only either FORCE or IGNORE or REDIRECT or FAIL.");
        }
        break;
      case CARBON_OPTIONS_SORT_SCOPE:
        isValid = CarbonUtil.isValidSortOption(value);
        if (!isValid) {
          throw new InvalidConfigurationException("The sort scope " + key
              + " can have only either BATCH_SORT or LOCAL_SORT or NO_SORT.");
        }
        break;
      case CARBON_OPTIONS_BATCH_SORT_SIZE_INMB:
      case CARBON_OPTIONS_GLOBAL_SORT_PARTITIONS:
      case NUM_CORES_LOADING:
      case NUM_CORES_COMPACTING:
      case BLOCKLET_SIZE_IN_MB:
      case CARBON_MAJOR_COMPACTION_SIZE:
        isValid = CarbonUtil.validateValidIntType(value);
        if (!isValid) {
          throw new InvalidConfigurationException(
              "The configured value for key " + key + " must be valid integer.");
        }
        break;
      case CARBON_OPTIONS_BAD_RECORD_PATH:
        isValid = CarbonUtil.isValidBadStorePath(value);
        if (!isValid) {
          throw new InvalidConfigurationException("Invalid bad records location.");
        }
        break;
      // no validation needed while set for CARBON_OPTIONS_DATEFORMAT
      case CARBON_OPTIONS_DATEFORMAT:
        isValid = true;
        break;
      // no validation needed while set for CARBON_OPTIONS_TIMESTAMPFORMAT
      case CARBON_OPTIONS_TIMESTAMPFORMAT:
        isValid = true;
        break;
      // no validation needed while set for CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT
      case CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT:
        isValid = true;
        break;
      case COMPACTION_SEGMENT_LEVEL_THRESHOLD:
        int[] values = CarbonProperties.getInstance().getIntArray(value);
        if (values.length != 2) {
          throw new InvalidConfigurationException(
              "Invalid COMPACTION_SEGMENT_LEVEL_THRESHOLD: " + value);
        }
        isValid = true;
        break;
      default:
        if (key.startsWith(CarbonCommonConstants.CARBON_INPUT_SEGMENTS)) {
          isValid = CarbonUtil.validateRangeOfSegmentList(value);
          if (!isValid) {
            throw new InvalidConfigurationException("Invalid CARBON_INPUT_SEGMENT_IDs");
          }
        } else if (key.startsWith(CarbonCommonConstants.VALIDATE_CARBON_INPUT_SEGMENTS)) {
          isValid = true;
        } else if (key.equalsIgnoreCase(CarbonCommonConstants.SUPPORT_DIRECT_QUERY_ON_DATAMAP)) {
          isValid = true;
        } else if (key.startsWith(CarbonCommonConstantsInternal.QUERY_ON_PRE_AGG_STREAMING)) {
          isValid = true;
        } else if (key.startsWith(CarbonCommonConstants.CARBON_DATAMAP_VISIBLE)) {
          String[] keyArray = key.split("\\.");
          isValid = DataMapStoreManager.getInstance().isDataMapExist(
              keyArray[keyArray.length - 3],
              keyArray[keyArray.length - 2],
              keyArray[keyArray.length - 1]);
          if (!isValid) {
            throw new InvalidConfigurationException(
                String.format("Invalid configuration of %s, datamap does not exist", key));
          }
        } else if (key.startsWith(CarbonCommonConstants.CARBON_LOAD_DATAMAPS_PARALLEL)) {
          isValid = CarbonUtil.validateBoolean(value);
          if (!isValid) {
            throw new InvalidConfigurationException("Invalid value " + value + " for key " + key);
          }
        } else {
          throw new InvalidConfigurationException(
              "The key " + key + " not supported for dynamic configuration.");
        }
    }
    return isValid;
  }

  public void removeProperty(String property) {
    sProps.remove(property);
  }

  public void removeExtraInfo(String key) {
    extraInfo.remove(key);
  }
  /**
   * clear the set properties
   */
  public void clear() {
    sProps.clear();
  }

  public SessionParams clone() throws CloneNotSupportedException {
    super.clone();
    SessionParams newObj = new SessionParams();
    newObj.addedProps.putAll(this.addedProps);
    newObj.sProps.putAll(this.sProps);
    newObj.extraInfo.putAll(this.extraInfo);
    return newObj;
  }
}

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.util;
19
20	import java.io.Serializable;
21	import java.util.HashMap;
22	import java.util.Map;
23	import java.util.concurrent.ConcurrentHashMap;
24
25	import org.apache.carbondata.common.constants.LoggerAction;
26	import org.apache.carbondata.common.logging.LogService;
27	import org.apache.carbondata.common.logging.LogServiceFactory;
28	import org.apache.carbondata.core.cache.CacheProvider;
29	import org.apache.carbondata.core.constants.CarbonCommonConstants;
30	import org.apache.carbondata.core.constants.CarbonCommonConstantsInternal;
31	import org.apache.carbondata.core.constants.CarbonLoadOptionConstants;
32	import org.apache.carbondata.core.datamap.DataMapStoreManager;
33	import org.apache.carbondata.core.exception.InvalidConfigurationException;
34
35	import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_CUSTOM_BLOCK_DISTRIBUTION;
36	import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_MAJOR_COMPACTION_SIZE;
37	import static org.apache.carbondata.core.constants.CarbonCommonConstants.CARBON_SEARCH_MODE_ENABLE;
38	import static org.apache.carbondata.core.constants.CarbonCommonConstants.COMPACTION_SEGMENT_LEVEL_THRESHOLD;
39	import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_AUTO_LOAD_MERGE;
40	import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_OFFHEAP_SORT;
41	import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_UNSAFE_IN_QUERY_EXECUTION;
42	import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_UNSAFE_SORT;
43	import static org.apache.carbondata.core.constants.CarbonCommonConstants.ENABLE_VECTOR_READER;
44	import static org.apache.carbondata.core.constants.CarbonCommonConstants.NUM_CORES_COMPACTING;
45	import static org.apache.carbondata.core.constants.CarbonCommonConstants.NUM_CORES_LOADING;
46	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_ACTION;
47	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_LOGGER_ENABLE;
48	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORD_PATH;
49	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_BATCH_SORT_SIZE_INMB;
50	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_DATEFORMAT;
51	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_GLOBAL_SORT_PARTITIONS;
52	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_IS_EMPTY_DATA_BAD_RECORD;
53	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT;
54	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SINGLE_PASS;
55	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_SORT_SCOPE;
56	import static org.apache.carbondata.core.constants.CarbonLoadOptionConstants.CARBON_OPTIONS_TIMESTAMPFORMAT;
57	import static org.apache.carbondata.core.constants.CarbonV3DataFormatConstants.BLOCKLET_SIZE_IN_MB;
58
59	/**
60	* This class maintains carbon session params
61	*/
62	public class SessionParams implements Serializable, Cloneable {
63
64	private static final LogService LOGGER =	2✔
65	LogServiceFactory.getLogService(CacheProvider.class.getName());	2✔
66	private static final long serialVersionUID = -7801994600594915264L;
67
68	private Map<String, String> sProps;
69	private ConcurrentHashMap<String, String> addedProps;
70	// below field to be used when we want the objects to be serialized
71	private Map<String, Object> extraInfo;
72	public SessionParams() {	2✔
73	sProps = new HashMap<>();	2✔
74	addedProps = new ConcurrentHashMap<>();	2✔
75	extraInfo = new HashMap<>();	2✔
76	}	2✔
77
78	public void setExtraInfo(String key, Object value) {
79	this.extraInfo.put(key, value);	1✔
80	}	1✔
81
82	public Object getExtraInfo(String key) {
83	return this.extraInfo.get(key);	1✔
84	}
85
86	/**
87	* This method will be used to get the properties value
88	*
89	* @param key
90	* @return properties value
91	*/
92	public String getProperty(String key) {
93	return sProps.get(key);	2✔
94	}
95
96	public String getProperty(String key, String defaultValue) {
97	if (!sProps.containsKey(key)) {	1✔
98	return defaultValue;	1✔
99	}
100	return sProps.get(key);	1✔
101	}
102
103	/**
104	* This method will be used to add a new property
105	*
106	* @param key
107	* @return properties value
108	*/
109	public SessionParams addProperty(String key, String value) throws InvalidConfigurationException {
110	return addProperty(key, value, true);	1✔
111	}
112
113	/**
114	* This method will be used to add a new property
115	*
116	* @param key
117	* @return properties value
118	*/
119	public SessionParams addProperty(String key, String value, Boolean doAuditing)
120	throws InvalidConfigurationException {
121	boolean isValidConf = validateKeyValue(key, value);	1✔
122	if (isValidConf) {	1✔
123	if (key.equals(CarbonLoadOptionConstants.CARBON_OPTIONS_BAD_RECORDS_ACTION)) {	1✔
124	value = value.toUpperCase();	×
125	}
126	if (doAuditing) {	1✔
127	LOGGER.audit("The key " + key + " with value " + value + " added in the session param");	1✔
128	}
129	sProps.put(key, value);	1✔
130	}
131	return this;	1✔
132	}
133
134	public Map<String, String> getAll() {
135	return sProps;	1✔
136	}
137
138	public SessionParams addProps(Map<String, String> addedProps) {
139	this.addedProps.putAll(addedProps);	1✔
140	return this;	1✔
141	}
142
143	public Map<String, String> getAddedProps() {
144	return addedProps;	1✔
145	}
146
147	/**
148	* validate the key value to be set using set command
149	* @param key
150	* @param value
151	* @return
152	* @throws InvalidConfigurationException
153	*/
154	private boolean validateKeyValue(String key, String value) throws InvalidConfigurationException {
155	boolean isValid = false;	1✔
156	switch (key) {	1✔
157	case ENABLE_UNSAFE_SORT:
158	case ENABLE_OFFHEAP_SORT:
159	case CARBON_CUSTOM_BLOCK_DISTRIBUTION:
160	case CARBON_OPTIONS_BAD_RECORDS_LOGGER_ENABLE:
161	case CARBON_OPTIONS_IS_EMPTY_DATA_BAD_RECORD:
162	case CARBON_OPTIONS_SINGLE_PASS:
163	case CARBON_SEARCH_MODE_ENABLE:
164	case ENABLE_VECTOR_READER:
165	case ENABLE_UNSAFE_IN_QUERY_EXECUTION:
166	case ENABLE_AUTO_LOAD_MERGE:
167	isValid = CarbonUtil.validateBoolean(value);	1✔
168	if (!isValid) {	1✔
169	throw new InvalidConfigurationException("Invalid value " + value + " for key " + key);	1✔
170	}
171	break;
172	case CARBON_OPTIONS_BAD_RECORDS_ACTION:
173	try {
174	LoggerAction.valueOf(value.toUpperCase());	×
175	isValid = true;	×
176	} catch (IllegalArgumentException iae) {	×
177	throw new InvalidConfigurationException(	×
178	"The key " + key + " can have only either FORCE or IGNORE or REDIRECT or FAIL.");
179	}	×
180	break;
181	case CARBON_OPTIONS_SORT_SCOPE:
182	isValid = CarbonUtil.isValidSortOption(value);	1✔
183	if (!isValid) {	1✔
184	throw new InvalidConfigurationException("The sort scope " + key	1✔
185	+ " can have only either BATCH_SORT or LOCAL_SORT or NO_SORT.");
186	}
187	break;
188	case CARBON_OPTIONS_BATCH_SORT_SIZE_INMB:
189	case CARBON_OPTIONS_GLOBAL_SORT_PARTITIONS:
190	case NUM_CORES_LOADING:
191	case NUM_CORES_COMPACTING:
192	case BLOCKLET_SIZE_IN_MB:
193	case CARBON_MAJOR_COMPACTION_SIZE:
194	isValid = CarbonUtil.validateValidIntType(value);	1✔
195	if (!isValid) {	1✔
196	throw new InvalidConfigurationException(	1✔
197	"The configured value for key " + key + " must be valid integer.");
198	}
199	break;
200	case CARBON_OPTIONS_BAD_RECORD_PATH:
201	isValid = CarbonUtil.isValidBadStorePath(value);	×
202	if (!isValid) {	×
203	throw new InvalidConfigurationException("Invalid bad records location.");	×
204	}
205	break;
206	// no validation needed while set for CARBON_OPTIONS_DATEFORMAT
207	case CARBON_OPTIONS_DATEFORMAT:
208	isValid = true;	×
209	break;	×
210	// no validation needed while set for CARBON_OPTIONS_TIMESTAMPFORMAT
211	case CARBON_OPTIONS_TIMESTAMPFORMAT:
212	isValid = true;	×
213	break;	×
214	// no validation needed while set for CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT
215	case CARBON_OPTIONS_SERIALIZATION_NULL_FORMAT:
216	isValid = true;	×
217	break;	×
218	case COMPACTION_SEGMENT_LEVEL_THRESHOLD:
219	int[] values = CarbonProperties.getInstance().getIntArray(value);	×
220	if (values.length != 2) {	×
221	throw new InvalidConfigurationException(	×
222	"Invalid COMPACTION_SEGMENT_LEVEL_THRESHOLD: " + value);
223	}
224	isValid = true;	×
225	break;	×
226	default:
227	if (key.startsWith(CarbonCommonConstants.CARBON_INPUT_SEGMENTS)) {	1✔
228	isValid = CarbonUtil.validateRangeOfSegmentList(value);	1✔
229	if (!isValid) {	1✔
230	throw new InvalidConfigurationException("Invalid CARBON_INPUT_SEGMENT_IDs");	×
231	}
232	} else if (key.startsWith(CarbonCommonConstants.VALIDATE_CARBON_INPUT_SEGMENTS)) {	1✔
233	isValid = true;	1✔
234	} else if (key.equalsIgnoreCase(CarbonCommonConstants.SUPPORT_DIRECT_QUERY_ON_DATAMAP)) {	1✔
235	isValid = true;	1✔
236	} else if (key.startsWith(CarbonCommonConstantsInternal.QUERY_ON_PRE_AGG_STREAMING)) {	1✔
237	isValid = true;	1✔
238	} else if (key.startsWith(CarbonCommonConstants.CARBON_DATAMAP_VISIBLE)) {	1✔
239	String[] keyArray = key.split("\\.");	1✔
240	isValid = DataMapStoreManager.getInstance().isDataMapExist(	1✔
241	keyArray[keyArray.length - 3],
242	keyArray[keyArray.length - 2],
243	keyArray[keyArray.length - 1]);
244	if (!isValid) {	1✔
245	throw new InvalidConfigurationException(	×
246	String.format("Invalid configuration of %s, datamap does not exist", key));	×
247	}
248	} else if (key.startsWith(CarbonCommonConstants.CARBON_LOAD_DATAMAPS_PARALLEL)) {	1✔
249	isValid = CarbonUtil.validateBoolean(value);	×
250	if (!isValid) {	×
251	throw new InvalidConfigurationException("Invalid value " + value + " for key " + key);	×
252	}
253	} else {
254	throw new InvalidConfigurationException(	×
255	"The key " + key + " not supported for dynamic configuration.");
256	}
257	}
258	return isValid;	1✔
259	}
260
261	public void removeProperty(String property) {
262	sProps.remove(property);	1✔
263	}	1✔
264
265	public void removeExtraInfo(String key) {
266	extraInfo.remove(key);	1✔
267	}	1✔
268	/**
269	* clear the set properties
270	*/
271	public void clear() {
272	sProps.clear();	1✔
273	}	1✔
274
275	public SessionParams clone() throws CloneNotSupportedException {
276	super.clone();	1✔
277	SessionParams newObj = new SessionParams();	1✔
278	newObj.addedProps.putAll(this.addedProps);	1✔
279	newObj.sProps.putAll(this.sProps);	1✔
280	newObj.extraInfo.putAll(this.extraInfo);	1✔
281	return newObj;	1✔
282	}
283	}

apache / carbondata / 425

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