You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2016/12/12 05:56:41 UTC
[2/3] incubator-carbondata git commit: test case for columnar package
and manage package for filesystem
test case for columnar package and manage package for filesystem
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/4afef29b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/4afef29b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/4afef29b
Branch: refs/heads/master
Commit: 4afef29b43a4dc86a4977b8dc52c253a1c445f13
Parents: 61fe6d4
Author: Anurag <an...@knoldus.com>
Authored: Wed Nov 30 15:50:43 2016 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Mon Dec 12 11:25:10 2016 +0530
----------------------------------------------------------------------
.../filesystem/AlluxioCarbonFileTest.java | 295 ------------
.../filesystem/HDFSCarbonFileTest.java | 402 ----------------
.../filesystem/LocalCarbonFileTest.java | 468 -------------------
.../filesystem/ViewFsCarbonFileTest.java | 314 -------------
.../ColumnarKeyStoreDataHolderUnitTest.java | 93 ++++
.../store/filesystem/AlluxioCarbonFileTest.java | 295 ++++++++++++
.../store/filesystem/HDFSCarbonFileTest.java | 402 ++++++++++++++++
.../store/filesystem/LocalCarbonFileTest.java | 468 +++++++++++++++++++
.../store/filesystem/ViewFsCarbonFileTest.java | 314 +++++++++++++
9 files changed, 1572 insertions(+), 1479 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/AlluxioCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/AlluxioCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/AlluxioCarbonFileTest.java
deleted file mode 100644
index acd30c9..0000000
--- a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/AlluxioCarbonFileTest.java
+++ /dev/null
@@ -1,295 +0,0 @@
-/*
- * 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.carbon.datastorage.filesystem;
-
-import mockit.Mock;
-import mockit.MockUp;
-import org.apache.carbondata.core.datastorage.store.filesystem.AlluxioCarbonFile;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileStatus;
-import org.apache.hadoop.fs.FileSystem;
-import org.apache.hadoop.fs.Options;
-import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.hdfs.DistributedFileSystem;
-import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-
-public class AlluxioCarbonFileTest {
-
- private static AlluxioCarbonFile alluxioCarbonFile;
- private static FileStatus fileStatus;
- private static FileStatus fileStatusWithOutDirectoryPermission;
- private static String fileName;
- private static File file;
-
-
- @BeforeClass
- static public void setUp() {
- file = new File("Test.carbondata");
- if (!file.exists())
- try {
- file.createNewFile();
- } catch (IOException e) {
- e.printStackTrace();
- }
- try {
- FileOutputStream oFile = new FileOutputStream(file, true);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- }
-
- fileStatus = new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- fileStatusWithOutDirectoryPermission = new FileStatus(12L, false, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- fileName = file.getAbsolutePath();
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- }
-
- @AfterClass
- static public void cleanUp() {
- file.delete();
- }
-
- @Test
- public void testRenameForceForException() throws IOException {
-
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- alluxioCarbonFile.renameForce(fileName);
- }
-
- @Test
- public void testListFilesWithOutDirectoryPermission() {
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
- assertTrue(alluxioCarbonFile.listFiles() == null);
- }
-
- @Test
- public void testConstructorWithFilePath() {
- alluxioCarbonFile = new AlluxioCarbonFile(file.getAbsolutePath());
- assertTrue(alluxioCarbonFile instanceof AlluxioCarbonFile);
- }
-
- @Test
- public void testListFilesForNullListStatus() {
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- return null;
- }
-
- };
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- assertTrue(alluxioCarbonFile.listFiles().length == 0);
- }
-
- @Test
- public void testListDirectory() {
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
-
- assertTrue(alluxioCarbonFile.listFiles().length == 1);
- }
-
- @Test
- public void testListFilesForException() throws IOException {
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(file.getAbsolutePath());
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- throw new IOException();
- }
-
- };
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- alluxioCarbonFile.listFiles();
- }
-
- @Test
- public void testListFilesWithCarbonFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- assertTrue(alluxioCarbonFile.listFiles(carbonFileFilter).length == 1);
- }
-
- @Test
- public void testlistFilesWithoutFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return false;
- }
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- assertTrue(alluxioCarbonFile.listFiles(carbonFileFilter).length == 0);
- }
-
- @Test
- public void testGetParentFile() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public Path getParent() {
- return new Path(file.getAbsolutePath()
- );
- }
-
- };
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(file.getAbsolutePath());
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus getFileStatus(Path path) throws IOException {
-
- return new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- }
-
- };
-
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- assertFalse(alluxioCarbonFile.getParentFile().equals(null));
- }
-
- @Test
- public void testForNonDisributedSystem() {
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new WebHdfsFileSystem();
- }
-
- };
- assertFalse(alluxioCarbonFile.renameForce(fileName));
- }
-
- @Test
- public void testrenameForceForDisributedSystem() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public void rename(Path src, Path dst, final Options.Rename... options) throws IOException {
-
- }
-
- };
-
- alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
- assertTrue(alluxioCarbonFile.renameForce(fileName));
-
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/HDFSCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/HDFSCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/HDFSCarbonFileTest.java
deleted file mode 100644
index c55c600..0000000
--- a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/HDFSCarbonFileTest.java
+++ /dev/null
@@ -1,402 +0,0 @@
-/*
- * 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.carbon.datastorage.filesystem;
-
-import mockit.Mock;
-import mockit.MockUp;
-import org.apache.carbondata.common.logging.LogService;
-import org.apache.carbondata.common.logging.LogServiceFactory;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
-import org.apache.carbondata.core.datastorage.store.filesystem.HDFSCarbonFile;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileStatus;
-import org.apache.hadoop.fs.FileSystem;
-import org.apache.hadoop.fs.Options;
-import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.hdfs.DistributedFileSystem;
-import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
-import org.apache.hadoop.util.Progressable;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import java.io.BufferedWriter;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.io.OutputStreamWriter;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-
-
-public class HDFSCarbonFileTest {
-
- private static final LogService LOGGER =
- LogServiceFactory.getLogService(HDFSCarbonFile.class.getName());
- private static HDFSCarbonFile hdfsCarbonFile;
- private static FileStatus fileStatus = null;
- private static FileStatus fileStatusWithOutDirectoryPermission;
- private static String fileName = null;
- private static FileSystem fs = null;
- private static Path pt;
-
- @BeforeClass
- static public void setUp() throws IOException {
- Configuration config = new Configuration();
-//adding local hadoop configuration
- config.addResource(new Path("core-site.xml"));
- config.addResource(new Path("hdfs-site.xml"));
- fileName = "Test.carbondata"; //this path is HDFS path
- pt = new Path(fileName);
- fs = FileSystem.get(new Configuration(config));
- fs.create(pt);
- if (fs.exists(pt)) {
- OutputStream os = fs.create(pt,
- new Progressable() {
- public void progress() {
- LOGGER.info("Started Writing to File===");
- }
- });
- BufferedWriter br = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));
- br.write("Hello World");
- br.close();
- fs.close();
-
- fileStatus = new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName));
- fileStatusWithOutDirectoryPermission = new FileStatus(12L, false, 60, 120l, 180L, new Path(fileName));
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
-
- }
- }
-
- @AfterClass
- static public void cleanUp() {
- try {
- fs.delete(pt, true);
- } catch (IOException e) {
- LOGGER.error("Exception Occured" + e.getMessage());
- }
- }
-
- @Test
- public void testRenameForceForException() throws IOException {
-
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- hdfsCarbonFile.renameForce(fileName);
- }
-
- @Test
- public void testListFilesWithOutDirectoryPermission() {
- hdfsCarbonFile = new HDFSCarbonFile(fileStatusWithOutDirectoryPermission);
- new MockUp<FileStatus>() {
- @Mock
- public boolean isDirectory() {
- return false;
- }
-
- };
-
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- assertEquals(hdfsCarbonFile.listFiles(), null);
- }
-
- @Test
- public void testConstructorWithFilePath() {
- hdfsCarbonFile = new HDFSCarbonFile(fileName);
- assertTrue(hdfsCarbonFile instanceof HDFSCarbonFile);
- }
-
- @Test
- public void testListFilesForNullListStatus() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- return null;
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertEquals(hdfsCarbonFile.listFiles().length, 0);
- }
-
- @Test
- public void testListDirectory() {
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
-
- assertEquals(hdfsCarbonFile.listFiles().length, 1);
- }
-
- @Test
- public void testListFilesForException() throws IOException {
- new HDFSCarbonFile(fileStatusWithOutDirectoryPermission);
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- throw new IOException();
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- hdfsCarbonFile.listFiles();
- }
-
- @Test
- public void testListFilesWithCarbonFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- new MockUp<FileStatus>() {
- @Mock
- public boolean isDirectory() {
- return true;
- }
-
- };
-
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus fileStatus[] = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertEquals(hdfsCarbonFile.listFiles(carbonFileFilter).length, 1);
- }
-
- @Test
- public void testlistFilesWithoutFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return false;
- }
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertEquals(hdfsCarbonFile.listFiles(carbonFileFilter).length, 0);
- }
-
- @Test
- public void testGetParentFileForNull() {
-
- new MockUp<Path>() {
- @Mock
- public Path getParent() {
- return null;
- }
-
- };
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertEquals(hdfsCarbonFile.getParentFile(), null);
- }
-
- @Test
- public void testGetParentFile() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public Path getParent() {
- return new Path(fileName);
- }
-
- };
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(fileName);
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus getFileStatus(Path file) throws IOException {
-
- return new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName));
- }
-
- };
-
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertTrue(hdfsCarbonFile.getParentFile() instanceof CarbonFile);
- }
-
- @Test
- public void testForNonDisributedSystem() {
- new HDFSCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new WebHdfsFileSystem();
- }
-
- };
- assertEquals(hdfsCarbonFile.renameForce(fileName), false);
- }
-
- @Test
- public void testrenameForceForDisributedSystem() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public void rename(Path src, Path dst, final Options.Rename... options) throws IOException {
-
- }
-
- };
- hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
- assertEquals(hdfsCarbonFile.renameForce(fileName), true);
-
- }
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/LocalCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/LocalCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/LocalCarbonFileTest.java
deleted file mode 100644
index 6b644dd..0000000
--- a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/LocalCarbonFileTest.java
+++ /dev/null
@@ -1,468 +0,0 @@
-/*
- * 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.carbon.datastorage.filesystem;
-
-import mockit.Mock;
-import mockit.MockUp;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
-import org.apache.carbondata.core.datastorage.store.filesystem.LocalCarbonFile;
-import org.apache.carbondata.core.datastorage.store.impl.FileFactory;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import sun.nio.ch.FileChannelImpl;
-
-import java.io.*;
-import java.nio.channels.ReadableByteChannel;
-import java.util.Objects;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-
-
-public class LocalCarbonFileTest {
-
- private static LocalCarbonFile localCarbonFile;
- private static File file;
- private static File dir;
- private static FileOutputStream oFile;
-
- @BeforeClass
- static public void setUp() {
- file = new File("Test.carbondata");
- dir = new File("Testdir.carbondata");
- if (!file.exists())
- try {
- file.createNewFile();
- dir.mkdir();
- } catch (IOException e) {
- e.printStackTrace();
- }
- try {
- oFile = new FileOutputStream(file, true);
-
-
- byte[] bytes = "core java api".getBytes();
-
- oFile.write(bytes);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- localCarbonFile = new LocalCarbonFile(file);
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-
- @AfterClass
- static public void cleanUp() {
- file.delete();
- dir.delete();
-
- }
-
- @Test
- public void testListFilesWithCarbonFileFilterAndWithOutOutDirectoryPermission() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
- @Override
- public boolean accept(CarbonFile file) {
- return false;
- }
- };
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return false;
- }
-
-
- };
- assertTrue(localCarbonFile.listFiles(carbonFileFilter) == null);
- }
-
- @Test
- public void testListFilesWithOutDirPermission() {
- localCarbonFile = new LocalCarbonFile(file);
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return false;
- }
- };
- assertTrue(localCarbonFile.listFiles() == null);
- }
-
- @Test
- public void testCreateNewFileForException() throws IOException {
- localCarbonFile = new LocalCarbonFile(new File(""));
- assertTrue(!localCarbonFile.createNewFile());
- }
-
- @Test
- public void testCheckIfFileExists() throws IOException {
- localCarbonFile = new LocalCarbonFile(new File(""));
- assertTrue(!localCarbonFile.exists());
- }
-
- @Test
- public void testRenameForce() {
- localCarbonFile = new LocalCarbonFile(file);
- assertTrue(localCarbonFile.renameForce("Testdb.carbon"));
- }
-
- @Test
- public void testRenameTo() {
- localCarbonFile = new LocalCarbonFile(file);
- assertTrue(!localCarbonFile.renameTo("Testdb.carbon"));
- }
-
- @Test
- public void testsetLastModifiedTime() {
- localCarbonFile = new LocalCarbonFile(file);
- assertTrue(!localCarbonFile.setLastModifiedTime(50L));
- }
-
- @Test
- public void testtruncate() {
- localCarbonFile = new LocalCarbonFile(file);
- final int[] counter = {0};
- new MockUp<FileFactory>() {
- @Mock
- public FileFactory.FileType getFileType(String path) {
- {
- return FileFactory.FileType.LOCAL;
- }
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public boolean isFileExist(String filePath, FileFactory.FileType fileType) throws IOException {
- {
- return true;
- }
- }
- };
- new MockUp<CarbonFile>() {
- @Mock
- boolean delete() {
- return true;
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public boolean createNewFile(String filePath, FileFactory.FileType fileType) throws IOException {
- {
- return true;
- }
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public CarbonFile getCarbonFile(String path, FileFactory.FileType fileType) {
- {
- return new LocalCarbonFile(path);
- }
- }
- };
- new MockUp<CarbonFile>() {
- @Mock
- boolean delete() {
- return true;
- }
- };
-
- new MockUp<FileChannelImpl>() {
- @Mock
- public long transferFrom(ReadableByteChannel var1, long var2, long var4) throws IOException {
- if (counter[0] == 0) {
- counter[0] = counter[0] + 1;
- return 0L;
- } else {
- return 1L;
- }
- }
- };
- new MockUp<CarbonFile>() {
- @Mock
- boolean renameForce(String changetoName) {
- return true;
- }
- };
- localCarbonFile = new LocalCarbonFile(file);
- assertTrue(localCarbonFile.truncate(file.getName(), 1L));
- }
-
- @Test
- public void testtruncateForException() throws IOException {
- localCarbonFile = new LocalCarbonFile(file);
- new MockUp<FileFactory>() {
- @Mock
- public FileFactory.FileType getFileType(String path) {
- {
- return FileFactory.FileType.LOCAL;
- }
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public boolean isFileExist(String filePath, FileFactory.FileType fileType) throws IOException {
- {
- return true;
- }
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public CarbonFile getCarbonFile(String path, FileFactory.FileType fileType) {
- {
- return new LocalCarbonFile(path);
- }
- }
- };
- new MockUp<CarbonFile>() {
- @Mock
- boolean delete() {
- return true;
- }
- };
- new MockUp<FileFactory>() {
- @Mock
- public boolean createNewFile(String filePath, FileFactory.FileType fileType) throws IOException {
- {
- throw new IOException();
- }
- }
- };
-
-
- localCarbonFile.truncate(file.getName(), 2L);
- }
-
- @Test
- public void testListFilesWithDirPermission() {
- localCarbonFile = new LocalCarbonFile(file);
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return true;
- }
- };
- new MockUp<File>() {
- @Mock
- public File[] listFiles() {
- return null;
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
- assertTrue(localCarbonFile.listFiles().length == 0);
- }
-
- @Test
- public void testListFilesWithCarbonFileFilterAndDirectoryPermission() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return true;
- }
- };
- new MockUp<File>() {
- @Mock
- public File[] listFiles(FileFilter filter) {
-
- File[] file = new File[]{dir};
- return file;
- }
-
-
- };
-
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertTrue(localCarbonFile.listFiles(carbonFileFilter).length == 1);
- }
-
- @Test
- public void testListFilesForNullWithCarbonFileFilterAndDirectoryPermission() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- new MockUp<File>() {
- @Mock
- public File[] listFiles(FileFilter filter) {
- return null;
- }
-
-
- };
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return false;
- }
-
- @Mock
- public File[] listFiles(FileFilter filter) {
- return null;
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertTrue(localCarbonFile.listFiles(carbonFileFilter) == null);
- }
-
- @Test
- public void testListFilesForEmptyFileArrayWithCarbonFileFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- new MockUp<CarbonFileFilter>() {
- @Mock
- boolean accept(CarbonFile file) {
- return true;
- }
- };
- new MockUp<File>() {
- @Mock
- public File[] listFiles(FileFilter filter) {
- return null;
- }
- };
- new MockUp<File>() {
- @Mock
- public boolean isDirectory() {
- return true;
- }
-
- @Mock
- public File[] listFiles(FileFilter filter) {
- return null;
- }
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertTrue(localCarbonFile.listFiles(carbonFileFilter).length == 0);
- }
-
- @Test
- public void testFilesForConnicalPath() {
-
- new MockUp<File>() {
- @Mock
- public String getCanonicalPath() throws IOException {
- return "testFile";
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertTrue(Objects.equals(localCarbonFile.getCanonicalPath(), "testFile"));
- }
-
- @Test
- public void testFilesForConnicalPathException() throws IOException {
-
- new MockUp<File>() {
- @Mock
- public String getCanonicalPath() throws IOException {
- throw new IOException();
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- localCarbonFile.getCanonicalPath();
- }
-
- @Test
- public void testFilesForAbsolutePath() {
-
- new MockUp<File>() {
- @Mock
- public String getAbsolutePath() {
- return "testFile";
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertEquals(localCarbonFile.getAbsolutePath(), "testFile");
- }
-
- @Test
- public void testFilesForGetPath() {
-
- new MockUp<File>() {
- @Mock
- public String getPath() {
- return "testFile";
- }
-
-
- };
- localCarbonFile = new LocalCarbonFile(dir);
-
- assertEquals(localCarbonFile.getPath(), "testFile");
- }
-
- @Test
- public void testFilesForFileExists() {
-
- localCarbonFile = new LocalCarbonFile(new File(""));
- assertEquals(localCarbonFile.exists(), false);
- }
-
- @Test
- public void testRenameForceForFileNotExists() {
- new MockUp<File>() {
- @Mock
- public boolean exists() {
- return false;
- }
-
- @Mock
- public boolean renameTo(File dest) {
- return true;
- }
- };
-
- localCarbonFile = new LocalCarbonFile("demo.txt");
-
- assertEquals(localCarbonFile.renameForce("Test.carbondata"), true);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/ViewFsCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/ViewFsCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/ViewFsCarbonFileTest.java
deleted file mode 100644
index 5637b3c..0000000
--- a/core/src/test/java/org/apache/carbondata/core/carbon/datastorage/filesystem/ViewFsCarbonFileTest.java
+++ /dev/null
@@ -1,314 +0,0 @@
-/*
- * 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.carbon.datastorage.filesystem;
-
-import mockit.Mock;
-import mockit.MockUp;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
-import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
-import org.apache.carbondata.core.datastorage.store.filesystem.ViewFSCarbonFile;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileStatus;
-import org.apache.hadoop.fs.FileSystem;
-import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.fs.viewfs.ViewFileSystem;
-import org.apache.hadoop.hdfs.DistributedFileSystem;
-import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-
-
-public class ViewFsCarbonFileTest {
-
- private static ViewFSCarbonFile viewFSCarbonFile;
- private static FileStatus fileStatus;
- private static FileStatus fileStatusWithOutDirectoryPermission;
- private static String fileName;
- private static File file;
-
-
- @BeforeClass
- static public void setUp() {
- file = new File("Test.carbondata");
- if (!file.exists())
- try {
- file.createNewFile();
- } catch (IOException e) {
- e.printStackTrace();
- }
- try {
- FileOutputStream oFile = new FileOutputStream(file, true);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- }
-
- fileStatus = new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- fileStatusWithOutDirectoryPermission = new FileStatus(12L, false, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- fileName = file.getAbsolutePath();
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- }
-
- @AfterClass
- static public void cleanUp() {
- file.delete();
- }
-
- @Test
- public void testRenameForceForException() throws IOException {
-
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- viewFSCarbonFile.renameForce(fileName);
- }
-
- @Test
- public void testListFilesWithOutDirectoryPermission() {
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatusWithOutDirectoryPermission);
- assertTrue(viewFSCarbonFile.listFiles() == null);
- }
-
- @Test
- public void testConstructorWithFilePath() {
- viewFSCarbonFile = new ViewFSCarbonFile(file.getAbsolutePath());
- assertTrue(viewFSCarbonFile instanceof ViewFSCarbonFile);
- }
-
- @Test
- public void testListFilesForNullListStatus() {
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatusWithOutDirectoryPermission);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new ViewFileSystem();
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- return null;
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public boolean delete(Path var1, boolean var2) throws IOException {
-
- return true;
- }
-
- };
- //public boolean delete(Path var1, boolean var2) throws IOException;
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- assertTrue(viewFSCarbonFile.listFiles().length == 0);
- }
-
- @Test
- public void testListDirectory() {
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new ViewFileSystem();
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
-
- assertTrue(viewFSCarbonFile.listFiles().length == 1);
- }
-
- @Test
- public void testListFilesForException() throws IOException {
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatusWithOutDirectoryPermission);
-
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(file.getAbsolutePath());
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- throw new IOException();
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- throw new IOException();
- }
-
- };
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- viewFSCarbonFile.listFiles();
- }
-
- @Test
- public void testListFilesWithCarbonFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return true;
- }
- };
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- assertTrue(viewFSCarbonFile.listFiles(carbonFileFilter).length == 1);
- }
-
- @Test
- public void testlistFilesWithoutFilter() {
- CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
-
- @Override
- public boolean accept(CarbonFile file) {
- return false;
- }
- };
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new ViewFileSystem();
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public FileStatus[] listStatus(Path var1) throws IOException {
-
- FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
- return fileStatus;
- }
-
- };
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- assertTrue(viewFSCarbonFile.listFiles(carbonFileFilter).length == 0);
- }
-
- @Test
- public void testGetParentFIle() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new DistributedFileSystem();
- }
-
- };
- new MockUp<Path>() {
- @Mock
- public Path getParent() {
- return new Path(file.getAbsolutePath()
- );
- }
-
- };
- new MockUp<FileStatus>() {
- @Mock
- public Path getPath() {
- return new Path(file.getAbsolutePath());
- }
-
- };
- new MockUp<DistributedFileSystem>() {
- @Mock
- public FileStatus getFileStatus(Path f) throws IOException {
-
- return new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
- }
-
- };
-
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- assertFalse(viewFSCarbonFile.getParentFile().equals(null));
- }
-
- @Test
- public void testForNonDisributedSystem() {
- viewFSCarbonFile = new ViewFSCarbonFile(fileStatus);
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new WebHdfsFileSystem();
- }
-
- };
- assertFalse(viewFSCarbonFile.renameForce(fileName));
- }
-
- @Test
- public void testrenameForceForViewFileSystem() {
- new MockUp<Path>() {
- @Mock
- public FileSystem getFileSystem(Configuration conf) throws IOException {
- return new ViewFileSystem();
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public boolean delete(Path f, boolean recursive) throws
- IOException {
- return true;
-
- }
-
- };
- new MockUp<ViewFileSystem>() {
- @Mock
- public boolean rename(Path src, Path dst) throws IOException {
- return true;
-
- }
-
- };
-
- assertTrue(viewFSCarbonFile.renameForce(fileName));
-
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/datastorage/store/columnar/ColumnarKeyStoreDataHolderUnitTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/datastorage/store/columnar/ColumnarKeyStoreDataHolderUnitTest.java b/core/src/test/java/org/apache/carbondata/core/datastorage/store/columnar/ColumnarKeyStoreDataHolderUnitTest.java
new file mode 100644
index 0000000..0ce6c1e
--- /dev/null
+++ b/core/src/test/java/org/apache/carbondata/core/datastorage/store/columnar/ColumnarKeyStoreDataHolderUnitTest.java
@@ -0,0 +1,93 @@
+/*
+ * 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.datastorage.store.columnar;
+
+import java.util.List;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+public class ColumnarKeyStoreDataHolderUnitTest {
+
+ private static ColumnarKeyStoreDataHolder columnarKeyStoreDataHolder;
+ private static ColumnarKeyStoreMetadata columnarKeyStoreMetadata;
+
+ @BeforeClass public static void setup() {
+ byte[] keyBlockData = new byte[] { 16, 8, 32, 40, 8, 8, 8 };
+ int eachRowSize = 2;
+ int[] reverseIndex = new int[] { 1, 5, 6, 3, 8 };
+ columnarKeyStoreMetadata = new ColumnarKeyStoreMetadata(eachRowSize);
+ columnarKeyStoreMetadata.setColumnReverseIndex(reverseIndex);
+ columnarKeyStoreDataHolder =
+ new ColumnarKeyStoreDataHolder(keyBlockData, columnarKeyStoreMetadata);
+ }
+
+ @Test public void testGetSurrogateKeyWithNullINGetColumnReverseIndex() {
+ byte[] keyBlockData = new byte[] { 16, 8, 32, 40, 8, 8, 8 };
+ int eachRowSize = 1;
+ ColumnarKeyStoreMetadata columnarKeyStoreMetadata = new ColumnarKeyStoreMetadata(eachRowSize);
+ ColumnarKeyStoreDataHolder columnarKeyStoreDataHolderNew =
+ new ColumnarKeyStoreDataHolder(keyBlockData, columnarKeyStoreMetadata);
+ int columnIndex = 5;
+ int expected_result = 8;
+ int result = columnarKeyStoreDataHolderNew.getSurrogateKey(columnIndex);
+ assertEquals(expected_result, result);
+ }
+
+ @Test public void testGetSurrogateKeyWithNullINGetColumnReverseIndexAndRowSizeTwo() {
+ byte[] keyBlockData = new byte[] { 16, 8, 32, 40, 8, 8, 8 };
+ int eachRowSize = 2;
+ ColumnarKeyStoreMetadata columnarKeyStoreMetadata = new ColumnarKeyStoreMetadata(eachRowSize);
+ ColumnarKeyStoreDataHolder columnarKeyStoreDataHolderNew =
+ new ColumnarKeyStoreDataHolder(keyBlockData, columnarKeyStoreMetadata);
+ int columnIndex = 0;
+ int expected_result = 4104;
+ int result = columnarKeyStoreDataHolderNew.getSurrogateKey(columnIndex);
+ assertEquals(expected_result, result);
+ }
+
+ @Test public void testGetSurrogateKeyWithNotNullINGetColumnReverseIndex() {
+ int columnIndex = 0;
+ int expected_result = 8232;
+ int result = columnarKeyStoreDataHolder.getSurrogateKey(columnIndex);
+ assertEquals(expected_result, result);
+ }
+
+ @Test(expected = ArrayIndexOutOfBoundsException.class)
+ public void testExceptionInGetSurrogateKey() {
+ int columnIndex = 10;
+ int expected_result = 8232;
+ int result = columnarKeyStoreDataHolder.getSurrogateKey(columnIndex);
+ assertEquals(expected_result, result);
+ }
+
+ @Test public void testGetSurrogateKeyWithListOfByteWhileCreatingObject() {
+ byte[] keyBlockData = new byte[] { 32, 64, 32, 40, 64, 8, 8 };
+ List<byte[]> noDictionaryValBasedKeyBlockData = new java.util.ArrayList<>();
+ noDictionaryValBasedKeyBlockData.add(keyBlockData);
+ new ColumnarKeyStoreDataHolder(noDictionaryValBasedKeyBlockData, columnarKeyStoreMetadata);
+ int columnIndex = 0;
+ int expected_result = 8232;
+ int result = columnarKeyStoreDataHolder.getSurrogateKey(columnIndex);
+ assertEquals(expected_result, result);
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/AlluxioCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/AlluxioCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/AlluxioCarbonFileTest.java
new file mode 100644
index 0000000..acd30c9
--- /dev/null
+++ b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/AlluxioCarbonFileTest.java
@@ -0,0 +1,295 @@
+/*
+ * 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.carbon.datastorage.filesystem;
+
+import mockit.Mock;
+import mockit.MockUp;
+import org.apache.carbondata.core.datastorage.store.filesystem.AlluxioCarbonFile;
+import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
+import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Options;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hdfs.DistributedFileSystem;
+import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+public class AlluxioCarbonFileTest {
+
+ private static AlluxioCarbonFile alluxioCarbonFile;
+ private static FileStatus fileStatus;
+ private static FileStatus fileStatusWithOutDirectoryPermission;
+ private static String fileName;
+ private static File file;
+
+
+ @BeforeClass
+ static public void setUp() {
+ file = new File("Test.carbondata");
+ if (!file.exists())
+ try {
+ file.createNewFile();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ try {
+ FileOutputStream oFile = new FileOutputStream(file, true);
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+
+ fileStatus = new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
+ fileStatusWithOutDirectoryPermission = new FileStatus(12L, false, 60, 120l, 180L, new Path(file.getAbsolutePath()));
+ fileName = file.getAbsolutePath();
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ }
+
+ @AfterClass
+ static public void cleanUp() {
+ file.delete();
+ }
+
+ @Test
+ public void testRenameForceForException() throws IOException {
+
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ throw new IOException();
+ }
+
+ };
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ alluxioCarbonFile.renameForce(fileName);
+ }
+
+ @Test
+ public void testListFilesWithOutDirectoryPermission() {
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
+ assertTrue(alluxioCarbonFile.listFiles() == null);
+ }
+
+ @Test
+ public void testConstructorWithFilePath() {
+ alluxioCarbonFile = new AlluxioCarbonFile(file.getAbsolutePath());
+ assertTrue(alluxioCarbonFile instanceof AlluxioCarbonFile);
+ }
+
+ @Test
+ public void testListFilesForNullListStatus() {
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ return null;
+ }
+
+ };
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ assertTrue(alluxioCarbonFile.listFiles().length == 0);
+ }
+
+ @Test
+ public void testListDirectory() {
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
+ return fileStatus;
+ }
+
+ };
+
+ assertTrue(alluxioCarbonFile.listFiles().length == 1);
+ }
+
+ @Test
+ public void testListFilesForException() throws IOException {
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatusWithOutDirectoryPermission);
+
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(file.getAbsolutePath());
+ }
+
+ };
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ throw new IOException();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ throw new IOException();
+ }
+
+ };
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ alluxioCarbonFile.listFiles();
+ }
+
+ @Test
+ public void testListFilesWithCarbonFilter() {
+ CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
+
+ @Override
+ public boolean accept(CarbonFile file) {
+ return true;
+ }
+ };
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ assertTrue(alluxioCarbonFile.listFiles(carbonFileFilter).length == 1);
+ }
+
+ @Test
+ public void testlistFilesWithoutFilter() {
+ CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
+
+ @Override
+ public boolean accept(CarbonFile file) {
+ return false;
+ }
+ };
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
+ return fileStatus;
+ }
+
+ };
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ assertTrue(alluxioCarbonFile.listFiles(carbonFileFilter).length == 0);
+ }
+
+ @Test
+ public void testGetParentFile() {
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<Path>() {
+ @Mock
+ public Path getParent() {
+ return new Path(file.getAbsolutePath()
+ );
+ }
+
+ };
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(file.getAbsolutePath());
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus getFileStatus(Path path) throws IOException {
+
+ return new FileStatus(12L, true, 60, 120l, 180L, new Path(file.getAbsolutePath()));
+ }
+
+ };
+
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ assertFalse(alluxioCarbonFile.getParentFile().equals(null));
+ }
+
+ @Test
+ public void testForNonDisributedSystem() {
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new WebHdfsFileSystem();
+ }
+
+ };
+ assertFalse(alluxioCarbonFile.renameForce(fileName));
+ }
+
+ @Test
+ public void testrenameForceForDisributedSystem() {
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public void rename(Path src, Path dst, final Options.Rename... options) throws IOException {
+
+ }
+
+ };
+
+ alluxioCarbonFile = new AlluxioCarbonFile(fileStatus);
+ assertTrue(alluxioCarbonFile.renameForce(fileName));
+
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/4afef29b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/HDFSCarbonFileTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/HDFSCarbonFileTest.java b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/HDFSCarbonFileTest.java
new file mode 100644
index 0000000..c55c600
--- /dev/null
+++ b/core/src/test/java/org/apache/carbondata/core/datastorage/store/filesystem/HDFSCarbonFileTest.java
@@ -0,0 +1,402 @@
+/*
+ * 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.carbon.datastorage.filesystem;
+
+import mockit.Mock;
+import mockit.MockUp;
+import org.apache.carbondata.common.logging.LogService;
+import org.apache.carbondata.common.logging.LogServiceFactory;
+import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFile;
+import org.apache.carbondata.core.datastorage.store.filesystem.CarbonFileFilter;
+import org.apache.carbondata.core.datastorage.store.filesystem.HDFSCarbonFile;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Options;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hdfs.DistributedFileSystem;
+import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
+import org.apache.hadoop.util.Progressable;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.io.BufferedWriter;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+
+public class HDFSCarbonFileTest {
+
+ private static final LogService LOGGER =
+ LogServiceFactory.getLogService(HDFSCarbonFile.class.getName());
+ private static HDFSCarbonFile hdfsCarbonFile;
+ private static FileStatus fileStatus = null;
+ private static FileStatus fileStatusWithOutDirectoryPermission;
+ private static String fileName = null;
+ private static FileSystem fs = null;
+ private static Path pt;
+
+ @BeforeClass
+ static public void setUp() throws IOException {
+ Configuration config = new Configuration();
+//adding local hadoop configuration
+ config.addResource(new Path("core-site.xml"));
+ config.addResource(new Path("hdfs-site.xml"));
+ fileName = "Test.carbondata"; //this path is HDFS path
+ pt = new Path(fileName);
+ fs = FileSystem.get(new Configuration(config));
+ fs.create(pt);
+ if (fs.exists(pt)) {
+ OutputStream os = fs.create(pt,
+ new Progressable() {
+ public void progress() {
+ LOGGER.info("Started Writing to File===");
+ }
+ });
+ BufferedWriter br = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));
+ br.write("Hello World");
+ br.close();
+ fs.close();
+
+ fileStatus = new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName));
+ fileStatusWithOutDirectoryPermission = new FileStatus(12L, false, 60, 120l, 180L, new Path(fileName));
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+
+ }
+ }
+
+ @AfterClass
+ static public void cleanUp() {
+ try {
+ fs.delete(pt, true);
+ } catch (IOException e) {
+ LOGGER.error("Exception Occured" + e.getMessage());
+ }
+ }
+
+ @Test
+ public void testRenameForceForException() throws IOException {
+
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ throw new IOException();
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ hdfsCarbonFile.renameForce(fileName);
+ }
+
+ @Test
+ public void testListFilesWithOutDirectoryPermission() {
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatusWithOutDirectoryPermission);
+ new MockUp<FileStatus>() {
+ @Mock
+ public boolean isDirectory() {
+ return false;
+ }
+
+ };
+
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ assertEquals(hdfsCarbonFile.listFiles(), null);
+ }
+
+ @Test
+ public void testConstructorWithFilePath() {
+ hdfsCarbonFile = new HDFSCarbonFile(fileName);
+ assertTrue(hdfsCarbonFile instanceof HDFSCarbonFile);
+ }
+
+ @Test
+ public void testListFilesForNullListStatus() {
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ return null;
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertEquals(hdfsCarbonFile.listFiles().length, 0);
+ }
+
+ @Test
+ public void testListDirectory() {
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
+ return fileStatus;
+ }
+
+ };
+
+ assertEquals(hdfsCarbonFile.listFiles().length, 1);
+ }
+
+ @Test
+ public void testListFilesForException() throws IOException {
+ new HDFSCarbonFile(fileStatusWithOutDirectoryPermission);
+
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ throw new IOException();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ throw new IOException();
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ hdfsCarbonFile.listFiles();
+ }
+
+ @Test
+ public void testListFilesWithCarbonFilter() {
+ CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
+
+ @Override
+ public boolean accept(CarbonFile file) {
+ return true;
+ }
+ };
+ new MockUp<FileStatus>() {
+ @Mock
+ public boolean isDirectory() {
+ return true;
+ }
+
+ };
+
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ FileStatus fileStatus[] = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
+ return fileStatus;
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertEquals(hdfsCarbonFile.listFiles(carbonFileFilter).length, 1);
+ }
+
+ @Test
+ public void testlistFilesWithoutFilter() {
+ CarbonFileFilter carbonFileFilter = new CarbonFileFilter() {
+
+ @Override
+ public boolean accept(CarbonFile file) {
+ return false;
+ }
+ };
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus[] listStatus(Path var1) throws IOException {
+
+ FileStatus[] fileStatus = new FileStatus[]{new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName))};
+ return fileStatus;
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertEquals(hdfsCarbonFile.listFiles(carbonFileFilter).length, 0);
+ }
+
+ @Test
+ public void testGetParentFileForNull() {
+
+ new MockUp<Path>() {
+ @Mock
+ public Path getParent() {
+ return null;
+ }
+
+ };
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertEquals(hdfsCarbonFile.getParentFile(), null);
+ }
+
+ @Test
+ public void testGetParentFile() {
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<Path>() {
+ @Mock
+ public Path getParent() {
+ return new Path(fileName);
+ }
+
+ };
+ new MockUp<FileStatus>() {
+ @Mock
+ public Path getPath() {
+ return new Path(fileName);
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public FileStatus getFileStatus(Path file) throws IOException {
+
+ return new FileStatus(12L, true, 60, 120l, 180L, new Path(fileName));
+ }
+
+ };
+
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertTrue(hdfsCarbonFile.getParentFile() instanceof CarbonFile);
+ }
+
+ @Test
+ public void testForNonDisributedSystem() {
+ new HDFSCarbonFile(fileStatus);
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new WebHdfsFileSystem();
+ }
+
+ };
+ assertEquals(hdfsCarbonFile.renameForce(fileName), false);
+ }
+
+ @Test
+ public void testrenameForceForDisributedSystem() {
+ new MockUp<Path>() {
+ @Mock
+ public FileSystem getFileSystem(Configuration conf) throws IOException {
+ return new DistributedFileSystem();
+ }
+
+ };
+ new MockUp<DistributedFileSystem>() {
+ @Mock
+ public void rename(Path src, Path dst, final Options.Rename... options) throws IOException {
+
+ }
+
+ };
+ hdfsCarbonFile = new HDFSCarbonFile(fileStatus);
+ assertEquals(hdfsCarbonFile.renameForce(fileName), true);
+
+ }
+}
+