Caideyipi commented on code in PR #12541:
URL: https://github.com/apache/iotdb/pull/12541#discussion_r1620208984
##########
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportTsFile.java:
##########
@@ -0,0 +1,436 @@
+package org.apache.iotdb.tool;
+
+import org.apache.iotdb.cli.utils.IoTPrinter;
+import org.apache.iotdb.exception.ArgsErrorException;
+import org.apache.iotdb.session.pool.SessionPool;
+
+import org.apache.commons.cli.CommandLine;
+import org.apache.commons.cli.CommandLineParser;
+import org.apache.commons.cli.DefaultParser;
+import org.apache.commons.cli.HelpFormatter;
+import org.apache.commons.cli.Option;
+import org.apache.commons.cli.ParseException;
+
+import java.io.File;
+import java.io.IOException;
+import java.nio.file.FileAlreadyExistsException;
+import java.nio.file.FileStore;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardCopyOption;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class ImportTsFile extends AbstractTsFileTool {
+
+ private static final String SOURCE_ARGS = "s";
+ private static final String SOURCE_NAME = "source";
+
+ private static final String ON_SUCCESS_ARGS = "os";
+ private static final String ON_SUCCESS_NAME = "on_success";
+
+ private static final String SUCCESS_DIR_ARGS = "sd";
+ private static final String SUCCESS_DIR_NAME = "success_dir";
+
+ private static final String FAIL_DIR_ARGS = "fd";
+ private static final String FAIL_DIR_NAME = "fail_dir";
+
+ private static final String ON_FAIL_ARGS = "of";
+ private static final String ON_FAIL_NAME = "on_fail";
+
+ private static final String THREAD_NUM_ARGS = "tn";
+ private static final String THREAD_NUM_NAME = "thread_num";
+
+ private static final IoTPrinter ioTPrinter = new IoTPrinter(System.out);
+
+ private static final String TSFILEDB_CLI_PREFIX = "ImportTsFile";
+
+ private static String source;
+ private static String sourceFullPath;
+ private static String failDir = "fail/";
+ private static String successDir = "success/";
+ private static String onSuccess;
+ private static String onFail;
+ private static Operation successOperation;
+ private static Operation failOperation;
+ private static int threadNum = 8;
+ private static final LinkedBlockingQueue<String> linkedBlockingQueue =
+ new LinkedBlockingQueue<>();
+
+ private static void createOptions() {
+ createBaseOptions();
+
+ Option opSource =
+ Option.builder(SOURCE_ARGS)
+ .longOpt(SOURCE_NAME)
+ .required()
Review Comment:
There are 2 "required"s.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
