hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkDataFrameToHoloExample.java [32:53]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static void main(String[] args) throws Exception {
        Options options = new Options();
        options.addOption("e", "endpoint", true, "Hologres endpoint");
        options.addOption("u", "username", true, "Username");
        options.addOption("p", "password", true, "Password");
        options.addOption("d", "database", true, "Database");
        options.addOption("t", "tablename", true, "Table name");

        CommandLineParser parser = new DefaultParser();
        CommandLine commandLine = parser.parse(options, args);
        String endPoint = commandLine.getOptionValue("endpoint");
        String userName = commandLine.getOptionValue("username");
        String password = commandLine.getOptionValue("password");
        String database = commandLine.getOptionValue("database");
        String tableName = commandLine.getOptionValue("tablename");

        SparkSession sparkSession =
                SparkSession.builder()
                        .master("local")
                        .appName("SparkDataFrameToHoloExample")
                        .config("spark.default.parallelism", 1)
                        .getOrCreate();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hologres-connector-examples/hologres-connector-spark-examples/src/main/java/com/alibaba/hologres/spark/example/SparkHoloToDataFrameExample.java [28:49]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static void main(String[] args) throws Exception {
        Options options = new Options();
        options.addOption("e", "endpoint", true, "Hologres endpoint");
        options.addOption("u", "username", true, "Username");
        options.addOption("p", "password", true, "Password");
        options.addOption("d", "database", true, "Database");
        options.addOption("t", "tablename", true, "Table name");

        CommandLineParser parser = new DefaultParser();
        CommandLine commandLine = parser.parse(options, args);
        String endPoint = commandLine.getOptionValue("endpoint");
        String userName = commandLine.getOptionValue("username");
        String password = commandLine.getOptionValue("password");
        String database = commandLine.getOptionValue("database");
        String tableName = commandLine.getOptionValue("tablename");

        SparkSession sparkSession =
                SparkSession.builder()
                        .master("local")
                        .appName("SparkDataFrameToHoloExample")
                        .config("spark.default.parallelism", 1)
                        .getOrCreate();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -