I am trying to create aggregators to count values that satisfy a condition across all input data . I looked into documentation and found the below for creation . 

<https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/transforms/Aggregator> .. 

I am using : google-cloud-dataflow-java-sdk-all - 2.4.0 (apache beam based) 

However I am not able to find the corresponding class in the new beam api.. 
I looked into org.apache.beam.sdk.transforms package . 

Can you please let me know how can I use aggregators with dataflow runner in new api . ?