flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [01/18] flink git commit: [hotfix][docs][table] Minor fixes
Date Wed, 04 Apr 2018 12:22:19 GMT
Repository: flink
Updated Branches:
  refs/heads/master db366cd3d -> 6ffe22db8


[hotfix][docs][table] Minor fixes

This closes #5795.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2426f788
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2426f788
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2426f788

Branch: refs/heads/master
Commit: 2426f78841509c576770a9c30ef88e5d76ba90f4
Parents: ac07761
Author: mayyamus <chillon_m@outlook.com>
Authored: Fri Mar 30 21:44:47 2018 +0800
Committer: zentol <chesnay@apache.org>
Committed: Wed Apr 4 08:59:05 2018 +0200

----------------------------------------------------------------------
 docs/dev/table/common.md    | 4 ++--
 docs/dev/table/streaming.md | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/2426f788/docs/dev/table/common.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md
index e1d3809..3e3965a 100644
--- a/docs/dev/table/common.md
+++ b/docs/dev/table/common.md
@@ -775,8 +775,8 @@ DataSet<Row> dsRow = tableEnv.toDataSet(table, Row.class);
 TupleTypeInfo<Tuple2<String, Integer>> tupleType = new TupleTypeInfo<>(
   Types.STRING(),
   Types.INT());
-DataStream<Tuple2<String, Integer>> dsTuple = 
-  tableEnv.toAppendStream(table, tupleType);
+DataSet<Tuple2<String, Integer>> dsTuple = 
+  tableEnv.toDataSet(table, tupleType);
 {% endhighlight %}
 </div>
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2426f788/docs/dev/table/streaming.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/streaming.md b/docs/dev/table/streaming.md
index 310121e..dc0fdf8 100644
--- a/docs/dev/table/streaming.md
+++ b/docs/dev/table/streaming.md
@@ -362,7 +362,7 @@ In either case the event time timestamp field will hold the value of the
`DataSt
 // Option 1:
 
 // extract timestamp and assign watermarks based on knowledge of the stream
-DataStream<Tuple3<String, String>> stream = inputStream.assignTimestampsAndWatermarks(...);
+DataStream<Tuple2<String, String>> stream = inputStream.assignTimestampsAndWatermarks(...);
 
 // declare an additional logical field as an event time attribute
 Table table = tEnv.fromDataStream(stream, "Username, Data, UserActionTime.rowtime");


Mime
View raw message