BoundedReadEvaluatorFactory implements TransformEvaluatorFactory { @Override public void cleanup() { executor.shutdown(); } BoundedReadEvaluatorFactory(EvaluationContext evaluationContext, PipelineOptions options); @VisibleForTesting  BoundedReadEvaluatorFactory(
      EvaluationContext evaluationContext, PipelineOptions options, long minimumDynamicSplitSize); @SuppressWarnings({"unchecked", "rawtypes"}) @Override @Nullable TransformEvaluator<InputT> forApplication(
      AppliedPTransform<?, ?, ?> application, CommittedBundle<?> inputBundle); @Override void cleanup();  }
@Test public void cleanupShutsDownExecutor() { factory.cleanup(); assertThat(factory.executor.isShutdown(), is(true)); }