geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bschucha...@apache.org
Subject [28/37] incubator-geode git commit: GEODE-287: Remove old gfsh code
Date Tue, 01 Sep 2015 16:49:06 GMT
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rm.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rm.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rm.java
deleted file mode 100644
index dc4b7fb..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rm.java
+++ /dev/null
@@ -1,175 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-
-import com.gemstone.gemfire.cache.EntryNotFoundException;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshFunction;
-import com.gemstone.gemfire.internal.tools.gfsh.app.util.ObjectUtil;
-
-public class rm implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public rm(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("rm [-a|-g] [-k] <key>|<enum list>");
-		gfsh.println("     Remove keys locally and/or remotely. If no options are specified,");
-		gfsh.println("     it removes <key> from the local region only.");
-		gfsh.println("     -a Remove keys from both the local region and the server");
-		gfsh.println("        region. This command will be distributed to other caches if");
-        gfsh.println("        scope is not Scope.LOCAL.");
-		gfsh.println("     -g Remove keys globally. Remote from the local region and all");
-		gfsh.println("        server regions regardless of scope. This option also removes");
-		gfsh.println("        keys from server regions with Scope.LOCAL.");
-		gfsh.println("     -k Remove enumerated keys. If this option is not specified, then");
-		gfsh.println("        <key> is expected.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("rm -?")) {
-			help();
-		} else {
-			rm(command);
-		}
-	}
-	
-	private void rm(String command) throws Exception
-	{
-		LinkedList<String> list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath = null;
-		if (list.size() > 1) {
-			regionPath = (String)list.get(1);
-		} else {
-			gfsh.println("Error: must specify a region path to remove");
-			return;
-		}
-		
-		boolean enumerated = false;
-		boolean removeAll = false;
-		boolean removeServer = false;
-		
-		String val;
-		int keyIndex = 0;
-		for (int i = 1; i < list.size(); i++) {
-			val = list.get(i);
-			if (val.equals("-a")) {
-				removeServer = true;
-			} else if (val.equals("-g")) {
-				removeAll = true;
-			} else if (val.equals("-k")) {
-				enumerated = true;
-			} else {
-				keyIndex = i;
-				break;
-			}
-		}
-		
-		Region region = gfsh.getCurrentRegion();
-		String numbers;
-		Object key;
-		if (removeServer) {
-			
-			if (enumerated) {
-				Map keyMap = gfsh.getKeyMap(list, keyIndex);
-				Object keys[] = keyMap.values().toArray();
-				for (Object k: keyMap.values()) {
-					region.remove(k);
-					gfsh.println("removed server: " + ObjectUtil.getPrintableObject(k));
-				}
-				
-			} else {
-				key = gfsh.getQueryKey(list, keyIndex);
-				region.remove(key);
-				gfsh.println("removed server: " + ObjectUtil.getPrintableObject(key));
-			}
-			
-		} else if (removeAll) {
-			
-			if (enumerated) {
-				Map keyMap = gfsh.getKeyMap(list, keyIndex);
-				Object keys[] = keyMap.values().toArray();
-
-				boolean serverError = false;
-				List<AggregateResults> results = (List<AggregateResults>)gfsh.getAggregator().aggregate(new GfshFunction(command, gfsh.getCurrentPath(), keys), gfsh.getAggregateRegionPath());
-				for (Object k: keyMap.values()) {
-					try {
-						region.localDestroy(k);
-					} catch (Exception ex) {
-						// ignore
-					}
-					gfsh.println("removed all: " + ObjectUtil.getPrintableObject(k));
-				}
-				for (AggregateResults aggregateResults : results) {
-					if (aggregateResults.getCode() == AggregateResults.CODE_ERROR) {
-						gfsh.println("Error from server: " + aggregateResults.getCodeMessage());
-					}
-				}
-				if (serverError) {
-					gfsh.println("Error: One or more keys may have not been removed from the server(s)");
-				}
-			} else {
-				key = gfsh.getQueryKey(list, keyIndex);
-				
-				List<AggregateResults> results = (List<AggregateResults>)gfsh.getAggregator().aggregate(new GfshFunction(command, gfsh.getCurrentPath(), new Object[] { key }), gfsh.getAggregateRegionPath());
-				try {
-					region.localDestroy(key);
-				} catch (Exception ex) {
-					// ignore
-				}
-				boolean serverError = false;
-				for (AggregateResults aggregateResults : results) {
-					if (aggregateResults.getCode() == AggregateResults.CODE_ERROR) {
-						gfsh.println("Error from server: " + aggregateResults.getCodeMessage());
-						serverError = true;
-					}
-				}
-				if (serverError) {
-					gfsh.println("Error: One or more keys may have not been removed from the server(s)");
-				} else {
-					gfsh.println("removed: " + ObjectUtil.getPrintableObject(key));
-				}
-			}
-
-		} else {
-			// remove local
-			if (enumerated) {
-				Map keyMap = gfsh.getKeyMap(list, keyIndex);
-				for (Object k: keyMap.values()) {
-					// remove local
-					try {
-						region.localDestroy(k);
-						gfsh.println("removed local: " + ObjectUtil.getPrintableObject(k));
-					} catch (EntryNotFoundException ex) {
-						gfsh.println("local (not found): " + ObjectUtil.getPrintableObject(k));
-					}
-					
-				}
-			} else {
-				key = gfsh.getQueryKey(list, keyIndex);
-				// remove local
-				try {
-					region.localDestroy(key);
-					gfsh.println("removed local: " + ObjectUtil.getPrintableObject(key));
-				} catch (EntryNotFoundException ex) {
-					gfsh.println("local (not found): " + ObjectUtil.getPrintableObject(key));
-				}
-			}
-		}
-	}
-	
-	
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rmdir.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rmdir.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rmdir.java
deleted file mode 100644
index 71491c8..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/rmdir.java
+++ /dev/null
@@ -1,249 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-import java.util.List;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.DataPolicy;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.Scope;
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.aggregator.Aggregator;
-import com.gemstone.gemfire.internal.tools.gfsh.app.aggregator.functions.util.RegionDestroyFunction;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.CommandClient;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.RegionDestroyTask;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.data.MemberInfo;
-import com.gemstone.gemfire.internal.tools.gfsh.command.CommandResults;
-import com.gemstone.gemfire.internal.tools.gfsh.util.RegionUtil;
-
-public class rmdir implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public rmdir(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("rmdir [-a|-g|-s] [-?] <region path>");
-		gfsh.println("     Remove the local region if no options specified. The region path");
-		gfsh.println("     can be absolute or relative.");
-		gfsh.println("     -a Remove both the local region and the server region.");
-		gfsh.println("        The region destroy will be distributed to other caches if the");
-		gfsh.println("        scope is not Scope.LOCAL.");
-		gfsh.println("     -g Remove globally. Remove the local region and all server");
-		gfsh.println("        regions regardless of scope. This option also removes server");
-		gfsh.println("        regions with Scope.LOCAL.");
-		gfsh.println("     -s Remove only the server region. The local region is not destroyed.");
-		gfsh.println("        The region destroy will be distributed to other caches if the");
-		gfsh.println("        scope is not Scope.LOCAL."); 
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("rmdir -?")) {
-			help();
-		} else if (command.startsWith("rmdir -a")) {
-			rmdir_a(command);
-		} else if (command.startsWith("rmdir -g")) {
-			rmdir_g(command);
-		} else if (command.startsWith("rmdir -s")) {
-			rmdir_s(command);
-		} else {
-			rmdir_local(command);
-		}
-	}
-	
-	private void rmdir(String command) throws Exception
-	{
-		int index = command.indexOf(" ");
-		if (index == -1) {
-			gfsh.println("Error: rmdir requires a region path to remove");
-		} else {
-			Cache cache = gfsh.getCache();
-			Region region;
-			String newPath = command.substring(index).trim();
-			String fullPath = gfsh.getFullPath(newPath, gfsh.getCurrentPath());
-			if (fullPath == null) {
-				gfsh.println("Error: region path must be provided. mkdir <regionPath>");
-			} else {
-				// absolute path
-				region = cache.getRegion(fullPath);
-				if (region == null) {
-					gfsh.println("Error: region does not exist - " + fullPath);
-					return;
-				}
-				region.close();
-				gfsh.println("Region removed: " + fullPath);
-			}
-		}
-	}
-	
-	private void rmdir_local(String command) 
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath = null;
-		if (list.size() > 1) {
-			regionPath = (String)list.get(1);
-		} else {
-			gfsh.println("Error: must specify a region path to remove");
-			return;
-		}
-		
-		remove_local(regionPath);
-	}
-	
-	private void rmdir_a(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath = null;
-		if (list.size() > 2) {
-			regionPath = (String)list.get(2);
-		} else {
-			gfsh.println("Error: must specify a region path to remove");
-			return;
-		}
-		
-		remove_server(regionPath, false);
-		remove_local(regionPath);
-	}
-	
-	private void rmdir_g(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath = null;
-		if (list.size() > 2) {
-			regionPath = (String)list.get(2);
-		} else {
-			gfsh.println("Error: must specify a region path to remove");
-			return;
-		}
-		
-		remove_server(regionPath, true);
-		remove_local(regionPath);
-	}
-	
-	private void rmdir_s(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath = null;
-		if (list.size() > 2) {
-			regionPath = (String)list.get(2);
-		} else {
-			gfsh.println("Error: must specify a region path to remove");
-			return;
-		}
-		
-		remove_server(regionPath, false);
-	}
-	
-	private void remove_local(String regionPath)
-	{
-		if (regionPath == null) {
-			return;
-		}
-		
-		String currentPath = gfsh.getCurrentPath();
-		String fullPath = gfsh.getFullPath(regionPath, currentPath);
-		if (fullPath == null) {
-			gfsh.println("Error: invalid region path");
-		} else if (fullPath.equals("/")) {
-			gfsh.println("Error: cannot remove top level");
-		} else {
-			Region region = gfsh.getCache().getRegion(fullPath);
-			if (region == null) {
-				gfsh.println("Error: undefined region path " + fullPath);
-				return;
-			} 
-			region.close();
-			
-			// correct the current path if the removed region path
-			// lies in the current path
-			String currentSplit[] = currentPath.split("/");
-			Cache cache = gfsh.getCache();
-			Region currentRegion = null;
-			if (currentSplit.length > 1) {
-				currentRegion = region = cache.getRegion(currentSplit[1]);
-				if (region != null) {
-					for (int i = 2; i < currentSplit.length; i++) {
-						region = region.getSubregion(currentSplit[i]);
-						if (region == null) {
-							break;
-						}
-						currentRegion = region;
-					}
-				}
-			}
-			if (currentRegion == null) {
-				gfsh.setCurrentPath("/");
-			} else {
-				gfsh.setCurrentPath(currentRegion.getFullPath());
-			}
-			gfsh.setCurrentRegion(currentRegion);
-			
-			gfsh.println("Region removed from local VM: " + regionPath);
-		}
-	}
-	
-	private void remove_server(String regionPath, boolean global) throws Exception
-	{
-		if (regionPath == null) {
-			return;
-		}
-		
-		String currentPath = gfsh.getCurrentPath();
-		String fullPath = gfsh.getFullPath(regionPath, currentPath);
-		if (fullPath == null) {
-			gfsh.println("Error: invalid region path");
-		} else if (fullPath.equals("/")) {
-			gfsh.println("Error: cannot remove top level");
-		} else {
-			
-			String confirmation = gfsh.getLine("This command will remove the region " + fullPath + " from the server(s). \nDo you want to proceed? (yes|no): ");
-			if (confirmation.equalsIgnoreCase("yes") == false) {
-				gfsh.println("Command aborted.");
-				return;
-			}
-			
-			if (global) {
-				
-				Aggregator aggregator = gfsh.getAggregator();
-				List<CommandResults> aggregateList = (List<CommandResults>)aggregator.aggregate(new RegionDestroyFunction(fullPath), gfsh.getAggregateRegionPath());
-				
-				int i = 1;
-				for (CommandResults commandResults : aggregateList) {
-					
-					MemberInfo memberInfo = (MemberInfo)commandResults.getDataObject();
-					gfsh.print(i + ". " + memberInfo.getMemberName() + "(" + memberInfo.getMemberId() + ")" + ": ");
-					if (commandResults.getCode() == RegionDestroyTask.ERROR_REGION_DESTROY) {
-						gfsh.println("error - " + commandResults.getCodeMessage());
-					} else {
-						Region region = RegionUtil.getRegion(fullPath, Scope.LOCAL, DataPolicy.NORMAL, null);
-						gfsh.println("region removed: " + region.getFullPath());
-					}
-					i++;
-				}
-			} else {
-				CommandClient commandClient = gfsh.getCommandClient();
-				CommandResults commandResults = commandClient.execute(new RegionDestroyTask(fullPath));
-				MemberInfo memberInfo = (MemberInfo)commandResults.getDataObject();
-				gfsh.print(memberInfo.getMemberName() + "(" + memberInfo.getMemberId() + ")" + ": ");
-				if (commandResults.getCode() == RegionDestroyTask.ERROR_REGION_DESTROY) {
-					gfsh.println("error - " + commandResults.getCodeMessage());
-				} else {
-					Region region = RegionUtil.getRegion(regionPath, Scope.LOCAL, DataPolicy.NORMAL, null);
-					gfsh.println("region removed: " + region.getFullPath());
-				}
-			}
-		}
-	}
-	
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/select.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/select.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/select.java
deleted file mode 100644
index 9caf017..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/select.java
+++ /dev/null
@@ -1,139 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-import java.util.List;
-
-import com.gemstone.gemfire.cache.query.SelectResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Nextable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.QueryResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.QueryTask;
-import com.gemstone.gemfire.internal.tools.gfsh.app.util.PrintUtil;
-import com.gemstone.gemfire.internal.tools.gfsh.command.CommandResults;
-
-public class select implements CommandExecutable, Nextable
-{
-	private final static int DEFAULT_LIMIT = 1000;
-	private final static int MAX_LIMIT = 5000;
-	
-	private Gfsh gfsh;
-	
-	private int limit = DEFAULT_LIMIT;
-
-	public select(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-		gfsh.setSelectLimit(limit);
-	}
-	
-	public void help()
-	{
-		gfsh.println("select [-l <limit>|-show] | -?");
-		gfsh.println("select <tuples where ...> | -?");
-		gfsh.println("     Execute the specified query in the remote cache.");
-		gfsh.println("     -l set the result set size limit, i.e.,");
-		gfsh.println("        'select ... from ... limit <limit>'. Note that gfsh automatically");
-		gfsh.println("        appends 'limit' to your select statement. Do not add your own limit.");
-		gfsh.println("        The default limit is 1000. The allowed max limit is 5000.");
-		gfsh.println("     -show Displays the select limit value.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{	
-		LinkedList<String> list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		
-		String queryString = command;
-		
-		if (list.contains("-?")) {
-			help();
-		} else {
-			for (int i = 1; i < list.size(); i++) {
-				String token = list.get(i);
-				if (token.equals("-l")) {
-					if (i + 1 >= list.size()) {
-						gfsh.println("Error: '-l' requires limit value");
-						return;
-					}
-					int val = Integer.parseInt((String) list.get(++i));
-					if (val > MAX_LIMIT) {
-						limit = MAX_LIMIT;
-					} else if (val < 0) {
-						limit = 0;
-					} else {
-						limit = val;
-					}
-					gfsh.setSelectLimit(limit);
-					return;
-				} else if (token.equals("-show")) {
-					select_show();
-					return;
-				}
-			}
-			
-			queryString += " limit " + limit;
-			select(queryString, true);
-		}
-	}
-	
-	public List getRemoteKeys(String regionPath) throws Exception
-	{
-		List list = select("select * from " + regionPath + ".keySet limit " + limit, true);	
-		return list;
-	}
-	
-	public void select_show()
-	{
-		gfsh.println("select limit = " + limit);
-	}
-	
-	public List select(String queryString, boolean nextEnabled) throws Exception
-	{
-		long startTime = System.currentTimeMillis();
-		CommandResults cr = gfsh.getCommandClient().execute(new QueryTask(queryString, gfsh.getFetchSize(), nextEnabled));
-		long stopTime = System.currentTimeMillis();
-		if (cr.getCode() == QueryTask.ERROR_QUERY) {
-			gfsh.println(cr.getCodeMessage());
-			return null;
-		}
-		QueryResults results = (QueryResults) cr.getDataObject();
-		if (results == null) {
-			gfsh.println("No results");
-			return null;
-		}
-
-		List list = null;
-		Object obj = results.getResults();
-		if (obj instanceof SelectResults) {
-			SelectResults sr = (SelectResults) results.getResults();
-			list = sr.asList();
-			int startRowNum = results.getReturnedSize() - sr.size() + 1;
-			if (gfsh.isShowResults()) {
-				int rowsPrinted = PrintUtil.printSelectResults(sr, 0, startRowNum, sr.size());
-				gfsh.println("Fetch size: " + gfsh.getFetchSize() + ", Limit: " + limit);
-				gfsh.println("   Results: " + sr.size()
-						+ ", Returned: " + results.getReturnedSize() + "/" + results.getActualSize());
-				next n = (next)gfsh.getCommand("next");
-				n.setCommand(getClass().getSimpleName());
-			} else {
-				gfsh.println("Fetch size: " + gfsh.getFetchSize() + ", Limit: " + limit);
-				gfsh.println("   Results: " + sr.size() + 
-						", Returned: " + results.getReturnedSize() + "/" + results.getActualSize());
-			}
-		} else {
-			gfsh.println("Results: " + obj);
-		}
-		if (gfsh.isShowTime()) {
-			gfsh.println("elapsed (msec): " + (stopTime - startTime));
-		}
-		return list;
-	}
-	
-	public List next(Object userData) throws Exception
-	{
-		select(null, true);
-		return null;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/show.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/show.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/show.java
deleted file mode 100644
index acea0de..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/show.java
+++ /dev/null
@@ -1,240 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.LinkedList;
-import java.util.Map;
-
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.misc.util.ReflectionUtil;
-
-import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
-
-public class show implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public show(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("show [-p [true|false]]");
-		gfsh.println("     [-t [true|false]]");
-		gfsh.println("     [-c|-k|-v]");
-		gfsh.println("     [-table [true|false]");
-		gfsh.println("     [-type [true|false]");
-		gfsh.println("     [-col <collection entry print count>]");
-		gfsh.println();
-		gfsh.println("     [-?]");
-		gfsh.println("     Show or toggle settings.");
-		gfsh.println("     <no option> Show all current settings.");
-		
-		gfsh.println("     -p Toggle print. If enabled, results are printed to stdout.");
-		gfsh.println("     -t Toggle the time taken to execute each command.");
-		gfsh.println("     -c Show configuration");
-		gfsh.println("     -k Show key class fields. Use the 'key' command to set key class.");
-		gfsh.println("     -v Show value class fields. Use the 'value' command to set value class.");
-		gfsh.println("     -table Set the print format to the tabular or catalog form. The");
-		gfsh.println("         tabular form prints in a table with a column header. The catalog");
-		gfsh.println("         form prints in each row in a data structure form.");
-		gfsh.println("     -type Enable or disable printing the data type. This option is");
-		gfsh.println("         valid only for the '-table false' option.");
-		gfsh.println("     -col <collection entry print count> In the catalog mode, gfsh");
-		gfsh.println("         prints the contents of Map and Collection objects. By default, it");
-		gfsh.println("         prints 5 entries per object. Use this option to change the count.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("show -?")) {
-			help();
-		} else if (command.startsWith("show -table")) {
-			show_table(command);
-		} else if (command.startsWith("show -type")) {
-			show_type(command);
-		} else if (command.startsWith("show -col")) {
-			show_count(command);
-		} else if (command.startsWith("show -p")) {
-			show_p(command);
-		} else if (command.startsWith("show -t")) {
-			show_t(command);
-		} else if (command.startsWith("show -c")) {
-			show_c();
-		} else if (command.startsWith("show -k")) {
-			show_k();
-		} else if (command.startsWith("show -v")) {
-			show_v();
-		} else {
-			show();
-		}
-	}
-	
-	private void show_table(String command) throws Exception
-	{
-		ArrayList<String> list = new ArrayList();
-		gfsh.parseCommand(command, list);
-		if (list.size() >= 3) {
-			boolean enable = list.get(2).equalsIgnoreCase("true");
-			gfsh.setTableFormat(enable);
-		} else {
-			gfsh.setTableFormat(!gfsh.isTableFormat());
-		}
-		gfsh.println("show -table is " + (gfsh.isTableFormat() ? "true" : "false"));
-		
-	}
-	
-	private void show_type(String command) throws Exception
-	{
-		ArrayList<String> list = new ArrayList();
-		gfsh.parseCommand(command, list);
-		if (list.size() >= 3) {
-			boolean enable = list.get(2).equalsIgnoreCase("true");
-			gfsh.setPrintType(enable);
-		} else {
-			gfsh.setPrintType(!gfsh.isPrintType());
-		}
-		gfsh.println("show -type is " + (gfsh.isPrintType() ? "true" : "false"));
-		
-	}
-
-	private void show_count(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		if (list.size() < 3) {
-			gfsh.println("Error: must specify <collection entry print count>. Current count is " + gfsh.getCollectionEntryPrintCount());
-			return;
-		}
-		try {
-			int count = Integer.parseInt((String)list.get(2));
-			gfsh.setCollectionEntryPrintCount(count);
-		} catch (Exception ex) {
-			gfsh.println("Error: " + ex.getClass().getSimpleName() + " - " + ex.getMessage());
-		}
-	}
-	
-	public void show_p(String command)
-	{
-		ArrayList<String> list = new ArrayList();
-		gfsh.parseCommand(command, list);
-		if (list.size() >= 3) {
-			boolean enable = list.get(2).equalsIgnoreCase("true");
-			gfsh.setShowResults(enable);
-		} else {
-			gfsh.setShowResults(!gfsh.isShowResults());
-		}
-		gfsh.println("show -p is " + (gfsh.isShowResults() ? "true" : "false"));
-	}
-
-	private void show_t(String command) throws Exception
-	{
-		ArrayList<String> list = new ArrayList();
-		gfsh.parseCommand(command, list);
-		if (list.size() >= 3) {
-			boolean enable = list.get(2).equalsIgnoreCase("true");
-			gfsh.setShowResults(enable);
-		} else {
-			gfsh.setShowTime(!gfsh.isShowTime());
-		}
-		gfsh.println("show -t is " + (gfsh.isShowTime() ? "true" : "false"));
-	}
-	
-	@SuppressFBWarnings(value="NM_METHOD_CONSTRUCTOR_CONFUSION",justification="This is method and not constructor")
-	public void show()
-	{
-		show_c();
-		gfsh.println();
-		show_k();
-		gfsh.println();
-		show_v();
-	}
-	
-	public void show_c()
-	{
-		db dbCommand = (db)gfsh.getCommand("db");
-//		String dbInit = dbCommand.getDbInitCommand();
-		
-		gfsh.println("     connected = " + gfsh.isConnected());
-		if (dbCommand/*dbInit*/ != null) {
-			gfsh.println("            db = " + /*dbInit*/dbCommand.getDbInitCommand());	
-		}
-		gfsh.println("          echo = " + gfsh.isEcho());
-		if (gfsh.getEndpoints() == null && gfsh.getEndpoints() == null) {
-			gfsh.println("      locators = null");
-			gfsh.println("       servers = null");
-		} else {
-			if (gfsh.isLocator()) {
-				gfsh.println("      locators = " + gfsh.getEndpoints());
-				if (gfsh.getServerGroup() == null) {
-					gfsh.println("  server group = <undefined>");
-				} else {
-					gfsh.println("  server group = " + gfsh.getServerGroup());
-				}
-			} else {
-				gfsh.println("       servers = " + gfsh.getEndpoints());
-			}
-			gfsh.println("  read timeout = " + gfsh.getReadTimeout());
-		}
-		
-		gfsh.println("  select limit = " + gfsh.getSelectLimit());
-		gfsh.println("         fetch = " + gfsh.getFetchSize());
-		gfsh.println("           key = " + gfsh.getQueryKeyClassName());
-		gfsh.println("         value = " + gfsh.getValueClassName());
-		gfsh.println("       show -p = " + gfsh.isShowResults());
-		gfsh.println("       show -t = " + gfsh.isShowTime());
-		gfsh.println("   show -table = " + gfsh.isTableFormat());
-		gfsh.println("    show -type = " + gfsh.isPrintType());
-		gfsh.println("     show -col = " + gfsh.getCollectionEntryPrintCount());
-		gfsh.println("  zone (hours) = " + gfsh.getZoneDifference() / (60 * 60 * 1000));
-//		gfsh.println("command region = " + gfsh.getCommandRegionPath());
-	}
-	
-	public void show_k()
-	{
-		printClassSetters(gfsh.getQueryKeyClass(), "key");
-	}
-	
-	public void show_v()
-	{
-		printClassSetters(gfsh.getValueClass(), "value");
-	}
-	
-	private void printClassSetters(Class cls, String header)
-	{
-		if (cls == null) {
-			gfsh.println(header + " class: undefined");
-		} else {
-			gfsh.println(header + " class " + cls.getName());
-			gfsh.println("{");
-			try {
-				Map<String, Method> setterMap = ReflectionUtil.getAllSettersMap(cls);
-				ArrayList list = new ArrayList(setterMap.keySet());
-				Collections.sort(list);
-				for (Object object : list) {
-					Method method = setterMap.get(object);
-					if (isSupportedMethod(method)) {
-						gfsh.println("    " + method.getName().substring(3) + "::"
-								+ method.getParameterTypes()[0].getCanonicalName());
-//						gfsh.println("    " + method.getParameterTypes()[0].getCanonicalName() + " " + method.getName().substring(3));
-					}
-				}
-			} catch (Exception e) {
-				e.printStackTrace();
-			}
-			gfsh.println("}");
-		}
-	}
-	
-	
-	private boolean isSupportedMethod(Method method)
-	{
-		return true;
-	}
-
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/size.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/size.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/size.java
deleted file mode 100644
index 21f7c49..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/size.java
+++ /dev/null
@@ -1,281 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.List;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.aggregator.functions.util.LocalRegionInfoFunction;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.MapMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.Mappable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.RegionSizeTask;
-import com.gemstone.gemfire.internal.tools.gfsh.app.misc.util.StringUtil;
-import com.gemstone.gemfire.internal.tools.gfsh.app.util.PrintUtil;
-import com.gemstone.gemfire.internal.tools.gfsh.command.CommandResults;
-
-public class size implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public size(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("size [-m|-s] | [-?] <region path>");
-		gfsh.println("     Display the local and server region sizes. If no option");
-		gfsh.println("     is provided then it displays the local region size");
-		gfsh.println("     -m List all server member region sizes.");
-		gfsh.println("     -s Display the region size of the connected server.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("size -?")) {
-			help();
-		} else if (command.startsWith("size -m")) {
-			size_m(command);
-		} else if (command.startsWith("size -s")) {
-			size_s(command);
-		} else {
-			size(command);
-		}
-	}
-	
-	// local region size
-	private void size(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath;
-		if (list.size() == 1) {
-			regionPath = gfsh.getCurrentPath();
-		} else if (list.size() == 2) {
-			regionPath = (String)list.get(1);
-		} else {
-			regionPath = (String)list.get(2);
-		}
-	
-		regionPath = regionPath.trim();
-		if (regionPath.equals("/")) {
-			gfsh.println("Error: Invalid path. Root path not allowed.");
-			return;
-		}
-		
-		regionPath = gfsh.getFullPath(regionPath, gfsh.getCurrentPath());
-		
-		gfsh.println("            Region: " + regionPath);
-		
-		// Local region
-		Cache cache = gfsh.getCache();
-		Region region = cache.getRegion(regionPath);
-		if (region == null) {
-			gfsh.println("Error: region undefine - " + regionPath);
-		} else {
-			gfsh.println(" Local region size: " + region.size());
-		}
-	}
-	
-	private void size_m(String command) throws Exception
-	{
-		if (gfsh.getAggregateRegionPath() == null) {
-			gfsh.println("Error: The aggregate region path is not specified. Use the command ");
-			gfsh.println("'connect -a <region path>' to specify any existing partitioned region path in the server.");
-			return;
-		}
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath;
-		if (list.size() == 2) {
-			regionPath = gfsh.getCurrentPath();
-		} else {
-			regionPath = (String) list.get(2);
-		}
-		
-		regionPath = gfsh.getFullPath(regionPath, gfsh.getCurrentPath());
-		
-		if (regionPath.equals("/")) {
-			gfsh.println("Error: invalid region \"/\". Change to a valid region or specify the region path, i.e. size -a /foo");
-			return;
-		}
-
-		long startTime = System.currentTimeMillis();
-		List<MapMessage> resultList = (List<MapMessage>)gfsh.getAggregator().aggregate(new LocalRegionInfoFunction(regionPath), gfsh.getAggregateRegionPath());
-		long stopTime = System.currentTimeMillis();
-		
-		String memberIdHeader = "Member Id";
-		String memberNameHeader = "Member Name";
-		String regionSizeHeader = "Region Size";
-		
-		
-		// Find the max string sizes
-		int memberIdMax = memberIdHeader.length();
-		int memberNameMax = memberNameHeader.length();
-		int regionSizeMax = regionSizeHeader.length();
-		boolean isPR = false;
-		boolean isPeerClient = false;
-		String returnedRegionPath = null;
-		HashMap<String, Mappable> infoMap = new HashMap<String, Mappable>();
-		for (int i = 0; i < resultList.size(); i++) {
-			Mappable info = resultList.get(i);
-			try {
-				if (info.getByte("Code") == AggregateResults.CODE_ERROR) {
-					gfsh.println("Error: " + info.getString("CodeMessage"));
-					return;
-				}
-			} catch (Exception ex) {
-				// ignore
-			}
-
-			isPR = info.getBoolean("IsPR");
-			if (isPR) {
-				try {
-					isPeerClient = info.getBoolean("IsPeerClient");
-				} catch (Exception ex) {
-					continue;
-				}
-				if (isPeerClient) {
-					continue;
-				}
-			}
-			
-			returnedRegionPath = info.getString("RegionPath");
-			String memberId = info.getString("MemberId");
-			if (memberIdMax < memberId.length()) {
-				memberIdMax = memberId.length();
-			}
-			String memberName = info.getString("MemberName");
-			if (memberName != null && memberNameMax < memberName.length()) {
-				memberNameMax = memberName.length();
-			}
-			String val = Integer.toString(info.getInt("RegionSize"));
-			if (regionSizeMax < val.length()) {
-				regionSizeMax = val.length();
-			}
-			infoMap.put(info.getString("MemberId"), info);
-		}
-		
-		ArrayList keyList = new ArrayList(infoMap.keySet());
-		Collections.sort(keyList);
-		
-		
-		// display
-		gfsh.println("     Region: " + returnedRegionPath);
-		if (isPR) {
-			gfsh.println("Region Type: Partitioned");
-		} else {
-			gfsh.println("Region Type: Replicated");
-		}
-		gfsh.print(StringUtil.getRightPaddedString(memberIdHeader, memberIdMax, ' '));
-		gfsh.print("  ");
-		gfsh.print(StringUtil.getRightPaddedString(memberNameHeader, memberNameMax, ' '));
-		gfsh.print("  ");
-		gfsh.println(regionSizeHeader);
-		gfsh.print(StringUtil.getRightPaddedString("---------", memberIdMax, ' '));
-		gfsh.print("  ");
-		gfsh.print(StringUtil.getRightPaddedString("-----------", memberNameMax, ' '));
-		gfsh.print("  ");
-		gfsh.println(StringUtil.getRightPaddedString("-----------", regionSizeMax, ' '));
-		
-		int totalRegionSize = 0;
-		for (int i = 0; i < keyList.size(); i++) {
-			Mappable info = infoMap.get(keyList.get(i));
-			try {
-				if (info.getByte("Code") == AggregateResults.CODE_ERROR) {
-					gfsh.println("Error: " + info.getString("CodeMessage"));
-					return;
-				}
-			} catch (Exception ex) {
-				// ignore
-			}
-			isPR = info.getBoolean("IsPR");
-			gfsh.print(StringUtil.getRightPaddedString(info.getString("MemberId"), memberIdMax, ' '));
-			gfsh.print("  ");
-			gfsh.print(StringUtil.getRightPaddedString(info.getString("MemberName"), memberNameMax, ' '));
-			gfsh.print("  ");
-			gfsh.println(StringUtil.getLeftPaddedString(Integer.toString(info.getInt("RegionSize")), regionSizeMax, ' '));
-			totalRegionSize += info.getInt("RegionSize");
-		}
-		
-		gfsh.println();
-		if (isPR) {
-			gfsh.print(StringUtil.getLeftPaddedString("Total: ", 
-					memberIdMax + memberNameMax + 2*2, ' '));
-			gfsh.println(StringUtil.getLeftPaddedString(Integer.toString(totalRegionSize), regionSizeMax, ' '));
-		}
-		gfsh.println();
-		if (gfsh.isShowTime()) {
-			gfsh.println("elapsed (msec): " + (stopTime - startTime));
-		}
-	}
-	
-	private void size_s(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		String regionPath;
-		if (list.size() == 2) {
-			regionPath = gfsh.getCurrentPath();
-		} else {
-			regionPath = (String) list.get(2);
-		}
-		regionPath = regionPath.trim();
-		if (regionPath.equals("/")) {
-			gfsh.println("Error: Invalid path. Root path not allowed.");
-			return;
-		}
-		
-		regionPath = gfsh.getFullPath(regionPath, gfsh.getCurrentPath());
-		
-		gfsh.println("            Region: " + regionPath);
-		
-		// Local region
-		Cache cache = gfsh.getCache();
-		Region region = cache.getRegion(regionPath);
-		if (region == null) {
-			gfsh.println("Error: region undefine - " + regionPath);
-		} else {
-			gfsh.println(" Local region size: " + region.size());
-		}
-		
-		// Server region
-		CommandResults results = gfsh.getCommandClient().execute(new RegionSizeTask(regionPath));
-		Object obj = results.getDataObject();
-		if (obj == null) {
-			gfsh.println("Error: Unable to get size from the server - " + results.getCodeMessage());
-		} else {
-			ArrayList sizeList = new ArrayList(2);
-			sizeList.add(results.getDataObject());
-			PrintUtil.printMappableList(sizeList);
-		}
-	}
-	
-	
-//	private void size(String command) throws Exception
-//	{
-//		LinkedList list = new LinkedList();
-//		gfsh.parseCommand(command, list);
-//
-//		if (list.size() < 2) {
-//			gfsh.println("Error: size requires <query predicate>");
-//		} else {
-//			Object queryKey = gfsh.getQueryKey(list);
-//			if (queryKey == null) {
-//				return;
-//			}
-//			int size = gfsh.getLookupService().size(gfsh.getQueryRegionPath(), queryKey);
-//			gfsh.println("Size: " + size);
-//		}
-//
-//	}
-
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/value.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/value.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/value.java
deleted file mode 100644
index a689051..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/value.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-
-public class value implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public value(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("value [-?] <class name>");
-		gfsh.println("     Set the value class to be used for the 'put' command.");
-		gfsh.println("     Use the 'key' command to set the key class name.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("value -?")) {
-			help();
-		} else {
-			value(command);
-		}
-	}
-	
-	private void value(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		if (list.size() < 2) {
-			gfsh.println("value = " + gfsh.getValueClassName());
-			gfsh.println("   Use value <class name> to set the value class");
-		} else {
-			if (list.size() > 1) {
-				gfsh.setValueClass((String) list.get(1));
-			}
-		}
-	}
-	
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/which.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/which.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/which.java
deleted file mode 100644
index 8d3ac52..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/which.java
+++ /dev/null
@@ -1,189 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-import com.gemstone.gemfire.internal.tools.gfsh.app.aggregator.Aggregator;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.data.MemberInfo;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshFunction;
-import com.gemstone.gemfire.internal.tools.gfsh.app.util.PrintUtil;
-
-public class which implements CommandExecutable
-{
-	private Gfsh gfsh;
-
-	public which(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-
-	public void help()
-	{
-		gfsh.println("which [-p <region path>] [-r] <query predicate> | -k <number> | [-?]");
-		gfsh.println("     Show the members and regions that have the specified key.");
-		gfsh.println("     -p <region path> The region path in which to find the specified key.");
-		gfsh.println("     -r Search recursively. It search all of the subregions including");
-		gfsh.println("        the specified region or the current region if not specified.");
-		gfsh.println("     -k <number>   Use an enumerated key. Use 'ls -k' to get the list");
-		gfsh.println("            of enumerated keys. Only one key number is supported.");
-		gfsh.println("     <query predicate>: field=val1 and field2='val1' \\");
-		gfsh.println("                        and field3=to_date('<date>', '<format>'");
-		gfsh.println("     Data formats: primitives, String, and java.util.Date");
-		gfsh.println("         <decimal>b|B - Byte      (e.g., 1b)");
-		gfsh.println("         <decimal>c|C - Character (e.g., 1c)");
-		gfsh.println("         <decimal>s|S - Short     (e.g., 12s)");
-		gfsh.println("         <decimal>i|I - Integer   (e.g., 15 or 15i)");
-		gfsh.println("         <decimal>l|L - Long      (e.g., 20l");
-		gfsh.println("         <decimal>f|F - Float     (e.g., 15.5 or 15.5f)");
-		gfsh.println("         <decimal>d|D - Double    (e.g., 20.0d)");
-		gfsh.println("         '<string with \\ delimiter>' (e.g., '\\'Wow!\\'!' Hello, world')");
-		gfsh.println("         to_date('<date string>', '<simple date format>'");
-		gfsh.println("                       (e.g., to_date('04/10/2009', 'MM/dd/yyyy')");
-		gfsh.println("Examples: ");
-		gfsh.println("      which 'string'  -- string key");
-		gfsh.println("      which 10f  -- float key");
-		gfsh.println("      which -k 1");
-		gfsh.println("      which -p /foo/yong -r x=10.0 and y=1 and date=to_date('04/10/2009', 'MM/dd/yyyy')");
-		gfsh.println();
-	}
-
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("which -?")) {
-			help();
-		} else {
-			which(command);
-		}
-	}
-
-	private Object getKeyFromInput(List list, int index) throws Exception
-	{
-		String input = (String) list.get(index);
-		Object key = null;
-		if (input.startsWith("'")) {
-			int lastIndex = -1;
-			if (input.endsWith("'") == false) {
-				lastIndex = input.length();
-			} else {
-				lastIndex = input.lastIndexOf("'");
-			}
-			if (lastIndex <= 1) {
-				gfsh.println("Error: Invalid key. Empty string not allowed.");
-				return null;
-			}
-			key = input.substring(1, lastIndex); // lastIndex exclusive
-		} else {
-			key = gfsh.getQueryKey(list, index);
-		}
-		return key;
-	}
-
-	private void which(String command) throws Exception
-	{
-		LinkedList<String> list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		if (list.size() < 2) {
-			gfsh.println("Error: 'which' requires a query predicate or key number");
-			return;
-		}
-
-		String regionPath = gfsh.getCurrentPath();
-		boolean recursive = false;
-		Object key = null;
-		for (int i = 1; i < list.size(); i++) {
-			String token = list.get(i);
-			if (token.equals("-p")) {
-				if (i + 1 >= list.size()) {
-					gfsh.println("Error: '-p' requires region path");
-					return;
-				}
-				regionPath = list.get(++i);
-			} else if (token.equals("-r")) {
-				recursive = true;
-			} else if (token.equals("-k")) {
-				if (i + 1 >= list.size()) {
-					gfsh.println("Error: '-k' requires key number");
-					return;
-				}
-				int keyNum = Integer.parseInt((String) list.get(++i));
-				key = gfsh.getKeyFromKeyList(keyNum);
-				break;
-			} else {
-				int inputIndex = i;
-				key = getKeyFromInput(list, inputIndex);
-				break;
-			}
-		}
-
-		if (key == null) {
-			gfsh.println("Error: Key is not defined.");
-			return;
-		}
-		executeWhich(regionPath, key, recursive);
-	}
-
-	private void executeWhich(String regionPath, Object key, boolean recursive) throws Exception
-	{
-		String currentPath = gfsh.getCurrentPath();
-		String fullPath = gfsh.getFullPath(regionPath, currentPath);
-
-		Aggregator aggregator = gfsh.getAggregator();
-		long startTime = System.currentTimeMillis();
-		List<AggregateResults> results = (List<AggregateResults>) gfsh.getAggregator().aggregate(
-				new GfshFunction("which", fullPath, new Object[] { key, recursive }), gfsh.getAggregateRegionPath());
-		long stopTime = System.currentTimeMillis();
-
-		int i = 0;
-		for (AggregateResults aggregateResults : results) {
-			GfshData data = (GfshData) aggregateResults.getDataObject();
-			if (aggregateResults.getCode() == AggregateResults.CODE_ERROR) {
-				gfsh.println("Error: " + aggregateResults.getCodeMessage());
-				if (gfsh.isDebug() && aggregateResults.getException() != null) {
-					aggregateResults.getException().printStackTrace();
-				}
-				break;
-			}
-			Object value = data.getDataObject();
-			if (value != null) {
-				MemberInfo memberInfo = data.getMemberInfo();
-				Map map = (Map) value;
-				Set<Map.Entry> entrySet = map.entrySet();
-				if (map != null && map.size() > 0) {
-					i++;
-					gfsh.print(i + ". " + memberInfo.getMemberName() + " (" + memberInfo.getMemberId() + ")");
-					Object obj = data.getUserData();
-					if (obj != null) {
-						if (obj instanceof Map) {
-							Map infoMap = (Map)obj;
-							boolean isPrimary = (Boolean)infoMap.get("IsPrimary");
-							int bucketId = (Integer)infoMap.get("BucketId");
-							if (isPrimary) {
-								gfsh.println(" -- BucketId=" + bucketId + " *Primary PR*");
-							} else {
-								gfsh.println(" -- BucketId=" + bucketId);
-							}
-						}
-					} else {
-						gfsh.println();
-					}
-					PrintUtil.printEntries(map, map.size(), null, "Region", "Value", false, gfsh.isShowResults());
-					gfsh.println();
-				}
-			}
-		}
-		if (i == 0) {
-			gfsh.println("Key is not found.");
-		}
-		gfsh.println();
-		if (gfsh.isShowTime()) {
-			gfsh.println("elapsed (msec): " + (stopTime - startTime));
-		}
-	}
-
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/zone.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/zone.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/zone.java
deleted file mode 100644
index 4fb2c00..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/commands/zone.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.commands;
-
-import java.util.LinkedList;
-
-import com.gemstone.gemfire.internal.tools.gfsh.app.CommandExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.Gfsh;
-
-public class zone implements CommandExecutable
-{
-	private Gfsh gfsh;
-	
-	public zone(Gfsh gfsh)
-	{
-		this.gfsh = gfsh;
-	}
-	
-	public void help()
-	{
-		gfsh.println("zone [-?] <hours>");
-		gfsh.println("     Set the zone difference. This value is added to all time-related data.");
-		gfsh.println("     For example, set this value to -3 if the data in the cache is");
-		gfsh.println("     timestamped in EST and you are running this program in PST.");
-		gfsh.println();
-	}
-	
-	public void execute(String command) throws Exception
-	{
-		if (command.startsWith("zone -?")) {
-			help();
-		} else {
-			zone(command);
-		}
-	}
-	
-	// zone hours
-	// zone -3
-	private void zone(String command) throws Exception
-	{
-		LinkedList list = new LinkedList();
-		gfsh.parseCommand(command, list);
-		if (list.size() < 2) {
-			gfsh.println("zone = " + gfsh.getZoneDifference() / (60 * 60 * 1000));
-			gfsh.println("   Use zone <hours> to change the zone hour difference");
-		} else {
-			int hours = Integer.parseInt((String) list.get(1));
-			gfsh.setZoneDifference(hours * 60 * 60 * 1000L);//FindBugs - integer multiplication cast to long
-		}
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshData.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshData.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshData.java
deleted file mode 100644
index 1d8c631..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshData.java
+++ /dev/null
@@ -1,86 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-
-import com.gemstone.gemfire.DataSerializable;
-import com.gemstone.gemfire.DataSerializer;
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.distributed.DistributedMember;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.data.MemberInfo;
-
-public class GfshData implements DataSerializable
-{
-	private static final long serialVersionUID = 1L;
-	
-	private MemberInfo memberInfo;
-	private Object dataObject;
-	private Object userData;
-	
-	public GfshData() {}
-	
-	public GfshData(Object dataObject)
-	{
-		Cache cache = CacheFactory.getAnyInstance();
-		memberInfo = new MemberInfo();
-		DistributedMember member = cache.getDistributedSystem().getDistributedMember();
-		memberInfo.setHost(member.getHost());
-		memberInfo.setMemberId(member.getId());
-		memberInfo.setMemberName(cache.getName());
-		memberInfo.setPid(member.getProcessId());
-		
-		this.dataObject = dataObject;
-	}
-	
-	public GfshData(MemberInfo memberInfo, Object dataObject)
-	{
-		this.memberInfo = memberInfo;
-		this.dataObject = dataObject;
-	}
-
-	public MemberInfo getMemberInfo()
-	{
-		return memberInfo;
-	}
-
-	public void setMemberInfo(MemberInfo memberInfo)
-	{
-		this.memberInfo = memberInfo;
-	}
-
-	public Object getDataObject()
-	{
-		return dataObject;
-	}
-
-	public void setDataObject(Object dataObject)
-	{
-		this.dataObject = dataObject;
-	}
-	
-	public Object getUserData()
-	{
-		return userData;
-	}
-
-	public void setUserData(Object userData)
-	{
-		this.userData = userData;
-	}
-
-	public void fromData(DataInput in) throws IOException, ClassNotFoundException
-	{
-		memberInfo = (MemberInfo)DataSerializer.readObject(in);
-		dataObject = DataSerializer.readObject(in);
-		userData = DataSerializer.readObject(in);
-	}
-
-	public void toData(DataOutput out) throws IOException
-	{
-		DataSerializer.writeObject(memberInfo, out);
-		DataSerializer.writeObject(dataObject, out);
-		DataSerializer.writeObject(userData, out);
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshFunction.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshFunction.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshFunction.java
deleted file mode 100644
index 65c7964..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/GfshFunction.java
+++ /dev/null
@@ -1,149 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-
-import com.gemstone.gemfire.DataSerializable;
-import com.gemstone.gemfire.DataSerializer;
-import com.gemstone.gemfire.cache.execute.FunctionContext;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateFunction;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.command.task.data.MemberInfo;
-
-public class GfshFunction implements AggregateFunction, DataSerializable
-{	
-	private static final long serialVersionUID = 1L;
-
-	private String command; 
-	private String regionPath;
-	private Object arg;
-	
-	public GfshFunction()
-	{
-	}
-	
-	public GfshFunction(String command, String regionPath, Object arg)
-	{
-		this.command = command;
-		this.regionPath = regionPath;
-		this.arg = arg;
-	}
-
-	public String getCommand()
-	{
-		return command;
-	}
-
-	public void setCommand(String command)
-	{
-		this.command = command;
-	}
-
-	public Object getArg()
-	{
-		return arg;
-	}
-
-	public void setArg(Object arg)
-	{
-		this.arg = arg;
-	}
-
-	public String getRegionPath() 
-	{
-		return regionPath;
-	}
-
-	public void setRegionPath(String regionPath) 
-	{
-		this.regionPath = regionPath;
-	}
-	
-	public AggregateResults run(FunctionContext context) 
-	{
-		AggregateResults results = new AggregateResults();
-		try {
-			String split[] = command.split(" ");
-			String className = split[0].trim();
-			Class clas = Class.forName("com.gemstone.gemfire.internal.tools.gfsh.app.function.command." + className);
-			ServerExecutable se = (ServerExecutable)clas.newInstance();
-			Object obj = se.execute(command, regionPath, arg);
-			results.setDataObject(obj);
-			results.setCode(se.getCode());
-			results.setCodeMessage(se.getCodeMessage());
-		} catch (Exception ex) {
-			results.setCode(AggregateResults.CODE_ERROR);
-			results.setCodeMessage(getCauseMessage(ex));
-			results.setException(ex);
-		}
-		return results;
-	}
-	
-	private String getCauseMessage(Throwable ex)
-	{
-		Throwable cause = ex.getCause();
-		String causeMessage = null;
-		if (cause != null) {
-			causeMessage = getCauseMessage(cause);
-		} else {
-			causeMessage = ex.getClass().getSimpleName();
-			causeMessage += " -- " + ex.getMessage();
-		}
-		return causeMessage;
-	}
-
-	/**
-	 * Returns a java.util.List of LocalRegionInfo objects;
-	 */
-	public synchronized Object aggregate(List list)
-	{
-		// 5.7: each bucket returns results. Discard all but one that is success
-		MemberInfo info;
-		HashMap map = new HashMap();
-		for (int i = 0; i < list.size(); i++) {
-			AggregateResults results = (AggregateResults)list.get(i);
-			GfshData data = (GfshData)results.getDataObject();
-			if (data == null) {
-				data = new GfshData(null);
-			}
-			info = data.getMemberInfo();
-			AggregateResults mapResults = (AggregateResults)map.get(info.getMemberId());
-			if (mapResults == null) {
-				map.put(info.getMemberId(), results);
-			} else if (mapResults.getCode() != AggregateResults.CODE_NORMAL) {
-				map.put(info.getMemberId(), results);
-			}
-		}
-		
-		return new ArrayList(map.values());
-	}
-	
-	public synchronized Object aggregateDistributedSystems(Object[] results)
-	{
-		ArrayList list = new ArrayList();
-		for (int i = 0; i < results.length; i++) {
-			list.add(results[i]);
-		}
-		return list;
-	}
-	
-	public void fromData(DataInput input) throws IOException, ClassNotFoundException 
-	{
-		command = DataSerializer.readString(input);
-		regionPath = DataSerializer.readString(input);
-		arg = DataSerializer.readObject(input);
-	}
-
-	public void toData(DataOutput output) throws IOException 
-	{
-		DataSerializer.writeString(command, output);
-		DataSerializer.writeString(regionPath, output);
-		DataSerializer.writeObject(arg, output);
-	}
-	
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/clear.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/clear.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/clear.java
deleted file mode 100644
index 24a5c36..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/clear.java
+++ /dev/null
@@ -1,95 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.util.Iterator;
-import java.util.Set;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.partition.PartitionRegionHelper;
-import com.gemstone.gemfire.internal.cache.BucketRegion;
-import com.gemstone.gemfire.internal.cache.LocalDataSet;
-import com.gemstone.gemfire.internal.cache.PartitionedRegion;
-import com.gemstone.gemfire.internal.cache.ProxyBucketRegion;
-import com.gemstone.gemfire.internal.cache.partitioned.Bucket;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.MapMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class clear implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		Cache cache = CacheFactory.getAnyInstance();
-		Region region = cache.getRegion(regionPath);
-		
-		if (region == null) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = "Undefined region: " + regionPath;
-			return null;
-		}
-		
-		MapMessage message = new MapMessage();
-		
-		if (region instanceof PartitionedRegion) {
-			PartitionedRegion pr = (PartitionedRegion)region;
-			if (pr.getDataStore() == null) {
-				code = AggregateResults.CODE_NORMAL;
-				codeMessage = "No data store: " + regionPath;
-				message.put("IsPeerClient", true);
-				return new GfshData(message);
-			}
-		}
-
-		message.put("IsPeerClient", false);
-		try {
-			synchronized (region) {
-				if (region instanceof PartitionedRegion) {
-					// PR clear is not supported. Must clear the local data set
-					// individually.
-					clearPartitionedRegion((PartitionedRegion)region);
-				} else {
-					region.clear();
-				}
-				codeMessage = "Cleared";
-			}
-		} catch (Exception ex) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = ex.getMessage();
-		}
-		return new GfshData(message);
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-	
-	private void clearPartitionedRegion(PartitionedRegion partitionedRegion)
-	{
-		LocalDataSet lds = (LocalDataSet)PartitionRegionHelper.getLocalPrimaryData(partitionedRegion);
-		Set<Integer>set = lds.getBucketSet(); // this returns bucket ids in the function context 
-		for (Integer bucketId : set) {
-			Bucket bucket = partitionedRegion.getRegionAdvisor().getBucket(bucketId);
-			if (bucket instanceof ProxyBucketRegion == false) {
-				if (bucket instanceof BucketRegion) {
-					BucketRegion bucketRegion = (BucketRegion) bucket;
-					Set keySet = bucketRegion.keySet();
-					for (Iterator iterator = keySet.iterator(); iterator.hasNext();) {
-						Object key = iterator.next();
-						bucketRegion.remove(key);
-					}
-				}
-			}
-		}
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/deploy.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/deploy.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/deploy.java
deleted file mode 100644
index 1935815..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/deploy.java
+++ /dev/null
@@ -1,111 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.lang.reflect.Method;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-import com.gemstone.gemfire.internal.tools.gfsh.app.misc.util.ClassFinder;
-import com.gemstone.gemfire.internal.tools.gfsh.app.misc.util.SystemClassPathManager;
-import com.gemstone.gemfire.internal.tools.gfsh.app.pogo.KeyType;
-import com.gemstone.gemfire.internal.tools.gfsh.app.pogo.KeyTypeManager;
-
-public class deploy implements ServerExecutable
-{
-	private final static String ENV_GEMFIRE_HOME = "GEMFIRE";
-	
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	private final static SimpleDateFormat dateFormatter = new SimpleDateFormat("yyyyMMddHHmm");
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		GfshData data = new GfshData(null);
-		
-		Cache cache = CacheFactory.getAnyInstance();
-		
-		Object[] args = (Object[])arg;
-		
-		String operationType = (String)args[0];
-		if (operationType.equals("-jar")) {
-			String jarNames[] = (String[])args[1];
-			byte byteBuffers[][] = (byte[][])args[2];
-			try {
-				String home = System.getenv(ENV_GEMFIRE_HOME);
-				String classDir = home + "/gfsh/plugins";
-				File classDirFile = new File(classDir);
-				classDirFile.mkdirs();
-		
-				// Store the jar files
-				String datedFilePaths[] = new String[jarNames.length];
-				for (int i = 0; i < byteBuffers.length; i++) {
-					String filePath = classDir + "/" + getDatedJarName(jarNames[i]);
-					datedFilePaths[i] = filePath;
-					File file = new File(filePath);
-					FileOutputStream fos = new FileOutputStream(file);
-					fos.write(byteBuffers[i]);
-					fos.close();
-				}
-				
-				// Add the jars to the class path
-				for (int i = 0; i < datedFilePaths.length; i++) {
-					File file = new File(datedFilePaths[i]);
-					SystemClassPathManager.addFile(file);
-				}
-				
-				// Register KeyTypes
-				for (int i = 0; i < datedFilePaths.length; i++) {
-					Class[] classes = ClassFinder.getAllClasses(datedFilePaths[i]);
-					for (int j = 0; j < classes.length; j++) {
-						Class<?> cls = classes[j];
-						if (KeyType.class.isAssignableFrom(cls) && 
-							cls.getSimpleName().matches(".*_v\\d++$")) 
-						{
-							Method method = cls.getMethod("getKeyType", (Class[])null);
-							KeyType fieldType = (KeyType)method.invoke(cls, (Object[])null);
-							KeyTypeManager.registerSingleKeyType(fieldType);
-						}
-					}
-				}
-				
-				codeMessage = "deployed to " + classDirFile.getAbsolutePath();
-			} catch (Exception ex) {
-				while (ex.getCause() != null) {
-					ex = (Exception)ex.getCause();
-				}
-				codeMessage = ex.getMessage();
-				if (codeMessage != null) 
-					codeMessage = codeMessage.trim();
-				if (codeMessage == null || codeMessage.length() == 0) {
-					codeMessage = ex.getClass().getSimpleName();
-				}
-			}
-			
-			data.setDataObject(codeMessage);
-		}
-		
-		return data;
-	}
-	
-	private static String getDatedJarName(String jarName)
-	{
-		String nameNoExtension = jarName.substring(0, jarName.lastIndexOf(".jar"));
-		return nameNoExtension + ".v" + dateFormatter.format(new Date()) + ".jar";
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/gc.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/gc.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/gc.java
deleted file mode 100644
index e59568b..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/gc.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
-
-public class gc implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	
-	@SuppressFBWarnings(value="DM_GC",justification="This is the desired functionality")
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		String memberId = (String)arg;
-		
-		if (memberId != null) {
-			Cache cache = CacheFactory.getAnyInstance();
-			String thisMemberId = cache.getDistributedSystem().getDistributedMember().getId();
-			if (memberId.equals(thisMemberId) == false) {
-				return new GfshData(null);
-			}
-		}
-		
-		try {
-			Runtime.getRuntime().gc(); //FindBugs - extremely dubious except in benchmarking code
-		} catch (Exception ex) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = ex.getMessage();
-		}
-		
-		return new GfshData(null);
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/index.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/index.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/index.java
deleted file mode 100644
index 5614df0..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/index.java
+++ /dev/null
@@ -1,199 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.query.Index;
-import com.gemstone.gemfire.cache.query.IndexStatistics;
-import com.gemstone.gemfire.cache.query.IndexType;
-import com.gemstone.gemfire.cache.query.QueryService;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.MapMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.Mappable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class index implements ServerExecutable
-{
-	public static enum DeleteType {
-		DELETE_INDEX,
-		DELETE_REGION_INDEXES,
-		DELETE_ALL_INDEXES
-	}
-	
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		GfshData data = new GfshData(null);
-		
-		Cache cache = CacheFactory.getAnyInstance();
-		
-		Region region = null;
-		if (regionPath != null) {
-			region = cache.getRegion(regionPath);
-		}
-		
-		String thisMemberId = cache.getDistributedSystem().getDistributedMember().getId();
-		QueryService qs = cache.getQueryService();
-		
-		Object[] args = (Object[])arg;
-		String memberId = null;
-		String indexName = null;
-		IndexType indexType;
-		boolean isFunctional;
-		String indexExpression;
-		String fromClause;
-		String imports;
-		
-		String operationType = (String)args[0];
-		if (operationType.equals("-create")) {
-			
-			memberId = (String)args[1];
-			if (memberId != null && memberId.equals(thisMemberId) == false) {
-				return data;
-			}
-			
-			indexName = (String)args[2];
-			isFunctional = (Boolean)args[3];
-			if (isFunctional) {
-				indexType = IndexType.FUNCTIONAL;
-			} else {
-				indexType = IndexType.PRIMARY_KEY;
-			}
-			indexExpression = (String)args[4];
-			fromClause = (String)args[5];
-			imports = (String)args[6];
-			
-			try {
-				Index index = qs.createIndex(indexName, indexType, indexExpression, fromClause, imports);
-				codeMessage = "index created: " + indexName;
-			} catch (Exception ex) {
-				while (ex.getCause() != null) {
-					ex = (Exception)ex.getCause();
-				}
-				codeMessage = ex.getMessage();
-				if (codeMessage != null) 
-					codeMessage = codeMessage.trim();
-				if (codeMessage == null || codeMessage.length() == 0) {
-					codeMessage = ex.getClass().getSimpleName();
-				}
-			}
-			
-			data.setDataObject(codeMessage);
-			
-		} else if (operationType.equals("-delete")) {
-			
-			DeleteType deleteType = (DeleteType)args[1];
-			
-			memberId = (String)args[2];
-			if (memberId != null && memberId.equals(thisMemberId) == false) {
-				return data;
-			}
-			indexName = (String)args[3];
-			
-			switch (deleteType) {
-			case DELETE_ALL_INDEXES:
-				qs.removeIndexes();
-				codeMessage = "all indexes deleted from the member";
-				break;
-				
-			case DELETE_REGION_INDEXES:
-				try {
-					qs.removeIndexes(region);
-					codeMessage = "all indexes deleted from " + region.getFullPath();
-				} catch (Exception ex) {
-					codeMessage = ex.getMessage();
-				}
-				break;
-				
-			case DELETE_INDEX:
-				Index index = qs.getIndex(region, indexName);
-				if (index == null) {
-					codeMessage = "index does not exist";
-				} else {
-					try {
-						qs.removeIndex(index);
-						codeMessage = "index deleted from " + region.getFullPath();
-					} catch (Exception ex) {
-						codeMessage = ex.getMessage();
-						if (codeMessage != null) 
-							codeMessage = codeMessage.trim();
-						if (codeMessage == null || codeMessage.length() == 0) {
-							codeMessage = ex.getClass().getSimpleName();
-						}
-					}
-				}
-				break;
-			}
-			data.setDataObject(codeMessage);
-
-		} else if (operationType.equals("-list")) {
-			
-			memberId = (String)args[1];
-			if (memberId != null && memberId.equals(thisMemberId) == false) {
-				return data;
-			}
-			
-			boolean isAll = (Boolean)args[2];
-			boolean isStats = (Boolean)args[3];
-			
-			Collection<Index> col = null;
-			if (isAll) {
-				col = qs.getIndexes();
-			} else if (region != null) {
-				col = qs.getIndexes(region);
-			} else {
-				codeMessage = "Invalid index command. Region path not specified.";
-				data.setDataObject(codeMessage);
-				return data;
-			}
-			
-			List<Mappable> mappableList = new ArrayList();
-			for (Index index : col) {
-				indexName = index.getName();
-				String type = index.getType().toString();
-				indexExpression = index.getIndexedExpression();
-				fromClause = index.getFromClause();
-				
-				MapMessage mapMessage = new MapMessage();
-				mapMessage.put("Name", indexName);
-				mapMessage.put("Type", type);
-				mapMessage.put("Expression", indexExpression);
-				mapMessage.put("From", fromClause);
-				if (isStats) {
-					try {
-						IndexStatistics stats = index.getStatistics();
-						mapMessage.put("Keys", stats.getNumberOfKeys());
-						mapMessage.put("Values", stats.getNumberOfValues());
-						mapMessage.put("Updates", stats.getNumUpdates());
-						mapMessage.put("TotalUpdateTime", stats.getTotalUpdateTime());
-						mapMessage.put("TotalUses", stats.getTotalUses());
-					} catch (Exception ex) {
-						// index not supported for pr
-					}
-				}
-				
-				mappableList.add(mapMessage);
-			}
-			data.setDataObject(mappableList);
-		}
-		
-		return data;
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/ls.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/ls.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/ls.java
deleted file mode 100644
index ace1161..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/ls.java
+++ /dev/null
@@ -1,80 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.util.List;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.server.CacheServer;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.ListMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.MapMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class ls implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		Region region = CacheFactory.getAnyInstance().getRegion(regionPath);
-		if (region == null) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = "Undefined region: " + regionPath;
-			return null;
-		}
-		
-		Cache cache = region.getCache();
-		ListMessage topMessage = new ListMessage();
-		if (command.startsWith("ls -c")) {
-			List<CacheServer> cacheServerList = cache.getCacheServers();
-			if (cacheServerList.size() > 0) {
-				for (CacheServer cacheServer : cacheServerList) {
-					MapMessage cacheServerMessage = new MapMessage();
-					String groups[] = cacheServer.getGroups();
-					if (groups.length > 0) {
-						String groupsStr = "";
-						for (int i = 0; i < groups.length; i++) {
-							groupsStr += groups[i];
-							if (i < groups.length - 1) {
-								groupsStr += ", ";
-							}
-						}
-						cacheServerMessage.put("ServerGroups", groupsStr);
-					} else {
-						cacheServerMessage.put("ServerGroups", "");
-					}
-					
-					cacheServerMessage.put("BindAddress", cacheServer.getBindAddress());
-					cacheServerMessage.put("HostnameForClients", cacheServer.getHostnameForClients());
-					cacheServerMessage.put("LoadPollInterval", cacheServer.getLoadPollInterval());
-					cacheServerMessage.put("MaxConnections", cacheServer.getMaxConnections());
-					cacheServerMessage.put("MaximumMessageCount", cacheServer.getMaximumMessageCount());
-					cacheServerMessage.put("MaximumTimeBetweenPings", cacheServer.getMaximumTimeBetweenPings());
-					cacheServerMessage.put("MaxThreads", cacheServer.getMaxThreads());
-					cacheServerMessage.put("MessageTimeToLive", cacheServer.getMessageTimeToLive());
-					cacheServerMessage.put("NotifyBySubscription", cacheServer.getNotifyBySubscription());
-					cacheServerMessage.put("Port", cacheServer.getPort());
-					cacheServerMessage.put("SocketBufferSize", cacheServer.getSocketBufferSize());
-					cacheServerMessage.put("TcpNoDelay", cacheServer.getTcpNoDelay());
-					
-					topMessage.add(cacheServerMessage);
-				}
-			}
-		}
-		
-		return new GfshData(topMessage);
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/pr.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/pr.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/pr.java
deleted file mode 100644
index 4c991eb..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/pr.java
+++ /dev/null
@@ -1,118 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Set;
-import java.util.TreeMap;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.distributed.DistributedMember;
-import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember;
-import com.gemstone.gemfire.internal.cache.BucketRegion;
-import com.gemstone.gemfire.internal.cache.PartitionedRegion;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.MapMessage;
-import com.gemstone.gemfire.internal.tools.gfsh.app.cache.data.Mappable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class pr implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		Cache cache = CacheFactory.getAnyInstance();
-		
-		Object args[] = (Object[])arg;
-		
-		GfshData data = new GfshData(null);
-		try {
-			// Find the value from the partitioned region
-			if (regionPath == null || regionPath.equals("/")) {
-				code = AggregateResults.CODE_ERROR;
-				codeMessage = "Invalid region path " + regionPath;
-				return data;
-			}
-			Region region = cache.getRegion(regionPath);
-			if (region == null) {
-				code = AggregateResults.CODE_ERROR;
-				codeMessage = "Undefined region " + regionPath;
-				return data;
-			}
-			if (region instanceof PartitionedRegion == false) {
-				code = AggregateResults.CODE_ERROR;
-				codeMessage = "Not a partitioned region: " + regionPath;
-				return data;
-			}
-		
-			DistributedMember member = cache.getDistributedSystem().getDistributedMember();
-			
-//			PartitionRegionInfoImpl info = (PartitionRegionInfoImpl)PartitionRegionHelper.getPartitionRegionInfo(region);
-//			info.getLowRedundancyBucketCount();
-			PartitionedRegion pr = (PartitionedRegion)region;
-			if (pr.getDataStore() == null) {
-				// PROXY - no data store
-				code = AggregateResults.CODE_NORMAL;
-				codeMessage = "No data store: " + regionPath;
-				data.setUserData(pr.getPartitionAttributes().getTotalNumBuckets());
-				return data;
-			}
-			Set<BucketRegion> set2 = pr.getDataStore().getAllLocalBucketRegions();
-//			FindBugs - Unused
-//			TreeMap primaryMap = new TreeMap();
-//			TreeMap redundantMap = new TreeMap();
-//			for (BucketRegion br : set2) {
-//				TreeMap map = new TreeMap();
-//				map.put("Size", br.size());
-//				map.put("Bytes", br.getTotalBytes());
-//				InternalDistributedMember m = pr.getBucketPrimary(br.getId());
-//				if (m.getId().equals(member.getId())) {
-//					primaryMap.put(br.getId(), map);
-//				} else {
-//					redundantMap.put(br.getId(), map);
-//				}
-//			}
-			List<Mappable> primaryList = new ArrayList<Mappable>();
-			List<Mappable> redundantList = new ArrayList<Mappable>();
-			for (BucketRegion br : set2) {
-				MapMessage map = new MapMessage();
-				map.put("BucketId", br.getId());
-				map.put("Size", br.size());
-				map.put("Bytes", br.getTotalBytes());
-				InternalDistributedMember m = pr.getBucketPrimary(br.getId());
-				if (m.getId().equals(member.getId())) {
-					primaryList.add(map);
-				} else {
-					redundantList.add(map);
-				}
-			}
-			
-			TreeMap map = new TreeMap();
-//			map.put("Primary", primaryMap);
-//			map.put("Redundant", redundantMap);
-			map.put("Primary", primaryList);
-			map.put("Redundant", redundantList);
-			data.setDataObject(map);
-			data.setUserData(pr.getPartitionAttributes().getTotalNumBuckets());
-			
-		} catch (Exception ex) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = ex.getMessage();
-		}
-		return data;
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rebalance.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rebalance.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rebalance.java
deleted file mode 100644
index 29cee32..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rebalance.java
+++ /dev/null
@@ -1,129 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import java.util.Map;
-import java.util.Set;
-import java.util.TreeMap;
-import java.util.concurrent.CancellationException;
-import java.util.concurrent.TimeUnit;
-
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.control.RebalanceOperation;
-import com.gemstone.gemfire.cache.control.RebalanceResults;
-import com.gemstone.gemfire.cache.control.ResourceManager;
-import com.gemstone.gemfire.cache.partition.PartitionRebalanceInfo;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class rebalance implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		GfshData data = new GfshData(null);
-		Cache cache = CacheFactory.getAnyInstance();
-		
-		// args[0] = memberId
-		// args[1] = simulate optional (default true)
-		// args[2] = timeout optional (default 20000 mesec)
-		
-		Object args[] = (Object[])arg;
-		boolean simulate = true;
-		String memberId = null;
-		if (args != null && args.length > 0) {
-			memberId = args[0].toString();
-		} else {
-			return data;
-		}
-		if (args.length > 1) {
-			if (args[1] instanceof Boolean) {
-				simulate = (Boolean)args[1];
-			}
-		}
-		long timeout = 60000; // 60 sec default
-		if (args.length > 2) {
-			timeout = (Long)args[2];
-		}
-
-		String thisMemberId = cache.getDistributedSystem().getDistributedMember().getId();
-		if (memberId.equals(thisMemberId) == false) {
-			return data;
-		}
-		
-		try {
-			Map map = null;
-			if (simulate) {
-				map = simulate();
-			} else {
-				map = rebalance(timeout);
-			}
-			data.setDataObject(map);
-		} catch (Exception ex) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = ex.getMessage();
-		}
-		return data;
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-
-	private Map rebalance(long timeout) throws CancellationException, InterruptedException
-	{
-		Cache cache = CacheFactory.getAnyInstance();
-		ResourceManager manager = cache.getResourceManager();
-		RebalanceOperation op = manager.createRebalanceFactory().start();
-
-		// Timeout if it's taking too long. Rebalancing will still complete.
-		try {
-			RebalanceResults results = op.getResults(timeout, TimeUnit.MILLISECONDS);	
-			return convertToMap(results);
-		} catch (Exception ex) {
-			return null;
-		}
-	}
-
-	private Map simulate() throws CancellationException, InterruptedException
-	{
-		Cache cache = CacheFactory.getAnyInstance();
-		ResourceManager manager = cache.getResourceManager();
-		RebalanceOperation op = manager.createRebalanceFactory().simulate();
-		RebalanceResults results = op.getResults();
-		Set<PartitionRebalanceInfo> set = results.getPartitionRebalanceDetails();
-		return convertToMap(results);
-	}
-	
-	private TreeMap convertToMap(RebalanceResults results)
-	{
-		TreeMap map = new TreeMap();
-//		if (results.getPartitionRebalanceDetails() != null) {
-//			map.put("RebalanceDetails", results.getPartitionRebalanceDetails());
-//		}
-//		Set<PartitionRebalanceInfo> set = results.getPartitionRebalanceDetails();
-//		if (set != null) {
-//			for (PartitionRebalanceInfo info : set) {
-//				info.
-//			}
-//		}
-		map.put("TotalBucketCreateBytes", results.getTotalBucketCreateBytes());
-		map.put("TotalBucketCreatesCompleted", results.getTotalBucketCreatesCompleted());
-		map.put("TotalBucketCreateTime", results.getTotalBucketCreateTime());
-		map.put("TotalBucketTransferBytes", results.getTotalBucketTransferBytes());
-		map.put("TotalBucketTransfersCompleted", results.getTotalBucketTransfersCompleted());
-		map.put("TotalBucketTransferTime", results.getTotalBucketTransferTime());
-		map.put("TotalPrimaryTransfersCompleted", results.getTotalPrimaryTransfersCompleted());
-		map.put("TotalPrimaryTransferTime", results.getTotalPrimaryTransferTime());
-		map.put("TotalTime", results.getTotalTime());
-		return map;
-	}
-}

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/49d99d4e/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rm.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rm.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rm.java
deleted file mode 100644
index 0ca99aa..0000000
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/tools/gfsh/app/function/command/rm.java
+++ /dev/null
@@ -1,43 +0,0 @@
-package com.gemstone.gemfire.internal.tools.gfsh.app.function.command;
-
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.internal.tools.gfsh.aggregator.AggregateResults;
-import com.gemstone.gemfire.internal.tools.gfsh.app.ServerExecutable;
-import com.gemstone.gemfire.internal.tools.gfsh.app.function.GfshData;
-
-public class rm implements ServerExecutable
-{
-	private byte code = AggregateResults.CODE_NORMAL;
-	private String codeMessage = null;
-	
-	public Object execute(String command, String regionPath, Object arg) throws Exception
-	{
-		Region region = CacheFactory.getAnyInstance().getRegion(regionPath);
-		if (region == null) {
-			code = AggregateResults.CODE_ERROR;
-			codeMessage = "Undefined region: " + regionPath;
-			return null;
-		}
-		Object[] keys = (Object[])arg;
-		
-		for (int i = 0; i < keys.length; i++) {
-			try {
-				region.remove(keys[i]);
-			} catch (Exception ex) {
-				// ignore
-			}
-		}
-		return new GfshData(null);
-	}
-
-	public byte getCode()
-	{
-		return code;
-	}
-	
-	public String getCodeMessage()
-	{
-		return codeMessage;
-	}
-}



Mime
View raw message