IGNITE-2206: intermadiate for review.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4553562b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4553562b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4553562b Branch: refs/heads/ignite-2206 Commit: 4553562b99b345b086ed339b47b6ae8b95f08c0c Parents: d485969 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Tue Dec 22 18:17:56 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Tue Dec 22 18:17:56 2015 +0300 ---------------------------------------------------------------------- .../ignite/igfs/HadoopFileSystemFactory.java | 29 -------------------- .../processors/hadoop/PayloadAware.java | 9 ++++++ .../hadoop/fs/HadoopFileSystemFactory.java | 29 ++++++++++++++++++++ 3 files changed, 38 insertions(+), 29 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/4553562b/modules/core/src/main/java/org/apache/ignite/igfs/HadoopFileSystemFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/igfs/HadoopFileSystemFactory.java b/modules/core/src/main/java/org/apache/ignite/igfs/HadoopFileSystemFactory.java deleted file mode 100644 index 6720da9..0000000 --- a/modules/core/src/main/java/org/apache/ignite/igfs/HadoopFileSystemFactory.java +++ /dev/null @@ -1,29 +0,0 @@ -package org.apache.ignite.igfs; - -import java.io.IOException; -import java.io.Serializable; - -/** - * This factory is {@link Serializable} because it should be transferable over the network. - * - * @param <T> The type - */ -public interface HadoopFileSystemFactory <T> extends Serializable { - /** - * Gets the file system, possibly creating it or taking a cached instance. - * All the other data needed for the file system creation are expected to be contained - * in this object instance. - * - * @param userName The user name - * @return The file system. - * @throws IOException On error. - */ - public T get(String userName) throws IOException; - -// /** -// * Getter for the file system URI. -// * -// * @return The file system URI. -// */ -// public URI uri(); -} http://git-wip-us.apache.org/repos/asf/ignite/blob/4553562b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/PayloadAware.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/PayloadAware.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/PayloadAware.java new file mode 100644 index 0000000..24a8545 --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/hadoop/PayloadAware.java @@ -0,0 +1,9 @@ +package org.apache.ignite.internal.processors.hadoop; + +/** + * Created by ivan on 22.12.15. + */ +public interface PayloadAware <P> { + + public P getPayload(); +} http://git-wip-us.apache.org/repos/asf/ignite/blob/4553562b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/HadoopFileSystemFactory.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/HadoopFileSystemFactory.java b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/HadoopFileSystemFactory.java new file mode 100644 index 0000000..5337f12 --- /dev/null +++ b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/HadoopFileSystemFactory.java @@ -0,0 +1,29 @@ +package org.apache.ignite.hadoop.fs; + +import java.io.IOException; +import java.io.Serializable; + +/** + * This factory is {@link Serializable} because it should be transferable over the network. + * + * @param <T> The type + */ +public interface HadoopFileSystemFactory <T> extends Serializable { + /** + * Gets the file system, possibly creating it or taking a cached instance. + * All the other data needed for the file system creation are expected to be contained + * in this object instance. + * + * @param userName The user name + * @return The file system. + * @throws IOException On error. + */ + public T get(String userName) throws IOException; + +// /** +// * Getter for the file system URI. +// * +// * @return The file system URI. +// */ +// public URI uri(); +}
