Переименовать поля с одинаковыми именами в SPARK

Question

Я использую JSON с такими же именами полей.Как я могу переименовать в искра dataframe.пожалуйста, помогите.

val df1 =dataframe.select( "BusinessAsset.Name", "BusinessAsset.Code", "BusinessOperation.Name" as Name1, "BusinessOperation.Code" as code1, "Measurement.RecordedBy.System", "Measurement.RecordedBy.Code" as c1)

Answer 1

То же самое, что создать псевдоним в SQL.Это то, что вы можете использовать это

Answer 2

.select() также может принимать тип Column вместо строк. Типу Column можно присвоить имя с помощью метода .as():

val df1 = dataframe.select(
  $"BusinessAsset.Name",
  $"BusinessAsset.Code",
  $"BusinessOperation.Name".as("Name1"),
  $"BusinessOperation.Code".as("code1"),
  $"Measurement.RecordedBy.System",
  $"Measurement.RecordedBy.Code".as("c1")
)