I'm trying to rebase a PR and adjust for the DoFn changes. CounterSet is gone and there is now AggregatorFactory and I'm looking to fix an existing usage of org.apache.beam.sdk.util.DoFnRunners.simpleRunner.
Given the instance of OldDoFn, what is the recommended way to obtain the aggregator factory when creating the fn runner? Thanks! java.lang.NullPointerException at org.apache.beam.sdk.util.DoFnRunnerBase$DoFnContext.createAggregatorInternal(DoFnRunnerBase.java:348) at org.apache.beam.sdk.transforms.OldDoFn$Context.setupDelegateAggregator(OldDoFn.java:224) at org.apache.beam.sdk.transforms.OldDoFn$Context.setupDelegateAggregators(OldDoFn.java:215) at org.apache.beam.sdk.util.DoFnRunnerBase$DoFnContext.<init>(DoFnRunnerBase.java:214) at org.apache.beam.sdk.util.DoFnRunnerBase.<init>(DoFnRunnerBase.java:87) at org.apache.beam.sdk.util.SimpleDoFnRunner.<init>(SimpleDoFnRunner.java:42) at org.apache.beam.sdk.util.DoFnRunners.simpleRunner(DoFnRunners.java:60)
