Artificial Intelligence Recommendation:Java SDK リファレンス

API

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

パラメーターの説明

RecallEngine サービスのエンドポイントは、PAI-Rec コンソールの「リコール管理」＞「基本情報」ページで確認できます。

オプションの構成方法

注記

• クライアントのデフォルト接続タイムアウトは 200 ms、読み取り／書き込みタイムアウトは 500 ms、接続プール内の最大接続数は 1,000 です。

• すべてのオプション構成メソッドは、チェーン呼び出しをサポートしています。

例

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);

API

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("総件数: " + result.size());
System.out.println("フィールド名: " + result.fieldNames());

API

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("状態コード: " + resp.getCode());       // 成功時は「OK」が返されます
System.out.println("メッセージ: " + resp.getMessage());

API

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 カラムで降順ソート → item_id で重複除去 → 先頭 10 件を取得
Record processed = result
        .sort("score", true)
        .filter("item_id")
        .retain(10);

System.out.println("処理後の件数: " + processed.size());

// item_id カラムのすべての値を取得
List<String> itemIds = processed.columnValuesString("item_id");
System.out.println("アイテム ID: " + 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());
});