You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by GitBox <gi...@apache.org> on 2019/01/14 08:57:16 UTC

[flink] Diff for: [GitHub] intsmaze closed pull request #7471: Update state.md

diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index 8fe2981a20a..1654c9a77be 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) {


With regards,
Apache Git Services