Thanks Pablo! On Fri, Mar 31, 2017 at 3:42 PM, Pablo Estrada <[email protected]> wrote:
> 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 > > >
