sjwiesman commented on a change in pull request #14594:
URL: https://github.com/apache/flink/pull/14594#discussion_r558397412
##########
File path: docs/dev/table/common.md
##########
@@ -1185,43 +1037,48 @@ val table: Table = tableEnv.fromDataStream(stream,
$"_2" as "myInt", $"_1" as "m
#### Atomic Types
-Flink treats primitives (`Integer`, `Double`, `String`) or generic types
(types that cannot be analyzed and decomposed) as atomic types. A `DataStream`
or `DataSet` of an atomic type is converted into a `Table` with a single
attribute. The type of the attribute is inferred from the atomic type and the
name of the attribute can be specified.
+Flink treats primitives (`Integer`, `Double`, `String`) or generic types
(types that cannot be analyzed and decomposed) as atomic types.
+A `DataStream` of an atomic type is converted into a `Table` with a single
column.
+The type of the column is inferred from the atomic type and the name of the
column can be specified.
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-// get a StreamTableEnvironment, works for BatchTableEnvironment equivalently
-StreamTableEnvironment tableEnv = ...; // see "Create a TableEnvironment"
section
+StreamTableEnvironment tableEnv = ...;
DataStream<Long> stream = ...
-// convert DataStream into Table with default field name "f0"
+// Convert DataStream into Table with default field name "f0"
Table table = tableEnv.fromDataStream(stream);
-// convert DataStream into Table with field name "myLong"
+// Convert DataStream into Table with field name "myLong"
Table table = tableEnv.fromDataStream(stream, $("myLong"));
{% endhighlight %}
</div>
<div data-lang="scala" markdown="1">
{% highlight scala %}
-// get a TableEnvironment
-val tableEnv: StreamTableEnvironment = ... // see "Create a TableEnvironment"
section
+val tableEnv: StreamTableEnvironment = ???
val stream: DataStream[Long] = ...
-// convert DataStream into Table with default field name "f0"
+// Convert DataStream into Table with default field name "f0"
Review comment:
😸
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
