Package com.hazelcast.map.impl

Examples of com.hazelcast.map.impl.MapServiceContext.toObject()

266
267
268
269
270
271
272
273
274
275
276
        final Set<Object> keys = new HashSet<Object>(keySet.size());
        final MapService service = getService();
        final MapServiceContext mapServiceContext = service.getMapServiceContext();
        // convert Data to Object
        for (final Data data : keySet) {
            keys.add(mapServiceContext.toObject(data));
        }

        for (final Map.Entry<Object, TxnValueWrapper> entry : txMap.entrySet()) {
            if (TxnValueWrapper.Type.NEW.equals(entry.getValue().type)) {
                keys.add(entry.getKey());
View Full Code Here
296
297
298
299
300
301
302
303
304
305
306
        final Set<Object> keySet = new HashSet<Object>(queryResultSet);

        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
                        ? mapServiceContext.toObject(entry.getValue().value) : entry.getValue().value;

                final SerializationService ss = getNodeEngine().getSerializationService();
                final QueryEntry queryEntry =
                        new QueryEntry(ss, mapServiceContext.toData(entry.getKey()), entry.getKey(), value);
                // apply predicate on txMap.
View Full Code Here
339
340
341
342
343
344
345
346
347
348
349
            }
        }
        Iterator<Map.Entry<Data, Data>> iterator = entries.iterator();
        while (iterator.hasNext()) {
            final Map.Entry entry = iterator.next();
            Object key = mapServiceContext.toObject(entry.getKey());
            if (keyWontBeIncluded.contains(key)) {
                continue;
            }
            Object value = mapServiceContext.toObject(entry.getValue());
            values.add(value);
View Full Code Here
343
344
345
346
347
348
349
350
351
352
353
            final Map.Entry entry = iterator.next();
            Object key = mapServiceContext.toObject(entry.getKey());
            if (keyWontBeIncluded.contains(key)) {
                continue;
            }
            Object value = mapServiceContext.toObject(entry.getValue());
            values.add(value);
        }
        return values;
    }
View Full Code Here
378
379
380
381
382
383
384
385
386
387
388
                if (isUpdated) {
                    keyWontBeIncluded.add(objectKey);
                }
                Object entryValue = entry.getValue().value;
                final Object objectValue = entryValue instanceof Data
                        ? mapServiceContext.toObject(entryValue) : entryValue;
                Data dataKey = mapServiceContext.toData(objectKey);
                final SerializationService serializationService = getNodeEngine().getSerializationService();
                final QueryEntry queryEntry = new QueryEntry(serializationService, dataKey, objectKey, objectValue);
                if (predicate.apply(queryEntry)) {
                    valueSet.add(entryValue);
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
        return mapEntry.getValue();
    }

    private Object toObject(Object data) {
        final MapServiceContext mapServiceContext = mapService.getMapServiceContext();
        return mapServiceContext.toObject(data);
    }

    private long getNow() {
        return Clock.currentTimeMillis();
    }
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
        return Clock.currentTimeMillis() - begin;
    }

    private Object toObject(Object data) {
        final MapServiceContext mapServiceContext = mapService.getMapServiceContext();
        return mapServiceContext.toObject(data);
    }

    private Data toData(Object obj) {
        final MapServiceContext mapServiceContext = mapService.getMapServiceContext();
        return mapServiceContext.toData(obj);
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.