Hi, I think I understand the concepts of PCollection name and PTransform name. But, what is the stepName in the MetricsContainer?
/**
* Create a new {@link MetricsContainer} associated with the given {@code
stepName}.
*/
public MetricsContainer(String stepName) { this.stepName = stepName; }
In the MetricsTest.java, it seems that the stepName is the same as
PTransform name.
.apply("MyStep1", ParDo.of(new DoFn<Integer, Integer>() { ...
Thanks,
Shen
