2069

Build # 2069

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/c5f1191664511cab05c067ac690c1352a8045662">c5f119166<a href="https://github.com/apache/carbondata/commit/c5f1191664511cab05c067ac690c1352a8045662">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/78f5d72a5b169b38d7d6bd0f7fbd9ebf8bfa6d55">78f5d72a5</a>">78f5d72a5</a><a href="https://github.com/apache/carbondata/commit/c5f1191664511cab05c067ac690c1352a8045662"> into c0d858139">c0d858139</a>

Run Details

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

61381 of 77769 relevant lines covered (78.93%)

1.05 hits per line

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

88.24

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

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.datastore.impl.FileFactory;

import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.Logger;

public class AlluxioCarbonFile extends AbstractDFSCarbonFile {
  /**
   * LOGGER
   */
  private static final Logger LOGGER =
      LogServiceFactory.getLogService(AlluxioCarbonFile.class.getName());

  public AlluxioCarbonFile(String filePath) {
    super(filePath);
  }

  public AlluxioCarbonFile(Path path) {
    super(path);
  }

  public AlluxioCarbonFile(FileStatus fileStatus) {
    super(fileStatus);
  }

  /**
   * @param listStatus
   * @return
   */
  @Override
  protected CarbonFile[] getFiles(FileStatus[] listStatus) {
    if (listStatus == null) {
      return new CarbonFile[0];
    }
    CarbonFile[] files = new CarbonFile[listStatus.length];
    for (int i = 0; i < files.length; i++) {
      files[i] = new AlluxioCarbonFile(listStatus[i]);
    }
    return files;
  }

  @Override
  public CarbonFile[] listFiles(final CarbonFileFilter fileFilter) {
    CarbonFile[] files = listFiles();
    if (files != null && files.length >= 1) {
      List<CarbonFile> fileList = new ArrayList<CarbonFile>(files.length);
      for (int i = 0; i < files.length; i++) {
        if (fileFilter.accept(files[i])) {
          fileList.add(files[i]);
        }
      }
      if (fileList.size() >= 1) {
        return fileList.toArray(new CarbonFile[fileList.size()]);
      } else {
        return new CarbonFile[0];
      }
    }
    return files;
  }

  @Override
  public CarbonFile getParentFile() {
    Path parent = fileStatus.getPath().getParent();
    return null == parent ? null : new AlluxioCarbonFile(parent);
  }

  @Override
  public boolean renameForce(String changeToName) {
    FileSystem fs;
    try {
      fs = fileStatus.getPath().getFileSystem(FileFactory.getConfiguration());
      Path targetPath = new Path(changeToName);
      if (fs.exists(targetPath)) {
        fs.delete(targetPath, true);
      }
      return fs.rename(fileStatus.getPath(), targetPath);
    } catch (IOException e) {
      LOGGER.error("Exception occured: " + e.getMessage(), e);
      return false;
    }
  }
}

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.datastore.filesystem;
19
20	import java.io.IOException;
21	import java.util.ArrayList;
22	import java.util.List;
23
24	import org.apache.carbondata.common.logging.LogServiceFactory;
25	import org.apache.carbondata.core.datastore.impl.FileFactory;
26
27	import org.apache.hadoop.fs.FileStatus;
28	import org.apache.hadoop.fs.FileSystem;
29	import org.apache.hadoop.fs.Path;
30	import org.apache.log4j.Logger;
31
32	public class AlluxioCarbonFile extends AbstractDFSCarbonFile {
33	/**
34	* LOGGER
35	*/
36	private static final Logger LOGGER =	2✔
37	LogServiceFactory.getLogService(AlluxioCarbonFile.class.getName());	2✔
38
39	public AlluxioCarbonFile(String filePath) {
40	super(filePath);	2✔
41	}	2✔
42
43	public AlluxioCarbonFile(Path path) {
44	super(path);	2✔
45	}	2✔
46
47	public AlluxioCarbonFile(FileStatus fileStatus) {
48	super(fileStatus);	2✔
49	}	2✔
50
51	/**
52	* @param listStatus
53	* @return
54	*/
55	@Override
56	protected CarbonFile[] getFiles(FileStatus[] listStatus) {
57	if (listStatus == null) {	2✔
58	return new CarbonFile[0];	2✔
59	}
60	CarbonFile[] files = new CarbonFile[listStatus.length];	2✔
61	for (int i = 0; i < files.length; i++) {	2✔
62	files[i] = new AlluxioCarbonFile(listStatus[i]);	2✔
63	}
64	return files;	2✔
65	}
66
67	@Override
68	public CarbonFile[] listFiles(final CarbonFileFilter fileFilter) {
69	CarbonFile[] files = listFiles();	2✔
70	if (files != null && files.length >= 1) {	2✔
71	List<CarbonFile> fileList = new ArrayList<CarbonFile>(files.length);	2✔
72	for (int i = 0; i < files.length; i++) {	2✔
73	if (fileFilter.accept(files[i])) {	2✔
74	fileList.add(files[i]);	2✔
75	}
76	}
77	if (fileList.size() >= 1) {	2✔
78	return fileList.toArray(new CarbonFile[fileList.size()]);	2✔
79	} else {
80	return new CarbonFile[0];	2✔
81	}
82	}
83	return files;	×
84	}
85
86	@Override
87	public CarbonFile getParentFile() {
88	Path parent = fileStatus.getPath().getParent();	2✔
89	return null == parent ? null : new AlluxioCarbonFile(parent);	2✔
90	}
91
92	@Override
93	public boolean renameForce(String changeToName) {
94	FileSystem fs;
95	try {
96	fs = fileStatus.getPath().getFileSystem(FileFactory.getConfiguration());	2✔
97	Path targetPath = new Path(changeToName);	2✔
98	if (fs.exists(targetPath)) {	×
99	fs.delete(targetPath, true);	×
100	}
101	return fs.rename(fileStatus.getPath(), targetPath);	×
102	} catch (IOException e) {	2✔
103	LOGGER.error("Exception occured: " + e.getMessage(), e);	2✔
104	return false;	2✔
105	}
106	}
107	}

apache / carbondata / 2069

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