提交 80b570be 编写于 作者: A Aljoscha Krettek

[FLINK-1823] Remove linq from Table API documentation

上级 62c465c3
...@@ -40,7 +40,7 @@ under the License. ...@@ -40,7 +40,7 @@ under the License.
<li><div class="sidenav-item"><a href="{{ site.baseurl }}/iterations.html">Iterations</a></div></li> <li><div class="sidenav-item"><a href="{{ site.baseurl }}/iterations.html">Iterations</a></div></li>
<li><div class="sidenav-item"><a href="{{ site.baseurl }}/spargel_guide.html">Spargel Graph API</a></div></li> <li><div class="sidenav-item"><a href="{{ site.baseurl }}/spargel_guide.html">Spargel Graph API</a></div></li>
<li><div class="sidenav-item"><a href="{{ site.baseurl }}/gelly_guide.html">Gelly Graph API</a></div></li> <li><div class="sidenav-item"><a href="{{ site.baseurl }}/gelly_guide.html">Gelly Graph API</a></div></li>
<li><div class="sidenav-item"><a href="{{ site.baseurl }}/linq.html">Language-Integrated Queries</a></div></li> <li><div class="sidenav-item"><a href="{{ site.baseurl }}/table.html">Table API - Relational Queries</a></div></li>
<li><div class="sidenav-item"><a href="{{ site.baseurl }}/hadoop_compatibility.html">Hadoop Compatibility</a></div></li> <li><div class="sidenav-item"><a href="{{ site.baseurl }}/hadoop_compatibility.html">Hadoop Compatibility</a></div></li>
<li><div class="sidenav-item-bottom"><a href="{{ site.baseurl }}/flink_on_tez_guide.html">Running Flink on Tez</a></div></li> <li><div class="sidenav-item-bottom"><a href="{{ site.baseurl }}/flink_on_tez_guide.html">Running Flink on Tez</a></div></li>
......
--- ---
title: "Language-Integrated Queries (Table API)" title: "Table API - Relational Queries"
--- ---
<!-- <!--
Licensed to the Apache Software Foundation (ASF) under one Licensed to the Apache Software Foundation (ASF) under one
...@@ -23,7 +23,7 @@ under the License. ...@@ -23,7 +23,7 @@ under the License.
* This will be replaced by the TOC * This will be replaced by the TOC
{:toc} {:toc}
**Language-Integrated Queries are an experimental feature** **The Table API an experimental feature**
Flink provides an API that allows specifying operations using SQL-like expressions. Instead of Flink provides an API that allows specifying operations using SQL-like expressions. Instead of
manipulating `DataSet` or `DataStream` you work with `Table` on which relational operations can manipulating `DataSet` or `DataStream` you work with `Table` on which relational operations can
...@@ -67,7 +67,7 @@ This is another example that shows how you ...@@ -67,7 +67,7 @@ This is another example that shows how you
can join to Tables: can join to Tables:
{% highlight scala %} {% highlight scala %}
case class MyResult(a: String, b: Int) case class MyResult(a: String, d: Int)
val input1 = env.fromElements(...).toTable('a, 'b) val input1 = env.fromElements(...).toTable('a, 'b)
val input2 = env.fromElements(...).toTable('c, 'd) val input2 = env.fromElements(...).toTable('c, 'd)
...@@ -87,6 +87,21 @@ When using Java, Tables can be converted to and from DataSet and DataStream usin ...@@ -87,6 +87,21 @@ When using Java, Tables can be converted to and from DataSet and DataStream usin
This example is equivalent to the above Scala Example: This example is equivalent to the above Scala Example:
{% highlight java %} {% highlight java %}
public class WC {
public WC(String word, int count) {
this.word = word; this.count = count;
}
public WC() {} // empty constructor to satisfy POJO requirements
public String word;
public int count;
}
...
ExecutionEnvironment env = ExecutionEnvironment.createCollectionsEnvironment(); ExecutionEnvironment env = ExecutionEnvironment.createCollectionsEnvironment();
TableEnvironment tableEnv = new TableEnvironment(); TableEnvironment tableEnv = new TableEnvironment();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册