Examples of toData()

Examples of com.hazelcast.spi.NodeEngine.toData()

109
110
111
112
113
114
115
116
117
118
119
    @Override
    public <R> InternalCompletableFuture<R> asyncApply(IFunction<E, R> function) {
        isNotNull(function, "function");

        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new ApplyOperation(name, nodeEngine.toData(function));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public void clear() {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

131
132
133
134
135
136
137
138
139
140
141
    }

    @Override
    public InternalCompletableFuture<Boolean> asyncCompareAndSet(E expect, E update) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new CompareAndSetOperation(name, nodeEngine.toData(expect), nodeEngine.toData(update));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public E get() {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

131
132
133
134
135
136
137
138
139
140
141
    }

    @Override
    public InternalCompletableFuture<Boolean> asyncCompareAndSet(E expect, E update) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new CompareAndSetOperation(name, nodeEngine.toData(expect), nodeEngine.toData(update));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public E get() {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

154
155
156
157
158
159
160
161
162
163
164
    }

    @Override
    public InternalCompletableFuture<Boolean> asyncContains(E value) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new ContainsOperation(name, nodeEngine.toData(value));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public void set(E newValue) {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

166
167
168
169
170
171
172
173
174
175
176
    }

    @Override
    public InternalCompletableFuture<Void> asyncSet(E newValue) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new SetOperation(name, nodeEngine.toData(newValue));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public E getAndSet(E newValue) {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

178
179
180
181
182
183
184
185
186
187
188
    }

    @Override
    public InternalCompletableFuture<E> asyncGetAndSet(E newValue) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new GetAndSetOperation(name, nodeEngine.toData(newValue));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public E setAndGet(E update) {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

190
191
192
193
194
195
196
197
198
199
200
    }

    @Override
    public InternalCompletableFuture<E> asyncSetAndGet(E update) {
        NodeEngine nodeEngine = getNodeEngine();
        Operation operation = new SetAndGetOperation(name, nodeEngine.toData(update));
        return asyncInvoke(operation, nodeEngine);
    }

    @Override
    public boolean isNull() {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

46
47
48
49
50
51
52
53
54
55
56
        TransactionManagerServiceImpl txManagerService = getService();
        final Set<RecoveredTransaction> recovered = txManagerService.recoverLocal();
        final Set<Data> recoveredData = new HashSet<Data>(recovered.size());
        final NodeEngine nodeEngine = getNodeEngine();
        for (RecoveredTransaction rt : recovered) {
            recoveredData.add(nodeEngine.toData(rt));
        }
        response = new SerializableCollection(recoveredData);
    }

    @Override
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

81
82
83
84
85
86
87
88
89
90
91
        }
    }

    public boolean put(K key, V value) {
        final NodeEngine nodeEngine = getNodeEngine();
        Data dataKey = nodeEngine.toData(key);
        Data dataValue = nodeEngine.toData(value);
        return putInternal(dataKey, dataValue, -1);
    }

    public Collection<V> get(K key) {
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

82
83
84
85
86
87
88
89
90
91
92
    }

    public boolean put(K key, V value) {
        final NodeEngine nodeEngine = getNodeEngine();
        Data dataKey = nodeEngine.toData(key);
        Data dataValue = nodeEngine.toData(value);
        return putInternal(dataKey, dataValue, -1);
    }

    public Collection<V> get(K key) {
        final NodeEngine nodeEngine = getNodeEngine();
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.