# Minors in IGFS.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/83e02dcf Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/83e02dcf Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/83e02dcf Branch: refs/heads/ignite-368 Commit: 83e02dcfa422e8f91a281b0c29ff9843cec66226 Parents: 1ef545a Author: vozerov-gridgain <voze...@gridgain.com> Authored: Tue Mar 10 11:28:50 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Tue Mar 10 11:28:50 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/IgniteFileSystem.java | 18 ++++---- .../igfs/IgfsDirectoryNotEmptyException.java | 42 +++++++++++++++++++ .../igfs/IgfsDirectoryNotEmptyException.java | 44 -------------------- .../processors/hadoop/igfs/HadoopIgfsUtils.java | 1 - 4 files changed, 51 insertions(+), 54 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83e02dcf/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java b/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java index d221ae2..51f0e71 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java @@ -80,7 +80,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * * @param path Path to get information for. * @return Summary object. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path is not found. + * @throws IgfsFileNotFoundException If path is not found. * @throws IgniteException If failed. */ public IgfsPathSummary summary(IgfsPath path) throws IgniteException; @@ -91,7 +91,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param path File path to read. * @return File input stream to read data from. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist. + * @throws IgfsFileNotFoundException If path doesn't exist. */ public IgfsInputStream open(IgfsPath path) throws IgniteException; @@ -102,7 +102,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param bufSize Read buffer size (bytes) or {@code zero} to use default value. * @return File input stream to read data from. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist. + * @throws IgfsFileNotFoundException If path doesn't exist. */ public IgfsInputStream open(IgfsPath path, int bufSize) throws IgniteException; @@ -114,7 +114,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param seqReadsBeforePrefetch Amount of sequential reads before prefetch is started. * @return File input stream to read data from. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist. + * @throws IgfsFileNotFoundException If path doesn't exist. */ public IgfsInputStream open(IgfsPath path, int bufSize, int seqReadsBeforePrefetch) throws IgniteException; @@ -168,7 +168,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param create Create file if it doesn't exist yet. * @return File output stream to append data to. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist and create flag is {@code false}. + * @throws IgfsFileNotFoundException If path doesn't exist and create flag is {@code false}. */ public IgfsOutputStream append(IgfsPath path, boolean create) throws IgniteException; @@ -181,7 +181,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param props File properties to set only in case it file was just created. * @return File output stream to append data to. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist and create flag is {@code false}. + * @throws IgfsFileNotFoundException If path doesn't exist and create flag is {@code false}. */ public IgfsOutputStream append(IgfsPath path, int bufSize, boolean create, @Nullable Map<String, String> props) throws IgniteException; @@ -194,7 +194,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param accessTime Optional last access time to set. Value {@code -1} does not update access time. * @param modificationTime Optional last modification time to set. Value {@code -1} does not update * modification time. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If target was not found. + * @throws IgfsFileNotFoundException If target was not found. * @throws IgniteException If error occurred. */ public void setTimes(IgfsPath path, long accessTime, long modificationTime) throws IgniteException; @@ -208,7 +208,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param len Size of data in the file to resolve affinity for. * @return Affinity block locations. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist. + * @throws IgfsFileNotFoundException If path doesn't exist. */ public Collection<IgfsBlockLocation> affinity(IgfsPath path, long start, long len) throws IgniteException; @@ -223,7 +223,7 @@ public interface IgniteFileSystem extends IgniteAsyncSupport { * @param maxLen Maximum length of a single returned block location length. * @return Affinity block locations. * @throws IgniteException In case of error. - * @throws org.apache.ignite.igfs.IgfsFileNotFoundException If path doesn't exist. + * @throws IgfsFileNotFoundException If path doesn't exist. */ public Collection<IgfsBlockLocation> affinity(IgfsPath path, long start, long len, long maxLen) throws IgniteException; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83e02dcf/modules/core/src/main/java/org/apache/ignite/igfs/IgfsDirectoryNotEmptyException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/igfs/IgfsDirectoryNotEmptyException.java b/modules/core/src/main/java/org/apache/ignite/igfs/IgfsDirectoryNotEmptyException.java new file mode 100644 index 0000000..38a7eaf --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/igfs/IgfsDirectoryNotEmptyException.java @@ -0,0 +1,42 @@ +/* + * 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.ignite.igfs; + +/** + * Exception indicating that directory can not be deleted because it is not empty. + */ +public class IgfsDirectoryNotEmptyException extends IgfsException { + /** */ + private static final long serialVersionUID = 0L; + + /** + * @param msg Exception message. + */ + public IgfsDirectoryNotEmptyException(String msg) { + super(msg); + } + + /** + * Creates an instance of IGFS exception caused by nested exception. + * + * @param cause Exception cause. + */ + public IgfsDirectoryNotEmptyException(Throwable cause) { + super(cause); + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83e02dcf/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryNotEmptyException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryNotEmptyException.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryNotEmptyException.java deleted file mode 100644 index 48b9b39..0000000 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDirectoryNotEmptyException.java +++ /dev/null @@ -1,44 +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.ignite.internal.processors.igfs; - -import org.apache.ignite.igfs.*; - -/** - * Exception indicating that directory can not be deleted because it is not empty. - */ -public class IgfsDirectoryNotEmptyException extends IgfsException { - /** */ - private static final long serialVersionUID = 0L; - - /** - * @param msg Exception message. - */ - public IgfsDirectoryNotEmptyException(String msg) { - super(msg); - } - - /** - * Creates an instance of IGFS exception caused by nested exception. - * - * @param cause Exception cause. - */ - public IgfsDirectoryNotEmptyException(Throwable cause) { - super(cause); - } -} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/83e02dcf/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsUtils.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsUtils.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsUtils.java index e30a4ec..3fe8124 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsUtils.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsUtils.java @@ -21,7 +21,6 @@ import org.apache.hadoop.conf.*; import org.apache.hadoop.fs.*; import org.apache.ignite.*; import org.apache.ignite.igfs.*; -import org.apache.ignite.internal.processors.igfs.*; import org.jetbrains.annotations.*; import java.io.*;