Skip to content

Commit f22bb95

Browse files
authored
Add include describing use of rowtime (#1642)
* add include for rowtime * add link to WITH properties * remove INFO tag to show hyperlinks * updates per comments
1 parent 9f6a423 commit f22bb95

File tree

5 files changed

+10
-1
lines changed

5 files changed

+10
-1
lines changed
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,2 @@
1-
NOTE: Confluent Cloud manages several options for you when using Flink SQL. So, if you run this tutorial on Confluent Cloud, you can copy just the `CREATE TABLE` statements without the `WITH` clause when creating tables.
1+
Confluent Cloud manages several options for you when using Flink SQL. So, if you run this tutorial on Confluent Cloud, you can copy just the `CREATE TABLE` statements without the `WITH` clause when creating tables.
2+
Consult the https://docs.confluent.io/cloud/current/flink/reference/statements/create-table.html#with-options[Flink SQL WITH documentation] for the full list supported options when creating a table.
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
NOTE: If you have a table that does not have an explicit timestamp column you can use the `SYSTEM` column `$rowtime` for the `DESCRIPTOR` parameter when performing windowed aggregations with Flink SQL in Confluent Cloud.
2+

_includes/tutorials/cumulating-windows/flinksql/markup/dev/transient-query-revenue-per-hour-cumulating.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@ This query will continue to return results until you quit by entering `Q`.
99
<pre class="snippet"><code class="sql">{% include_raw tutorials/cumulating-windows/flinksql/code/tutorial-steps/dev/transient-query-revenue-per-hour-cumulating.sql %}</code></pre>
1010
+++++
1111

12+
{% include shared/markup/dev/flink_sql_rowtime_aggregation.adoc %}
13+
1214
This should yield the following output:
1315

1416
+++++

_includes/tutorials/hopping-windows/flinksql/markup/dev/transient-query-temperature-by-10min-window.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ This query will continue to return results until you quit by entering `Q`.
88
<pre class="snippet"><code class="sql">{% include_raw tutorials/hopping-windows/flinksql/code/tutorial-steps/dev/transient-query-temperature-by-10min-window.sql %}</code></pre>
99
+++++
1010

11+
{% include shared/markup/dev/flink_sql_rowtime_aggregation.adoc %}
12+
1113
This should yield the following output:
1214

1315
+++++

_includes/tutorials/tumbling-windows/flinksql/markup/dev/transient-query-ratings-by-6hr-window.adoc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ This query will continue to return results until you quit by entering `Q`.
88
<pre class="snippet"><code class="sql">{% include_raw tutorials/tumbling-windows/flinksql/code/tutorial-steps/dev/transient-query-ratings-by-6hr-window.sql %}</code></pre>
99
+++++
1010

11+
{% include shared/markup/dev/flink_sql_rowtime_aggregation.adoc %}
12+
1113
This should yield the following output:
1214

1315
+++++

0 commit comments

Comments
 (0)