1389

Build # 1389

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/c073fe3770e06907c819d1e864d1f9c02abeabce">c073fe377<a href="https://github.com/apache/carbondata/commit/c073fe3770e06907c819d1e864d1f9c02abeabce">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/f9cc4dd03a0ca39f647fa502696618da13602c53">f9cc4dd03</a>">f9cc4dd03</a><a href="https://github.com/apache/carbondata/commit/c073fe3770e06907c819d1e864d1f9c02abeabce"> into 3e0693b9e">3e0693b9e</a>

Run Details

14 of 14 new or added lines in 2 files covered. (100.0%)

61368 of 77126 relevant lines covered (79.57%)

1.05 hits per line

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

69.23

/core/src/main/java/org/apache/carbondata/core/scan/executor/impl/SearchModeDetailQueryExecutor.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.scan.executor.impl;

import java.io.IOException;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.carbondata.common.CarbonIterator;
import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.constants.CarbonCommonConstants;
import org.apache.carbondata.core.scan.executor.exception.QueryExecutionException;
import org.apache.carbondata.core.scan.executor.infos.BlockExecutionInfo;
import org.apache.carbondata.core.scan.model.QueryModel;
import org.apache.carbondata.core.scan.result.iterator.SearchModeResultIterator;
import org.apache.carbondata.core.util.CarbonProperties;

import org.apache.hadoop.conf.Configuration;
import org.apache.log4j.Logger;

public class SearchModeDetailQueryExecutor extends AbstractQueryExecutor<Object> {
  private static final Logger LOGGER =
          LogServiceFactory.getLogService(SearchModeDetailQueryExecutor.class.getName());
  private static ExecutorService executorService = null;

  public SearchModeDetailQueryExecutor(Configuration configuration) {
    super(configuration);
    if (executorService == null) {
      initThreadPool();
    }
  }

  private static synchronized void initThreadPool() {
    int defaultValue = Runtime.getRuntime().availableProcessors();
    int nThread;
    try {
      nThread = Integer.parseInt(CarbonProperties.getInstance()
          .getProperty(CarbonCommonConstants.CARBON_SEARCH_MODE_SCAN_THREAD,
              String.valueOf(defaultValue)));
    } catch (NumberFormatException e) {
      nThread = defaultValue;
      LOGGER.warn("The carbon.search.mode.thread is invalid. Using the default value " + nThread);
    }
    if (nThread > 0) {
      executorService = Executors.newFixedThreadPool(nThread);
    } else {
      executorService = Executors.newCachedThreadPool();
    }
  }

  public static synchronized void shutdownThreadPool() {
    if (executorService != null) {
      executorService.shutdownNow();
      executorService = null;
    }
  }

  @Override
  public CarbonIterator<Object> execute(QueryModel queryModel)
      throws QueryExecutionException, IOException {
    List<BlockExecutionInfo> blockExecutionInfoList = getBlockExecutionInfos(queryModel);

    this.queryIterator = new SearchModeResultIterator(
        blockExecutionInfoList,
        queryModel,
        executorService
    );
    return this.queryIterator;
  }

}

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.scan.executor.impl;
18
19	import java.io.IOException;
20	import java.util.List;
21	import java.util.concurrent.ExecutorService;
22	import java.util.concurrent.Executors;
23
24	import org.apache.carbondata.common.CarbonIterator;
25	import org.apache.carbondata.common.logging.LogServiceFactory;
26	import org.apache.carbondata.core.constants.CarbonCommonConstants;
27	import org.apache.carbondata.core.scan.executor.exception.QueryExecutionException;
28	import org.apache.carbondata.core.scan.executor.infos.BlockExecutionInfo;
29	import org.apache.carbondata.core.scan.model.QueryModel;
30	import org.apache.carbondata.core.scan.result.iterator.SearchModeResultIterator;
31	import org.apache.carbondata.core.util.CarbonProperties;
32
33	import org.apache.hadoop.conf.Configuration;
34	import org.apache.log4j.Logger;
35
36	public class SearchModeDetailQueryExecutor extends AbstractQueryExecutor<Object> {
37	private static final Logger LOGGER =	1✔
38	LogServiceFactory.getLogService(SearchModeDetailQueryExecutor.class.getName());	1✔
39	private static ExecutorService executorService = null;	1✔
40
41	public SearchModeDetailQueryExecutor(Configuration configuration) {
42	super(configuration);	1✔
43	if (executorService == null) {	1✔
44	initThreadPool();	1✔
45	}
46	}	1✔
47
48	private static synchronized void initThreadPool() {
49	int defaultValue = Runtime.getRuntime().availableProcessors();	1✔
50	int nThread;
51	try {
52	nThread = Integer.parseInt(CarbonProperties.getInstance()	1✔
53	.getProperty(CarbonCommonConstants.CARBON_SEARCH_MODE_SCAN_THREAD,	1✔
54	String.valueOf(defaultValue)));	1✔
55	} catch (NumberFormatException e) {	×
56	nThread = defaultValue;	×
57	LOGGER.warn("The carbon.search.mode.thread is invalid. Using the default value " + nThread);	×
58	}	1✔
59	if (nThread > 0) {	1✔
60	executorService = Executors.newFixedThreadPool(nThread);	1✔
61	} else {
62	executorService = Executors.newCachedThreadPool();	×
63	}
64	}	1✔
65
66	public static synchronized void shutdownThreadPool() {
67	if (executorService != null) {	×
68	executorService.shutdownNow();	×
69	executorService = null;	×
70	}
71	}	×
72
73	@Override
74	public CarbonIterator<Object> execute(QueryModel queryModel)
75	throws QueryExecutionException, IOException {
76	List<BlockExecutionInfo> blockExecutionInfoList = getBlockExecutionInfos(queryModel);	1✔
77
78	this.queryIterator = new SearchModeResultIterator(	1✔
79	blockExecutionInfoList,
80	queryModel,
81	executorService
82	);
83	return this.queryIterator;	1✔
84	}
85
86	}

apache / carbondata / 1389

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