@Benchmark
  @Threads(16) // Use several threads since we expect contention during bundle processing.
  public void testStateWithCaching(StatefulTransform statefulTransform) throws Exception {
    testState(statefulTransform, statefulTransform.cachingStateRequestHandler);
  }
@Test
  public void testStateWithCaching() throws Exception {
    StatefulTransform transform = new StatefulTransform();
    transform.elementsEmbedding = elementsEmbedding;
    new ProcessBundleBenchmark().testStateWithCaching(transform);
    transform.tearDown();
  }