Как привести DataFrame к DynamicFrame в Scala - PullRequest
Новая
       73

Как привести DataFrame к DynamicFrame в Scala

0 голосов
/ 07 сентября 2018 
val ruleDs = glueContext.getSource(connectionType = "dynamodb",connectionOptions= JsonOptions(Map("dynamodb.input.tableName" -> "rules"))).getDynamicFrame()
ruleDs.toDF().createOrReplaceTempView("rules")
val ruleSqlDf = glueContext.getSparkSession.sql(s"Select * from rules where id='$ruleID'")
val ruleSqlDyf = DynamicFrame(ruleSqlDf, glueContext).withName("ruleSqlDyf")
ruleDs.printSchema()
/*result 
|-- Conditions: string
|-- InstalledApps: struct
| |-- applicationPackages: set
| | |-- element: string */

ruleSqlDyf.printSchema()
/*result
|-- Conditions: null
|-- InstalledApps: struct
| |-- applicationPackages: array
| | |-- element: string */

Как привести DataFrame к DynamicFrame? Схема меняется, когда я создаю новый DynamicFrame с помощью 'ruleDs'

...