You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by da...@apache.org on 2022/12/05 09:57:43 UTC
[flink] branch release-1.15 updated: [hotfix][docs][Connector/Firehose] Add missing references to Firehose connector
This is an automated email from the ASF dual-hosted git repository.
dannycranmer pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 504ecee874a [hotfix][docs][Connector/Firehose] Add missing references to Firehose connector
504ecee874a is described below
commit 504ecee874a548564b31eab9eff1732b0f38f079
Author: Danny Cranmer <da...@apache.org>
AuthorDate: Mon Dec 5 00:02:57 2022 +0000
[hotfix][docs][Connector/Firehose] Add missing references to Firehose connector
---
docs/content.zh/docs/connectors/datastream/guarantees.md | 9 +++++++--
docs/content.zh/docs/connectors/datastream/overview.md | 3 ++-
docs/content.zh/docs/connectors/table/formats/overview.md | 4 ++++
docs/content.zh/docs/connectors/table/overview.md | 6 ++++++
docs/content/docs/connectors/datastream/guarantees.md | 7 ++++++-
docs/content/docs/connectors/datastream/overview.md | 3 ++-
docs/content/docs/connectors/table/formats/overview.md | 4 ++++
docs/content/docs/connectors/table/overview.md | 6 ++++++
docs/data/sql_connectors.yml | 7 ++++++-
9 files changed, 43 insertions(+), 6 deletions(-)
diff --git a/docs/content.zh/docs/connectors/datastream/guarantees.md b/docs/content.zh/docs/connectors/datastream/guarantees.md
index 828109c5aeb..12da9b07788 100644
--- a/docs/content.zh/docs/connectors/datastream/guarantees.md
+++ b/docs/content.zh/docs/connectors/datastream/guarantees.md
@@ -47,7 +47,7 @@ under the License.
<td>根据你的版本用恰当的 Kafka 连接器</td>
</tr>
<tr>
- <td>AWS Kinesis Streams</td>
+ <td>Amazon Kinesis Data Streams</td>
<td>精确一次</td>
<td></td>
</tr>
@@ -106,7 +106,12 @@ under the License.
<td>只有当更新是幂等时，保证精确一次</td>
</tr>
<tr>
- <td>AWS Kinesis Streams</td>
+ <td>Amazon Kinesis Data Streams</td>
+ <td>至少一次</td>
+ <td></td>
+ </tr>
+ <tr>
+ <td>Amazon Kinesis Data Firehose</td>
<td>至少一次</td>
<td></td>
</tr>
diff --git a/docs/content.zh/docs/connectors/datastream/overview.md b/docs/content.zh/docs/connectors/datastream/overview.md
index 6d08762541b..b61646f9c11 100644
--- a/docs/content.zh/docs/connectors/datastream/overview.md
+++ b/docs/content.zh/docs/connectors/datastream/overview.md
@@ -39,7 +39,8 @@ under the License.
* [Apache Kafka]({{< ref "docs/connectors/datastream/kafka" >}}) (source/sink)
* [Apache Cassandra]({{< ref "docs/connectors/datastream/cassandra" >}}) (sink)
- * [Amazon Kinesis Streams]({{< ref "docs/connectors/datastream/kinesis" >}}) (source/sink)
+ * [Amazon Kinesis Data Streams]({{< ref "docs/connectors/datastream/kinesis" >}}) (source/sink)
+ * [Amazon Kinesis Data Firehose]({{< ref "docs/connectors/datastream/firehose" >}}) (sink)
* [Elasticsearch]({{< ref "docs/connectors/datastream/elasticsearch" >}}) (sink)
* [FileSystem]({{< ref "docs/connectors/datastream/filesystem" >}}) (sink)
* [RabbitMQ]({{< ref "docs/connectors/datastream/rabbitmq" >}}) (source/sink)
diff --git a/docs/content.zh/docs/connectors/table/formats/overview.md b/docs/content.zh/docs/connectors/table/formats/overview.md
index 644bbc6b86c..2e30d7dda72 100644
--- a/docs/content.zh/docs/connectors/table/formats/overview.md
+++ b/docs/content.zh/docs/connectors/table/formats/overview.md
@@ -43,6 +43,7 @@ Flink 支持以下格式：
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
<tr>
@@ -50,6 +51,7 @@ Flink 支持以下格式：
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a>,
<a href="{{< ref "docs/connectors/table/elasticsearch" >}}">Elasticsearch</a></td>
</tr>
@@ -58,6 +60,7 @@ Flink 支持以下格式：
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
<tr>
@@ -98,6 +101,7 @@ Flink 支持以下格式：
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
</tbody>
diff --git a/docs/content.zh/docs/connectors/table/overview.md b/docs/content.zh/docs/connectors/table/overview.md
index 03fb840f5e6..7058e7ea102 100644
--- a/docs/content.zh/docs/connectors/table/overview.md
+++ b/docs/content.zh/docs/connectors/table/overview.md
@@ -72,6 +72,12 @@ Flink natively support various connectors. The following tables list all availab
<td>Unbounded Scan</td>
<td>Streaming Sink</td>
</tr>
+ <tr>
+ <td><a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a></td>
+ <td></td>
+ <td>Not supported</td>
+ <td>Streaming Sink</td>
+ </tr>
<tr>
<td><a href="{{< ref "docs/connectors/table/jdbc" >}}">JDBC</a></td>
<td></td>
diff --git a/docs/content/docs/connectors/datastream/guarantees.md b/docs/content/docs/connectors/datastream/guarantees.md
index 93c4a802e64..b7915ba3066 100644
--- a/docs/content/docs/connectors/datastream/guarantees.md
+++ b/docs/content/docs/connectors/datastream/guarantees.md
@@ -111,7 +111,12 @@ state updates) of Flink coupled with bundled sinks:
<td>exactly once only for idempotent updates</td>
</tr>
<tr>
- <td>AWS Kinesis Streams</td>
+ <td>Amazon Kinesis Data Streams</td>
+ <td>at least once</td>
+ <td></td>
+ </tr>
+ <tr>
+ <td>Amazon Kinesis Data Firehose</td>
<td>at least once</td>
<td></td>
</tr>
diff --git a/docs/content/docs/connectors/datastream/overview.md b/docs/content/docs/connectors/datastream/overview.md
index 42cf647f774..31a09cd213e 100644
--- a/docs/content/docs/connectors/datastream/overview.md
+++ b/docs/content/docs/connectors/datastream/overview.md
@@ -40,7 +40,8 @@ Connectors provide code for interfacing with various third-party systems. Curren
* [Apache Kafka]({{< ref "docs/connectors/datastream/kafka" >}}) (source/sink)
* [Apache Cassandra]({{< ref "docs/connectors/datastream/cassandra" >}}) (sink)
- * [Amazon Kinesis Streams]({{< ref "docs/connectors/datastream/kinesis" >}}) (source/sink)
+ * [Amazon Kinesis Data Streams]({{< ref "docs/connectors/datastream/kinesis" >}}) (source/sink)
+ * [Amazon Kinesis Data Firehose]({{< ref "docs/connectors/datastream/firehose" >}}) (sink)
* [Elasticsearch]({{< ref "docs/connectors/datastream/elasticsearch" >}}) (sink)
* [FileSystem]({{< ref "docs/connectors/datastream/filesystem" >}}) (sink)
* [RabbitMQ]({{< ref "docs/connectors/datastream/rabbitmq" >}}) (source/sink)
diff --git a/docs/content/docs/connectors/table/formats/overview.md b/docs/content/docs/connectors/table/formats/overview.md
index a07e2ee042d..987ba8d8820 100644
--- a/docs/content/docs/connectors/table/formats/overview.md
+++ b/docs/content/docs/connectors/table/formats/overview.md
@@ -43,6 +43,7 @@ Flink supports the following formats:
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
<tr>
@@ -50,6 +51,7 @@ Flink supports the following formats:
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a>,
<a href="{{< ref "docs/connectors/table/elasticsearch" >}}">Elasticsearch</a></td>
</tr>
@@ -58,6 +60,7 @@ Flink supports the following formats:
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
<tr>
@@ -98,6 +101,7 @@ Flink supports the following formats:
<td><a href="{{< ref "docs/connectors/table/kafka" >}}">Apache Kafka</a>,
<a href="{{< ref "docs/connectors/table/upsert-kafka" >}}">Upsert Kafka</a>,
<a href="{{< ref "docs/connectors/table/kinesis" >}}">Amazon Kinesis Data Streams</a>,
+ <a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a>,
<a href="{{< ref "docs/connectors/table/filesystem" >}}">Filesystem</a></td>
</tr>
</tbody>
diff --git a/docs/content/docs/connectors/table/overview.md b/docs/content/docs/connectors/table/overview.md
index 90dd56dbc0a..169ed340a25 100644
--- a/docs/content/docs/connectors/table/overview.md
+++ b/docs/content/docs/connectors/table/overview.md
@@ -72,6 +72,12 @@ Flink natively support various connectors. The following tables list all availab
<td>Unbounded Scan</td>
<td>Streaming Sink</td>
</tr>
+ <tr>
+ <td><a href="{{< ref "docs/connectors/table/firehose" >}}">Amazon Kinesis Data Firehose</a></td>
+ <td></td>
+ <td>Not supported</td>
+ <td>Streaming Sink</td>
+ </tr>
<tr>
<td><a href="{{< ref "docs/connectors/table/jdbc" >}}">JDBC</a></td>
<td></td>
diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml
index e136c661ba8..a3fc878003e 100644
--- a/docs/data/sql_connectors.yml
+++ b/docs/data/sql_connectors.yml
@@ -161,8 +161,13 @@ upsert-kafka:
sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/$version/flink-sql-connector-kafka-$version.jar
kinesis:
- name: Kinesis
+ name: Amazon Kinesis Data Streams
category: connector
maven: flink-connector-kinesis
sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kinesis/$version/flink-sql-connector-kinesis-$version.jar
+aws-kinesis-firehose:
+ name: Amazon Kinesis Data Firehose
+ category: connector
+ maven: flink-connector-kinesis-firehose
+ sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-aws-kinesis-firehose/$version/flink-sql-connector-aws-kinesis-firehose-$version.jar