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

Reply via email to