apache / carbondata / 297

Build # 297

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/624abf50420ece9dbd081e2a008108cd1cda889b">624abf504<a href="https://github.com/apache/carbondata/commit/624abf50420ece9dbd081e2a008108cd1cda889b">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/ba4221cc18700b1c22866dbd86055065aefdb1d4">ba4221cc1</a>">ba4221cc1</a><a href="https://github.com/apache/carbondata/commit/624abf50420ece9dbd081e2a008108cd1cda889b"> into f04850f39">f04850f39</a>

Run Details

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

57950 of 71919 relevant lines covered (80.58%)

1.07 hits per line

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

56.52

/core/src/main/java/org/apache/carbondata/core/datastore/block/AbstractIndex.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.datastore.block;

import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

import org.apache.carbondata.core.cache.Cacheable;
import org.apache.carbondata.core.datastore.DataRefNode;
import org.apache.carbondata.core.metadata.blocklet.DataFileFooter;
import org.apache.carbondata.core.mutate.DeleteDeltaVo;

public abstract class AbstractIndex implements Cacheable {

  /**
   * vo class which will hold the RS information of the block
   */
  protected SegmentProperties segmentProperties;

  /**
   * data block
   */
  protected DataRefNode dataRefNode;

  /**
   * atomic integer to maintain the access count for a column access
   */
  protected AtomicInteger accessCount = new AtomicInteger();

  /**
   * Table block meta size.
   */
  protected long memorySize;

  /**
   * last fetch delete deltaFile timestamp
   */
  private long deleteDeltaTimestamp;

  /**
   * map of blockletidAndPageId to
   * deleted rows
   */
  private Map<String, DeleteDeltaVo> deletedRowsMap;
  /**
   * @return the segmentProperties
   */
  public SegmentProperties getSegmentProperties() {
    return segmentProperties;
  }

  /**
   * @return the dataBlock
   */
  public DataRefNode getDataRefNode() {
    return dataRefNode;
  }

  @Override public long getFileTimeStamp() {
    return 0;
  }

  /**
   * Below method will be used to load the data block
   *
   * @param footerList footer list
   */
  public abstract void buildIndex(List<DataFileFooter> footerList);

  /**
   * the method returns the access count
   *
   * @return
   */
  @Override public int getAccessCount() {
    return accessCount.get();
  }

  /**
   * The method returns table block size
   *
   * @return
   */
  @Override public long getMemorySize() {
    return this.memorySize;
  }

  @Override public void invalidate() {

  }

  /**
   * The method is used to set the access count
   */
  public void incrementAccessCount() {
    accessCount.incrementAndGet();
  }

  /**
   * This method will release the objects and set default value for primitive types
   */
  public void clear() {
    decrementAccessCount();
  }

  /**
   * This method will decrement the access count for a column by 1
   * whenever a column usage is complete
   */
  private void decrementAccessCount() {
    if (accessCount.get() > 0) {
      accessCount.decrementAndGet();
    }
  }

  /**
   * the method is used to set the memory size of the b-tree
   * @param memorySize
   */
  public void setMemorySize(long memorySize) {
    this.memorySize = memorySize;
  }

  /**
   * @return latest deleted delta timestamp
   */
  public long getDeleteDeltaTimestamp() {
    return deleteDeltaTimestamp;
  }

  /**
   * set the latest delete delta timestamp
   * @param deleteDeltaTimestamp
   */
  public void setDeleteDeltaTimestamp(long deleteDeltaTimestamp) {
    this.deleteDeltaTimestamp = deleteDeltaTimestamp;
  }

  /**
   * @return the deleted record for block map
   */
  public Map<String, DeleteDeltaVo> getDeletedRowsMap() {
    return deletedRowsMap;
  }

