@Before
  public void setup() throws IOException {
    cache = (InternalCache) new CacheFactory().create();
    cache.createDiskStoreFactory().setDiskDirs(new File[] {tempFolder.newFolder("diskDir")})
        .create(DISK_STORE_NAME);
    PartitionAttributesImpl partitionAttributes = new PartitionAttributesImpl();
    partitionAttributes.setTotalNumBuckets(BUCKETS);
    testRegion = cache.<String, String>createRegionFactory(RegionShortcut.PARTITION_PERSISTENT)
        .setPartitionAttributes(partitionAttributes).setDiskStoreName(DISK_STORE_NAME)
        .create(REGION_NAME);

    blockingWriter = new BlockingWriter<>();
  }
Tests the basic use cases for PR persistence.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistPRKRFIntegrationTest.java