9397

Build # 9397

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/0a667a035195c1870b8d682f8e42b1af93a7089c">0a667a035<a href="https://github.com/apache/carbondata/commit/0a667a035195c1870b8d682f8e42b1af93a7089c">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/4e6a8efc4727f11ddc4080bdf71e17ccfce3e422">4e6a8efc4</a>">4e6a8efc4</a><a href="https://github.com/apache/carbondata/commit/0a667a035195c1870b8d682f8e42b1af93a7089c"> into e2c517e3f">e2c517e3f</a>

Run Details

6 of 6 new or added lines in 1 file covered. (100.0%)

61665 of 77091 relevant lines covered (79.99%)

1.06 hits per line

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

53.57

/store/search/src/main/scala/org/apache/spark/search/Searcher.scala

/*
 * 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.spark.search

import org.apache.spark.SerializableWritable
import org.apache.spark.rpc.{RpcCallContext, RpcEndpoint, RpcEnv}

import org.apache.carbondata.common.logging.LogServiceFactory
import org.apache.carbondata.core.datamap.dev.expr.DataMapExprWrapper
import org.apache.carbondata.core.metadata.schema.table.TableInfo
import org.apache.carbondata.core.scan.expression.Expression
import org.apache.carbondata.hadoop.CarbonMultiBlockSplit
import org.apache.carbondata.store.worker.SearchRequestHandler

/**
 * Search service implementation
 */
class Searcher(override val rpcEnv: RpcEnv) extends RpcEndpoint {
  private val LOG = LogServiceFactory.getLogService(this.getClass.getName)

  override def onStart(): Unit = {
    LOG.info("Searcher Endpoint started")
  }

  override def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit] = {
    case req: SearchRequest =>
      val response = new SearchRequestHandler().handleSearch(req)
      context.reply(response)

    case req: ShutdownRequest =>
      val response = new SearchRequestHandler().handleShutdown(req)
      context.reply(response)

  }

  override def onStop(): Unit = {
    LOG.info("Searcher Endpoint stopped")
  }
}

// Search request sent from master to worker
case class SearchRequest(
    searchId: Int,
    split: SerializableWritable[CarbonMultiBlockSplit],
    tableInfo: TableInfo,
    projectColumns: Array[String],
    filterExpression: Expression,
    limit: Long)

// Search result sent from worker to master
case class SearchResult(
    queryId: Int,
    status: Int,
    message: String,
    rows: Array[Array[Object]])

// Shutdown request sent from master to worker
case class ShutdownRequest(
    reason: String)

// Shutdown response sent from worker to master
case class ShutdownResponse(
    status: Int,
    message: String)

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.spark.search
19
20	import org.apache.spark.SerializableWritable
21	import org.apache.spark.rpc.{RpcCallContext, RpcEndpoint, RpcEnv}
22
23	import org.apache.carbondata.common.logging.LogServiceFactory
24	import org.apache.carbondata.core.datamap.dev.expr.DataMapExprWrapper
25	import org.apache.carbondata.core.metadata.schema.table.TableInfo
26	import org.apache.carbondata.core.scan.expression.Expression
27	import org.apache.carbondata.hadoop.CarbonMultiBlockSplit
28	import org.apache.carbondata.store.worker.SearchRequestHandler
29
30	/**
31	* Search service implementation
32	*/
33	class Searcher(override val rpcEnv: RpcEnv) extends RpcEndpoint {	1✔
34	private val LOG = LogServiceFactory.getLogService(this.getClass.getName)	1✔
35
36	override def onStart(): Unit = {
37	LOG.info("Searcher Endpoint started")	1✔
38	}
39
40	override def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit] = {	×
41	case req: SearchRequest =>	×
42	val response = new SearchRequestHandler().handleSearch(req)	×
43	context.reply(response)	×
44
45	case req: ShutdownRequest =>	×
46	val response = new SearchRequestHandler().handleShutdown(req)	×
47	context.reply(response)	×
48
49	}
50
51	override def onStop(): Unit = {
52	LOG.info("Searcher Endpoint stopped")	×
53	}
54	}
55
56	// Search request sent from master to worker
57	case class SearchRequest(	1✔
58	searchId: Int,	1✔
59	split: SerializableWritable[CarbonMultiBlockSplit],	1✔
60	tableInfo: TableInfo,	1✔
61	projectColumns: Array[String],	1✔
62	filterExpression: Expression,	1✔
63	limit: Long)	1✔
64
65	// Search result sent from worker to master
66	case class SearchResult(	×
67	queryId: Int,	1✔
68	status: Int,	1✔
69	message: String,	×
70	rows: Array[Array[Object]])	1✔
71
72	// Shutdown request sent from master to worker
73	case class ShutdownRequest(	1✔
74	reason: String)	1✔
75
76	// Shutdown response sent from worker to master
77	case class ShutdownResponse(	×
78	status: Int,	×
79	message: String)	×

apache / carbondata / 9397

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