private void doImport(boolean explode) throws ClassNotFoundException, IOException {
    Region region = getCache().getRegion("test");
    RegionSnapshotService rss = region.getSnapshotService();

    final TestSnapshotFileMapper mapper = new TestSnapshotFileMapper();
    mapper.setShouldExplode(explode);

    SnapshotOptionsImpl opt = (SnapshotOptionsImpl) rss.createOptions();
    opt.setParallelMode(true);
    opt.setMapper(mapper);

    for (int i = 0; i < DATA_POINTS; i++) {
      region.put(i, eeee);
    }

    rss.load(directory, SnapshotFormat.GEODE, opt);
    for (int i = 0; i < DATA_POINTS; i++) {
      assertTrue(Arrays.equals(ffff, (byte[]) region.get(i)));
    }
  }
This test ensures that parallel import succeeds even when each node does not have a file to
import (import cluster larger than export one)
geode-core/src/distributedTest/java/org/apache/geode/cache/snapshot/ParallelSnapshotDUnitTest.java