Mirrored javadoc

apache · Mar 3, 2016 · 7d1c881 · 7d1c881
1 parent 8f689f4
commit 7d1c881
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/CountingInput.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/io/CountingInput.java
@@ -42,12 +42,10 @@
  * Pipeline p = ...
  *
  * // To create an unbounded producer that uses processing time as the element timestamp.
- * PTransform<PBegin, PCollection<Long>> producer = CountingInput.unbounded();
+ * PCollection<Long> unbounded = p.apply(CountingInput.unbounded());
  * // Or, to create an unbounded source that uses a provided function to set the element timestamp.
- * PTransform<PBegin, PCollection<Long>> producer =
- *     CountingInput.unbounded().withTimestampFn(someFn);
- *
- * PCollection<Long> unbounded = p.apply(producer);
+ * PCollection<Long> unboundedWithTimestamps =
+ *     p.apply(CountingInput.unbounded().withTimestampFn(someFn));
  * }</pre>
  */
 public class CountingInput {