apache / carbondata / 3071

3071

push

jenkins

GitHub 
<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/4ea780746927670d6c9495004dd2aa6fd169722a">4ea780746<a href="https://github.com/apache/carbondata/commit/4ea780746927670d6c9495004dd2aa6fd169722a">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/d3edfd711f4d0833abe897f3533227051cfeed85">d3edfd711</a>">d3edfd711</a><a href="https://github.com/apache/carbondata/commit/4ea780746927670d6c9495004dd2aa6fd169722a"> into 7f05e6948">7f05e6948</a>

66 of 66 new or added lines in 4 files covered. (100.0%)

62814 of 79713 relevant lines covered (78.8%)

1.04 hits per line

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

0.0
/integration/spark2/src/main/scala/org/apache/carbondata/indexserver/DistributedDataMapJob.scala
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.indexserver
18 









19



import java.util










20












21



import scala.collection.JavaConverters._










22












23



import org.apache.carbondata.core.datamap.{AbstractDataMapJob, DistributableDataMapFormat}










24



import org.apache.carbondata.core.indexstore.ExtendedBlocklet










25



import org.apache.carbondata.core.scan.filter.resolver.FilterResolverIntf










26













27



class DistributedDataMapJob extends AbstractDataMapJob {




×







28












29



  override def execute(dataMapFormat: DistributableDataMapFormat,










30



      filter: FilterResolverIntf): util.List[ExtendedBlocklet] = {











31



    IndexServer.getSplits(dataMapFormat).map(_._2).toList.asJava




×







32



  }










33












34



}
























    

  • 

    •