download()
方法及相关类:
Response download(String fileName, String taskId, DownloadListener listener)
Response download(String fileName, String taskId, DownloadListener listener, RequestConfig requestConfig)
class DownloadListener implements Listener<DownloadFileResult>
interface Listener<T> {
void onReady();
void next(T var1);
void onComplete();
void onError(Throwable var1);
}
class DownloadFileResult {
int totalSize;
byte[] bytes;
}
示例:使用异步接口下载算法任务 134 中的文件 degree_test
public class Main {
public static void main(String[] args) {
// 创建名为 conn 的连接,此部分代码省略
Thread.sleep(100000);
Response res = conn.download("degree_test", "134", new DownloadListener() {
@Override
public void onReady() {
System.out.println("start download");
}
@Override
public void next(DownloadFileResult downloadFileResult) {
System.out.println(new String(downloadFileResult.getBytes(), StandardCharsets.UTF_8));
}
@Override
public void onComplete() {
System.out.println("finish download");
}
@Override
public void onError(Throwable throwable) {
System.out.println("error occurred");
}
});
System.out.println(new Gson().toJson(res));
}
}
export()
方法及相关类:
Response export(ExportRequest request, ExportListener listener)
Response export(ExportRequest request, ExportListener listener, RequestConfig requestConfig)
class ExportRequest {
Ultipa.DBType dbType;
String schema;
Integer limit;
List<String> selectPropertiesName;
}
class ExportListener implements Listener<ExportData>
interface Listener<T> {
void onReady();
void next(T var1);
void onComplete();
void onError(Throwable var1);
}
class ExportData {
List<UqlEntity> nodes;
List<UqlEntity> edges;
}
示例:使用异步接口从图集 test 导出 100 个 default 点,要求导出属性 'name' 和 'age'
public class Main {
public static void main(String[] args) {
// 创建名为 conn 的连接并使用 default 图集,此部分代码省略
ExportRequest request = new ExportRequest();
request.setDbType(Ultipa.DBType.DBNODE);
request.setLimit(100);
request.setSchema("default");
request.setSelectPropertiesName(Arrays.asList("name", "age"));
RequestConfig requestConfig = new RequestConfig();
requestConfig.setGraphName("test");
Response res = conn.export(request, new ExportListener() {
@Override
public void onReady() {
System.out.println("start download");
}
@Override
public void next(ExportData exportData) {
System.out.println(exportData.getNodes());
}
@Override
public void onComplete() {
System.out.println("finish download");
}
@Override
public void onError(Throwable throwable) {
System.out.println("error occurred");
}
}, requestConfig);
System.out.println(new Gson().toJson(res.getExportData()));
}
}