Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[SPARK-6775] [SPARK-6776] [SQL] [WIP] Refactors converters for converting Parquet records to row objects #5422

Closed
wants to merge 7 commits into from
Closed

[SPARK-6775] [SPARK-6776] [SQL] [WIP] Refactors converters for converting Parquet records to row objects #5422

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
1ed764b
Initial draft for Parquet converters refactoring
liancheng Mar 7, 2015
43e2252
Removes old converters
liancheng Apr 1, 2015
184eb27
Minor cleanups
liancheng Apr 1, 2015
058ad84
More cleanups, and comments
liancheng Apr 2, 2015
0de2e8b
Moves converter classes back to ParquetConverter.scala
liancheng Apr 6, 2015
9522949
Fixes comments
liancheng Apr 8, 2015
2529b76
Removes DateType support from SpecificMutableRow
liancheng Apr 8, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 10 additions & 0 deletions sql/catalyst/src/main/scala/org/apache/spark/sql/types/dataTypes.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ import scala.math._
import scala.math.Numeric.{FloatAsIfIntegral, DoubleAsIfIntegral}
import scala.reflect.ClassTag
import scala.reflect.runtime.universe.{TypeTag, runtimeMirror, typeTag}
import scala.util.Try
import scala.util.parsing.combinator.RegexParsers

import org.json4s._
Expand All @@ -39,6 +40,10 @@ import org.apache.spark.util.Utils


object DataType {
private[sql] def fromString(raw: String) = {
Try(DataType.fromJson(raw)).getOrElse(DataType.fromCaseClassString(raw))
}

def fromJson(json: String): DataType = parseDataType(parse(json))

private object JSortedObject {
Expand Down Expand Up @@ -887,6 +892,11 @@ case class StructField(


object StructType {
private[sql] def fromString(raw: String): StructType = DataType.fromString(raw) match {
case t: StructType => t
case _ => throw new RuntimeException(s"Failed parsing StructType: $raw")
}

protected[sql] def fromAttributes(attributes: Seq[Attribute]): StructType =
StructType(attributes.map(a => StructField(a.name, a.dataType, a.nullable, a.metadata)))

Expand Down
Loading