1174

Build # 1174

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/2586e3c6f1ed0cd743d7fdea9b784ef7a4fb4c21">2586e3c6f<a href="https://github.com/apache/carbondata/commit/2586e3c6f1ed0cd743d7fdea9b784ef7a4fb4c21">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/d176cfd2b77aa6c97d55976945a38a84a1c2c85c">d176cfd2b</a>">d176cfd2b</a><a href="https://github.com/apache/carbondata/commit/2586e3c6f1ed0cd743d7fdea9b784ef7a4fb4c21"> into fa9a4eeeb">fa9a4eeeb</a>

Run Details

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

60530 of 75059 relevant lines covered (80.64%)

1.06 hits per line

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

75.44

/core/src/main/java/org/apache/carbondata/core/mutate/SegmentUpdateDetails.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.mutate;

import java.io.Serializable;

import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.statusmanager.SegmentStatus;

import org.apache.log4j.Logger;

/**
 * This class stores the segment details of table update status file
 */
public class SegmentUpdateDetails implements Serializable {

  private static final long serialVersionUID = 1206104914918491724L;
  private String segmentName;
  private String blockName;
  private SegmentStatus segmentStatus;
  private String deleteDeltaEndTimestamp = "";
  private String deleteDeltaStartTimestamp = "";
  private String actualBlockName;
  private String deletedRowsInBlock = "0";

  /**
   * LOGGER
   */
  private static final Logger LOGGER =
      LogServiceFactory.getLogService(SegmentUpdateDetails.class.getName());

  public String getDeleteDeltaEndTimestamp() {
    return deleteDeltaEndTimestamp;
  }

  public void setDeleteDeltaEndTimestamp(String deleteDeltaEndTimestamp) {
    this.deleteDeltaEndTimestamp = deleteDeltaEndTimestamp;
  }

  public String getSegmentName() {
    return segmentName;
  }

  public void setSegmentName(String segmentName) {
    this.segmentName = segmentName;
  }

  public String getBlockName() {
    return blockName;
  }

  public void setBlockName(String blockName) {
    this.blockName = blockName;
  }

  public String getDeleteDeltaStartTimestamp() {
    return deleteDeltaStartTimestamp;
  }

  public void setDeleteDeltaStartTimestamp(String deleteDeltaStartTimestamp) {
    this.deleteDeltaStartTimestamp = deleteDeltaStartTimestamp;
  }

  public void setSegmentStatus(SegmentStatus segmentStatus) {
    this.segmentStatus = segmentStatus;
  }

  public SegmentStatus getSegmentStatus() {
    return this.segmentStatus;
  }

  @Override public int hashCode() {
    final int prime = 31;
    int result = segmentName.hashCode();
    result = prime * result + blockName.hashCode();
    return result;
  }

  @Override public boolean equals(Object obj) {
    if (obj == null) {
      return false;

    }
    if (!(obj instanceof SegmentUpdateDetails)) {
      return false;
    }
    SegmentUpdateDetails other = (SegmentUpdateDetails) obj;
    if (segmentName == null) {
      if (other.segmentName != null) {
        return false;
      }
    } else if (!segmentName.equals(other.segmentName)) {
      return false;
    }
    if (blockName == null) {
      if (other.blockName != null) {
        return false;
      }
    } else if (!blockName.equals(other.blockName)) {
      return false;
    }
    return true;
  }

  /**
   * return deleteDeltaTime as long
   *
   * @return
   */
  public long getDeleteDeltaEndTimeAsLong() {
    return getTimeStampAsLong(deleteDeltaEndTimestamp);
  }

  /**
   * return deleteDeltaTime as long
   *
   * @return
   */
  public long getDeleteDeltaStartTimeAsLong() {

    return getTimeStampAsLong(deleteDeltaStartTimestamp);
  }

  /**
   * returns complete block name
   *
   * @return
   */
  public String getActualBlockName() {
    return actualBlockName;
  }

  public void setActualBlockName(String actualBlockName) {
    this.actualBlockName = actualBlockName;
  }

  /**
   * returns timestamp as long value
   *
   * @param timtstamp
   * @return
   */
  private Long getTimeStampAsLong(String timtstamp) {
    long longValue = 0;
    try {
      longValue = Long.parseLong(timtstamp);
    } catch (NumberFormatException nfe) {
      if (LOGGER.isDebugEnabled()) {
        String errorMsg = "Invalid timestamp : " + timtstamp;
        LOGGER.debug(errorMsg);
      }
    }
    return longValue;
  }

  public String getDeletedRowsInBlock() {
    return deletedRowsInBlock;
  }

