9274

Build # 9274

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/5aa43a48e6173907836664dcdc6c3a72e754b570">5aa43a48e<a href="https://github.com/apache/carbondata/commit/5aa43a48e6173907836664dcdc6c3a72e754b570">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/48c44c26bf62c117c5a8132e92f452e123b05b41">48c44c26b</a>">48c44c26b</a><a href="https://github.com/apache/carbondata/commit/5aa43a48e6173907836664dcdc6c3a72e754b570"> into 33a6dc2ac">33a6dc2ac</a>

Run Details

41 of 41 new or added lines in 6 files covered. (100.0%)

60499 of 75047 relevant lines covered (80.61%)

1.06 hits per line

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

77.39

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

import java.io.Serializable;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.constants.CarbonCommonConstants;

import org.apache.log4j.Logger;

/*
  Prior to Carbon 1.3 the the loadMetaData @timestamp and @loadStartTime was stored as
  as date string format "dd-MM-yyyy HH:mm:ss:SSS". The date string value is specific
  to the timezone. SO the timestamp in long by the date string will not result into
  same value if converted to date in different timezone.
  Json Object of LoadMetaData before CarbonData 1.3
 |-------------------------------------------------------------------------------------------|
 | [{"timestamp":"15-12-2017 16:50:31:703","loadStatus":"Success","loadName":"0",            |
 | "partitionCount":"0","isDeleted":"FALSE","dataSize":"912","indexSize":"700",              |
 | "updateDeltaEndTimestamp":"","updateDeltaStartTimestamp":"","updateStatusFileName":"",    |
 | "loadStartTime":"15-12-2017 16:50:27:493","visibility":"true","fileFormat":"COLUMNAR_V3"}]|
 |-------------------------------------------------------------------------------------------|
  Fix: As the System.currentTimeMillis() returns the same value irrespective of timezone.
  So if Carbon stores the long value for @timestamp  and @loadStartTime value then the
  value will be same irrespective of the timezone.
  Json Object of LoadMetaData for CarbonData 1.3
 |-------------------------------------------------------------------------------------------|
 | [{"timestamp":"1513336827593","loadStatus":"Success","loadName":"0",                      |
 | "partitionCount":"0","isDeleted":"FALSE","dataSize":"912","indexSize":"700",              |
 | "updateDeltaEndTimestamp":"","updateDeltaStartTimestamp":"","updateStatusFileName":"",    |
 | "loadStartTime":"1513336827593","visibility":"true","fileFormat":"COLUMNAR_V3"}]          |
 |-------------------------------------------------------------------------------------------|
 */
public class LoadMetadataDetails implements Serializable {

  private static final long serialVersionUID = 1106104914918491724L;
  private String timestamp;

  // For backward compatibility, this member is required to read from JSON in the table_status file
  private SegmentStatus loadStatus;

  // name of the segment
  private String loadName;

  // partition count of this segment
  private String partitionCount;

  private String isDeleted = CarbonCommonConstants.KEYWORD_FALSE;
  private String dataSize;
  private String indexSize;

  public String getDataSize() {
    return dataSize;
  }

  public void setDataSize(String dataSize) {
    this.dataSize = dataSize;
  }

  public String getIndexSize() {
    return indexSize;
  }

  public void setIndexSize(String indexSize) {
    this.indexSize = indexSize;
  }

  // update delta end timestamp
  private String updateDeltaEndTimestamp = "";

  // update delta start timestamp
  private String updateDeltaStartTimestamp = "";

  // this will represent the update status file name at that point of time.
  private String updateStatusFileName = "";

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

