in backup-command/src/main/java/org/apache/iotdb/backup/command/ExportTool.java [80:112]
public static void main(String[] args) {
CommandLine commandLine = null;
CommandLineParser parser = new DefaultParser();
int exitCode = CODE_OK;
commandLine = init(args, commandLine, parser);
try {
initSession();
ExportStarter exportStarter = new ExportStarter();
ExportModel exportModel = generateExportModel();
exportModel.setSession(session);
Disposable disposable = exportStarter.start(exportModel);
while (!disposable.isDisposed()) {
System.out.print("完成行数:" + exportStarter.finishedRowNum() + "行\r");
Thread.sleep(1000);
}
System.out.print("完成行数:" + exportStarter.finishedRowNum() + "行\r");
} catch (IoTDBConnectionException | StatementExecutionException | InterruptedException e) {
System.out.println("Connect failed because " + e.getMessage());
exitCode = CODE_ERROR;
} finally {
if (session != null) {
try {
session.close();
} catch (IoTDBConnectionException e) {
exitCode = CODE_ERROR;
System.out.println(
"Encounter an error when closing session, error is: " + e.getMessage());
}
}
}
System.exit(exitCode);
}