public interface Row
extends scala.Serializable
It is invalid to use the native primitive interface to retrieve a value that is null, instead a
user must check isNullAt
before attempting to retrieve a value that might be null.
To create a new Row, use RowFactory.create()
in Java or Row.apply()
in Scala.
A Row
object can be constructed by providing field values. Example:
import org.apache.spark.sql._
// Create a Row from values.
Row(value1, value2, value3, ...)
// Create a Row from a Seq of values.
Row.fromSeq(Seq(value1, value2, ...))
A value of a row can be accessed through both generic access by ordinal, which will incur boxing overhead for primitives, as well as native primitive access. An example of generic access by ordinal:
import org.apache.spark.sql._
val row = Row(1, true, "a string", null)
// row: Row = [1,true,a string,null]
val firstValue = row(0)
// firstValue: Any = 1
val fourthValue = row(3)
// fourthValue: Any = null
For native primitive access, it is invalid to use the native primitive interface to retrieve
a value that is null, instead a user must check isNullAt
before attempting to retrieve a
value that might be null.
An example of native primitive access:
// using the row from the previous example.
val firstValue = row.getInt(0)
// firstValue: Int = 1
val isNull = row.isNullAt(3)
// isNull: Boolean = true
In Scala, fields in a Row
object can be extracted in a pattern match. Example:
import org.apache.spark.sql._
val pairs = sql("SELECT key, value FROM src").rdd.map {
case Row(key: Int, value: String) =>
key -> value
}
Modifier and Type | Method and Description |
---|---|
boolean |
anyNull()
Returns true if there are any NULL values in this row.
|
Object |
apply(int i)
Returns the value at position i.
|
Row |
copy()
Make a copy of the current
Row object. |
boolean |
equals(Object that) |
Object |
get(int i)
Returns the value at position i.
|
<T> T |
getAs(int i)
Returns the value at position i.
|
boolean |
getBoolean(int i)
Returns the value at position i as a primitive boolean.
|
byte |
getByte(int i)
Returns the value at position i as a primitive byte.
|
java.sql.Date |
getDate(int i)
Returns the value at position i of date type as java.sql.Date.
|
java.math.BigDecimal |
getDecimal(int i)
Returns the value at position i of decimal type as java.math.BigDecimal.
|
double |
getDouble(int i)
Returns the value at position i as a primitive double.
|
float |
getFloat(int i)
Returns the value at position i as a primitive float.
|
int |
getInt(int i)
Returns the value at position i as a primitive int.
|
<K,V> java.util.Map<K,V> |
getJavaMap(int i)
Returns the value at position i of array type as a
Map . |
<T> java.util.List<T> |
getList(int i)
Returns the value at position i of array type as
List . |
long |
getLong(int i)
Returns the value at position i as a primitive long.
|
<K,V> scala.collection.Map<K,V> |
getMap(int i)
Returns the value at position i of map type as a Scala Map.
|
<T> scala.collection.Seq<T> |
getSeq(int i)
Returns the value at position i of array type as a Scala Seq.
|
short |
getShort(int i)
Returns the value at position i as a primitive short.
|
String |
getString(int i)
Returns the value at position i as a String object.
|
Row |
getStruct(int i)
Returns the value at position i of struct type as an
Row object. |
int |
hashCode() |
boolean |
isNullAt(int i)
Checks whether the value at position i is null.
|
int |
length()
Number of elements in the Row.
|
String |
mkString()
Displays all elements of this sequence in a string (without a separator).
|
String |
mkString(String sep)
Displays all elements of this sequence in a string using a separator string.
|
String |
mkString(String start,
String sep,
String end)
Displays all elements of this traversable or iterator in a string using
start, end, and separator strings.
|
StructType |
schema()
Schema for the row.
|
int |
size()
Number of elements in the Row.
|
scala.collection.Seq<Object> |
toSeq()
Return a Scala Seq representing the row.
|
String |
toString() |
int size()
int length()
StructType schema()
Object apply(int i)
BooleanType -> java.lang.Boolean
ByteType -> java.lang.Byte
ShortType -> java.lang.Short
IntegerType -> java.lang.Integer
FloatType -> java.lang.Float
DoubleType -> java.lang.Double
StringType -> String
DecimalType -> java.math.BigDecimal
DateType -> java.sql.Date
TimestampType -> java.sql.Timestamp
BinaryType -> byte array
ArrayType -> scala.collection.Seq (use getList for java.util.List)
MapType -> scala.collection.Map (use getJavaMap for java.util.Map)
StructType -> org.apache.spark.sql.Row
Object get(int i)
BooleanType -> java.lang.Boolean
ByteType -> java.lang.Byte
ShortType -> java.lang.Short
IntegerType -> java.lang.Integer
FloatType -> java.lang.Float
DoubleType -> java.lang.Double
StringType -> String
DecimalType -> java.math.BigDecimal
DateType -> java.sql.Date
TimestampType -> java.sql.Timestamp
BinaryType -> byte array
ArrayType -> scala.collection.Seq (use getList for java.util.List)
MapType -> scala.collection.Map (use getJavaMap for java.util.Map)
StructType -> org.apache.spark.sql.Row
boolean isNullAt(int i)
boolean getBoolean(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.byte getByte(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.short getShort(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.int getInt(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.long getLong(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.float getFloat(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.double getDouble(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.String getString(int i)
ClassCastException
- when data type does not match.NullPointerException
- when value is null.java.math.BigDecimal getDecimal(int i)
ClassCastException
- when data type does not match.java.sql.Date getDate(int i)
ClassCastException
- when data type does not match.<T> scala.collection.Seq<T> getSeq(int i)
ClassCastException
- when data type does not match.<T> java.util.List<T> getList(int i)
List
.
ClassCastException
- when data type does not match.<K,V> scala.collection.Map<K,V> getMap(int i)
ClassCastException
- when data type does not match.<K,V> java.util.Map<K,V> getJavaMap(int i)
Map
.
ClassCastException
- when data type does not match.Row getStruct(int i)
Row
object.
ClassCastException
- when data type does not match.<T> T getAs(int i)
ClassCastException
- when data type does not match.String toString()
toString
in class Object
boolean anyNull()
boolean equals(Object that)
equals
in class Object
int hashCode()
hashCode
in class Object
scala.collection.Seq<Object> toSeq()
String mkString()
String mkString(String sep)
String mkString(String start, String sep, String end)