Examples of PortableCollection

Examples of com.hazelcast.spi.impl.PortableCollection

51
52
53
54
55
56
57
            Collection<Data> coll = response.getCollection();
            if (coll != null) {
                keySet.addAll(coll);
            }
        }
        return new PortableCollection(keySet);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

57
58
59
60
61
62
63
64
65
    @Override
    protected Object filter(Object response) {
        if (response instanceof SerializableCollection) {
            Collection<Data> coll = ((SerializableCollection) response).getCollection();
            return new PortableCollection(coll);
        }
        return super.filter(response);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

50
51
52
53
54
55
56
57
58
    @Override
    protected Object filter(Object response) {
        if (response instanceof SerializableCollection) {
            SerializableCollection serializableCollection = (SerializableCollection) response;
            Collection<Data> coll = serializableCollection.getCollection();
            return new PortableCollection(coll);
        }
        return super.filter(response);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
    protected Object filter(Object response) {
        if (response instanceof MultiMapResponse) {
            Collection<MultiMapRecord> coll = ((MultiMapResponse) response).getCollection();
            if (coll == null) {
                return new PortableCollection();
            }
            Collection<Data> collection = new ArrayList<Data>(coll.size());
            for (MultiMapRecord record : coll) {
                collection.add(serializationService.toData(record.getObject()));
            }
            return new PortableCollection(collection);
        }
        return super.filter(response);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

37
38
39
40
41
42
43
        Collection<Data> coll = createCollection(objects.size());
        for (Object object : objects) {
            final Data data = toData(object);
            coll.add(data);
        }
        return new PortableCollection(coll);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

50
51
52
53
54
55
56
        Collection<Data> coll = createCollection(objects.size());
        for (Object object : objects) {
            final Data data = toData(object);
            coll.add(data);
        }
        return new PortableCollection(coll);
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

49
50
51
52
53
54
55
56
57
58
59
60
        return result;
    }

    public Collection<V> get(K key) {
        TxnMultiMapGetRequest request = new TxnMultiMapGetRequest(getName(), toData(key));
        final PortableCollection portableCollection = invoke(request);
        final Collection<Data> collection = portableCollection.getCollection();
        Collection<V> coll;
        if (collection instanceof List) {
            coll = new ArrayList<V>(collection.size());
        } else {
            coll = new HashSet<V>(collection.size());
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

71
72
73
74
75
76
77
78
79
80
81
82
        return result;
    }

    public Collection<V> remove(Object key) {
        TxnMultiMapRemoveAllRequest request = new TxnMultiMapRemoveAllRequest(getName(), toData(key));
        PortableCollection portableCollection = invoke(request);
        final Collection<Data> collection = portableCollection.getCollection();
        Collection<V> coll;
        if (collection instanceof List) {
            coll = new ArrayList<V>(collection.size());
        } else {
            coll = new HashSet<V>(collection.size());
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
        mm.put("key2", "value1");
        mm.put("key2", "value2");

        final SimpleClient client = getClient();
        client.send(new GetAllRequest(name, ss.toData("key1")));
        PortableCollection result = (PortableCollection) client.receive();
        Collection<Data> coll = result.getCollection();
        assertEquals(1, coll.size());
        assertEquals("value1", ss.toObject(coll.iterator().next()));

        client.send(new GetAllRequest(name, ss.toData("key2")));
        result = (PortableCollection) client.receive();
        coll = result.getCollection();
        assertEquals(2, coll.size());
    }
View Full Code Here

Examples of com.hazelcast.spi.impl.PortableCollection

325
326
327
328
329
330
331
332
333
334
335
336
        mm.put("key2", "value1");
        mm.put("key2", "value2");

        final SimpleClient client = getClient();
        client.send(new KeySetRequest(name));
        PortableCollection result = (PortableCollection) client.receive();
        Collection<Data> keySet = result.getCollection();
        assertEquals(2, keySet.size());

        String s = (String) ss.toObject(keySet.iterator().next());
        assertTrue(s.startsWith("key"));
    }
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.