  public void setDeletedRowsInBlock(String deletedRowsInBlock) {
    this.deletedRowsInBlock = deletedRowsInBlock;
  }
}

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.mutate;
19
20	import java.io.Serializable;
21
22	import org.apache.carbondata.common.logging.LogServiceFactory;
23	import org.apache.carbondata.core.statusmanager.SegmentStatus;
24
25	import org.apache.log4j.Logger;
26
27	/**
28	* This class stores the segment details of table update status file
29	*/
30	public class SegmentUpdateDetails implements Serializable {	1✔
31
32	private static final long serialVersionUID = 1206104914918491724L;
33	private String segmentName;
34	private String blockName;
35	private SegmentStatus segmentStatus;
36	private String deleteDeltaEndTimestamp = "";	1✔
37	private String deleteDeltaStartTimestamp = "";	1✔
38	private String actualBlockName;
39	private String deletedRowsInBlock = "0";	1✔
40
41	/**
42	* LOGGER
43	*/
44	private static final Logger LOGGER =	1✔
45	LogServiceFactory.getLogService(SegmentUpdateDetails.class.getName());	1✔
46
47	public String getDeleteDeltaEndTimestamp() {
48	return deleteDeltaEndTimestamp;	1✔
49	}
50
51	public void setDeleteDeltaEndTimestamp(String deleteDeltaEndTimestamp) {
52	this.deleteDeltaEndTimestamp = deleteDeltaEndTimestamp;	1✔
53	}	1✔
54
55	public String getSegmentName() {
56	return segmentName;	1✔
57	}
58
59	public void setSegmentName(String segmentName) {
60	this.segmentName = segmentName;	1✔
61	}	1✔
62
63	public String getBlockName() {
64	return blockName;	1✔
65	}
66
67	public void setBlockName(String blockName) {
68	this.blockName = blockName;	1✔
69	}	1✔
70
71	public String getDeleteDeltaStartTimestamp() {
72	return deleteDeltaStartTimestamp;	1✔
73	}
74
75	public void setDeleteDeltaStartTimestamp(String deleteDeltaStartTimestamp) {
76	this.deleteDeltaStartTimestamp = deleteDeltaStartTimestamp;	1✔
77	}	1✔
78
79	public void setSegmentStatus(SegmentStatus segmentStatus) {
80	this.segmentStatus = segmentStatus;	1✔
81	}	1✔
82
83	public SegmentStatus getSegmentStatus() {
84	return this.segmentStatus;	1✔
85	}
86
87	@Override public int hashCode() {
88	final int prime = 31;	×
89	int result = segmentName.hashCode();	×
90	result = prime * result + blockName.hashCode();	×
91	return result;	×
92	}
93
94	@Override public boolean equals(Object obj) {
95	if (obj == null) {	1✔
96	return false;	×
97
98	}
99	if (!(obj instanceof SegmentUpdateDetails)) {	1✔
100	return false;	×
101	}
102	SegmentUpdateDetails other = (SegmentUpdateDetails) obj;	1✔
103	if (segmentName == null) {	1✔
104	if (other.segmentName != null) {	×
105	return false;	×
106	}
107	} else if (!segmentName.equals(other.segmentName)) {	1✔
108	return false;	1✔
109	}
110	if (blockName == null) {	1✔
111	if (other.blockName != null) {	×
112	return false;	×
113	}
114	} else if (!blockName.equals(other.blockName)) {	1✔
115	return false;	1✔
116	}
117	return true;	1✔
118	}
119
120	/**
121	* return deleteDeltaTime as long
122	*
123	* @return
124	*/
125	public long getDeleteDeltaEndTimeAsLong() {
126	return getTimeStampAsLong(deleteDeltaEndTimestamp);	1✔
127	}
128
129	/**
130	* return deleteDeltaTime as long
131	*
132	* @return
133	*/
134	public long getDeleteDeltaStartTimeAsLong() {
135
136	return getTimeStampAsLong(deleteDeltaStartTimestamp);	1✔
137	}
138
139	/**
140	* returns complete block name
141	*
142	* @return
143	*/
144	public String getActualBlockName() {
145	return actualBlockName;	1✔
146	}
147
148	public void setActualBlockName(String actualBlockName) {
149	this.actualBlockName = actualBlockName;	1✔
150	}	1✔
151
152	/**
153	* returns timestamp as long value
154	*
155	* @param timtstamp
156	* @return
157	*/
158	private Long getTimeStampAsLong(String timtstamp) {
159	long longValue = 0;	1✔
160	try {
161	longValue = Long.parseLong(timtstamp);	1✔
162	} catch (NumberFormatException nfe) {	×
163	if (LOGGER.isDebugEnabled()) {	×
164	String errorMsg = "Invalid timestamp : " + timtstamp;	×
165	LOGGER.debug(errorMsg);	×
166	}
167	}	1✔
168	return longValue;	1✔
169	}
170
171	public String getDeletedRowsInBlock() {
172	return deletedRowsInBlock;	1✔
173	}
174
175	public void setDeletedRowsInBlock(String deletedRowsInBlock) {
176	this.deletedRowsInBlock = deletedRowsInBlock;	1✔
177	}	1✔
178	}

apache / carbondata / 1174

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