Examples of MapService

Examples of com.hazelcast.map.MapService

258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
            throw new NullPointerException("Predicate should not be null!");
        }
        if (predicate instanceof PagingPredicate) {
            throw new NullPointerException("Paging is not supported for Transactional queries!");
        }
        final MapService service = getService();
        final QueryResultSet queryResultSet = (QueryResultSet) queryInternal(predicate, IterationType.KEY, false);
        final Set<Object> keySet = new HashSet<Object>(queryResultSet); //todo: Can't we just use the original set?

        for (final Map.Entry<Object, TxnValueWrapper> entry : txMap.entrySet()) {
            if (!TxnValueWrapper.Type.REMOVED.equals(entry.getValue().type)) {
                final Object value = entry.getValue().value instanceof Data ?
                        service.toObject(entry.getValue().value) : entry.getValue().value;
                final QueryEntry queryEntry = new QueryEntry(null, service.toData(entry.getKey()), entry.getKey(), value);
                // apply predicate on txMap.
                if (predicate.apply(queryEntry)) {
                    keySet.add(entry.getKey());
                }
            } else {
View Full Code Here

Examples of com.hazelcast.map.MapService

561
562
563
564
565
566
567
568
569
570
571
572
573
    @Override
    public Map<K, Object> executeOnKeys(Set<K> keys, EntryProcessor entryProcessor) {
        if (keys == null || keys.size() == 0) {
            throw new NullPointerException(NULL_KEY_IS_NOT_ALLOWED);
        }
        MapService service = getService();
        Set<Data> dataKeys = new HashSet<Data>(keys.size());
        for(K key : keys)
        {
            dataKeys.add(service.toData(key, partitionStrategy));
        }
        return executeOnKeysInternal(dataKeys, entryProcessor);
    }
View Full Code Here

Examples of com.hazelcast.map.impl.MapService

65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
    @Override
    public boolean open(NodeEngine nodeEngine) {
        NodeEngineImpl nei = (NodeEngineImpl) nodeEngine;
        InternalPartitionService ps = nei.getPartitionService();
        MapService mapService = nei.getService(MapService.SERVICE_NAME);
        ss = nei.getSerializationService();
        Address partitionOwner = ps.getPartitionOwner(partitionId);
        if (partitionOwner == null) {
            return false;
        }
        RecordStore recordStore = mapService.getMapServiceContext().getRecordStore(partitionId, mapName);
        iterator = recordStore.entrySetData().iterator();
        return true;
    }
View Full Code Here

Examples of org.fusesource.restygwt.examples.client.MapService

40
41
42
43
44
45
46
47
48
49
50
51
    }

    private static final int REQUEST_TIMEOUT = 2000;

    public void testGet() {
        MapService service = GWT.create(MapService.class);
        Map<String, String> map = new LinkedHashMap<String, String>();
        map.put("hello", "world");
        map.put("another", "value");
        service.get(expectResult(new MapResult(map)));
        delayTestFinish(REQUEST_TIMEOUT);
    }
View Full Code Here

Examples of test.component3.MapService

108
109
110
111
112
113
114
115
116
117
118
119
  }

  @Test
  public void testMapInject() {
    MapService mapService = xmlApplicationContext.getBean("mapService");
    Map<Object, Object> map = mapService.getMap();
    // System.out.println("size ================================ "+map.size());
    for (Entry<Object, Object> entry : map.entrySet()) {
      log.info(entry.getKey() + "\t" + entry.getValue());
      if(entry.getKey().getClass().isArray()) {
        Object[] objects = (Object[])entry.getKey();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.