Java SDK 参考

接口

RecallEngineClient client = new RecallEngineClient(endpoint, username, password);

参数说明

召回引擎服务的访问地址可以在PAI-Rec管控台 召回管理基本信息页面查看。

可选配置方法

说明

• 客户端默认连接超时为200ms，读写超时为500ms，连接池最大连接数为1000。

• 所有可选配置方法支持链式调用。

示例

import com.aliyun.openservices.pairec.recallengine.RecallEngineClient;

// 通过环境变量获取认证信息
String endpoint = System.getenv("RECALL_ENGINE_SERVICE_ENDPOINT");
String username = System.getenv("RECALL_ENGINE_SERVICE_USERNAME");
String password = System.getenv("RECALL_ENGINE_SERVICE_PASSWORD");

// 创建客户端
RecallEngineClient client = new RecallEngineClient(endpoint, username, password);

// 设置重试次数
client.withRetryTimes(2);

接口

public RecallResponse recall(RecallRequest request) throws RecallEngineException;

RecallRequest参数说明

RecallConf参数说明

RecallResponse说明

示例

import com.aliyun.openservices.pairec.recallengine.*;

import java.util.HashMap;
import java.util.Map;

// 构造召回请求
RecallRequest request = new RecallRequest();
request.setInstanceId("your-instance-id");
request.setService("recall_test");
request.setVersion("V1");
request.setUid("123");

// 设置召回配置
Map<String, RecallConf> recalls = new HashMap<>();
recalls.put("u2i_recall", new RecallConf("123", 100));
request.setRecalls(recalls);

// 执行召回
RecallResponse resp = client.recall(request);
Record result = resp.getResult();

// 获取结果信息
System.out.println("Total records: " + result.size());
System.out.println("Field names: " + result.fieldNames());

接口

public WriteResponse write(String instanceId, String table, WriteRequest request) throws RecallEngineException;

参数说明

WriteRequest参数说明

WriteResponse说明

WriteResponse 继承自 Response，包含以下字段：

示例

import com.aliyun.openservices.pairec.recallengine.*;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

// 构造写入请求
WriteRequest request = new WriteRequest();
request.setRequestId("write-req-123");

// 构造写入数据
Map<String, Object> item = new HashMap<>();
item.put("user_id", "123");
item.put("item_id", "item_123");
item.put("score", 0.95);

List<Map<String, Object>> content = new ArrayList<>();
content.add(item);
request.setContent(content);

// 执行写入
WriteResponse resp = client.write("your-instance-id", "u2i_table", request);

// 检查写入结果
System.out.println("Code: " + resp.getCode());       // 成功时返回 "OK"
System.out.println("Message: " + resp.getMessage());

接口

public Record sort(String name, boolean desc);
public Record retain(int count);
public Record filter(String name);
public Record filterByColumnValue(String name, Predicate<Object> predicate);
public Record filterByValues(Predicate<Map<String, Object>> predicate);
public Record random();
public List<Object> columnValues(String columnName);
public List<String> columnValuesString(String columnName);
public List<String> fieldNames();
public int size();

方法说明

说明

• sort、retain、filter、filterByColumnValue、filterByValues、random 方法均返回 this，支持链式调用。

• Record 不是线程安全的，请勿在多线程环境下并发操作同一个 Record 实例。

示例

RecallResponse resp = client.recall(request);
Record result = resp.getResult();

// 按 score 列降序排序，去重后取前10条
Record processed = result
        .sort("score", true)
        .filter("item_id")
        .retain(10);

System.out.println("Processed records: " + processed.size());

// 获取 item_id 列的所有值
List<String> itemIds = processed.columnValuesString("item_id");
System.out.println("Item IDs: " + itemIds);

// 按条件过滤：仅保留 score > 0.5 的记录
Record filtered = result.filterByColumnValue("score", value -> {
    if (value instanceof Number) {
        return ((Number) value).doubleValue() > 0.5;
    }
    return false;
});

// 按全行条件过滤
Record filtered2 = result.filterByValues(row -> {
    Object category = row.get("category");
    return category != null && "video".equals(category.toString());
});