Skip to content

Commit

Permalink
style edits
Browse files Browse the repository at this point in the history
  • Loading branch information
jkbradley committed Nov 2, 2014
1 parent f25fbc1 commit f8002b4
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ package org.apache.spark.sql.parquet
import java.util.{HashMap => JHashMap}

import org.apache.hadoop.conf.Configuration
import org.apache.spark.sql.catalyst.types.decimal.Decimal
import parquet.column.ParquetProperties
import parquet.hadoop.ParquetOutputFormat
import parquet.hadoop.api.ReadSupport.ReadContext
Expand All @@ -31,6 +30,7 @@ import parquet.schema.MessageType
import org.apache.spark.Logging
import org.apache.spark.sql.catalyst.expressions.{Attribute, Row}
import org.apache.spark.sql.catalyst.types._
import org.apache.spark.sql.catalyst.types.decimal.Decimal

/**
* A `parquet.io.api.RecordMaterializer` for Rows.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ protected[sql] object DataTypeConversions {
* Returns the equivalent DataType in Java for the given DataType in Scala.
*/
def asJavaDataType(scalaDataType: DataType): JDataType = scalaDataType match {
// Check UDT first since UDTs can override other types
case udtType: UserDefinedType[_] =>
UDTWrappers.wrapAsJava(udtType)

Expand Down Expand Up @@ -87,7 +86,6 @@ protected[sql] object DataTypeConversions {
* Returns the equivalent DataType in Scala for the given DataType in Java.
*/
def asScalaDataType(javaDataType: JDataType): DataType = javaDataType match {
// Check UDT first since UDTs can override other types
case udtType: org.apache.spark.sql.api.java.UserDefinedType[_] =>
UDTWrappers.wrapAsScala(udtType)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -233,8 +233,8 @@ class JsonSuite extends QueryTest {
StructField("field2", StringType, true) ::
StructField("field3", StringType, true) :: Nil), false), true) ::
StructField("struct", StructType(
StructField("field1", BooleanType, true) ::
StructField("field2", DecimalType.Unlimited, true) :: Nil), true) ::
StructField("field1", BooleanType, true) ::
StructField("field2", DecimalType.Unlimited, true) :: Nil), true) ::
StructField("structWithArrayFields", StructType(
StructField("field1", ArrayType(IntegerType, false), true) ::
StructField("field2", ArrayType(StringType, false), true) :: Nil), true) :: Nil)
Expand Down

0 comments on commit f8002b4

Please sign in to comment.