设置Flink Connector

1. 根据Flink版本选择RecallEngine Connector相应的版本

RecallEngine Connector 版本与 Flink 版本对应关系如下：

2. 注册资源到Flink

1. 登录实时计算控制台。

2. 在连接器页面，选择自定义连接器，单击创建自定义连接器。

3. 上传上述下载的 RecallEngine Connector JAR 包。

4. 点击下一步，设置连接器属性（可选），最后点击完成创建。

连接器 recallengine 的属性包括 endpoint、instance、username、password、table、connector（均为必填），以及 retry_time（默认值为 3）等，可按需修改后单击完成。

3. 作业编辑

在作业中使用 RecallEngine Connector，编写 Flink SQL 作业，将数据写入召回引擎。

1. 在召回引擎中创建目标表

需要在召回引擎中预先创建好目标表，定义好表的字段结构。

2. 在Flink中进行数据写入

以下示例展示如何将数据通过 Flink SQL 写入召回引擎。

定义数据源表：

CREATE TEMPORARY TABLE source_table (
    user_id BIGINT,
    item_id BIGINT,
    score FLOAT,
    tag STRING
) WITH (
    'connector' = 'datagen',
    'rows-per-second' = '10'
);

定义 RecallEngine Sink 表：

CREATE TEMPORARY TABLE recallengine_sink (
    user_id BIGINT,
    item_id BIGINT,
    score FLOAT,
    tag STRING
) WITH (
    'connector' = 'recallengine',
    'endpoint' = 'http://<your-endpoint>',
    'instance_id' = '<your-instance-id>',
    'table' = '<your-table-name>',
    'username' = '<your-username>',
    'password' = '<your-password>'
);

执行写入：

INSERT INTO recallengine_sink
SELECT user_id, item_id, score, tag
FROM source_table;