包

特征行扩展可序列化的

代表一行输出的关系操作符。允许两个通用的访问顺序,这将招致拳击开销原语,以及本地原始访问。

无效的使用本机原始接口检索的值为空,而不是一个用户必须检查isNullAt之前试图检索的值可能是零。

创建一个新行,使用RowFactory.create ()在Java或Row.apply ()在Scala中。

一个行对象可以由提供字段值。例子:

进口org.apache.spark.sql._/ /创建一个行值。行(value1, value2, value3,…)/ /创建一个连续的Seq值。Row.fromSeq (Seq(value1, value2,…))

的值可以通过通用访问一行访问顺序,这将招致拳击开销原语,以及本地原始访问。一个通用的访问顺序的例子:

进口org.apache.spark.sql._瓦尔行=行(1,真正的,“字符串”,零)/ /行:行=[1,真的,一个字符串,零)瓦尔firstValue =行(0)/ / firstValue:任何= 1瓦尔fourthValue =行(3)/ / fourthValue:任何=零

对于本机原始访问,这是无效的使用本机原始接口检索的值为空,而不是一个用户必须检查isNullAt之前试图检索的值可能是零。本机原始访问的一个例子:

/ /使用行从前面的示例。瓦尔firstValue = row.getInt (0)/ / firstValue: Int = 1瓦尔isNull = row.isNullAt (3)/ / isNull:布尔= true

在Scala中,字段中行对象可以提取模式匹配。例子:

进口org.apache.spark.sql._瓦尔对= sql (“从src选择键,值”).rdd。{地图情况下行(关键:Int价值:字符串)= >键- >值}
注释
@Stable ()
自

1.3.0

线性超
可序列化的,可序列化的,AnyRef,任何
已知的子类
MutableAggregationBuffer
订购
  1. 字母
  2. 通过继承
继承了
  1. 行
  2. 可序列化的
  3. 可序列化的
  4. AnyRef
  5. 任何
  1. 隐藏所有
  2. 显示所有
可见性
  1. 公共
  2. 所有

抽象价值的成员

  1. 文摘def复制():行

    使当前的副本行对象。

  2. 文摘def得到(我:Int):任何

    我返回值的位置。

    我返回值位置。如果该值为null,则返回null。下面是一个火花SQL类型和返回类型之间的映射:

    BooleanType - > . lang。布尔ByteType - > . lang。字节ShortType - > . lang。短IntegerType - > . lang。Integer LongType -> java.lang.长FloatType - > . lang。浮动倍增式- > . lang。双StringType - >字符串DecimalType - > java.math。BigDecimal日期Type -> java.sql.Date如果spark.sql.datetime.java8API。使是假DateType - > java.time.LocalDate如果spark.sql.datetime.java8API。使是真正的TimestampType - > java.sql.Timestamp如果spark.sql.datetime.java8API。使是假TimestampType - > java.time.Instant如果spark.sql.datetime.java8API。使是真正的BinaryType - >字节数组ArrayType - > scala.collection。Seq(使用getList为java.util。列表)MapType - > scala.collection。地图(使用getJavaMap为java.util。地图)StructType - > org.apache.spark.sql.Row
  3. 文摘def长度:Int

    元素的行数。

