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