You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2015/10/01 19:58:50 UTC
[09/26] incubator-geode git commit: GEODE-322: Added following
parameters while creating the HDFSStore
GEODE-322: Added following parameters while creating the HDFSStore
- maxMemory
- minorCompactionThreads
- purgeInterval
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/1517f88f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/1517f88f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/1517f88f
Branch: refs/heads/feature/GEODE-77
Commit: 1517f88fd99957c11f6306c82f2d3537960d22d0
Parents: 16571a6
Author: nthanvi <nt...@pivotal.io>
Authored: Thu Sep 10 17:38:04 2015 +0530
Committer: nthanvi <nt...@pivotal.io>
Committed: Thu Sep 10 17:38:04 2015 +0530
----------------------------------------------------------------------
.../internal/cli/functions/CreateHDFSStoreFunction.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/1517f88f/gemfire-core/src/main/java/com/gemstone/gemfire/management/internal/cli/functions/CreateHDFSStoreFunction.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/management/internal/cli/functions/CreateHDFSStoreFunction.java b/gemfire-core/src/main/java/com/gemstone/gemfire/management/internal/cli/functions/CreateHDFSStoreFunction.java
index 0667020..b4e5033 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/management/internal/cli/functions/CreateHDFSStoreFunction.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/management/internal/cli/functions/CreateHDFSStoreFunction.java
@@ -96,11 +96,13 @@ public class CreateHDFSStoreFunction extends FunctionAdapter implements Internal
hdfsStoreFactory.setMajorCompactionInterval(configHolder.getMajorCompactionInterval());
hdfsStoreFactory.setMajorCompactionThreads(configHolder.getMajorCompactionThreads());
hdfsStoreFactory.setMinorCompaction(configHolder.getMinorCompaction());
-
+ hdfsStoreFactory.setMaxMemory(configHolder.getMaxMemory());
hdfsStoreFactory.setBatchSize(configHolder.getBatchSize());
hdfsStoreFactory.setBatchInterval(configHolder.getBatchInterval());
hdfsStoreFactory.setDiskStoreName(configHolder.getDiskStoreName());
hdfsStoreFactory.setDispatcherThreads(configHolder.getDispatcherThreads());
+ hdfsStoreFactory.setMinorCompactionThreads(configHolder.getMinorCompactionThreads());
+ hdfsStoreFactory.setPurgeInterval(configHolder.getPurgeInterval());
hdfsStoreFactory.setSynchronousDiskWrite(configHolder.getSynchronousDiskWrite());
hdfsStoreFactory.setBufferPersistent(configHolder.getBufferPersistent());