  // dont remove static as the write will fail.
  private static final SimpleDateFormat parser =
      new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP_MILLIS);
  /**
   * Segment modification or deletion time stamp
   */
  private String modificationOrdeletionTimesStamp;
  private String loadStartTime;

  private String mergedLoadName;
  /**
   * visibility is used to determine whether to the load is visible or not.
   */
  private String visibility = "true";

  /**
   * To know if the segment is a major compacted segment or not.
   */
  private String majorCompacted;

  /**
   * the file format of this segment
   */
  private FileFormat fileFormat = FileFormat.COLUMNAR_V3;

  /**
   * Segment file name where it has the information of partition information.
   */
  private String segmentFile;

  public String getPartitionCount() {
    return partitionCount;
  }

  @Deprecated
  public void setPartitionCount(String partitionCount) {
    this.partitionCount = partitionCount;
  }

  public long getLoadEndTime() {
    if (timestamp == null) {
      return CarbonCommonConstants.SEGMENT_LOAD_TIME_DEFAULT;
    }
    return convertTimeStampToLong(timestamp);
  }

  public void setLoadEndTime(long timestamp) {
    this.timestamp = Long.toString(timestamp);
  }

  public SegmentStatus getSegmentStatus() {
    return loadStatus;
  }

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

  public String getLoadName() {
    return loadName;
  }

  public void setLoadName(String loadName) {
    this.loadName = loadName;
  }

  /**
   * @return the modificationOrdeletionTimesStamp
   */
  public long getModificationOrdeletionTimesStamp() {
    if (null == modificationOrdeletionTimesStamp) {
      return 0;
    }
    return convertTimeStampToLong(modificationOrdeletionTimesStamp);
  }

  /**
   * @param modificationOrdeletionTimesStamp the modificationOrdeletionTimesStamp to set
   */
  public void setModificationOrdeletionTimesStamp(long modificationOrdeletionTimesStamp) {
    this.modificationOrdeletionTimesStamp =
        Long.toString(modificationOrdeletionTimesStamp);
  }

  /* (non-Javadoc)
   * @see java.lang.Object#hashCode()
   */
  @Override public int hashCode() {
    final int prime = 31;
    int result = 1;
    result = prime * result + ((loadName == null) ? 0 : loadName.hashCode());
    return result;
  }

  /* (non-Javadoc)
   * @see java.lang.Object#equals(java.lang.Object)
   */
  @Override public boolean equals(Object obj) {
    if (obj == null) {
      return false;

    }
    if (!(obj instanceof LoadMetadataDetails)) {
      return false;
    }
    LoadMetadataDetails other = (LoadMetadataDetails) obj;
    if (loadName == null) {
      if (other.loadName != null) {
        return false;
      }
    } else if (!loadName.equals(other.loadName)) {
      return false;
    }
    return true;
  }

  /**
   * @return the startLoadTime
   */
  public long getLoadStartTime() {
    if (loadStartTime == null) {
      return CarbonCommonConstants.SEGMENT_LOAD_TIME_DEFAULT;
    }
    return convertTimeStampToLong(loadStartTime);
  }

  /**
   * return loadStartTime
   *
   * @return
   */
  public long getLoadStartTimeAsLong() {
    if (!loadStartTime.isEmpty()) {
      Long time = getTimeStamp(loadStartTime);
      if (null != time) {
        return time;
      }
    }
    return 0;
  }

  /**
   * This method will convert a given timestamp to long value and then to string back
   *
   * @param factTimeStamp
   * @return Long    TimeStamp value is milliseconds
   */
  private long convertTimeStampToLong(String factTimeStamp) {
    try {
      return Long.parseLong(factTimeStamp);
    } catch (NumberFormatException nf) {
      SimpleDateFormat parser = new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP_MILLIS);
      // it is the processing for existing table before carbon 1.3
      Date dateToStr = null;
      try {
        dateToStr = parser.parse(factTimeStamp);
        return dateToStr.getTime();
      } catch (ParseException e) {
        LOGGER
            .error("Cannot convert" + factTimeStamp + " to Time/Long type value" + e.getMessage());
        parser = new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP);
        try {
          // if the load is in progress, factTimeStamp will be null, so use current time
          if (null == factTimeStamp) {
            return System.currentTimeMillis();
          }
          dateToStr = parser.parse(factTimeStamp);
          return dateToStr.getTime();
        } catch (ParseException e1) {
          LOGGER.error(
              "Cannot convert" + factTimeStamp + " to Time/Long type value" + e1.getMessage());
          return 0;
        }
      }
    }
  }

  /**
   * returns load start time as long value
   *
   * @param loadStartTime
   * @return Long  TimeStamp value is nanoseconds
   */
  public Long getTimeStamp(String loadStartTime) {
    try {
      return Long.parseLong(loadStartTime) * 1000L;
    } catch (NumberFormatException nf) {
      // it is the processing for existing table before carbon 1.3
      Date dateToStr = null;
      try {
        dateToStr = parser.parse(loadStartTime);
        return dateToStr.getTime() * 1000;
      } catch (ParseException e) {
        LOGGER.error("Cannot convert" + loadStartTime +
            " to Time/Long type value" + e.getMessage());
        return null;
      }
    }
  }

  /**
   * @param loadStartTime
   */
  public void setLoadStartTime(long loadStartTime) {
    this.loadStartTime = Long.toString(loadStartTime);
  }

  /**
   * @return the mergedLoadName
   */
  public String getMergedLoadName() {
    return mergedLoadName;
  }

  /**
   * @param mergedLoadName the mergedLoadName to set
   */
  public void setMergedLoadName(String mergedLoadName) {
    this.mergedLoadName = mergedLoadName;
  }

  /**
   * @return the visibility
   */
  public String getVisibility() {
    return visibility;
  }

  /**
   * @param visibility the visibility to set
   */
  public void setVisibility(String visibility) {
    this.visibility = visibility;
  }

  /**
   * Return true if it is a major compacted segment.
   * @return majorCompacted
   */
  public String isMajorCompacted() {
    return majorCompacted;
  }

  /**
   * Set true if it is a major compacted segment.
   *
   * @param majorCompacted
   */
  public void setMajorCompacted(String majorCompacted) {
    this.majorCompacted = majorCompacted;
  }

  /**
   * To set isDeleted property.
   *
   * @param isDeleted
   */
  public void setIsDeleted(String isDeleted) {
    this.isDeleted = isDeleted;
  }

  /**
   * To get the update delta end timestamp
   *
   * @return updateDeltaEndTimestamp
   */
  public String getUpdateDeltaEndTimestamp() {
    return updateDeltaEndTimestamp;
  }

  /**
   * To set the update delta end timestamp
   *
   * @param updateDeltaEndTimestamp
   */
  public void setUpdateDeltaEndTimestamp(String updateDeltaEndTimestamp) {
    this.updateDeltaEndTimestamp = updateDeltaEndTimestamp;
  }

  /**
   * To get the update delta start timestamp
   *
   * @return updateDeltaStartTimestamp
   */
  public String getUpdateDeltaStartTimestamp() {
    return updateDeltaStartTimestamp;
  }

  /**
   * To set the update delta start timestamp
   *
   * @param updateDeltaStartTimestamp
   */
  public void setUpdateDeltaStartTimestamp(String updateDeltaStartTimestamp) {
    this.updateDeltaStartTimestamp = updateDeltaStartTimestamp;
  }

  /**
   * To get the updateStatusFileName
   *
   * @return updateStatusFileName
   */
  public String getUpdateStatusFileName() {
    return updateStatusFileName;
  }

  /**
   * To set the updateStatusFileName
   *
   * @param updateStatusFileName
   */
  public void setUpdateStatusFileName(String updateStatusFileName) {
    this.updateStatusFileName = updateStatusFileName;
  }

  public FileFormat getFileFormat() {
    return fileFormat;
  }

  public void setFileFormat(FileFormat fileFormat) {
    this.fileFormat = fileFormat;
  }

  public String getSegmentFile() {
    return segmentFile;
  }

  public void setSegmentFile(String segmentFile) {
    this.segmentFile = segmentFile;
  }

  @Override public String toString() {
    return "LoadMetadataDetails{" + "loadStatus=" + loadStatus + ", loadName='" + loadName + '\''
        + ", loadStartTime='" + loadStartTime + '\'' + ", segmentFile='" + segmentFile + '\'' + '}';
  }
}

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.statusmanager;
19
20	import java.io.Serializable;
21	import java.text.ParseException;
22	import java.text.SimpleDateFormat;
23	import java.util.Date;
24
25	import org.apache.carbondata.common.logging.LogServiceFactory;
26	import org.apache.carbondata.core.constants.CarbonCommonConstants;
27
28	import org.apache.log4j.Logger;
29
30	/*
31	Prior to Carbon 1.3 the the loadMetaData @timestamp and @loadStartTime was stored as
32	as date string format "dd-MM-yyyy HH:mm:ss:SSS". The date string value is specific
33	to the timezone. SO the timestamp in long by the date string will not result into
34	same value if converted to date in different timezone.
35	Json Object of LoadMetaData before CarbonData 1.3
36	\|-------------------------------------------------------------------------------------------\|
37	\| [{"timestamp":"15-12-2017 16:50:31:703","loadStatus":"Success","loadName":"0", \|
38	\| "partitionCount":"0","isDeleted":"FALSE","dataSize":"912","indexSize":"700", \|
39	\| "updateDeltaEndTimestamp":"","updateDeltaStartTimestamp":"","updateStatusFileName":"", \|
40	\| "loadStartTime":"15-12-2017 16:50:27:493","visibility":"true","fileFormat":"COLUMNAR_V3"}]\|
41	\|-------------------------------------------------------------------------------------------\|
42	Fix: As the System.currentTimeMillis() returns the same value irrespective of timezone.
43	So if Carbon stores the long value for @timestamp and @loadStartTime value then the
44	value will be same irrespective of the timezone.
45	Json Object of LoadMetaData for CarbonData 1.3
46	\|-------------------------------------------------------------------------------------------\|
47	\| [{"timestamp":"1513336827593","loadStatus":"Success","loadName":"0", \|
48	\| "partitionCount":"0","isDeleted":"FALSE","dataSize":"912","indexSize":"700", \|
49	\| "updateDeltaEndTimestamp":"","updateDeltaStartTimestamp":"","updateStatusFileName":"", \|
50	\| "loadStartTime":"1513336827593","visibility":"true","fileFormat":"COLUMNAR_V3"}] \|
51	\|-------------------------------------------------------------------------------------------\|
52	*/
53	public class LoadMetadataDetails implements Serializable {	2✔
54
55	private static final long serialVersionUID = 1106104914918491724L;
56	private String timestamp;
57
58	// For backward compatibility, this member is required to read from JSON in the table_status file
59	private SegmentStatus loadStatus;
60
61	// name of the segment
62	private String loadName;
63
64	// partition count of this segment
65	private String partitionCount;
66
67	private String isDeleted = CarbonCommonConstants.KEYWORD_FALSE;	2✔
68	private String dataSize;
69	private String indexSize;
70
71	public String getDataSize() {
72	return dataSize;	1✔
73	}
74
75	public void setDataSize(String dataSize) {
76	this.dataSize = dataSize;	1✔
77	}	1✔
78
79	public String getIndexSize() {
80	return indexSize;	1✔
81	}
82
83	public void setIndexSize(String indexSize) {
84	this.indexSize = indexSize;	1✔
85	}	1✔
86
87	// update delta end timestamp
88	private String updateDeltaEndTimestamp = "";	2✔
89
90	// update delta start timestamp
91	private String updateDeltaStartTimestamp = "";	2✔
92
93	// this will represent the update status file name at that point of time.
94	private String updateStatusFileName = "";	2✔
95
96	/**
97	* LOGGER
98	*/
99	private static final Logger LOGGER =	2✔
100	LogServiceFactory.getLogService(LoadMetadataDetails.class.getName());	2✔
101
102	// dont remove static as the write will fail.
103	private static final SimpleDateFormat parser =	2✔
104	new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP_MILLIS);
105	/**
106	* Segment modification or deletion time stamp
107	*/
108	private String modificationOrdeletionTimesStamp;
109	private String loadStartTime;
110
111	private String mergedLoadName;
112	/**
113	* visibility is used to determine whether to the load is visible or not.
114	*/
115	private String visibility = "true";	2✔
116
117	/**
118	* To know if the segment is a major compacted segment or not.
119	*/
120	private String majorCompacted;
121
122	/**
123	* the file format of this segment
124	*/
125	private FileFormat fileFormat = FileFormat.COLUMNAR_V3;	2✔
126
127	/**
128	* Segment file name where it has the information of partition information.
129	*/
130	private String segmentFile;
131
132	public String getPartitionCount() {
133	return partitionCount;	×
134	}
135
136	@Deprecated
137	public void setPartitionCount(String partitionCount) {
138	this.partitionCount = partitionCount;	1✔
139	}	1✔
140
141	public long getLoadEndTime() {
142	if (timestamp == null) {	1✔
143	return CarbonCommonConstants.SEGMENT_LOAD_TIME_DEFAULT;	1✔
144	}
145	return convertTimeStampToLong(timestamp);	1✔
146	}
147
148	public void setLoadEndTime(long timestamp) {
149	this.timestamp = Long.toString(timestamp);	1✔
150	}	1✔
151
152	public SegmentStatus getSegmentStatus() {
153	return loadStatus;	1✔
154	}
155
156	public void setSegmentStatus(SegmentStatus segmentStatus) {
157	this.loadStatus = segmentStatus;	1✔
158	}	1✔
159
160	public String getLoadName() {
161	return loadName;	1✔
162	}
163
164	public void setLoadName(String loadName) {
165	this.loadName = loadName;	2✔
166	}	2✔
167
168	/**
169	* @return the modificationOrdeletionTimesStamp
170	*/
171	public long getModificationOrdeletionTimesStamp() {
172	if (null == modificationOrdeletionTimesStamp) {	1✔
173	return 0;	1✔
174	}
175	return convertTimeStampToLong(modificationOrdeletionTimesStamp);	1✔
176	}
177
178	/**
179	* @param modificationOrdeletionTimesStamp the modificationOrdeletionTimesStamp to set
180	*/
181	public void setModificationOrdeletionTimesStamp(long modificationOrdeletionTimesStamp) {
182	this.modificationOrdeletionTimesStamp =	1✔
183	Long.toString(modificationOrdeletionTimesStamp);	1✔
184	}	1✔
185
186	/* (non-Javadoc)
187	* @see java.lang.Object#hashCode()
188	*/
189	@Override public int hashCode() {
190	final int prime = 31;	2✔
191	int result = 1;	2✔
192	result = prime * result + ((loadName == null) ? 0 : loadName.hashCode());	2✔
193	return result;	2✔
194	}
195
196	/* (non-Javadoc)
197	* @see java.lang.Object#equals(java.lang.Object)
198	*/
199	@Override public boolean equals(Object obj) {
200	if (obj == null) {	2✔
201	return false;	×
202
203	}
204	if (!(obj instanceof LoadMetadataDetails)) {	2✔
205	return false;	2✔
206	}
207	LoadMetadataDetails other = (LoadMetadataDetails) obj;	2✔
208	if (loadName == null) {	2✔
209	if (other.loadName != null) {	2✔
210	return false;	2✔
211	}
212	} else if (!loadName.equals(other.loadName)) {	2✔
213	return false;	2✔
214	}
215	return true;	2✔
216	}
217
218	/**
219	* @return the startLoadTime
220	*/
221	public long getLoadStartTime() {
222	if (loadStartTime == null) {	2✔
223	return CarbonCommonConstants.SEGMENT_LOAD_TIME_DEFAULT;	×
224	}
225	return convertTimeStampToLong(loadStartTime);	2✔
226	}
227
228	/**
229	* return loadStartTime
230	*
231	* @return
232	*/
233	public long getLoadStartTimeAsLong() {
234	if (!loadStartTime.isEmpty()) {	1✔
235	Long time = getTimeStamp(loadStartTime);	1✔
236	if (null != time) {	1✔
237	return time;	1✔
238	}
239	}
240	return 0;	×
241	}
242
243	/**
244	* This method will convert a given timestamp to long value and then to string back
245	*
246	* @param factTimeStamp
247	* @return Long TimeStamp value is milliseconds
248	*/
249	private long convertTimeStampToLong(String factTimeStamp) {
250	try {
251	return Long.parseLong(factTimeStamp);	2✔
252	} catch (NumberFormatException nf) {	×
253	SimpleDateFormat parser = new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP_MILLIS);	×
254	// it is the processing for existing table before carbon 1.3
255	Date dateToStr = null;	×
256	try {
257	dateToStr = parser.parse(factTimeStamp);	×
258	return dateToStr.getTime();	×
259	} catch (ParseException e) {	×
260	LOGGER	×
261	.error("Cannot convert" + factTimeStamp + " to Time/Long type value" + e.getMessage());	×
262	parser = new SimpleDateFormat(CarbonCommonConstants.CARBON_TIMESTAMP);	×
263	try {
264	// if the load is in progress, factTimeStamp will be null, so use current time
265	if (null == factTimeStamp) {	×
266	return System.currentTimeMillis();	×
267	}
268	dateToStr = parser.parse(factTimeStamp);	×
269	return dateToStr.getTime();	×
270	} catch (ParseException e1) {	×
271	LOGGER.error(	×
272	"Cannot convert" + factTimeStamp + " to Time/Long type value" + e1.getMessage());	×
273	return 0;	×
274	}
275	}
276	}
277	}
278
279	/**
280	* returns load start time as long value
281	*
282	* @param loadStartTime
283	* @return Long TimeStamp value is nanoseconds
284	*/
285	public Long getTimeStamp(String loadStartTime) {
286	try {
287	return Long.parseLong(loadStartTime) * 1000L;	1✔
288	} catch (NumberFormatException nf) {	2✔
289	// it is the processing for existing table before carbon 1.3
290	Date dateToStr = null;	2✔
291	try {
292	dateToStr = parser.parse(loadStartTime);	2✔
293	return dateToStr.getTime() * 1000;	2✔
294	} catch (ParseException e) {	×
295	LOGGER.error("Cannot convert" + loadStartTime +	×
296	" to Time/Long type value" + e.getMessage());	×
297	return null;	×
298	}
299	}
300	}
301
302	/**
303	* @param loadStartTime
304	*/
305	public void setLoadStartTime(long loadStartTime) {
306	this.loadStartTime = Long.toString(loadStartTime);	2✔
307	}	2✔
308
309	/**
310	* @return the mergedLoadName
311	*/
312	public String getMergedLoadName() {
313	return mergedLoadName;	1✔
314	}
315
316	/**
317	* @param mergedLoadName the mergedLoadName to set
318	*/
319	public void setMergedLoadName(String mergedLoadName) {
320	this.mergedLoadName = mergedLoadName;	1✔
321	}	1✔
322
323	/**
324	* @return the visibility
325	*/
326	public String getVisibility() {
327	return visibility;	1✔
328	}
329
330	/**
331	* @param visibility the visibility to set
332	*/
333	public void setVisibility(String visibility) {
334	this.visibility = visibility;	1✔
335	}	1✔
336
337	/**
338	* Return true if it is a major compacted segment.
339	* @return majorCompacted
340	*/
341	public String isMajorCompacted() {
342	return majorCompacted;	1✔
343	}
344
345	/**
346	* Set true if it is a major compacted segment.
347	*
348	* @param majorCompacted
349	*/
350	public void setMajorCompacted(String majorCompacted) {
351	this.majorCompacted = majorCompacted;	1✔
352	}	1✔
353
354	/**
355	* To set isDeleted property.
356	*
357	* @param isDeleted
358	*/
359	public void setIsDeleted(String isDeleted) {
360	this.isDeleted = isDeleted;	1✔
361	}	1✔
362
363	/**
364	* To get the update delta end timestamp
365	*
366	* @return updateDeltaEndTimestamp
367	*/
368	public String getUpdateDeltaEndTimestamp() {
369	return updateDeltaEndTimestamp;	1✔
370	}
371
372	/**
373	* To set the update delta end timestamp
374	*
375	* @param updateDeltaEndTimestamp
376	*/
377	public void setUpdateDeltaEndTimestamp(String updateDeltaEndTimestamp) {
378	this.updateDeltaEndTimestamp = updateDeltaEndTimestamp;	1✔
379	}	1✔
380
381	/**
382	* To get the update delta start timestamp
383	*
384	* @return updateDeltaStartTimestamp
385	*/
386	public String getUpdateDeltaStartTimestamp() {
387	return updateDeltaStartTimestamp;	1✔
388	}
389
390	/**
391	* To set the update delta start timestamp
392	*
393	* @param updateDeltaStartTimestamp
394	*/
395	public void setUpdateDeltaStartTimestamp(String updateDeltaStartTimestamp) {
396	this.updateDeltaStartTimestamp = updateDeltaStartTimestamp;	1✔
397	}	1✔
398
399	/**
400	* To get the updateStatusFileName
401	*
402	* @return updateStatusFileName
403	*/
404	public String getUpdateStatusFileName() {
405	return updateStatusFileName;	1✔
406	}
407
408	/**
409	* To set the updateStatusFileName
410	*
411	* @param updateStatusFileName
412	*/
413	public void setUpdateStatusFileName(String updateStatusFileName) {
414	this.updateStatusFileName = updateStatusFileName;	1✔
415	}	1✔
416
417	public FileFormat getFileFormat() {
418	return fileFormat;	1✔
419	}
420
421	public void setFileFormat(FileFormat fileFormat) {
422	this.fileFormat = fileFormat;	1✔
423	}	1✔
424
425	public String getSegmentFile() {
426	return segmentFile;	1✔
427	}
428
429	public void setSegmentFile(String segmentFile) {
430	this.segmentFile = segmentFile;	1✔
431	}	1✔
432
433	@Override public String toString() {
434	return "LoadMetadataDetails{" + "loadStatus=" + loadStatus + ", loadName='" + loadName + '\''	×
435	+ ", loadStartTime='" + loadStartTime + '\'' + ", segmentFile='" + segmentFile + '\'' + '}';
436	}
437	}

apache / carbondata / 9274

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