1519

Build # 1519

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/1c008ff2e3cb392e1ec6e0d102e3d9d7fe9a007e">1c008ff2e<a href="https://github.com/apache/carbondata/commit/1c008ff2e3cb392e1ec6e0d102e3d9d7fe9a007e">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/65d9a4e1ada7de024dff8f5b778487e552764a75">65d9a4e1a</a>">65d9a4e1a</a><a href="https://github.com/apache/carbondata/commit/1c008ff2e3cb392e1ec6e0d102e3d9d7fe9a007e"> into a3a83dcad">a3a83dcad</a>

Run Details

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

62154 of 77503 relevant lines covered (80.2%)

1.06 hits per line

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

94.44

/core/src/main/java/org/apache/carbondata/core/scan/result/RowBatch.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.result;

import java.util.ArrayList;
import java.util.List;
import java.util.NoSuchElementException;

import org.apache.carbondata.common.CarbonIterator;

/**
 * Below class holds the query result
 */
public class RowBatch extends CarbonIterator<Object[]> {

  /**
   * list of keys
   */
  protected List<Object[]> rows;

  /**
   * counter to check whether all the records are processed or not
   */
  protected int counter;

  public RowBatch() {
    this.rows = new ArrayList<>();
  }

  /**
   * Below method will be used to get the rows
   *
   * @return
   */
  public List<Object[]> getRows() {
    return rows;
  }

  /**
   * Below method will be used to get the set the values
   *
   * @param rows
   */
  public void setRows(List<Object[]> rows) {
    this.rows = rows;
  }

  /**
   * This method will return one row at a time based on the counter given.
   * @param counter
   * @return
   */
  public Object[] getRawRow(int counter) {
    return rows.get(counter);
  }

  /**
   * For getting the total size.
   * @return
   */
  public int getSize() {
    return rows.size();
  }


  /**
   * Returns {@code true} if the iteration has more elements.
   *
   * @return {@code true} if the iteration has more elements
   */
  @Override public boolean hasNext() {
    return counter < rows.size();
  }

  /**
   * Returns the next element in the iteration.
   *
   * @return the next element in the iteration
   */
  @Override public Object[] next() {
    if (!hasNext()) {
      throw new NoSuchElementException();
    }
    Object[] row = rows.get(counter);
    counter++;
    return row;
  }

  /**
   * read next batch
   *
   * @return rows
   */
  public List<Object[]> nextBatch() {
    if (!hasNext()) {
      throw new NoSuchElementException();
    }
    counter = counter + rows.size();
    return rows;
  }
}

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.scan.result;
19
20	import java.util.ArrayList;
21	import java.util.List;
22	import java.util.NoSuchElementException;
23
24	import org.apache.carbondata.common.CarbonIterator;
25
26	/**
27	* Below class holds the query result
28	*/
29	public class RowBatch extends CarbonIterator<Object[]> {
30
31	/**
32	* list of keys
33	*/
34	protected List<Object[]> rows;
35
36	/**
37	* counter to check whether all the records are processed or not
38	*/
39	protected int counter;
40
41	public RowBatch() {	2✔
42	this.rows = new ArrayList<>();	2✔
43	}	2✔
44
45	/**
46	* Below method will be used to get the rows
47	*
48	* @return
49	*/
50	public List<Object[]> getRows() {
51	return rows;	2✔
52	}
53
54	/**
55	* Below method will be used to get the set the values
56	*
57	* @param rows
58	*/
59	public void setRows(List<Object[]> rows) {
60	this.rows = rows;	2✔
61	}	2✔
62
63	/**
64	* This method will return one row at a time based on the counter given.
65	* @param counter
66	* @return
67	*/
68	public Object[] getRawRow(int counter) {
69	return rows.get(counter);	2✔
70	}
71
72	/**
73	* For getting the total size.
74	* @return
75	*/
76	public int getSize() {
77	return rows.size();	2✔
78	}
79
80
81	/**
82	* Returns {@code true} if the iteration has more elements.
83	*
84	* @return {@code true} if the iteration has more elements
85	*/
86	@Override public boolean hasNext() {
87	return counter < rows.size();	2✔
88	}
89
90	/**
91	* Returns the next element in the iteration.
92	*
93	* @return the next element in the iteration
94	*/
95	@Override public Object[] next() {
96	if (!hasNext()) {	2✔
97	throw new NoSuchElementException();	2✔
98	}
99	Object[] row = rows.get(counter);	2✔
100	counter++;	2✔
101	return row;	2✔
102	}
103
104	/**
105	* read next batch
106	*
107	* @return rows
108	*/
109	public List<Object[]> nextBatch() {
110	if (!hasNext()) {	1✔
111	throw new NoSuchElementException();	×
112	}
113	counter = counter + rows.size();	1✔
114	return rows;	1✔
115	}
116	}

apache / carbondata / 1519

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