CatalystIO

For some reason Row and InternalRow share no common base type. Instead of using structural types (which use reflection), this typeclass is used to normalize access to the underlying storage construct.

R: row storage type

Linear Supertypes

Serializable, Serializable, AnyRef, Any

Known Subclasses

AbstractRowEncoder

Abstract Value Members

abstract def create(values: Any*): R
abstract def encode(str: String): AnyRef
abstract def get[T >: Null](d: R, ordinal: Int)(implicit arg0: CatalystSerializer[T]): T
abstract def getBoolean(d: R, ordinal: Int): Boolean
abstract def getByte(d: R, ordinal: Int): Byte
abstract def getByteArray(d: R, ordinal: Int): Array[Byte]
abstract def getDouble(d: R, ordinal: Int): Double
abstract def getFloat(d: R, ordinal: Int): Float
abstract def getInt(d: R, ordinal: Int): Int
abstract def getLong(d: R, ordinal: Int): Long
abstract def getSeq[T >: Null](d: R, ordinal: Int)(implicit arg0: CatalystSerializer[T]): Seq[T]
abstract def getShort(d: R, ordinal: Int): Short
abstract def getString(d: R, ordinal: Int): String
abstract def isNullAt(d: R, ordinal: Int): Boolean
abstract def toSeq[T](t: Seq[T])(implicit arg0: CatalystSerializer[T]): AnyRef

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def to[T](t: T)(implicit arg0: CatalystSerializer[T]): R
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: object CatalystIO | package CatalystSerializer

trait CatalystIO[R] extends Serializable

Abstract Value Members

abstract def create(values: Any*): R

abstract def encode(str: String): AnyRef

abstract def get[T >: Null](d: R, ordinal: Int)(implicit arg0: CatalystSerializer[T]): T

abstract def getBoolean(d: R, ordinal: Int): Boolean

abstract def getByte(d: R, ordinal: Int): Byte

abstract def getByteArray(d: R, ordinal: Int): Array[Byte]

abstract def getDouble(d: R, ordinal: Int): Double

abstract def getFloat(d: R, ordinal: Int): Float

abstract def getInt(d: R, ordinal: Int): Int

abstract def getLong(d: R, ordinal: Int): Long

abstract def getSeq[T >: Null](d: R, ordinal: Int)(implicit arg0: CatalystSerializer[T]): Seq[T]

abstract def getShort(d: R, ordinal: Int): Short

abstract def getString(d: R, ordinal: Int): String

abstract def isNullAt(d: R, ordinal: Int): Boolean

abstract def toSeq[T](t: Seq[T])(implicit arg0: CatalystSerializer[T]): AnyRef

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def to[T](t: T)(implicit arg0: CatalystSerializer[T]): R

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped