ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [1/3] incubator-ignite git commit: # IGNITE-226: WIP.
Date Fri, 13 Feb 2015 11:24:52 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-226 4d8e3edb4 -> 4daa02139


# IGNITE-226: WIP.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f9facce7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f9facce7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f9facce7

Branch: refs/heads/ignite-226
Commit: f9facce755e4bb9ea13628b6b5ef2aa3af8e943f
Parents: 4d8e3ed
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Fri Feb 13 14:18:45 2015 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Fri Feb 13 14:18:45 2015 +0300

----------------------------------------------------------------------
 .../visor/ggfs/VisorIgfsFormatTask.java         |  10 +-
 .../visor/ggfs/VisorIgfsProfilerClearTask.java  |  10 +-
 .../visor/ggfs/VisorIgfsProfilerTask.java       |  40 +-
 .../visor/ggfs/VisorIgfsResetMetricsTask.java   |  10 +-
 .../visor/ggfs/VisorIgfsSamplingStateTask.java  |  10 +-
 .../visor/node/VisorGgfsConfiguration.java      | 574 -------------------
 .../visor/node/VisorGridConfiguration.java      |   8 +-
 .../visor/node/VisorIgfsConfiguration.java      | 574 +++++++++++++++++++
 8 files changed, 618 insertions(+), 618 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsFormatTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsFormatTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsFormatTask.java
index 47227a7..a20f986 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsFormatTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsFormatTask.java
@@ -31,14 +31,14 @@ public class VisorIgfsFormatTask extends VisorOneNodeTask<String, Void> {
     private static final long serialVersionUID = 0L;
 
     /** {@inheritDoc} */
-    @Override protected VisorGgfsFormatJob job(String arg) {
-        return new VisorGgfsFormatJob(arg, debug);
+    @Override protected VisorIgfsFormatJob job(String arg) {
+        return new VisorIgfsFormatJob(arg, debug);
     }
 
     /**
      * Job that format GGFS.
      */
-    private static class VisorGgfsFormatJob extends VisorJob<String, Void> {
+    private static class VisorIgfsFormatJob extends VisorJob<String, Void> {
         /** */
         private static final long serialVersionUID = 0L;
 
@@ -46,7 +46,7 @@ public class VisorIgfsFormatTask extends VisorOneNodeTask<String, Void> {
          * @param arg GGFS name to format.
          * @param debug Debug flag.
          */
-        private VisorGgfsFormatJob(String arg, boolean debug) {
+        private VisorIgfsFormatJob(String arg, boolean debug) {
             super(arg, debug);
         }
 
@@ -64,7 +64,7 @@ public class VisorIgfsFormatTask extends VisorOneNodeTask<String, Void> {
 
         /** {@inheritDoc} */
         @Override public String toString() {
-            return S.toString(VisorGgfsFormatJob.class, this);
+            return S.toString(VisorIgfsFormatJob.class, this);
         }
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerClearTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerClearTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerClearTask.java
index cea0782..4b3f73b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerClearTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerClearTask.java
@@ -39,7 +39,7 @@ public class VisorIgfsProfilerClearTask extends VisorOneNodeTask<String, IgniteB
     /**
      * Job to clear profiler logs.
      */
-    private static class VisorGgfsProfilerClearJob extends VisorJob<String, IgniteBiTuple<Integer, Integer>> {
+    private static class VisorIgfsProfilerClearJob extends VisorJob<String, IgniteBiTuple<Integer, Integer>> {
         /** */
         private static final long serialVersionUID = 0L;
 
@@ -49,7 +49,7 @@ public class VisorIgfsProfilerClearTask extends VisorOneNodeTask<String, IgniteB
          * @param arg Job argument.
          * @param debug Debug flag.
          */
-        private VisorGgfsProfilerClearJob(String arg, boolean debug) {
+        private VisorIgfsProfilerClearJob(String arg, boolean debug) {
             super(arg, debug);
         }
 
@@ -103,12 +103,12 @@ public class VisorIgfsProfilerClearTask extends VisorOneNodeTask<String, IgniteB
 
         /** {@inheritDoc} */
         @Override public String toString() {
-            return S.toString(VisorGgfsProfilerClearJob.class, this);
+            return S.toString(VisorIgfsProfilerClearJob.class, this);
         }
     }
 
     /** {@inheritDoc} */
-    @Override protected VisorGgfsProfilerClearJob job(String arg) {
-        return new VisorGgfsProfilerClearJob(arg, debug);
+    @Override protected VisorIgfsProfilerClearJob job(String arg) {
+        return new VisorIgfsProfilerClearJob(arg, debug);
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerTask.java
index 62ddecf..a92fb0c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsProfilerTask.java
@@ -43,7 +43,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
     /**
      * Holder class for parsed data.
      */
-    private static class VisorGgfsProfilerParsedLine {
+    private static class VisorIgfsProfilerParsedLine {
         /** Timestamp. */
         private final long ts;
 
@@ -80,7 +80,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
         /**
          * Create holder for log line.
          */
-        private VisorGgfsProfilerParsedLine(
+        private VisorIgfsProfilerParsedLine(
             long ts,
             int entryType,
             String path,
@@ -110,9 +110,9 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
     /**
      * Comparator to sort parsed log lines by timestamp.
      */
-    private static final Comparator<VisorGgfsProfilerParsedLine> PARSED_LINE_BY_TS_COMPARATOR =
-        new Comparator<VisorGgfsProfilerParsedLine>() {
-            @Override public int compare(VisorGgfsProfilerParsedLine a, VisorGgfsProfilerParsedLine b) {
+    private static final Comparator<VisorIgfsProfilerParsedLine> PARSED_LINE_BY_TS_COMPARATOR =
+        new Comparator<VisorIgfsProfilerParsedLine>() {
+            @Override public int compare(VisorIgfsProfilerParsedLine a, VisorIgfsProfilerParsedLine b) {
                 return a.ts < b.ts ? -1
                     : a.ts > b.ts ? 1
                     : 0;
@@ -122,7 +122,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
     /**
      * Job that do actual profiler work.
      */
-    private static class VisorGgfsProfilerJob extends VisorJob<String, Collection<VisorIgfsProfilerEntry>> {
+    private static class VisorIgfsProfilerJob extends VisorJob<String, Collection<VisorIgfsProfilerEntry>> {
         /** */
         private static final long serialVersionUID = 0L;
 
@@ -155,7 +155,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
          * @param arg GGFS name.
          * @param debug Debug flag.
          */
-        private VisorGgfsProfilerJob(String arg, boolean debug) {
+        private VisorIgfsProfilerJob(String arg, boolean debug) {
             super(arg, debug);
         }
 
@@ -266,7 +266,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
          * @param s Line with text to parse.
          * @return Parsed data.
          */
-        private VisorGgfsProfilerParsedLine parseLine(String s) {
+        private VisorIgfsProfilerParsedLine parseLine(String s) {
             String[] ss = s.split(DELIM_FIELD);
 
             long streamId = parseLong(ss, LOG_COL_STREAM_ID, -1);
@@ -276,7 +276,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
 
                 // Parse only needed types.
                 if (LOG_TYPES.contains(entryType))
-                    return new VisorGgfsProfilerParsedLine(
+                    return new VisorIgfsProfilerParsedLine(
                         parseLong(ss, LOG_COL_TIMESTAMP, 0),
                         entryType,
                         parseString(ss, LOG_COL_PATH),
@@ -297,7 +297,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
         /**
          * Aggregate information from parsed lines grouped by {@code streamId}.
          */
-        private VisorIgfsProfilerEntry aggregateParsedLines(List<VisorGgfsProfilerParsedLine> lines) {
+        private VisorIgfsProfilerEntry aggregateParsedLines(List<VisorIgfsProfilerParsedLine> lines) {
             VisorIgfsProfilerUniformityCounters counters = new VisorIgfsProfilerUniformityCounters();
 
             Collections.sort(lines, PARSED_LINE_BY_TS_COMPARATOR);
@@ -313,7 +313,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
             long userWriteTime = 0;
             IgfsMode mode = null;
 
-            for (VisorGgfsProfilerParsedLine line : lines) {
+            for (VisorIgfsProfilerParsedLine line : lines) {
                 if (!line.path.isEmpty())
                     path = line.path;
 
@@ -389,7 +389,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
          * @throws IOException if failed to read log file.
          */
         private Collection<VisorIgfsProfilerEntry> parseFile(Path p) throws IOException {
-            Collection<VisorGgfsProfilerParsedLine> parsedLines = new ArrayList<>(512);
+            Collection<VisorIgfsProfilerParsedLine> parsedLines = new ArrayList<>(512);
 
             try (BufferedReader br = Files.newBufferedReader(p, Charset.forName("UTF-8"))) {
                 String line = br.readLine(); // Skip first line with columns header.
@@ -401,7 +401,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
 
                         while (line != null) {
                             try {
-                                VisorGgfsProfilerParsedLine ln = parseLine(line);
+                                VisorIgfsProfilerParsedLine ln = parseLine(line);
 
                                 if (ln != null)
                                     parsedLines.add(ln);
@@ -416,10 +416,10 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
             }
 
             // Group parsed lines by streamId.
-            Map<Long, List<VisorGgfsProfilerParsedLine>> byStreamId = new HashMap<>();
+            Map<Long, List<VisorIgfsProfilerParsedLine>> byStreamId = new HashMap<>();
 
-            for (VisorGgfsProfilerParsedLine line: parsedLines) {
-                List<VisorGgfsProfilerParsedLine> grp = byStreamId.get(line.streamId);
+            for (VisorIgfsProfilerParsedLine line: parsedLines) {
+                List<VisorIgfsProfilerParsedLine> grp = byStreamId.get(line.streamId);
 
                 if (grp == null) {
                     grp = new ArrayList<>();
@@ -433,7 +433,7 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
             // Aggregate each group.
             Collection<VisorIgfsProfilerEntry> entries = new ArrayList<>(byStreamId.size());
 
-            for (List<VisorGgfsProfilerParsedLine> lines : byStreamId.values()) {
+            for (List<VisorIgfsProfilerParsedLine> lines : byStreamId.values()) {
                 VisorIgfsProfilerEntry entry = aggregateParsedLines(lines);
 
                 if (entry != null)
@@ -496,12 +496,12 @@ public class VisorIgfsProfilerTask extends VisorOneNodeTask<String, Collection<V
 
         /** {@inheritDoc} */
         @Override public String toString() {
-            return S.toString(VisorGgfsProfilerJob.class, this);
+            return S.toString(VisorIgfsProfilerJob.class, this);
         }
     }
 
     /** {@inheritDoc} */
-    @Override protected VisorGgfsProfilerJob job(String arg) {
-        return new VisorGgfsProfilerJob(arg, debug);
+    @Override protected VisorIgfsProfilerJob job(String arg) {
+        return new VisorIgfsProfilerJob(arg, debug);
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsResetMetricsTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsResetMetricsTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsResetMetricsTask.java
index 71c6cca..0cd5b4d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsResetMetricsTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsResetMetricsTask.java
@@ -33,14 +33,14 @@ public class VisorIgfsResetMetricsTask extends VisorOneNodeTask<Set<String>, Voi
     private static final long serialVersionUID = 0L;
 
     /** {@inheritDoc} */
-    @Override protected VisorGgfsResetMetricsJob job(Set<String> arg) {
-        return new VisorGgfsResetMetricsJob(arg, debug);
+    @Override protected VisorIgfsResetMetricsJob job(Set<String> arg) {
+        return new VisorIgfsResetMetricsJob(arg, debug);
     }
 
     /**
      * Job that reset GGFS metrics.
      */
-    private static class VisorGgfsResetMetricsJob extends VisorJob<Set<String>, Void> {
+    private static class VisorIgfsResetMetricsJob extends VisorJob<Set<String>, Void> {
         /** */
         private static final long serialVersionUID = 0L;
 
@@ -48,7 +48,7 @@ public class VisorIgfsResetMetricsTask extends VisorOneNodeTask<Set<String>, Voi
          * @param arg GGFS names.
          * @param debug Debug flag.
          */
-        private VisorGgfsResetMetricsJob(Set<String> arg, boolean debug) {
+        private VisorIgfsResetMetricsJob(Set<String> arg, boolean debug) {
             super(arg, debug);
         }
 
@@ -67,7 +67,7 @@ public class VisorIgfsResetMetricsTask extends VisorOneNodeTask<Set<String>, Voi
 
         /** {@inheritDoc} */
         @Override public String toString() {
-            return S.toString(VisorGgfsResetMetricsJob.class, this);
+            return S.toString(VisorIgfsResetMetricsJob.class, this);
         }
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsSamplingStateTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsSamplingStateTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsSamplingStateTask.java
index 131ce4d..d855ead 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsSamplingStateTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/ggfs/VisorIgfsSamplingStateTask.java
@@ -35,7 +35,7 @@ public class VisorIgfsSamplingStateTask extends VisorOneNodeTask<IgniteBiTuple<S
     /**
      * Job that perform parsing of GGFS profiler logs.
      */
-    private static class VisorGgfsSamplingStateJob extends VisorJob<IgniteBiTuple<String, Boolean>, Void> {
+    private static class VisorIgfsSamplingStateJob extends VisorJob<IgniteBiTuple<String, Boolean>, Void> {
         /** */
         private static final long serialVersionUID = 0L;
 
@@ -45,7 +45,7 @@ public class VisorIgfsSamplingStateTask extends VisorOneNodeTask<IgniteBiTuple<S
          * @param arg Job argument.
          * @param debug Debug flag.
          */
-        public VisorGgfsSamplingStateJob(IgniteBiTuple<String, Boolean> arg, boolean debug) {
+        public VisorIgfsSamplingStateJob(IgniteBiTuple<String, Boolean> arg, boolean debug) {
             super(arg, debug);
         }
 
@@ -66,12 +66,12 @@ public class VisorIgfsSamplingStateTask extends VisorOneNodeTask<IgniteBiTuple<S
 
         /** {@inheritDoc} */
         @Override public String toString() {
-            return S.toString(VisorGgfsSamplingStateJob.class, this);
+            return S.toString(VisorIgfsSamplingStateJob.class, this);
         }
     }
 
     /** {@inheritDoc} */
-    @Override protected VisorGgfsSamplingStateJob job(IgniteBiTuple<String, Boolean> arg) {
-        return new VisorGgfsSamplingStateJob(arg, debug);
+    @Override protected VisorIgfsSamplingStateJob job(IgniteBiTuple<String, Boolean> arg) {
+        return new VisorIgfsSamplingStateJob(arg, debug);
     }
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGgfsConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGgfsConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGgfsConfiguration.java
deleted file mode 100644
index 321f2b5..0000000
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGgfsConfiguration.java
+++ /dev/null
@@ -1,574 +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.visor.node;
-
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.ignitefs.*;
-import org.apache.ignite.internal.util.typedef.internal.*;
-import org.jetbrains.annotations.*;
-
-import java.io.*;
-import java.util.*;
-
-import static org.apache.ignite.internal.visor.util.VisorTaskUtils.*;
-
-/**
- * Data transfer object for GGFS configuration properties.
- */
-public class VisorGgfsConfiguration implements Serializable {
-    /** Property name for path to Hadoop configuration. */
-    public static final String SECONDARY_FS_CONFIG_PATH = "SECONDARY_FS_CONFIG_PATH";
-
-    /** Property name for URI of file system. */
-    public static final String SECONDARY_FS_URI = "SECONDARY_FS_URI";
-
-    /** */
-    private static final long serialVersionUID = 0L;
-
-    /** GGFS instance name. */
-    private String name;
-
-    /** Cache name to store GGFS meta information. */
-    private String metaCacheName;
-
-    /** Cache name to store GGFS data. */
-    private String dataCacheName;
-
-    /** File's data block size. */
-    private int blockSize;
-
-    /** Number of pre-fetched blocks if specific file's chunk is requested. */
-    private int prefetchBlocks;
-
-    /** Read/write buffer size for GGFS stream operations in bytes. */
-    private int streamBufferSize;
-
-    /** Number of file blocks buffered on local node before sending batch to remote node. */
-    private int perNodeBatchSize;
-
-    /** Number of batches that can be concurrently sent to remote node. */
-    private int perNodeParallelBatchCount;
-
-    /** URI of the secondary Hadoop file system. */
-    private String secondaryHadoopFileSystemUri;
-
-    /** Path for the secondary hadoop file system config. */
-    private String secondaryHadoopFileSystemConfigPath;
-
-    /** GGFS instance mode. */
-    private IgfsMode defaultMode;
-
-    /** Map of paths to GGFS modes. */
-    private Map<String, IgfsMode> pathModes;
-
-    /** Dual mode PUT operations executor service. */
-    private String dualModePutExecutorService;
-
-    /** Dual mode PUT operations executor service shutdown flag. */
-    private boolean dualModePutExecutorServiceShutdown;
-
-    /** Maximum amount of data in pending puts. */
-    private long dualModeMaxPendingPutsSize;
-
-    /** Maximum range length. */
-    private long maxTaskRangeLength;
-
-    /** Fragmentizer concurrent files. */
-    private int fragmentizerConcurrentFiles;
-
-    /** Fragmentizer local writes ratio. */
-    private float fragmentizerLocWritesRatio;
-
-    /** Fragmentizer enabled flag. */
-    private boolean fragmentizerEnabled;
-
-    /** Fragmentizer throttling block length. */
-    private long fragmentizerThrottlingBlockLen;
-
-    /** Fragmentizer throttling delay. */
-    private long fragmentizerThrottlingDelay;
-
-    /** IPC endpoint config (in JSON format) to publish GGFS over. */
-    private String ipcEndpointCfg;
-
-    /** IPC endpoint enabled flag. */
-    private boolean ipcEndpointEnabled;
-
-    /** Maximum space. */
-    private long maxSpace;
-
-    /** Management port. */
-    private int mgmtPort;
-
-    /** Amount of sequential block reads before prefetch is triggered. */
-    private int seqReadsBeforePrefetch;
-
-    /** Trash purge await timeout. */
-    private long trashPurgeTimeout;
-
-    /**
-     * @param ggfs GGFS configuration.
-     * @return Data transfer object for GGFS configuration properties.
-     */
-    public static VisorGgfsConfiguration from(IgfsConfiguration ggfs) {
-        VisorGgfsConfiguration cfg = new VisorGgfsConfiguration();
-
-        cfg.name(ggfs.getName());
-        cfg.metaCacheName(ggfs.getMetaCacheName());
-        cfg.dataCacheName(ggfs.getDataCacheName());
-        cfg.blockSize(ggfs.getBlockSize());
-        cfg.prefetchBlocks(ggfs.getPrefetchBlocks());
-        cfg.streamBufferSize(ggfs.getStreamBufferSize());
-        cfg.perNodeBatchSize(ggfs.getPerNodeBatchSize());
-        cfg.perNodeParallelBatchCount(ggfs.getPerNodeParallelBatchCount());
-
-        Igfs secFs = ggfs.getSecondaryFileSystem();
-
-        if (secFs != null) {
-            Map<String, String> props = secFs.properties();
-
-            cfg.secondaryHadoopFileSystemUri(props.get(SECONDARY_FS_URI));
-            cfg.secondaryHadoopFileSystemConfigPath(props.get(SECONDARY_FS_CONFIG_PATH));
-        }
-
-        cfg.defaultMode(ggfs.getDefaultMode());
-        cfg.pathModes(ggfs.getPathModes());
-        cfg.dualModePutExecutorService(compactClass(ggfs.getDualModePutExecutorService()));
-        cfg.dualModePutExecutorServiceShutdown(ggfs.getDualModePutExecutorServiceShutdown());
-        cfg.dualModeMaxPendingPutsSize(ggfs.getDualModeMaxPendingPutsSize());
-        cfg.maxTaskRangeLength(ggfs.getMaximumTaskRangeLength());
-        cfg.fragmentizerConcurrentFiles(ggfs.getFragmentizerConcurrentFiles());
-        cfg.fragmentizerLocalWritesRatio(ggfs.getFragmentizerLocalWritesRatio());
-        cfg.fragmentizerEnabled(ggfs.isFragmentizerEnabled());
-        cfg.fragmentizerThrottlingBlockLength(ggfs.getFragmentizerThrottlingBlockLength());
-        cfg.fragmentizerThrottlingDelay(ggfs.getFragmentizerThrottlingDelay());
-
-        Map<String, String> endpointCfg = ggfs.getIpcEndpointConfiguration();
-        cfg.ipcEndpointConfiguration(endpointCfg != null ? endpointCfg.toString() : null);
-
-        cfg.ipcEndpointEnabled(ggfs.isIpcEndpointEnabled());
-        cfg.maxSpace(ggfs.getMaxSpaceSize());
-        cfg.managementPort(ggfs.getManagementPort());
-        cfg.sequenceReadsBeforePrefetch(ggfs.getSequentialReadsBeforePrefetch());
-        cfg.trashPurgeTimeout(ggfs.getTrashPurgeTimeout());
-
-        return cfg;
-    }
-
-    /**
-     * Construct data transfer object for ggfs configurations properties.
-     *
-     * @param ggfss ggfs configurations.
-     * @return ggfs configurations properties.
-     */
-    public static Iterable<VisorGgfsConfiguration> list(IgfsConfiguration[] ggfss) {
-        if (ggfss == null)
-            return Collections.emptyList();
-
-        final Collection<VisorGgfsConfiguration> cfgs = new ArrayList<>(ggfss.length);
-
-        for (IgfsConfiguration ggfs : ggfss)
-            cfgs.add(from(ggfs));
-
-        return cfgs;
-    }
-
-    /**
-     * @return GGFS instance name.
-     */
-    @Nullable public String name() {
-        return name;
-    }
-
-    /**
-     * @param name New gGFS instance name.
-     */
-    public void name(@Nullable String name) {
-        this.name = name;
-    }
-
-    /**
-     * @return Cache name to store GGFS meta information.
-     */
-    @Nullable public String metaCacheName() {
-        return metaCacheName;
-    }
-
-    /**
-     * @param metaCacheName New cache name to store GGFS meta information.
-     */
-    public void metaCacheName(@Nullable String metaCacheName) {
-        this.metaCacheName = metaCacheName;
-    }
-
-    /**
-     * @return Cache name to store GGFS data.
-     */
-    @Nullable public String dataCacheName() {
-        return dataCacheName;
-    }
-
-    /**
-     * @param dataCacheName New cache name to store GGFS data.
-     */
-    public void dataCacheName(@Nullable String dataCacheName) {
-        this.dataCacheName = dataCacheName;
-    }
-
-    /**
-     * @return File's data block size.
-     */
-    public int blockSize() {
-        return blockSize;
-    }
-
-    /**
-     * @param blockSize New file's data block size.
-     */
-    public void blockSize(int blockSize) {
-        this.blockSize = blockSize;
-    }
-
-    /**
-     * @return Number of pre-fetched blocks if specific file's chunk is requested.
-     */
-    public int prefetchBlocks() {
-        return prefetchBlocks;
-    }
-
-    /**
-     * @param prefetchBlocks New number of pre-fetched blocks if specific file's chunk is requested.
-     */
-    public void prefetchBlocks(int prefetchBlocks) {
-        this.prefetchBlocks = prefetchBlocks;
-    }
-
-    /**
-     * @return Read/write buffer size for GGFS stream operations in bytes.
-     */
-    public int streamBufferSize() {
-        return streamBufferSize;
-    }
-
-    /**
-     * @param streamBufSize New read/write buffer size for GGFS stream operations in bytes.
-     */
-    public void streamBufferSize(int streamBufSize) {
-        streamBufferSize = streamBufSize;
-    }
-
-    /**
-     * @return Number of file blocks buffered on local node before sending batch to remote node.
-     */
-    public int perNodeBatchSize() {
-        return perNodeBatchSize;
-    }
-
-    /**
-     * @param perNodeBatchSize New number of file blocks buffered on local node before sending batch to remote node.
-     */
-    public void perNodeBatchSize(int perNodeBatchSize) {
-        this.perNodeBatchSize = perNodeBatchSize;
-    }
-
-    /**
-     * @return Number of batches that can be concurrently sent to remote node.
-     */
-    public int perNodeParallelBatchCount() {
-        return perNodeParallelBatchCount;
-    }
-
-    /**
-     * @param perNodeParallelBatchCnt New number of batches that can be concurrently sent to remote node.
-     */
-    public void perNodeParallelBatchCount(int perNodeParallelBatchCnt) {
-        perNodeParallelBatchCount = perNodeParallelBatchCnt;
-    }
-
-    /**
-     * @return URI of the secondary Hadoop file system.
-     */
-    @Nullable public String secondaryHadoopFileSystemUri() {
-        return secondaryHadoopFileSystemUri;
-    }
-
-    /**
-     * @param secondaryHadoopFileSysUri New URI of the secondary Hadoop file system.
-     */
-    public void secondaryHadoopFileSystemUri(@Nullable String secondaryHadoopFileSysUri) {
-        secondaryHadoopFileSystemUri = secondaryHadoopFileSysUri;
-    }
-
-    /**
-     * @return Path for the secondary hadoop file system config.
-     */
-    @Nullable public String secondaryHadoopFileSystemConfigPath() {
-        return secondaryHadoopFileSystemConfigPath;
-    }
-
-    /**
-     * @param secondaryHadoopFileSysCfgPath New path for the secondary hadoop file system config.
-     */
-    public void secondaryHadoopFileSystemConfigPath(@Nullable String secondaryHadoopFileSysCfgPath) {
-        secondaryHadoopFileSystemConfigPath = secondaryHadoopFileSysCfgPath;
-    }
-
-    /**
-     * @return GGFS instance mode.
-     */
-    public IgfsMode defaultMode() {
-        return defaultMode;
-    }
-
-    /**
-     * @param dfltMode New gGFS instance mode.
-     */
-    public void defaultMode(IgfsMode dfltMode) {
-        defaultMode = dfltMode;
-    }
-
-    /**
-     * @return Map of paths to GGFS modes.
-     */
-    @Nullable public Map<String, IgfsMode> pathModes() {
-        return pathModes;
-    }
-
-    /**
-     * @param pathModes New map of paths to GGFS modes.
-     */
-    public void pathModes(@Nullable Map<String, IgfsMode> pathModes) {
-        this.pathModes = pathModes;
-    }
-
-    /**
-     * @return Dual mode PUT operations executor service.
-     */
-    public String dualModePutExecutorService() {
-        return dualModePutExecutorService;
-    }
-
-    /**
-     * @param dualModePutExecutorSrvc New dual mode PUT operations executor service.
-     */
-    public void dualModePutExecutorService(String dualModePutExecutorSrvc) {
-        dualModePutExecutorService = dualModePutExecutorSrvc;
-    }
-
-    /**
-     * @return Dual mode PUT operations executor service shutdown flag.
-     */
-    public boolean dualModePutExecutorServiceShutdown() {
-        return dualModePutExecutorServiceShutdown;
-    }
-
-    /**
-     * @param dualModePutExecutorSrvcShutdown New dual mode PUT operations executor service shutdown flag.
-     */
-    public void dualModePutExecutorServiceShutdown(boolean dualModePutExecutorSrvcShutdown) {
-        dualModePutExecutorServiceShutdown = dualModePutExecutorSrvcShutdown;
-    }
-
-    /**
-     * @return Maximum amount of data in pending puts.
-     */
-    public long dualModeMaxPendingPutsSize() {
-        return dualModeMaxPendingPutsSize;
-    }
-
-    /**
-     * @param dualModeMaxPendingPutsSize New maximum amount of data in pending puts.
-     */
-    public void dualModeMaxPendingPutsSize(long dualModeMaxPendingPutsSize) {
-        this.dualModeMaxPendingPutsSize = dualModeMaxPendingPutsSize;
-    }
-
-    /**
-     * @return Maximum range length.
-     */
-    public long maxTaskRangeLength() {
-        return maxTaskRangeLength;
-    }
-
-    /**
-     * @param maxTaskRangeLen New maximum range length.
-     */
-    public void maxTaskRangeLength(long maxTaskRangeLen) {
-        maxTaskRangeLength = maxTaskRangeLen;
-    }
-
-    /**
-     * @return Fragmentizer concurrent files.
-     */
-    public int fragmentizerConcurrentFiles() {
-        return fragmentizerConcurrentFiles;
-    }
-
-    /**
-     * @param fragmentizerConcurrentFiles New fragmentizer concurrent files.
-     */
-    public void fragmentizerConcurrentFiles(int fragmentizerConcurrentFiles) {
-        this.fragmentizerConcurrentFiles = fragmentizerConcurrentFiles;
-    }
-
-    /**
-     * @return Fragmentizer local writes ratio.
-     */
-    public float fragmentizerLocalWritesRatio() {
-        return fragmentizerLocWritesRatio;
-    }
-
-    /**
-     * @param fragmentizerLocWritesRatio New fragmentizer local writes ratio.
-     */
-    public void fragmentizerLocalWritesRatio(float fragmentizerLocWritesRatio) {
-        this.fragmentizerLocWritesRatio = fragmentizerLocWritesRatio;
-    }
-
-    /**
-     * @return Fragmentizer enabled flag.
-     */
-    public boolean fragmentizerEnabled() {
-        return fragmentizerEnabled;
-    }
-
-    /**
-     * @param fragmentizerEnabled New fragmentizer enabled flag.
-     */
-    public void fragmentizerEnabled(boolean fragmentizerEnabled) {
-        this.fragmentizerEnabled = fragmentizerEnabled;
-    }
-
-    /**
-     * @return Fragmentizer throttling block length.
-     */
-    public long fragmentizerThrottlingBlockLength() {
-        return fragmentizerThrottlingBlockLen;
-    }
-
-    /**
-     * @param fragmentizerThrottlingBlockLen New fragmentizer throttling block length.
-     */
-    public void fragmentizerThrottlingBlockLength(long fragmentizerThrottlingBlockLen) {
-        this.fragmentizerThrottlingBlockLen = fragmentizerThrottlingBlockLen;
-    }
-
-    /**
-     * @return Fragmentizer throttling delay.
-     */
-    public long fragmentizerThrottlingDelay() {
-        return fragmentizerThrottlingDelay;
-    }
-
-    /**
-     * @param fragmentizerThrottlingDelay New fragmentizer throttling delay.
-     */
-    public void fragmentizerThrottlingDelay(long fragmentizerThrottlingDelay) {
-        this.fragmentizerThrottlingDelay = fragmentizerThrottlingDelay;
-    }
-
-    /**
-     * @return IPC endpoint config (in JSON format) to publish GGFS over.
-     */
-    @Nullable public String ipcEndpointConfiguration() {
-        return ipcEndpointCfg;
-    }
-
-    /**
-     * @param ipcEndpointCfg New IPC endpoint config (in JSON format) to publish GGFS over.
-     */
-    public void ipcEndpointConfiguration(@Nullable String ipcEndpointCfg) {
-        this.ipcEndpointCfg = ipcEndpointCfg;
-    }
-
-    /**
-     * @return IPC endpoint enabled flag.
-     */
-    public boolean ipcEndpointEnabled() {
-        return ipcEndpointEnabled;
-    }
-
-    /**
-     * @param ipcEndpointEnabled New iPC endpoint enabled flag.
-     */
-    public void ipcEndpointEnabled(boolean ipcEndpointEnabled) {
-        this.ipcEndpointEnabled = ipcEndpointEnabled;
-    }
-
-    /**
-     * @return Maximum space.
-     */
-    public long maxSpace() {
-        return maxSpace;
-    }
-
-    /**
-     * @param maxSpace New maximum space.
-     */
-    public void maxSpace(long maxSpace) {
-        this.maxSpace = maxSpace;
-    }
-
-    /**
-     * @return Management port.
-     */
-    public int managementPort() {
-        return mgmtPort;
-    }
-
-    /**
-     * @param mgmtPort New management port.
-     */
-    public void managementPort(int mgmtPort) {
-        this.mgmtPort = mgmtPort;
-    }
-
-    /**
-     * @return Amount of sequential block reads before prefetch is triggered.
-     */
-    public int sequenceReadsBeforePrefetch() {
-        return seqReadsBeforePrefetch;
-    }
-
-    /**
-     * @param seqReadsBeforePrefetch New amount of sequential block reads before prefetch is triggered.
-     */
-    public void sequenceReadsBeforePrefetch(int seqReadsBeforePrefetch) {
-        this.seqReadsBeforePrefetch = seqReadsBeforePrefetch;
-    }
-
-    /**
-     * @return Trash purge await timeout.
-     */
-    public long trashPurgeTimeout() {
-        return trashPurgeTimeout;
-    }
-
-    /**
-     * @param trashPurgeTimeout New trash purge await timeout.
-     */
-    public void trashPurgeTimeout(long trashPurgeTimeout) {
-        this.trashPurgeTimeout = trashPurgeTimeout;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String toString() {
-        return S.toString(VisorGgfsConfiguration.class, this);
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGridConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGridConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGridConfiguration.java
index c7bfd3e..7e688b1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGridConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorGridConfiguration.java
@@ -75,7 +75,7 @@ public class VisorGridConfiguration implements Serializable {
     private Iterable<VisorCacheConfiguration> caches;
 
     /** Ggfss. */
-    private Iterable<VisorGgfsConfiguration> ggfss;
+    private Iterable<VisorIgfsConfiguration> ggfss;
 
     /** Streamers. */
     private Iterable<VisorStreamerConfiguration> streamers;
@@ -108,7 +108,7 @@ public class VisorGridConfiguration implements Serializable {
         rest(VisorRestConfiguration.from(c));
         userAttributes(c.getUserAttributes());
         caches(VisorCacheConfiguration.list(c.getCacheConfiguration()));
-        ggfss(VisorGgfsConfiguration.list(c.getGgfsConfiguration()));
+        ggfss(VisorIgfsConfiguration.list(c.getGgfsConfiguration()));
         streamers(VisorStreamerConfiguration.list(c.getStreamerConfiguration()));
         env(new HashMap<>(getenv()));
         systemProperties(getProperties());
@@ -301,14 +301,14 @@ public class VisorGridConfiguration implements Serializable {
     /**
      * @return Ggfss.
      */
-    public Iterable<VisorGgfsConfiguration> ggfss() {
+    public Iterable<VisorIgfsConfiguration> ggfss() {
         return ggfss;
     }
 
     /**
      * @param ggfss New ggfss.
      */
-    public void ggfss(Iterable<VisorGgfsConfiguration> ggfss) {
+    public void ggfss(Iterable<VisorIgfsConfiguration> ggfss) {
         this.ggfss = ggfss;
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f9facce7/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorIgfsConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorIgfsConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorIgfsConfiguration.java
new file mode 100644
index 0000000..96c3b5c
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorIgfsConfiguration.java
@@ -0,0 +1,574 @@
+/*
+ * 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.visor.node;
+
+import org.apache.ignite.configuration.*;
+import org.apache.ignite.ignitefs.*;
+import org.apache.ignite.internal.util.typedef.internal.*;
+import org.jetbrains.annotations.*;
+
+import java.io.*;
+import java.util.*;
+
+import static org.apache.ignite.internal.visor.util.VisorTaskUtils.*;
+
+/**
+ * Data transfer object for GGFS configuration properties.
+ */
+public class VisorIgfsConfiguration implements Serializable {
+    /** Property name for path to Hadoop configuration. */
+    public static final String SECONDARY_FS_CONFIG_PATH = "SECONDARY_FS_CONFIG_PATH";
+
+    /** Property name for URI of file system. */
+    public static final String SECONDARY_FS_URI = "SECONDARY_FS_URI";
+
+    /** */
+    private static final long serialVersionUID = 0L;
+
+    /** GGFS instance name. */
+    private String name;
+
+    /** Cache name to store GGFS meta information. */
+    private String metaCacheName;
+
+    /** Cache name to store GGFS data. */
+    private String dataCacheName;
+
+    /** File's data block size. */
+    private int blockSize;
+
+    /** Number of pre-fetched blocks if specific file's chunk is requested. */
+    private int prefetchBlocks;
+
+    /** Read/write buffer size for GGFS stream operations in bytes. */
+    private int streamBufferSize;
+
+    /** Number of file blocks buffered on local node before sending batch to remote node. */
+    private int perNodeBatchSize;
+
+    /** Number of batches that can be concurrently sent to remote node. */
+    private int perNodeParallelBatchCount;
+
+    /** URI of the secondary Hadoop file system. */
+    private String secondaryHadoopFileSystemUri;
+
+    /** Path for the secondary hadoop file system config. */
+    private String secondaryHadoopFileSystemConfigPath;
+
+    /** GGFS instance mode. */
+    private IgfsMode defaultMode;
+
+    /** Map of paths to GGFS modes. */
+    private Map<String, IgfsMode> pathModes;
+
+    /** Dual mode PUT operations executor service. */
+    private String dualModePutExecutorService;
+
+    /** Dual mode PUT operations executor service shutdown flag. */
+    private boolean dualModePutExecutorServiceShutdown;
+
+    /** Maximum amount of data in pending puts. */
+    private long dualModeMaxPendingPutsSize;
+
+    /** Maximum range length. */
+    private long maxTaskRangeLength;
+
+    /** Fragmentizer concurrent files. */
+    private int fragmentizerConcurrentFiles;
+
+    /** Fragmentizer local writes ratio. */
+    private float fragmentizerLocWritesRatio;
+
+    /** Fragmentizer enabled flag. */
+    private boolean fragmentizerEnabled;
+
+    /** Fragmentizer throttling block length. */
+    private long fragmentizerThrottlingBlockLen;
+
+    /** Fragmentizer throttling delay. */
+    private long fragmentizerThrottlingDelay;
+
+    /** IPC endpoint config (in JSON format) to publish GGFS over. */
+    private String ipcEndpointCfg;
+
+    /** IPC endpoint enabled flag. */
+    private boolean ipcEndpointEnabled;
+
+    /** Maximum space. */
+    private long maxSpace;
+
+    /** Management port. */
+    private int mgmtPort;
+
+    /** Amount of sequential block reads before prefetch is triggered. */
+    private int seqReadsBeforePrefetch;
+
+    /** Trash purge await timeout. */
+    private long trashPurgeTimeout;
+
+    /**
+     * @param ggfs GGFS configuration.
+     * @return Data transfer object for GGFS configuration properties.
+     */
+    public static VisorIgfsConfiguration from(IgfsConfiguration ggfs) {
+        VisorIgfsConfiguration cfg = new VisorIgfsConfiguration();
+
+        cfg.name(ggfs.getName());
+        cfg.metaCacheName(ggfs.getMetaCacheName());
+        cfg.dataCacheName(ggfs.getDataCacheName());
+        cfg.blockSize(ggfs.getBlockSize());
+        cfg.prefetchBlocks(ggfs.getPrefetchBlocks());
+        cfg.streamBufferSize(ggfs.getStreamBufferSize());
+        cfg.perNodeBatchSize(ggfs.getPerNodeBatchSize());
+        cfg.perNodeParallelBatchCount(ggfs.getPerNodeParallelBatchCount());
+
+        Igfs secFs = ggfs.getSecondaryFileSystem();
+
+        if (secFs != null) {
+            Map<String, String> props = secFs.properties();
+
+            cfg.secondaryHadoopFileSystemUri(props.get(SECONDARY_FS_URI));
+            cfg.secondaryHadoopFileSystemConfigPath(props.get(SECONDARY_FS_CONFIG_PATH));
+        }
+
+        cfg.defaultMode(ggfs.getDefaultMode());
+        cfg.pathModes(ggfs.getPathModes());
+        cfg.dualModePutExecutorService(compactClass(ggfs.getDualModePutExecutorService()));
+        cfg.dualModePutExecutorServiceShutdown(ggfs.getDualModePutExecutorServiceShutdown());
+        cfg.dualModeMaxPendingPutsSize(ggfs.getDualModeMaxPendingPutsSize());
+        cfg.maxTaskRangeLength(ggfs.getMaximumTaskRangeLength());
+        cfg.fragmentizerConcurrentFiles(ggfs.getFragmentizerConcurrentFiles());
+        cfg.fragmentizerLocalWritesRatio(ggfs.getFragmentizerLocalWritesRatio());
+        cfg.fragmentizerEnabled(ggfs.isFragmentizerEnabled());
+        cfg.fragmentizerThrottlingBlockLength(ggfs.getFragmentizerThrottlingBlockLength());
+        cfg.fragmentizerThrottlingDelay(ggfs.getFragmentizerThrottlingDelay());
+
+        Map<String, String> endpointCfg = ggfs.getIpcEndpointConfiguration();
+        cfg.ipcEndpointConfiguration(endpointCfg != null ? endpointCfg.toString() : null);
+
+        cfg.ipcEndpointEnabled(ggfs.isIpcEndpointEnabled());
+        cfg.maxSpace(ggfs.getMaxSpaceSize());
+        cfg.managementPort(ggfs.getManagementPort());
+        cfg.sequenceReadsBeforePrefetch(ggfs.getSequentialReadsBeforePrefetch());
+        cfg.trashPurgeTimeout(ggfs.getTrashPurgeTimeout());
+
+        return cfg;
+    }
+
+    /**
+     * Construct data transfer object for ggfs configurations properties.
+     *
+     * @param ggfss ggfs configurations.
+     * @return ggfs configurations properties.
+     */
+    public static Iterable<VisorIgfsConfiguration> list(IgfsConfiguration[] ggfss) {
+        if (ggfss == null)
+            return Collections.emptyList();
+
+        final Collection<VisorIgfsConfiguration> cfgs = new ArrayList<>(ggfss.length);
+
+        for (IgfsConfiguration ggfs : ggfss)
+            cfgs.add(from(ggfs));
+
+        return cfgs;
+    }
+
+    /**
+     * @return GGFS instance name.
+     */
+    @Nullable public String name() {
+        return name;
+    }
+
+    /**
+     * @param name New gGFS instance name.
+     */
+    public void name(@Nullable String name) {
+        this.name = name;
+    }
+
+    /**
+     * @return Cache name to store GGFS meta information.
+     */
+    @Nullable public String metaCacheName() {
+        return metaCacheName;
+    }
+
+    /**
+     * @param metaCacheName New cache name to store GGFS meta information.
+     */
+    public void metaCacheName(@Nullable String metaCacheName) {
+        this.metaCacheName = metaCacheName;
+    }
+
+    /**
+     * @return Cache name to store GGFS data.
+     */
+    @Nullable public String dataCacheName() {
+        return dataCacheName;
+    }
+
+    /**
+     * @param dataCacheName New cache name to store GGFS data.
+     */
+    public void dataCacheName(@Nullable String dataCacheName) {
+        this.dataCacheName = dataCacheName;
+    }
+
+    /**
+     * @return File's data block size.
+     */
+    public int blockSize() {
+        return blockSize;
+    }
+
+    /**
+     * @param blockSize New file's data block size.
+     */
+    public void blockSize(int blockSize) {
+        this.blockSize = blockSize;
+    }
+
+    /**
+     * @return Number of pre-fetched blocks if specific file's chunk is requested.
+     */
+    public int prefetchBlocks() {
+        return prefetchBlocks;
+    }
+
+    /**
+     * @param prefetchBlocks New number of pre-fetched blocks if specific file's chunk is requested.
+     */
+    public void prefetchBlocks(int prefetchBlocks) {
+        this.prefetchBlocks = prefetchBlocks;
+    }
+
+    /**
+     * @return Read/write buffer size for GGFS stream operations in bytes.
+     */
+    public int streamBufferSize() {
+        return streamBufferSize;
+    }
+
+    /**
+     * @param streamBufSize New read/write buffer size for GGFS stream operations in bytes.
+     */
+    public void streamBufferSize(int streamBufSize) {
+        streamBufferSize = streamBufSize;
+    }
+
+    /**
+     * @return Number of file blocks buffered on local node before sending batch to remote node.
+     */
+    public int perNodeBatchSize() {
+        return perNodeBatchSize;
+    }
+
+    /**
+     * @param perNodeBatchSize New number of file blocks buffered on local node before sending batch to remote node.
+     */
+    public void perNodeBatchSize(int perNodeBatchSize) {
+        this.perNodeBatchSize = perNodeBatchSize;
+    }
+
+    /**
+     * @return Number of batches that can be concurrently sent to remote node.
+     */
+    public int perNodeParallelBatchCount() {
+        return perNodeParallelBatchCount;
+    }
+
+    /**
+     * @param perNodeParallelBatchCnt New number of batches that can be concurrently sent to remote node.
+     */
+    public void perNodeParallelBatchCount(int perNodeParallelBatchCnt) {
+        perNodeParallelBatchCount = perNodeParallelBatchCnt;
+    }
+
+    /**
+     * @return URI of the secondary Hadoop file system.
+     */
+    @Nullable public String secondaryHadoopFileSystemUri() {
+        return secondaryHadoopFileSystemUri;
+    }
+
+    /**
+     * @param secondaryHadoopFileSysUri New URI of the secondary Hadoop file system.
+     */
+    public void secondaryHadoopFileSystemUri(@Nullable String secondaryHadoopFileSysUri) {
+        secondaryHadoopFileSystemUri = secondaryHadoopFileSysUri;
+    }
+
+    /**
+     * @return Path for the secondary hadoop file system config.
+     */
+    @Nullable public String secondaryHadoopFileSystemConfigPath() {
+        return secondaryHadoopFileSystemConfigPath;
+    }
+
+    /**
+     * @param secondaryHadoopFileSysCfgPath New path for the secondary hadoop file system config.
+     */
+    public void secondaryHadoopFileSystemConfigPath(@Nullable String secondaryHadoopFileSysCfgPath) {
+        secondaryHadoopFileSystemConfigPath = secondaryHadoopFileSysCfgPath;
+    }
+
+    /**
+     * @return GGFS instance mode.
+     */
+    public IgfsMode defaultMode() {
+        return defaultMode;
+    }
+
+    /**
+     * @param dfltMode New gGFS instance mode.
+     */
+    public void defaultMode(IgfsMode dfltMode) {
+        defaultMode = dfltMode;
+    }
+
+    /**
+     * @return Map of paths to GGFS modes.
+     */
+    @Nullable public Map<String, IgfsMode> pathModes() {
+        return pathModes;
+    }
+
+    /**
+     * @param pathModes New map of paths to GGFS modes.
+     */
+    public void pathModes(@Nullable Map<String, IgfsMode> pathModes) {
+        this.pathModes = pathModes;
+    }
+
+    /**
+     * @return Dual mode PUT operations executor service.
+     */
+    public String dualModePutExecutorService() {
+        return dualModePutExecutorService;
+    }
+
+    /**
+     * @param dualModePutExecutorSrvc New dual mode PUT operations executor service.
+     */
+    public void dualModePutExecutorService(String dualModePutExecutorSrvc) {
+        dualModePutExecutorService = dualModePutExecutorSrvc;
+    }
+
+    /**
+     * @return Dual mode PUT operations executor service shutdown flag.
+     */
+    public boolean dualModePutExecutorServiceShutdown() {
+        return dualModePutExecutorServiceShutdown;
+    }
+
+    /**
+     * @param dualModePutExecutorSrvcShutdown New dual mode PUT operations executor service shutdown flag.
+     */
+    public void dualModePutExecutorServiceShutdown(boolean dualModePutExecutorSrvcShutdown) {
+        dualModePutExecutorServiceShutdown = dualModePutExecutorSrvcShutdown;
+    }
+
+    /**
+     * @return Maximum amount of data in pending puts.
+     */
+    public long dualModeMaxPendingPutsSize() {
+        return dualModeMaxPendingPutsSize;
+    }
+
+    /**
+     * @param dualModeMaxPendingPutsSize New maximum amount of data in pending puts.
+     */
+    public void dualModeMaxPendingPutsSize(long dualModeMaxPendingPutsSize) {
+        this.dualModeMaxPendingPutsSize = dualModeMaxPendingPutsSize;
+    }
+
+    /**
+     * @return Maximum range length.
+     */
+    public long maxTaskRangeLength() {
+        return maxTaskRangeLength;
+    }
+
+    /**
+     * @param maxTaskRangeLen New maximum range length.
+     */
+    public void maxTaskRangeLength(long maxTaskRangeLen) {
+        maxTaskRangeLength = maxTaskRangeLen;
+    }
+
+    /**
+     * @return Fragmentizer concurrent files.
+     */
+    public int fragmentizerConcurrentFiles() {
+        return fragmentizerConcurrentFiles;
+    }
+
+    /**
+     * @param fragmentizerConcurrentFiles New fragmentizer concurrent files.
+     */
+    public void fragmentizerConcurrentFiles(int fragmentizerConcurrentFiles) {
+        this.fragmentizerConcurrentFiles = fragmentizerConcurrentFiles;
+    }
+
+    /**
+     * @return Fragmentizer local writes ratio.
+     */
+    public float fragmentizerLocalWritesRatio() {
+        return fragmentizerLocWritesRatio;
+    }
+
+    /**
+     * @param fragmentizerLocWritesRatio New fragmentizer local writes ratio.
+     */
+    public void fragmentizerLocalWritesRatio(float fragmentizerLocWritesRatio) {
+        this.fragmentizerLocWritesRatio = fragmentizerLocWritesRatio;
+    }
+
+    /**
+     * @return Fragmentizer enabled flag.
+     */
+    public boolean fragmentizerEnabled() {
+        return fragmentizerEnabled;
+    }
+
+    /**
+     * @param fragmentizerEnabled New fragmentizer enabled flag.
+     */
+    public void fragmentizerEnabled(boolean fragmentizerEnabled) {
+        this.fragmentizerEnabled = fragmentizerEnabled;
+    }
+
+    /**
+     * @return Fragmentizer throttling block length.
+     */
+    public long fragmentizerThrottlingBlockLength() {
+        return fragmentizerThrottlingBlockLen;
+    }
+
+    /**
+     * @param fragmentizerThrottlingBlockLen New fragmentizer throttling block length.
+     */
+    public void fragmentizerThrottlingBlockLength(long fragmentizerThrottlingBlockLen) {
+        this.fragmentizerThrottlingBlockLen = fragmentizerThrottlingBlockLen;
+    }
+
+    /**
+     * @return Fragmentizer throttling delay.
+     */
+    public long fragmentizerThrottlingDelay() {
+        return fragmentizerThrottlingDelay;
+    }
+
+    /**
+     * @param fragmentizerThrottlingDelay New fragmentizer throttling delay.
+     */
+    public void fragmentizerThrottlingDelay(long fragmentizerThrottlingDelay) {
+        this.fragmentizerThrottlingDelay = fragmentizerThrottlingDelay;
+    }
+
+    /**
+     * @return IPC endpoint config (in JSON format) to publish GGFS over.
+     */
+    @Nullable public String ipcEndpointConfiguration() {
+        return ipcEndpointCfg;
+    }
+
+    /**
+     * @param ipcEndpointCfg New IPC endpoint config (in JSON format) to publish GGFS over.
+     */
+    public void ipcEndpointConfiguration(@Nullable String ipcEndpointCfg) {
+        this.ipcEndpointCfg = ipcEndpointCfg;
+    }
+
+    /**
+     * @return IPC endpoint enabled flag.
+     */
+    public boolean ipcEndpointEnabled() {
+        return ipcEndpointEnabled;
+    }
+
+    /**
+     * @param ipcEndpointEnabled New iPC endpoint enabled flag.
+     */
+    public void ipcEndpointEnabled(boolean ipcEndpointEnabled) {
+        this.ipcEndpointEnabled = ipcEndpointEnabled;
+    }
+
+    /**
+     * @return Maximum space.
+     */
+    public long maxSpace() {
+        return maxSpace;
+    }
+
+    /**
+     * @param maxSpace New maximum space.
+     */
+    public void maxSpace(long maxSpace) {
+        this.maxSpace = maxSpace;
+    }
+
+    /**
+     * @return Management port.
+     */
+    public int managementPort() {
+        return mgmtPort;
+    }
+
+    /**
+     * @param mgmtPort New management port.
+     */
+    public void managementPort(int mgmtPort) {
+        this.mgmtPort = mgmtPort;
+    }
+
+    /**
+     * @return Amount of sequential block reads before prefetch is triggered.
+     */
+    public int sequenceReadsBeforePrefetch() {
+        return seqReadsBeforePrefetch;
+    }
+
+    /**
+     * @param seqReadsBeforePrefetch New amount of sequential block reads before prefetch is triggered.
+     */
+    public void sequenceReadsBeforePrefetch(int seqReadsBeforePrefetch) {
+        this.seqReadsBeforePrefetch = seqReadsBeforePrefetch;
+    }
+
+    /**
+     * @return Trash purge await timeout.
+     */
+    public long trashPurgeTimeout() {
+        return trashPurgeTimeout;
+    }
+
+    /**
+     * @param trashPurgeTimeout New trash purge await timeout.
+     */
+    public void trashPurgeTimeout(long trashPurgeTimeout) {
+        this.trashPurgeTimeout = trashPurgeTimeout;
+    }
+
+    /** {@inheritDoc} */
+    @Override public String toString() {
+        return S.toString(VisorIgfsConfiguration.class, this);
+    }
+
+}


Mime
View raw message