From 96e6d0951d217089fbefd1f561d18b86235ccb5f Mon Sep 17 00:00:00 2001
From: zhouhai02 <zhouhai02@meituan.com>
Date: Sun, 4 Feb 2018 13:30:09 +0800
Subject: [PATCH] [hotfix][docs] Fix typos in window document

---
 docs/dev/stream/operators/windows.md | 12 ++++--------
 1 file changed, 4 insertions(+), 8 deletions(-)

diff --git a/docs/dev/stream/operators/windows.md b/docs/dev/stream/operators/windows.md
index 0327d0629bf50..7c01e4608ea36 100644
--- a/docs/dev/stream/operators/windows.md
+++ b/docs/dev/stream/operators/windows.md
@@ -718,7 +718,7 @@ input
 
 class MyProcessWindowFunction extends ProcessWindowFunction[(String, Long), String, String, TimeWindow] {
 
-  def apply(key: String, context: Context, input: Iterable[(String, Long)], out: Collector[String]): () = {
+  def process(key: String, context: Context, input: Iterable[(String, Long)], out: Collector[String]): () = {
     var count = 0L
     for (in <- input) {
       count = count + 1
@@ -773,7 +773,7 @@ private static class MyReduceFunction implements ReduceFunction<SensorReading> {
 private static class MyProcessWindowFunction
     implements ProcessWindowFunction<SensorReading, Tuple2<Long, SensorReading>, String, TimeWindow> {
 
-  public void apply(String key,
+  public void process(String key,
                     Context context,
                     Iterable<SensorReading> minReadings,
                     Collector<Tuple2<Long, SensorReading>> out) {
@@ -856,7 +856,7 @@ private static class AverageAggregate
 private static class MyProcessWindowFunction
     implements ProcessWindowFunction<Double, Tuple2<String, Double>, String, TimeWindow> {
 
-  public void apply(String key,
+  public void process(String key,
                     Context context,
                     Iterable<Double> averages,
                     Collector<Tuple2<String, Double>> out) {
@@ -897,11 +897,7 @@ class AverageAggregate extends AggregateFunction[(String, Long), (Long, Long), D
 
 class MyProcessWindowFunction extends ProcessWindowFunction[Double, (String, Double), String, TimeWindow] {
 
-  def apply(key: String, context: Context, averages: Iterable[Double], out: Collector[(String, Double]): () = {
-    var count = 0L
-    for (in <- input) {
-      count = count + 1
-    }
+  def process(key: String, context: Context, averages: Iterable[Double], out: Collector[(String, Double]): () = {
     val average = averages.iterator.next()
     out.collect((key, average))
   }