Examples of CountOperation

Examples of com.hazelcast.multimap.impl.operations.CountOperation

36
37
38
39
40
41
42
43
44
        super(name, key);
        this.threadId = threadId;
    }

    protected Operation prepareOperation() {
        CountOperation operation = new CountOperation(name, key);
        operation.setThreadId(threadId);
        return operation;
    }
View Full Code Here

Examples of com.hazelcast.multimap.impl.operations.CountOperation

122
123
124
125
126
127
128
129
130
131
132
                return new ContainsEntryOperation();
            }
        };
        constructors[COUNT] = new ConstructorFunction<Integer, IdentifiedDataSerializable>() {
            public IdentifiedDataSerializable createNew(Integer arg) {
                return new CountOperation();
            }
        };
        constructors[ENTRY_SET] = new ConstructorFunction<Integer, IdentifiedDataSerializable>() {
            public IdentifiedDataSerializable createNew(Integer arg) {
                return new EntrySetOperation();
View Full Code Here

Examples of com.hazelcast.multimap.impl.operations.CountOperation

215
216
217
218
219
220
221
222
223
224
225
226
        getService().publishMultiMapEvent(name, eventType, numberOfAffectedEntries);
    }

    protected Integer countInternal(Data dataKey) {
        try {
            CountOperation operation = new CountOperation(name, dataKey);
            operation.setThreadId(ThreadUtil.getThreadId());
            return invoke(operation, dataKey);
        } catch (Throwable throwable) {
            throw ExceptionUtil.rethrow(throwable);
        }
    }
View Full Code Here

Examples of com.hazelcast.multimap.impl.operations.CountOperation

189
190
191
192
193
194
195
196
197
198
199
200
    protected int valueCountInternal(Data key) {
        throwExceptionIfNull(key);
        Collection<MultiMapRecord> coll = txMap.get(key);
        if (coll == null) {
            CountOperation operation = new CountOperation(name, key);
            operation.setThreadId(ThreadUtil.getThreadId());
            try {
                int partitionId = getNodeEngine().getPartitionService().getPartitionId(key);
                final OperationService operationService = getNodeEngine().getOperationService();
                Future<Integer> f = operationService
                        .invokeOnPartition(MultiMapService.SERVICE_NAME, operation, partitionId);
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

33
34
35
36
37
38
39
    public CountRequest(String name, Data key) {
        super(name, key);
    }

    protected Operation prepareOperation() {
        return new CountOperation(name, key);
    }
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

179
180
181
182
183
184
185
186
187
188
189
    protected int valueCountInternal(Data key){
        throwExceptionIfNull(key);
        Collection<MultiMapRecord> coll = txMap.get(key);
        if (coll == null){
            CountOperation operation = new CountOperation(name, key);
            try {
                int partitionId = getNodeEngine().getPartitionService().getPartitionId(key);
                Future<Integer> f = getNodeEngine().getOperationService().invokeOnPartition(MultiMapService.SERVICE_NAME, operation, partitionId);
                return f.get();
            } catch (Throwable t) {
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

122
123
124
125
126
127
128
129
130
131
132
                return new ContainsEntryOperation();
            }
        };
        constructors[COUNT] = new ConstructorFunction<Integer, IdentifiedDataSerializable>() {
            public IdentifiedDataSerializable createNew(Integer arg) {
                return new CountOperation();
            }
        };
        constructors[ENTRY_SET] = new ConstructorFunction<Integer, IdentifiedDataSerializable>() {
            public IdentifiedDataSerializable createNew(Integer arg) {
                return new EntrySetOperation();
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

192
193
194
195
196
197
198
199
200
201
202
    protected int valueCountInternal(Data key) {
        throwExceptionIfNull(key);
        Collection<MultiMapRecord> coll = txMap.get(key);
        if (coll == null) {
            CountOperation operation = new CountOperation(name, key);
            try {
                int partitionId = getNodeEngine().getPartitionService().getPartitionId(key);
                final OperationService operationService = getNodeEngine().getOperationService();
                Future<Integer> f = operationService
                        .invokeOnPartition(MultiMapService.SERVICE_NAME, operation, partitionId);
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

30
31
32
33
34
35
36
    public CountRequest(String name, Data key) {
        super(name, key);
    }

    protected Operation prepareOperation() {
        return new CountOperation(name, key);
    }
View Full Code Here

Examples of com.hazelcast.multimap.operations.CountOperation

214
215
216
217
218
219
220
221
222
223
224
        getService().publishMultiMapEvent(name, eventType, numberOfAffectedEntries);
    }

    protected Integer countInternal(Data dataKey) {
        try {
            CountOperation operation = new CountOperation(name, dataKey);
            return invoke(operation, dataKey);
        } catch (Throwable throwable) {
            throw ExceptionUtil.rethrow(throwable);
        }
    }
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.