download()

Method and class:

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

Example: Download file 'degree_test' from algorithm task 134

public class Main {
    public static void main(String[] args) {
        // omit code of establishing server connection '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()

Method and class:

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

Example: Export 100 nodes from schema 'default' of graphset 'test', carring properties @default.name and @default.age

public class Main {
    public static void main(String[] args) {
        // omit code of establishing server connection 'conn' using graphset '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()));
    }
}