[flink] branch master updated: [hotfix][docs] Update references to deprecated SinkFunction#invoke(Object)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 4863bc1  [hotfix][docs] Update references to deprecated SinkFunction#invoke(Object)
4863bc1 is described below

commit 4863bc1aa7c376a996b66953c2cbd7afb6eccc1f
Author: intsmaze <li...@vip.qq.com>
AuthorDate: Wed Jan 16 20:26:02 2019 +0800

    [hotfix][docs] Update references to deprecated SinkFunction#invoke(Object)
---
 docs/dev/stream/state/state.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index 8fe2981..1654c9a 100644
--- a/docs/dev/stream/state/state.md
+++ b/docs/dev/stream/state/state.md
@@ -475,7 +475,7 @@ public class BufferingSink
     }
 
     @Override
-    public void invoke(Tuple2<String, Integer> value) throws Exception {
+    public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception {
         bufferedElements.add(value);
         if (bufferedElements.size() == threshold) {
             for (Tuple2<String, Integer> element: bufferedElements) {
@@ -523,7 +523,7 @@ class BufferingSink(threshold: Int = 0)
 
   private val bufferedElements = ListBuffer[(String, Int)]()
 
-  override def invoke(value: (String, Int)): Unit = {
+  override def invoke(value: (String, Int), context: Context): Unit = {
     bufferedElements += value
     if (bufferedElements.size == threshold) {
       for (element <- bufferedElements) {