Hi Shen, That's correct. The Metrics API fills in the step name automatically from the PTransfor, and it is used to group and aggregate Metrics per step. As a user, you're not supposed to set/modify it yourself. Hope that helps solve your question. Best -P.
On Fri, Mar 31, 2017 at 11:39 AM Shen Li <[email protected]> wrote: > 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 >
