DF.write.mode("append").jdbc(url, tableName, prop)

首先调用Dataset中的write方法,在write方法中创建DataFrameWriter对象;

Spark写入数据到MySQL解析(未完成)

在DataFrameWriter中,调用mode方法,将设置的mode值保存在类成员变量中;

Spark写入数据到MySQL解析(未完成)

调用jdbc方法,在jdbc方法中,调用format;

Spark写入数据到MySQL解析(未完成)

把成员变量source设置为jdbc;

Spark写入数据到MySQL解析(未完成)

然后调用save方法,在save方法中,调用DataSource中的lookupDataSource方法;

Spark写入数据到MySQL解析(未完成)

根据传进来的source="jdbc",去backwardCompatibilityMap中查找对应的值

Spark写入数据到MySQL解析(未完成)

Spark写入数据到MySQL解析(未完成)

此时从map中未找到对应的值,将原来的值返回,provider1=jdbc,provider2=jdbc.DefaultSource,去加载这个类;

Spark写入数据到MySQL解析(未完成)

相关文章:

  • 2021-12-07
  • 2022-12-23
  • 2022-12-23
  • 2021-10-10
  • 2022-12-23
  • 2021-05-11
  • 2022-01-06
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2021-11-27
  • 2022-12-23
  • 2021-10-13
  • 2021-08-13
  • 2021-12-10
相关资源
相似解决方案