ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [05/12] ignite git commit: IGNITE-2206: intermadiate for review.
Date Wed, 23 Dec 2015 10:40:47 GMT
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 <iveselovskiy@gridgain.com>
Authored: Tue Dec 22 18:17:56 2015 +0300
Committer: iveselovskiy <iveselovskiy@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();
+}


Mime
View raw message