This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new eec2407c3 [doc] Missing an import in flink-api.md (#3851)
eec2407c3 is described below
commit eec2407c3339324d8fc408b669f53a73fe1c32c2
Author: lupeng <[email protected]>
AuthorDate: Tue Jul 30 21:29:48 2024 +0800
[doc] Missing an import in flink-api.md (#3851)
---
docs/content/program-api/flink-api.md | 3 +++
1 file changed, 3 insertions(+)
diff --git a/docs/content/program-api/flink-api.md
b/docs/content/program-api/flink-api.md
index be52e3ab4..c2c5cf77c 100644
--- a/docs/content/program-api/flink-api.md
+++ b/docs/content/program-api/flink-api.md
@@ -69,6 +69,7 @@ See [DataStream API
Integration](https://nightlies.apache.org/flink/flink-docs-s
```java
import org.apache.paimon.catalog.Catalog;
import org.apache.paimon.catalog.Identifier;
+import org.apache.paimon.flink.FlinkCatalogFactory;
import org.apache.paimon.flink.sink.FlinkSinkBuilder;
import org.apache.paimon.options.Options;
import org.apache.paimon.table.Table;
@@ -129,6 +130,7 @@ public class WriteToTable {
```java
import org.apache.paimon.catalog.Catalog;
import org.apache.paimon.catalog.Identifier;
+import org.apache.paimon.flink.FlinkCatalogFactory;
import org.apache.paimon.flink.source.FlinkSourceBuilder;
import org.apache.paimon.options.Options;
import org.apache.paimon.table.Table;
@@ -185,6 +187,7 @@ Here is an example to use `RichCdcSinkBuilder` API:
import org.apache.paimon.catalog.Catalog;
import org.apache.paimon.catalog.CatalogContext;
import org.apache.paimon.catalog.CatalogFactory;
+import org.apache.paimon.flink.FlinkCatalogFactory;
import org.apache.paimon.catalog.Identifier;
import org.apache.paimon.flink.sink.cdc.RichCdcRecord;
import org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder;
