Package com.hazelcast.nio.serialization

Examples of com.hazelcast.nio.serialization.Data.readData()

60
61
62
63
64
65
66
67
68
69
70
        int size = in.readInt();
        dataMap = new HashMap<Long, Data>(size);
        for (int i = 0; i < size; i++) {
            long itemId = in.readLong();
            Data value = new Data();
            value.readData(in);
            dataMap.put(itemId, value);
        }
    }

    public int getId() {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        super.readInternal(in);
        int size = in.readInt();
        if (size > -1) {
            for (int i = 0; i < size; i++) {
                Data data = new Data();
                data.readData(in);
                keys.add(data);
            }
        }
    }
}
View Full Code Here
177
178
179
180
181
182
183
184
185
186
187
            if (binary) {
                byte[] dataBuffer = (byte[]) val;
                ObjectDataInput in = serializationService.createObjectDataInput(dataBuffer);
                Data data = new Data();
                try {
                    data.readData(in);
                } catch (IOException e) {
                    throw new HazelcastException(e);
                }
                return data;
            }
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
                for (Map.Entry<Long, ?> entry : map.entrySet()) {
                    byte[] dataBuffer = (byte[]) entry.getValue();
                    ObjectDataInput in = serializationService.createObjectDataInput(dataBuffer);
                    Data data = new Data();
                    try {
                        data.readData(in);
                    } catch (IOException e) {
                        throw new HazelcastException(e);
                    }
                    dataMap.put(entry.getKey(), data);
                }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    public void readData(ObjectDataInput in) throws IOException {
        int size = in.readInt();
        values = new ArrayList<Data>(size);
        for (int i = 0; i < size; i++) {
            Data data = new Data();
            data.readData(in);
            values.add(data);
        }
    }

    @Override
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
        this.name = in.readUTF();
        int size = in.readInt();
        this.keys = new HashSet<Data>(size);
        for (int i = 0; i < size; i++) {
            Data key = new Data();
            key.readData(in);
            keys.add(key);
        }
        this.entryProcessor = in.readObject();
    }
}
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        final ObjectDataInput in = reader.getRawDataInput();
        final int size = in.readInt();
        valueSet = new HashSet<Data>(size);
        for (int i=0; i<size; i++){
            final Data value = new Data();
            value.readData(in);
            valueSet.add(value);
        }
    }

    @Override
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        final ObjectDataInput in = reader.getRawDataInput();
        final int size = in.readInt();
        valueSet = new HashSet<Data>(size);
        for (int i = 0; i<size; i++){
            final Data value = new Data();
            value.readData(in);
            valueSet.add(value);
        }
    }

    @Override
View Full Code Here
73
74
75
76
77
78
79
80
81
82
        entrySet = new HashSet<Map.Entry>(size);
        for (int i=0; i<size; i++){
            Data key = new Data();
            Data value = new Data();
            key.readData(in);
            value.readData(in);
            entrySet.add(new AbstractMap.SimpleEntry(key,value));
        }
    }
}
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
        final ObjectDataInput in = reader.getRawDataInput();
        final int size = in.readInt();
        valueList = new ArrayList<Data>(size);
        for (int i=0; i<size; i++){
            final Data value = new Data();
            value.readData(in);
            valueList.add(value);
        }
    }

    @Override
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.