You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/04 13:31:07 UTC
[09/19] flink git commit: [hotfix][docs][table] Minor fixes
[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/40b9a638
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/40b9a638
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/40b9a638
Branch: refs/heads/release-1.5
Commit: 40b9a638c939769505bfbdcb5635cdc7c634e4e8
Parents: 15e4449
Author: mayyamus <ch...@outlook.com>
Authored: Fri Mar 30 21:44:47 2018 +0800
Committer: zentol <ch...@apache.org>
Committed: Wed Apr 4 14:26:45 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/40b9a638/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/40b9a638/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");