-
- Downloads
[SPARK-5167][SQL] Move Row into sql package and make it usable for Java.
Mostly just moving stuff around. This should still be source compatible since we type aliased Row previously in org.apache.spark.sql.Row. Added the following APIs to Row: ```scala def getMap[K, V](i: Int): scala.collection.Map[K, V] def getJavaMap[K, V](i: Int): java.util.Map[K, V] def getSeq[T](i: Int): Seq[T] def getList[T](i: Int): java.util.List[T] def getStruct(i: Int): StructType ``` Author: Reynold Xin <rxin@databricks.com> Closes #4030 from rxin/sql-row and squashes the following commits: 6c85c29 [Reynold Xin] Fixed style violation by adding a new line to Row.scala. 82b064a [Reynold Xin] [SPARK-5167][SQL] Move Row into sql package and make it usable for Java.
Showing
- sql/catalyst/src/main/java/org/apache/spark/sql/RowFactory.java 34 additions, 0 deletions...talyst/src/main/java/org/apache/spark/sql/RowFactory.java
- sql/catalyst/src/main/scala/org/apache/spark/sql/Row.scala 240 additions, 0 deletionssql/catalyst/src/main/scala/org/apache/spark/sql/Row.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/package.scala 4 additions, 0 deletions...a/org/apache/spark/sql/catalyst/expressions/package.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala 24 additions, 89 deletions...cala/org/apache/spark/sql/catalyst/expressions/rows.scala
- sql/catalyst/src/main/scala/org/apache/spark/sql/types/dataTypes.scala 1 addition, 1 deletion...src/main/scala/org/apache/spark/sql/types/dataTypes.scala
- sql/core/src/main/scala/org/apache/spark/sql/api/java/Row.scala 1 addition, 1 deletion...re/src/main/scala/org/apache/spark/sql/api/java/Row.scala
- sql/core/src/main/scala/org/apache/spark/sql/package.scala 0 additions, 83 deletionssql/core/src/main/scala/org/apache/spark/sql/package.scala
Loading
Please register or sign in to comment