Обработка mysql данных о свечах с использованием java

Question

Я новичок в искре. Я хочу обработать данные из базы данных mysql на спарк, используя java.

. Я попробовал следующий код:

 public  class Alert_Arret  {

    Connection_to_db cnx = new Connection_to_db();
    SparkSession sparkSession = SparkSession.builder().master("local[*]").appName("Example").config("").getOrCreate();
    SQLContext sqlContext = new org.apache.spark.sql.SQLContext(sparkSession);
    String dtable = "alert_p";
    Dataset<Row> track = sqlContext.read().jdbc(cnx.URL(),dtable,cnx.properties());

    }

, но когда я хочу назвать свой набор данных "track" , это не дает мне никакой возможности сделать это.

Пожалуйста, если у вас есть идеи об этом, помогите мне.

Спасибо.

Answer 1

Посмотрите, поможет ли вам приведенный ниже кодовый набор,

• Вариант 1 - когда можно ввести имя пользователя и пароль

Dataset<Row> jdbcDF = spark.read().format("jdbc")
.option("url", "jdbc:mysql://dbhost/sbschhema")
.option("dbtable", "schema.tablename")
.option("user", "username")
.option("password", "password")
.load();

• Вариант 2 - предоставление имени пользователя и пароля в качестве свойств

Properties connectionProperties = new Properties();
connectionProperties.put("user", "username");
connectionProperties.put("password", "password");
Dataset<Row> jdbcDF2 = spark.read()
.jdbc("jdbc:mysql://dbhost/sbschhema", "schema.tablename", connectionProperties);