2666

Build # 2666

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/33c01ed29ed4042c3282f5da1e26b22c5beac148">33c01ed29<a href="https://github.com/apache/carbondata/commit/33c01ed29ed4042c3282f5da1e26b22c5beac148">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/41042696fb6924638b0e07575c28bc76fb4af59a">41042696f</a>">41042696f</a><a href="https://github.com/apache/carbondata/commit/33c01ed29ed4042c3282f5da1e26b22c5beac148"> into 028eb25be">028eb25be</a>

Run Details

62402 of 78853 relevant lines covered (79.14%)

1.05 hits per line

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

84.0

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

import java.io.BufferedWriter;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;

import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.constants.CarbonCommonConstants;
import org.apache.carbondata.core.datastore.impl.FileFactory;
import org.apache.carbondata.core.mutate.DeleteDeltaBlockDetails;

import com.google.gson.Gson;
import org.apache.log4j.Logger;

/**
 * This class is responsible for writing the delete delta file
 */
public class CarbonDeleteDeltaWriterImpl implements CarbonDeleteDeltaWriter {

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

  private String filePath;

  private FileFactory.FileType fileType;

  private DataOutputStream dataOutStream = null;

  /**
   * @param filePath
   * @param fileType
   */
  public CarbonDeleteDeltaWriterImpl(String filePath, FileFactory.FileType fileType) {
    this.filePath = filePath;
    this.fileType = fileType;

  }

  /**
   * This method will write the deleted records data in the json format.
   * @param deleteDeltaBlockDetails
   * @throws IOException
   */
  @Override public void write(DeleteDeltaBlockDetails deleteDeltaBlockDetails) throws IOException {
    BufferedWriter brWriter = null;
    try {
      FileFactory.createNewFile(filePath, fileType);
      dataOutStream = FileFactory.getDataOutputStream(filePath, fileType);
      Gson gsonObjectToWrite = new Gson();
      brWriter = new BufferedWriter(new OutputStreamWriter(dataOutStream,
          CarbonCommonConstants.DEFAULT_CHARSET));
      String deletedData = gsonObjectToWrite.toJson(deleteDeltaBlockDetails);
      brWriter.write(deletedData);
    } catch (IOException ioe) {
      LOGGER.error("Error message: " + ioe.getLocalizedMessage());
      throw ioe;
    } finally {
      if (null != brWriter) {
        brWriter.flush();
      }
      if (null != dataOutStream) {
        dataOutStream.flush();
      }
      if (null != brWriter) {
        brWriter.close();
      }
    }

  }
}

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.writer;
19
20	import java.io.BufferedWriter;
21	import java.io.DataOutputStream;
22	import java.io.IOException;
23	import java.io.OutputStreamWriter;
24
25	import org.apache.carbondata.common.logging.LogServiceFactory;
26	import org.apache.carbondata.core.constants.CarbonCommonConstants;
27	import org.apache.carbondata.core.datastore.impl.FileFactory;
28	import org.apache.carbondata.core.mutate.DeleteDeltaBlockDetails;
29
30	import com.google.gson.Gson;
31	import org.apache.log4j.Logger;
32
33	/**
34	* This class is responsible for writing the delete delta file
35	*/
36	public class CarbonDeleteDeltaWriterImpl implements CarbonDeleteDeltaWriter {
37
38	/**
39	* LOGGER
40	*/
41	private static final Logger LOGGER =	1✔
42	LogServiceFactory.getLogService(CarbonDeleteDeltaWriterImpl.class.getName());	1✔
43
44	private String filePath;
45
46	private FileFactory.FileType fileType;
47
48	private DataOutputStream dataOutStream = null;	1✔
49
50	/**
51	* @param filePath
52	* @param fileType
53	*/
54	public CarbonDeleteDeltaWriterImpl(String filePath, FileFactory.FileType fileType) {	1✔
55	this.filePath = filePath;	1✔
56	this.fileType = fileType;	1✔
57
58	}	1✔
59
60	/**
61	* This method will write the deleted records data in the json format.
62	* @param deleteDeltaBlockDetails
63	* @throws IOException
64	*/
65	@Override public void write(DeleteDeltaBlockDetails deleteDeltaBlockDetails) throws IOException {
66	BufferedWriter brWriter = null;	1✔
67	try {
68	FileFactory.createNewFile(filePath, fileType);	1✔
69	dataOutStream = FileFactory.getDataOutputStream(filePath, fileType);	1✔
70	Gson gsonObjectToWrite = new Gson();	1✔
71	brWriter = new BufferedWriter(new OutputStreamWriter(dataOutStream,	1✔
72	CarbonCommonConstants.DEFAULT_CHARSET));
73	String deletedData = gsonObjectToWrite.toJson(deleteDeltaBlockDetails);	1✔
74	brWriter.write(deletedData);	1✔
75	} catch (IOException ioe) {	×
76	LOGGER.error("Error message: " + ioe.getLocalizedMessage());	×
77	throw ioe;	×
78	} finally {
79	if (null != brWriter) {	1✔
80	brWriter.flush();	1✔
81	}
82	if (null != dataOutStream) {	1✔
83	dataOutStream.flush();	1✔
84	}
85	if (null != brWriter) {	1✔
86	brWriter.close();	1✔
87	}
88	}	×
89
90	}	1✔
91	}

apache / carbondata / 2666

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