@Override
    public Object call() throws Exception {
      BucketQueryResult bukResult = new BucketQueryResult(_bucketId);
      try {
        List<Integer> bucketList = Collections.singletonList(_bucketId);
        ExecutionContext context =
            new QueryExecutionContext(parameters, pr.getCache(), query);
        context.setBucketList(bucketList);
        executeQueryOnBuckets(resultColl, context);
      } catch (ForceReattemptException | QueryException | CacheRuntimeException fre) {
        bukResult.setException(fre);
      }
      // Exception
      return bukResult;
    }
Implementation of call-able task to execute query on a bucket region. This task will be
generated by the PRQueryProcessor.
geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java