You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/12/23 11:40:47 UTC
[05/12] ignite git commit: IGNITE-2206: intermadiate for review.
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 <iv...@gridgain.com>
Authored: Tue Dec 22 18:17:56 2015 +0300
Committer: iveselovskiy <iv...@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();
+}