FeatureRecord

A named, nested view of a Chronon feature value.

Unlike the classic Map[String, AnyRef] fetcher response, where struct-typed values are positional Array[Any] and the field names live only in the schema, every level of a FeatureRecord is keyed by field name. Struct-typed fields resolve to nested FeatureRecords and lists of structs resolve to List[FeatureRecord], so callers can navigate arbitrarily deep nesting by name instead of by position.

values carries everything the underlying fetcher response carried, including the <name>_exception keys the fetcher uses to report partial failures (see errors). schema is narrowed to the declared fields actually present in values.

Linear Supertypes

Serializable, Serializable, Product, Equals, AnyRef, Any

Instance Constructors

new FeatureRecord(schema: StructType, values: Map[String, Any])

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
@IntrinsicCandidate() @throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def errors: Map[String, Any]

The <name>_exception entries the fetcher uses to report per-groupBy, per-external-part, derivation and codec failures.
The <name>_exception entries the fetcher uses to report per-groupBy, per-external-part, derivation and codec failures. These are not part of the declared value schema, so they are surfaced here rather than through the typed getters.
def getBoolean(field: String): Boolean
def getBooleanOpt(field: String): Option[Boolean]
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@IntrinsicCandidate()
def getDouble(field: String): Double
def getDoubleOpt(field: String): Option[Double]
def getInt(field: String): Int
def getIntOpt(field: String): Option[Int]
def getList[T](field: String): List[T]
def getLong(field: String): Long
def getLongOpt(field: String): Option[Long]
def getMap[V](field: String): Map[String, V]
def getString(field: String): String
def getStringOpt(field: String): Option[String]
def getStruct(field: String): FeatureRecord
def getStructList(field: String): List[FeatureRecord]
def getStructOpt(field: String): Option[FeatureRecord]
def hasErrors: Boolean
final def isInstanceOf[T0]: Boolean

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

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@IntrinsicCandidate()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@IntrinsicCandidate()
val schema: StructType
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val values: Map[String, Any]
final def wait(arg0: Long, arg1: Int): Unit

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )

Deprecated Value Members

def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
Deprecated
(Since version ) see corresponding Javadoc for more information.

Related Docs: object FeatureRecord | package serde

case class FeatureRecord(schema: StructType, values: Map[String, Any]) extends Product with Serializable

Instance Constructors

new FeatureRecord(schema: StructType, values: Map[String, Any])

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 errors: Map[String, Any]

def getBoolean(field: String): Boolean

def getBooleanOpt(field: String): Option[Boolean]

final def getClass(): Class[_]

def getDouble(field: String): Double

def getDoubleOpt(field: String): Option[Double]

def getInt(field: String): Int

def getIntOpt(field: String): Option[Int]

def getList[T](field: String): List[T]

def getLong(field: String): Long

def getLongOpt(field: String): Option[Long]

def getMap[V](field: String): Map[String, V]

def getString(field: String): String

def getStringOpt(field: String): Option[String]

def getStruct(field: String): FeatureRecord

def getStructList(field: String): List[FeatureRecord]

def getStructOpt(field: String): Option[FeatureRecord]

def hasErrors: Boolean

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val schema: StructType

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

val values: Map[String, Any]

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

final def wait(arg0: Long): Unit

final def wait(): Unit

Deprecated Value Members

def finalize(): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped