From 7d1c881283fd0bab9bb4e3f82ff334cbc0ce5287 Mon Sep 17 00:00:00 2001
From: Thomas Groh <tgroh@google.com>
Date: Thu, 3 Mar 2016 08:49:20 -0800
Subject: [PATCH] Mirrored javadoc

---
 .../com/google/cloud/dataflow/sdk/io/CountingInput.java   | 8 +++-----
 1 file changed, 3 insertions(+), 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
index e9b98e6721aae..17a057da97871 100644
--- 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 {