GeodeStore implements KeyValueStore, Serializable { @SuppressWarnings("rawtypes") public SelectResults query(String predicate) { try { return (getRegion().query(predicate)); } catch (FunctionDomainException | TypeMismatchException | NameResolutionException | QueryInvocationTargetException | IOException e) { logger.info("error in querying object ", e); return null; } }  String getRegionName(); ClientCache getClientCache(); int getLocatorPort(); void setLocatorPort(int locatorPort); String getLocatorHost(); void setLocatorHost(String locatorHost); Region<Object, Object> getRegion(); @Override void connect(); @Override void disconnect(); @Override boolean isConnected(); @Override Object get(Object key); @SuppressWarnings("unchecked") @Override List<Object> getAll(List<Object> keys); void setRegionName(String regionName); Map<Object, Object> getAllMap(List<Object> keys); @SuppressWarnings("rawtypes") SelectResults query(String predicate); @Override void put(Object key, Object value); @Override void putAll(Map<Object, Object> map); @Override void remove(Object key);  }
@Test public void testQuery() throws Exception { Map<Object, Object> m = new HashMap<Object, Object>(); m.put("test2_abc", "123"); m.put("test2_def", "456"); geodeStore.putAll(m); String predicate = "Select key,value from /operator.entries where key like 'test2%'"; SelectResults results = geodeStore.query(predicate); Assert.assertEquals(2, results.size()); }