Skip to content

Commit

Permalink
code alignment
Browse files Browse the repository at this point in the history
  • Loading branch information
jmchung committed Aug 7, 2017
1 parent f5eec40 commit 54a1a15
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -120,7 +120,9 @@ class JsonFileFormat extends TextBasedFileFormat with DataSourceRegister {
// for all json fields, i.g., all items in dataSchema.
val querySchema = if (actualSchema.isEmpty) {
StructType(dataSchema.filterNot(_.name == parsedOptions.columnNameOfCorruptRecord))
} else { actualSchema }
} else {
actualSchema
}
val parser = new JacksonParser(querySchema, parsedOptions)
JsonDataSource(parsedOptions).readFile(
broadcastedHadoopConf.value.value,
Expand Down

0 comments on commit 54a1a15

Please sign in to comment.