具体值的成员

  1. 最后def! =(arg0:任何):布尔
    定义类
    AnyRef→任何
  2. 最后def# #():Int
    定义类
    AnyRef→任何
  3. 最后def= =(arg0:任何):布尔
    定义类
    AnyRef→任何
  4. defanyNull:布尔

    返回true,如果在这一行有NULL值。

  5. def应用(我:Int):任何

    我返回值的位置。

    我返回值位置。如果该值为null,则返回null。下面是一个火花SQL类型和返回类型之间的映射:

    BooleanType - > . lang。布尔ByteType - > . lang。字节ShortType - > . lang。短IntegerType - > . lang。Integer LongType -> java.lang.长FloatType - > . lang。浮动倍增式- > . lang。双StringType - >字符串DecimalType - > java.math。BigDecimal日期Type -> java.sql.Date如果spark.sql.datetime.java8API。使是假DateType - > java.time.LocalDate如果spark.sql.datetime.java8API。使是真正的TimestampType - > java.sql.Timestamp如果spark.sql.datetime.java8API。使是假TimestampType - > java.time.Instant如果spark.sql.datetime.java8API。使是真正的BinaryType - >字节数组ArrayType - > scala.collection。Seq(使用getList为java.util。列表)MapType - > scala.collection。地图(使用getJavaMap为java.util。地图)StructType - > org.apache.spark.sql.Row
  6. 最后defasInstanceOf(T0]:T0
    定义类
    任何
  7. def克隆():AnyRef
    属性
    保护(朗]
    定义类
    AnyRef
    注释
    @throws (…) @native ()
  8. 最后def情商(arg0:AnyRef):布尔
    定义类
    AnyRef
  9. def=(o:任何):布尔
    定义类
    行→AnyRef→任何
  10. deffieldIndex(名称:字符串):Int

    返回给定的字段的索引名称。

    返回给定的字段的索引名称。

    抛出的异常

    IllegalArgumentException当一个字段的名字不存在。

    UnsupportedOperationException当模式没有定义。
  11. def完成():单位
    属性
    保护(朗]
    定义类
    AnyRef
    注释
    @throws (名为[java.lang.Throwable] classOf)
  12. def木屐(T](字段名:字符串):T

    返回给定的字段名的价值。

    返回给定的字段名的价值。原始类型如果值为空则返回零值的特定原始即0 Int -使用isNullAt确保值非空

    抛出的异常

    ClassCastException当数据类型不匹配。

    IllegalArgumentException当字段名不存在。

    UnsupportedOperationException当模式没有定义。
  13. def木屐(T](我:Int):T

    我返回值的位置。

    返回原始类型的价值在我的位置。如果值为空则返回零值的特定原始即0 Int -使用isNullAt确保值非空

    抛出的异常

    ClassCastException当数据类型不匹配。
  14. defgetBoolean(我:Int):布尔

    返回值的位置我作为一个原始的布尔。

    返回值的位置我作为一个原始的布尔。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  15. defgetByte(我:Int):字节

    返回的值在我作为一个原始字节的位置。

    返回的值在我作为一个原始字节的位置。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  16. 最后defgetClass():类(_)
    定义类
    AnyRef→任何
    注释
    @native ()
  17. def获取当前日期(我:Int):日期

    返回日期的位置我价值类型作为java.sql.Date。

    返回日期的位置我价值类型作为java.sql.Date。

    抛出的异常

    ClassCastException当数据类型不匹配。
  18. defgetDecimal(我:Int):BigDecimal

    返回值的位置我java.math.BigDecimal十进制类型。

    返回值的位置我java.math.BigDecimal十进制类型。

    抛出的异常

    ClassCastException当数据类型不匹配。
  19. def用(我:Int):双

    返回值的位置我作为一个原始的两倍。

    返回值的位置我作为一个原始的两倍。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  20. defgetFloat(我:Int):浮动

    返回值的位置我作为一个原始的浮动。

    返回值的位置我作为一个原始的浮动。抛出一个异常,如果类型不匹配或如果值是null。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  21. defgetInstant(我:Int):即时

    返回日期的位置我价值类型作为java.time.Instant。

    返回日期的位置我价值类型作为java.time.Instant。

    抛出的异常

    ClassCastException当数据类型不匹配。
  22. defgetInt(我:Int):Int

    返回值的位置我作为原始int。

    返回值的位置我作为原始int。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  23. defgetJavaMap(K,V](我:Int):地图(K,V]

    返回数组的值在位置我作为一个类型java.util.Map。

    返回数组的值在位置我作为一个类型java.util.Map。

    抛出的异常

    ClassCastException当数据类型不匹配。
  24. defgetList(T](我:Int):列表(T]

    返回数组的位置我价值类型并不知道。

    返回数组的位置我价值类型并不知道。

    抛出的异常

    ClassCastException当数据类型不匹配。
  25. defgetLocalDate(我:Int):LocalDate

    返回日期的位置我价值类型作为java.time.LocalDate。

    返回日期的位置我价值类型作为java.time.LocalDate。

    抛出的异常

    ClassCastException当数据类型不匹配。
  26. defgetLong(我:Int):长

    返回的值在我作为原始的位置。

    返回的值在我作为原始的位置。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  27. defgetMap(K,V](我:Int):地图(K,V]

    返回值的位置我作为一个Scala map映射类型。

    返回值的位置我作为一个Scala map映射类型。

    抛出的异常

    ClassCastException当数据类型不匹配。
  28. defgetSeq(T](我:Int):Seq(T]

    返回数组类型的价值立场,我作为一个Scala Seq。

    返回数组类型的价值立场,我作为一个Scala Seq。

    抛出的异常

    ClassCastException当数据类型不匹配。
  29. defgetShort(我:Int):短

    返回值的位置我作为原始短。

    返回值的位置我作为原始短。

    抛出的异常

    ClassCastException当数据类型不匹配。

    NullPointerException当值是null。
  30. defgetString(我:Int):字符串

    返回值的位置我作为一个字符串对象。

    返回值的位置我作为一个字符串对象。

    抛出的异常

    ClassCastException当数据类型不匹配。
  31. defgetStruct(我:Int):行

    返回值的位置我作为一个结构体类型行对象。

    返回值的位置我作为一个结构体类型行对象。

    抛出的异常

    ClassCastException当数据类型不匹配。
  32. defgetTimestamp(我:Int):时间戳

    返回日期的位置我价值类型作为java.sql.Timestamp。

    返回日期的位置我价值类型作为java.sql.Timestamp。

    抛出的异常

    ClassCastException当数据类型不匹配。
  33. defgetValuesMap(T](字段名:Seq(字符串]):地图(字符串,T]

    返回一个地图组成的名称和值为原始类型要求的字段名如果值为空则返回零值的特定于原始即。

    返回一个地图组成的名称和值为原始类型要求的字段名如果值为空则返回零值的特定原始即0 Int -使用isNullAt确保值非空

    抛出的异常

    ClassCastException当数据类型不匹配。

    IllegalArgumentException当字段名不存在。

    UnsupportedOperationException当模式没有定义。
  34. defhashCode():Int
    定义类
    行→AnyRef→任何
  35. 最后defisInstanceOf(T0]:布尔
    定义类
    任何
  36. defisNullAt(我:Int):布尔

    检查是否我是null的价值立场。

  37. defjson:字符串

    这一行的紧凑的JSON表示。

    这一行的紧凑的JSON表示。

    注释
    @Unstable ()
    自

    3.0

  38. defmkString(开始:字符串,9月:字符串,结束:字符串):字符串

    显示所有元素的可否认的或字符串中的迭代器使用开始,结束,分隔符字符串。

  39. defmkString(9月:字符串):字符串

    显示所有元素的序列字符串使用分隔符字符串。

  40. defmkString:字符串

    显示所有元素的序列在一个字符串(没有分隔符)。

  41. 最后def不(arg0:AnyRef):布尔
    定义类
    AnyRef
  42. 最后def通知():单位
    定义类
    AnyRef
    注释
    @native ()
  43. 最后defnotifyAll():单位
    定义类
    AnyRef
    注释
    @native ()
  44. defprettyJson:字符串

    (即。

    漂亮的(即缩进)JSON表示的这一行。

    注释
    @Unstable ()
    自

    3.0

  45. def模式:StructType

    行模式。

  46. def大小:Int

    元素的行数。

  47. 最后def同步(T0](arg0:⇒T0):T0
    定义类
    AnyRef
  48. deftoSeq:Seq(任何]

    返回一个Scala Seq代表行。

    返回一个Scala Seq代表行。元素在Seq放置在相同的顺序。

  49. deftoString():字符串
    定义类
    行→AnyRef→任何
  50. 最后def等待():单位
    定义类
    AnyRef
    注释
    @throws (…)
  51. 最后def等待(arg0:长,__arg1:Int):单位
    定义类
    AnyRef
    注释
    @throws (…)
  52. 最后def等待(arg0:长):单位
    定义类
    AnyRef
    注释
    @throws (…) @native ()

继承自可序列化的

继承自可序列化的

继承自AnyRef

继承自任何

未分组的