Repository: incubator-geode Updated Branches: refs/heads/develop 16571a6f0 -> 1517f88fd
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/develop Commit: 1517f88fd99957c11f6306c82f2d3537960d22d0 Parents: 16571a6 Author: nthanvi <[email protected]> Authored: Thu Sep 10 17:38:04 2015 +0530 Committer: nthanvi <[email protected]> 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());