  /**
   * @param deletedRowsMap
   */
  public void setDeletedRowsMap(Map<String, DeleteDeltaVo> deletedRowsMap) {
    this.deletedRowsMap = deletedRowsMap;
  }
}

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.datastore.block;
18
19	import java.util.List;
20	import java.util.Map;
21	import java.util.concurrent.atomic.AtomicInteger;
22
23	import org.apache.carbondata.core.cache.Cacheable;
24	import org.apache.carbondata.core.datastore.DataRefNode;
25	import org.apache.carbondata.core.metadata.blocklet.DataFileFooter;
26	import org.apache.carbondata.core.mutate.DeleteDeltaVo;
27
28	public abstract class AbstractIndex implements Cacheable {	1✔
29
30	/**
31	* vo class which will hold the RS information of the block
32	*/
33	protected SegmentProperties segmentProperties;
34
35	/**
36	* data block
37	*/
38	protected DataRefNode dataRefNode;
39
40	/**
41	* atomic integer to maintain the access count for a column access
42	*/
43	protected AtomicInteger accessCount = new AtomicInteger();	1✔
44
45	/**
46	* Table block meta size.
47	*/
48	protected long memorySize;
49
50	/**
51	* last fetch delete deltaFile timestamp
52	*/
53	private long deleteDeltaTimestamp;
54
55	/**
56	* map of blockletidAndPageId to
57	* deleted rows
58	*/
59	private Map<String, DeleteDeltaVo> deletedRowsMap;
60	/**
61	* @return the segmentProperties
62	*/
63	public SegmentProperties getSegmentProperties() {
64	return segmentProperties;	1✔
65	}
66
67	/**
68	* @return the dataBlock
69	*/
70	public DataRefNode getDataRefNode() {
71	return dataRefNode;	1✔
72	}
73
74	@Override public long getFileTimeStamp() {
75	return 0;	×
76	}
77
78	/**
79	* Below method will be used to load the data block
80	*
81	* @param footerList footer list
82	*/
83	public abstract void buildIndex(List<DataFileFooter> footerList);
84
85	/**
86	* the method returns the access count
87	*
88	* @return
89	*/
90	@Override public int getAccessCount() {
91	return accessCount.get();	×
92	}
93
94	/**
95	* The method returns table block size
96	*
97	* @return
98	*/
99	@Override public long getMemorySize() {
100	return this.memorySize;	×
101	}
102
103	@Override public void invalidate() {
104
105	}	×
106
107	/**
108	* The method is used to set the access count
109	*/
110	public void incrementAccessCount() {
111	accessCount.incrementAndGet();	×
112	}	×
113
114	/**
115	* This method will release the objects and set default value for primitive types
116	*/
117	public void clear() {
118	decrementAccessCount();	1✔
119	}	1✔
120
121	/**
122	* This method will decrement the access count for a column by 1
123	* whenever a column usage is complete
124	*/
125	private void decrementAccessCount() {
126	if (accessCount.get() > 0) {	1✔
127	accessCount.decrementAndGet();	×
128	}
129	}	1✔
130
131	/**
132	* the method is used to set the memory size of the b-tree
133	* @param memorySize
134	*/
135	public void setMemorySize(long memorySize) {
136	this.memorySize = memorySize;	×
137	}	×
138
139	/**
140	* @return latest deleted delta timestamp
141	*/
142	public long getDeleteDeltaTimestamp() {
143	return deleteDeltaTimestamp;	1✔
144	}
145
146	/**
147	* set the latest delete delta timestamp
148	* @param deleteDeltaTimestamp
149	*/
150	public void setDeleteDeltaTimestamp(long deleteDeltaTimestamp) {
151	this.deleteDeltaTimestamp = deleteDeltaTimestamp;	1✔
152	}	1✔
153
154	/**
155	* @return the deleted record for block map
156	*/
157	public Map<String, DeleteDeltaVo> getDeletedRowsMap() {
158	return deletedRowsMap;	×
159	}
160
161	/**
162	* @param deletedRowsMap
163	*/
164	public void setDeletedRowsMap(Map<String, DeleteDeltaVo> deletedRowsMap) {
165	this.deletedRowsMap = deletedRowsMap;	1✔
166	}	1✔
167	}

apache / carbondata / 297

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