@SuppressWarnings("unchecked")
    @Override
    public void execute(String mapName, Predicate predicate, Collection<Integer> partitions, Result result) {
        runUsingPartitionScanWithoutPaging(mapName, predicate, partitions, result);
        if (predicate instanceof PagingPredicateImpl pagingPredicate) {
            Map.Entry<Integer, Map.Entry> nearestAnchorEntry = pagingPredicate.getNearestAnchorEntry();
            result.orderAndLimit(pagingPredicate, nearestAnchorEntry);
        }
    }
@Test
    public void execute_success() throws Exception {
        IPartitionService partitionService = mock(IPartitionService.class);
        when(partitionService.getPartitionCount()).thenReturn(271);
        PartitionScanRunner runner = mock(PartitionScanRunner.class);
        ReflectionUtils.setFieldValueReflectively(runner, "partitionService", partitionService);
        ParallelPartitionScanExecutor executor = executor(runner);
        Predicate<Object, Object> predicate = Predicates.equal("attribute", 1);
        QueryResult queryResult = new QueryResult(IterationType.ENTRY, null, null, Long.MAX_VALUE, false);

        executor.execute("Map", predicate, asList(1, 2, 3), queryResult);
        List<QueryResultRow> result = queryResult.getRows();
        assertEquals(0, result.size());
    }