You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2018/04/05 09:24:58 UTC
[1/2] flink git commit: [hotfix] [docs] Improve description of
keyBy().
Repository: flink
Updated Branches:
refs/heads/master 7b0fc58f7 -> dec591a17
[hotfix] [docs] Improve description of keyBy().
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7712c027
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7712c027
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7712c027
Branch: refs/heads/master
Commit: 7712c027db4b07b92e6f1b2c3d2feb8cc00f409f
Parents: 7b0fc58
Author: Fabian Hueske <fh...@apache.org>
Authored: Thu Apr 5 10:55:05 2018 +0200
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Apr 5 10:55:05 2018 +0200
----------------------------------------------------------------------
docs/dev/stream/operators/index.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7712c027/docs/dev/stream/operators/index.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/operators/index.md b/docs/dev/stream/operators/index.md
index b0325ca..aaf3646 100644
--- a/docs/dev/stream/operators/index.md
+++ b/docs/dev/stream/operators/index.md
@@ -100,9 +100,9 @@ dataStream.filter(new FilterFunction<Integer>() {
<tr>
<td><strong>KeyBy</strong><br>DataStream → KeyedStream</td>
<td>
- <p>Logically partitions a stream into disjoint partitions, each partition containing elements of the same key.
- Internally, this is implemented with hash partitioning. See <a href="{{ site.baseurl }}/dev/api_concepts.html#specifying-keys">keys</a> on how to specify keys.
- This transformation returns a KeyedStream.</p>
+ <p>Logically partitions a stream into disjoint partitions. All records with the same key are assigned to the same partition. Internally, <em>keyBy()</em> is implemented with hash partitioning. There are different ways to <a href="{{ site.baseurl }}/dev/api_concepts.html#specifying-keys">specify keys</a>.</p>
+ <p>
+ This transformation returns a <em>KeyedStream</em>, which is, among other things, required to use <a href="{{ site.baseurl }}/dev/stream/state/state.html#keyed-state">keyed state</a>. </p>
{% highlight java %}
dataStream.keyBy("someKey") // Key by field "someKey"
dataStream.keyBy(0) // Key by the first element of a Tuple
[2/2] flink git commit: [hotfix] [docs] Update deprecated sql() to
sqlQuery().
Posted by fh...@apache.org.
[hotfix] [docs] Update deprecated sql() to sqlQuery().
This closes #5818.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dec591a1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dec591a1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dec591a1
Branch: refs/heads/master
Commit: dec591a17935088f314e0fae95e368554ea97e71
Parents: 7712c02
Author: mayyamus <ch...@outlook.com>
Authored: Thu Apr 5 09:54:11 2018 +0800
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Apr 5 11:00:29 2018 +0200
----------------------------------------------------------------------
docs/dev/table/sql.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/dec591a1/docs/dev/table/sql.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/sql.md b/docs/dev/table/sql.md
index eb7204a..60ce03a 100644
--- a/docs/dev/table/sql.md
+++ b/docs/dev/table/sql.md
@@ -22,7 +22,7 @@ specific language governing permissions and limitations
under the License.
-->
-SQL queries are specified with the `sql()` method of the `TableEnvironment`. The method returns the result of the SQL query as a `Table`. A `Table` can be used in [subsequent SQL and Table API queries](common.html#mixing-table-api-and-sql), be [converted into a DataSet or DataStream](common.html#integration-with-datastream-and-dataset-api), or [written to a TableSink](common.html#emit-a-table)). SQL and Table API queries can seamlessly mixed and are holistically optimized and translated into a single program.
+SQL queries are specified with the `sqlQuery()` method of the `TableEnvironment`. The method returns the result of the SQL query as a `Table`. A `Table` can be used in [subsequent SQL and Table API queries](common.html#mixing-table-api-and-sql), be [converted into a DataSet or DataStream](common.html#integration-with-datastream-and-dataset-api), or [written to a TableSink](common.html#emit-a-table)). SQL and Table API queries can seamlessly mixed and are holistically optimized and translated into a single program.
In order to access a table in a SQL query, it must be [registered in the TableEnvironment](common.html#register-a-table-in-the-catalog). A table can be registered from a [TableSource](common.html#register-a-tablesource), [Table](common.html#register-a-table), [DataStream, or DataSet](common.html#register-a-datastream-or-dataset-as-table). Alternatively, users can also [register external catalogs in a TableEnvironment](common.html#register-an-external-catalog) to specify the location of the data sources.