From 7e0401f5346ca95bdf149a3df421ac76c2c22041 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= <xavier@confluent.io>
Date: Tue, 8 Nov 2016 11:13:18 -0800
Subject: [PATCH] MINOR: fix typos and incorrect docs

---
 .../java/org/apache/kafka/streams/kstream/ForeachAction.java  | 2 +-
 .../java/org/apache/kafka/streams/kstream/Transformer.java    | 4 ++--
 .../main/java/org/apache/kafka/streams/kstream/Windows.java   | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java
index b3e3169792d40..4c773c9f9a04b 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java
@@ -22,7 +22,7 @@
  * The {@link ForeachAction} interface for performing an action on a key-value pair.
  * Note that this action is stateless. If stateful processing is required, consider
  * using {@link KStream#transform(TransformerSupplier, String...)} or
- * {@link KStream#process(ProcessorSupplier, String...)} instead.
+ * {@link KStream#process(org.apache.kafka.streams.processor.ProcessorSupplier, String...)} instead.
  *
  * @param <K>   original key type
  * @param <V>   original value type
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
index 239854beecf6b..e9363e8b53f4c 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
@@ -20,7 +20,7 @@
 import org.apache.kafka.streams.processor.ProcessorContext;
 
 /**
- * A stateful {@link Transformer} interface for transform a key-value pair into a new value.
+ * A stateful {@link Transformer} interface to transform a key-value pair into a new value.
  *
  * @param <K>   key type
  * @param <V>   value type
@@ -49,7 +49,7 @@ public interface Transformer<K, V, R> {
     R transform(K key, V value);
 
     /**
-     * Perform any periodic operations and possibly generate a key, if this processor {@link ProcessorContext#schedule(long) schedule itself} with the context
+     * Perform any periodic operations and possibly generate a key, if this processor {@link ProcessorContext#schedule(long) schedules itself} with the context
      * during {@link #init(ProcessorContext) initialization}.
      *
      * @param timestamp the stream time when this method is being called
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java
index 5a4f0d42f2b02..dbc52a854edf0 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java
@@ -64,9 +64,9 @@ protected Windows<W> segments(int segments) {
     }
 
     /**
-     * Return the window maintain duration in milliseconds of system time.
+     * Return the window maintain duration in milliseconds of streams time.
      *
-     * @return the window maintain duration in milliseconds of system time
+     * @return the window maintain duration in milliseconds of streams time
      */
     public long maintainMs() {
         return this.maintainDurationMs;